为何HystrixRequestContext未初始化？HystrixCollapser示例遇空指针异常

先直接点出你遇到的空指针问题的核心：你看到的java.lang.NullPointerException在HystrixCollapser$3.call这个位置，90%的概率是当前线程没有初始化HystrixRequestContext。HystrixCollapser的批量逻辑完全依赖请求上下文来收集同一请求周期内的多个调用请求，如果上下文不存在，内部用来存储批量请求的容器就是null，直接触发空指针。

为什么HystrixRequestContext会未初始化？ #

常见的原因有这几个：

• 请求入口没做上下文初始化：在Web应用里，你需要在请求处理的最开始（比如Filter）创建并绑定上下文到当前线程；如果是单元测试，就得在测试代码的开头手动初始化。
• 异步线程切换丢失上下文：HystrixRequestContext是线程绑定的，默认不会自动传递到子线程。如果你的Collapser调用是在异步线程里执行的，得手动把上下文传递过去。
• 直接调用Collapser方法跳过初始化：比如在测试里直接new Collapser然后调用queue()/execute()，完全没管上下文的事，自然会出问题。

给你一个能跑通的示例 #

1. 先处理上下文初始化 #

如果是Web应用，写一个Filter来自动管理上下文：

public class HystrixRequestContextFilter implements Filter {
    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        // 初始化上下文并绑定到当前线程
        HystrixRequestContext context = HystrixRequestContext.initializeContext();
        try {
            chain.doFilter(request, response);
        } finally {
            // 请求结束后关闭上下文
            context.shutdown();
        }
    }

    // init和destroy方法可以留空
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {}
    @Override
    public void destroy() {}
}

然后在web.xml或者Spring配置里注册这个Filter，确保它在所有业务Filter之前执行。

如果是单元测试，手动初始化和关闭：

@Test
public void testCollapserBatch() {
    // 初始化上下文
    HystrixRequestContext context = HystrixRequestContext.initializeContext();
    try {
        // 模拟两个并行的调用，会被Collapser批量处理
        Future<String> future1 = new MyIdCollapser("user1").queue();
        Future<String> future2 = new MyIdCollapser("user2").queue();
        
        // 获取结果
        System.out.println(future1.get());
        System.out.println(future2.get());
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        // 一定要关闭上下文，避免资源泄漏
        context.shutdown();
    }
}

2. 正确的HystrixCollapser实现 #

import com.netflix.hystrix.*;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors;

public class MyIdCollapser extends HystrixCollapser<List<String>, String, String> {

    private final String userId;

    public MyIdCollapser(String userId) {
        super(Setter.withCollapserKey(HystrixCollapserKey.Factory.asKey("MyIdCollapser"))
                // 设置批量收集的延迟时间，100ms内的请求会被批量处理
                .andCollapserPropertiesDefaults(HystrixCollapserProperties.Setter()
                        .withTimerDelayInMilliseconds(100)));
        this.userId = userId;
    }

    // 返回当前请求的参数，用来收集批量请求
    @Override
    public String getRequestArgument() {
        return userId;
    }

    // 当收集到足够的请求（或到了延迟时间），创建批量处理的Command
    @Override
    protected HystrixCommand<List<String>> createCommand(Collection<CollapsedRequest<String, String>> requests) {
        List<String> userIds = requests.stream()
                .map(CollapsedRequest::getArgument)
                .collect(Collectors.toList());
        return new BatchUserCommand(userIds);
    }

    // 将批量处理的结果映射回每个单独的请求
    @Override
    protected void mapResponseToRequests(List<String> batchResponse, Collection<CollapsedRequest<String, String>> requests) {
        int index = 0;
        for (CollapsedRequest<String, String> request : requests) {
            request.setResponse(batchResponse.get(index++));
        }
    }

    // 批量处理的Command实现
    private static class BatchUserCommand extends HystrixCommand<List<String>> {
        private final List<String> userIds;

        public BatchUserCommand(List<String> userIds) {
            super(HystrixCommandKey.Factory.asKey("BatchUserCommand"));
            this.userIds = userIds;
        }

        @Override
        protected List<String> run() throws Exception {
            // 这里模拟调用批量接口，比如DB批量查询或者远程服务批量调用
            return userIds.stream()
                    .map(id -> "User info for " + id)
                    .collect(Collectors.toList());
        }
    }
}

异步场景的注意事项 #

如果你的代码是在异步线程里调用Collapser，记得传递上下文：

// 在主线程获取上下文
HystrixRequestContext context = HystrixRequestContext.getContextForCurrentThread();

// 在异步线程里设置上下文
new Thread(() -> {
    HystrixRequestContext.setContextOnCurrentThread(context);
    try {
        Future<String> future = new MyIdCollapser("user3").queue();
        System.out.println(future.get());
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        // 子线程里不需要shutdown，因为上下文是主线程创建的，主线程会负责关闭
        HystrixRequestContext.setContextOnCurrentThread(null);
    }
}).start();

内容的提问来源于stack exchange，提问作者rayen