上一篇说了关于MDC跨线程为null的理解，而本讲主要说一下，如何去解决它，事实上，Hystrix为我们留了这个口，我们只需要继承HystrixConcurrencyStrategy，然后重写wrapCallable方法，再把这个重写的对象注册到Hystrix里就可以了，跨线程共享数据，可以使用阿里的 transmittable-thread-local组件，如果只是共离MDC的话，可以自己写个组件就行。

一 ThreadMdcUtil用来同步MDC对象

public class ThreadMdcUtil {

	public static <T> Callable<T> wrap(final Callable<T> callable, final Map<String, String> context) {
		return () -> {
			if (context == null) {
				MDC.clear();
			}
			else {
				MDC.setContextMap(context);
			}
			try {
				return callable.call();
			}
			finally {
				MDC.clear();
			}
		};
	}

	public static Runnable wrap(final Runnable runnable, final Map<String, String> context) {
		return () -> {
			if (context == null) {
				MDC.clear();
			}
			else {
				MDC.setContextMap(context);
			}
			try {
				runnable.run();
			}
			finally {
				MDC.clear();
			}
		};
	}

}

重写HystrixConcurrencyStrategy，将主线程的MDC传入Hystrix建立的新线程

/**
 * 线程上下文传递，hystrix的相关实现有兴趣可以看源码， hystrix提供了这个口子可以处理线程间传值问题，这里不做过多赘述
 */
public class RequestContextHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy {

	@Override
	public <T> Callable<T> wrapCallable(final Callable<T> callable) {
		// 使用阿里的 TtlCallable 重新包一层，解决线程间数据传递问题
		// return TtlCallable.get(callable);
		// 使用自定义的包装对象，将当前mdc复制到Hystrix新线程中
		return ThreadMdcUtil.wrap(callable, MDC.getCopyOfContextMap());
	}

}

注册我们的RequestContextHystrixConcurrencyStrategy策略到Hystrix

@Configuration
@Slf4j
public class HystrixCircuitBreakerConfiguration {

	@PostConstruct
	public void init() {
		HystrixPlugins.getInstance().registerConcurrencyStrategy(
				new RequestContextHystrixConcurrencyStrategy());
	}

}

运行结果，使用openFeign时，已经共享了traceId这个数据值