上海网站络公司长沙医院网站建设

上海网站络公司,长沙医院网站建设,代理网店怎么开,购买虚拟机建网站在整个链路中#xff0c;网关、业务服务、调用其他服务#xff0c;异步调用、或者发送mq是一个线程吗#x1f4ca; 线程切换详解表场景线程是否变化线程示例MDC/TraceId传递网关→业务服务✅ 变化http-nio-8080-exec-1 → http-nio-8081-exec-3通过HTTP Header自动传递业务服…在整个链路中网关、业务服务、调用其他服务异步调用、或者发送mq是一个线程吗 线程切换详解表场景线程是否变化线程示例MDC/TraceId传递网关→业务服务✅ 变化http-nio-8080-exec-1→http-nio-8081-exec-3通过HTTP Header自动传递业务服务内同步调用❌ 不变http-nio-8081-exec-3→http-nio-8081-exec-3MDC直接可用同步HTTP调用下游❌ 不变阻塞http-nio-8081-exec-3阻塞等待需拦截器设置Header异步HTTP调用✅ 变化http-nio-8081-exec-3→SimpleAsyncTaskExecutor-1需要手动传递上下文Async方法调用✅ 变化http-nio-8081-exec-3→task-1需要TaskDecoratorMQ发送同步❌ 不变http-nio-8081-exec-3MDC直接可用MQ发送异步✅ 变化http-nio-8081-exec-3→MQClient-Thread需要消息Header传递MQ消费✅ 变化ConsumeMessageThread_1全新线程从消息Header获取定时任务✅ 变化scheduling-1调度线程需要手动生成设置线程池任务✅ 变化pool-1-thread-1线程池线程需要TTL或手动包装 完整的线程切换流程示例关键结论HTTP请求跨服务一定线程切换不同Tomcat实例同步业务处理通常线程不变除非主动切换所有异步操作一定线程切换Async、CompletableFuture等MQ生产消费一定线程切换不同线程模型线程切换处必须手动传递TraceId否则链路断裂 不同场景的线程分析场景1网关 → 业务服务线程切换java// 网关线程Tomcat/Netty工作线程 public class TraceGlobalFilter { public MonoVoid filter(ServerWebExchange exchange, GatewayFilterChain chain) { // 当前线程Tomcat-NIO-1 或 reactor-http-nio-2 String threadName Thread.currentThread().getName(); // 如reactor-http-nio-2WebFlux // 或http-nio-8080-exec-1Tomcat // 网关处理完成后请求转发到业务服务 // 业务服务由另一个Tomcat实例接收使用不同的线程 } } // 业务服务线程另一个Tomcat实例 public class HeaderFilter { protected void doFilterInternal(HttpServletRequest request, ...) { // 当前线程http-nio-8081-exec-3业务服务的Tomcat线程 // 与网关线程完全不同 // 但TraceId通过HTTP header传递所以能保持链路 } }场景2同步HTTP调用可能线程不变javaService public class OrderService { Autowired private RestTemplate restTemplate; public Order createOrder(OrderRequest request) { // 当前线程http-nio-8081-exec-3Tomcat线程 // 同步调用库存服务 // 注意这里会阻塞当前线程直到响应返回 ResponseEntityStockResponse response restTemplate.postForEntity( http://inventory-service/stock/check, stockRequest, StockResponse.class ); // 返回后仍然是同一个线程http-nio-8081-exec-3 // 但被调用的服务使用另一个线程 } }场景3异步HTTP调用线程切换javaService public class OrderService { Autowired private AsyncRestTemplate asyncRestTemplate; public CompletableFutureOrder createOrderAsync(OrderRequest request) { // 当前线程http-nio-8081-exec-3 // 异步调用 ListenableFutureResponseEntityStockResponse future asyncRestTemplate.postForEntity( http://inventory-service/stock/check, stockRequest, StockResponse.class ); // 立即返回不会阻塞当前线程 // 实际HTTP请求会在另一个IO线程执行 return future.completable() .thenApply(response - { // 这里会在回调线程执行不是原来的Tomcat线程 // 线程可能是SimpleAsyncTaskExecutor-1 return processResponse(response); }); } }场景4MQ发送通常线程不变javaService public class OrderService { Autowired private RabbitTemplate rabbitTemplate; public void createOrderWithMQ(OrderRequest request) { // 当前线程http-nio-8081-exec-3 // 发送MQ消息通常是同步操作 rabbitTemplate.convertAndSend( order.exchange, order.create, orderMessage ); // 仍然是同一个线程除非配置了异步发送 // 但MQ消费者是另一个线程 RabbitListener(queues order.queue) public void processOrder(OrderMessage message) { // 这里由RabbitMQ监听器线程执行 // 如SimpleAsyncTaskExecutor-2 } } }场景5Async方法线程切换javaService public class OrderService { Async // 开启异步执行 public CompletableFutureString asyncProcess() { // 这里会在Spring线程池的线程执行 // 线程名task-1 或 SimpleAsyncTaskExecutor-1 // 不是原来的Tomcat线程 String threadName Thread.currentThread().getName(); log.info(异步方法线程: {}, threadName); return CompletableFuture.completedFuture(done); } public void callAsyncMethod() { // 当前线程http-nio-8081-exec-3Tomcat线程 // 调用异步方法 CompletableFutureString future asyncProcess(); // 立即返回不会阻塞 future.thenAccept(result - { // 这里在异步方法的线程执行回调 }); } }⚠️ 线程切换带来的问题MDC丢失MDC的工作原理java// MDC基于ThreadLocal public class MDC { private static final ThreadLocalMapString, String context new ThreadLocal(); public static void put(String key, String val) { // 存入当前线程的ThreadLocal getContext().put(key, val); } public static String get(String key) { // 从当前线程的ThreadLocal获取 MapString, String map context.get(); return map null ? null : map.get(key); } } // 关键结论线程切换 MDC丢失问题示例javaAsync public CompletableFutureString asyncTask() { // 新线程MDC为空 log.info(TraceId: {}, MDC.get(traceId)); // null return CompletableFuture.completedFuture(done); } // MQ消费者 RabbitListener(queues order.queue) public void process(OrderMessage message) { // MQ监听线程MDC为空 log.info(处理订单TraceId: {}, MDC.get(traceId)); // null }️ 解决方案跨线程传递TraceId方案1手动传递不推荐javaAsync public CompletableFutureString asyncTask() { // 手动传递参数 String traceId MDC.get(traceId); String userId MDC.get(userId); return CompletableFuture.supplyAsync(() - { // 在新线程恢复 MDC.put(traceId, traceId); MDC.put(userId, userId); try { return doTask(); } finally { MDC.clear(); } }); }方案2使用TaskDecoratorSpring异步javaConfiguration EnableAsync public class AsyncConfig implements AsyncConfigurer { Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor(); executor.setTaskDecorator(new MdcTaskDecorator()); return executor; } class MdcTaskDecorator implements TaskDecorator { Override public Runnable decorate(Runnable runnable) { // 保存当前线程的MDC MapString, String context MDC.getCopyOfContextMap(); return () - { try { // 在新线程恢复MDC if (context ! null) { MDC.setContextMap(context); } runnable.run(); } finally { MDC.clear(); } }; } } }方案3TransmittableThreadLocal阿里开源xml!-- 依赖 -- dependency groupIdcom.alibaba/groupId artifactIdtransmittable-thread-local/artifactId version2.14.2/version /dependencyjava// 使用TTL代替MDC public class TraceContext { private static final TransmittableThreadLocalString TRACE_ID new TransmittableThreadLocal(); public static void setTraceId(String traceId) { TRACE_ID.set(traceId); } public static String getTraceId() { return TRACE_ID.get(); } } // 在线程池中使用 ExecutorService executor TtlExecutors.getTtlExecutorService( Executors.newFixedThreadPool(10) ); executor.submit(() - { // 自动获取父线程的TraceId log.info(TraceId: {}, TraceContext.getTraceId()); });方案4CompletableFuture包装javapublic class TraceAwareCompletableFuture { public static U CompletableFutureU supplyAsync( SupplierU supplier) { // 捕获当前上下文 MapString, String context MDC.getCopyOfContextMap(); return CompletableFuture.supplyAsync(() - { // 恢复上下文 if (context ! null) { MDC.setContextMap(context); } try { return supplier.get(); } finally { MDC.clear(); } }); } } // 使用 TraceAwareCompletableFuture.supplyAsync(() - { log.info(异步任务TraceId: {}, MDC.get(traceId)); // 能获取 return result; });方案5MQ消息头传递java// 发送MQ时携带TraceId public void sendOrderMessage(Order order) { MessageProperties properties new MessageProperties(); // 将TraceId放入消息头 properties.setHeader(traceId, MDC.get(traceId)); properties.setHeader(userId, MDC.get(userId)); Message message new Message( JsonUtil.toJson(order).getBytes(), properties ); rabbitTemplate.send(order.exchange, order.create, message); } // 接收MQ时恢复 RabbitListener(queues order.queue) public void processOrder(Message message) { // 从消息头获取 String traceId (String) message.getMessageProperties() .getHeaders().get(traceId); String userId (String) message.getMessageProperties() .getHeaders().get(userId); // 恢复MDC MDC.put(traceId, traceId); MDC.put(userId, userId); try { // 处理消息 process(message); } finally { MDC.clear(); } } 各场景线程与TraceId传递总结场景是否同一线程TraceId传递方式解决方案网关→业务服务❌ 不同HTTP Header自动传递同步HTTP调用✅ 同一线程阻塞HTTP Header需配置拦截器RestTemplate拦截器异步HTTP调用❌ 不同HTTP Header 上下文传递AsyncRestTemplate TaskDecoratorAsync方法❌ 不同线程上下文传递TaskDecorator配置MQ发送/消费❌ 不同消息Header消息属性传递线程池任务❌ 不同任务包装传递TTL或手动传递 最佳实践建议1. 统一TraceId传播机制java// 创建TraceContext统一管理 Component public class TraceContext { // 获取当前上下文 public static MapString, String capture() { return MDC.getCopyOfContextMap(); } // 恢复上下文 public static void restore(MapString, String context) { if (context ! null) { MDC.setContextMap(context); } } // 包装Runnable public static Runnable wrap(Runnable task) { MapString, String context capture(); return () - { restore(context); try { task.run(); } finally { MDC.clear(); } }; } // 包装Callable public static T CallableT wrap(CallableT task) { MapString, String context capture(); return () - { restore(context); try { return task.call(); } finally { MDC.clear(); } }; } }2. 配置完整的异步支持javaConfiguration public class ThreadConfig { // 1. Spring异步支持 Bean public TaskDecorator mdcTaskDecorator() { return new MdcTaskDecorator(); } // 2. 线程池配置 Bean(traceAwareExecutor) public Executor traceAwareExecutor() { ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor(); executor.setTaskDecorator(mdcTaskDecorator()); return executor; } // 3. RestTemplate传播 Bean public RestTemplate restTemplate() { RestTemplate restTemplate new RestTemplate(); restTemplate.setInterceptors(Collections.singletonList( new TracePropagationInterceptor() )); return restTemplate; } } 核心结论网关和业务服务肯定不是同一个线程不同Tomcat实例业务服务内部同步调用通常是同一线程除非异步异步操作、MQ、线程池都会切换线程线程切换会导致MDC中的TraceId丢失必须手动传递TraceId通过参数、消息头、线程包装最终建议在你的系统中对于所有异步场景都需要实现TraceId的跨线程传递否则分布式追踪会在异步处断裂。使用统一的TraceContext工具类来管理所有上下文传递。