上一篇说了关于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这个数据值