Android中RxJava2与Socket.IO交互单元测试空指针问题排查

你遇到的核心问题在于单元测试的纯JVM环境和Android运行环境的差异：Socket.IO的底层传输实现（比如PollingXHR）依赖Android平台特有的网络相关API，而普通JVM单元测试无法提供这些依赖，导致握手数据（HandshakeData）初始化时抛出空指针异常。下面是具体分析和解决方案：

问题根源拆解 #

你的代码在MainActivity中能正常运行，是因为Android系统提供了Socket.IO所需的完整网络环境（比如Android版的HttpURLConnection、线程调度机制等）。但在单元测试的JVM环境下：

• Socket.IO的PollingXHR传输方式依赖Android专属的网络组件，JVM环境中没有对应的实现，导致握手数据解析时出现空指针
• 虽然你用了TrampolineSchedulerRule控制RxJava的线程，但Socket.IO自身的EventThread不受RxJava调度器管理，异步回调的执行环境依然不完整

针对性解决方案 #

1. 使用Robolectric模拟Android环境 #

Robolectric可以在JVM中模拟完整的Android运行环境，提供Socket.IO需要的网络相关类和上下文：

• 先在测试gradle配置中添加Robolectric依赖
• 测试类上添加注解：

  @RunWith(RobolectricTestRunner.class)
  @Config(sdk = [Build.VERSION_CODES.TIRAMISU]) // 根据你的目标SDK版本调整
  

• 这样测试就能在模拟的Android环境中运行，Socket.IO的底层传输逻辑可以正常工作

2. 模拟Socket.IO客户端，脱离真实网络连接 #

单元测试的核心是验证你的业务逻辑，而非测试Socket.IO的网络连接能力。用Mockito等工具模拟Socket.IO的行为是更合理的选择：

// 模拟Socket.IO客户端实例
Socket mockSocket = mock(Socket.class);
// 让ObservableFactory使用模拟的Socket
ObservableFactory.sharedInstance.setSocket(mockSocket);

// 模拟连接过程中的状态发射
doAnswer(invocation -> {
    // 先发射Connecting状态
    ObservableFactory.sharedInstance.connectionStatusObservable.onNext(new ConnectionStatus(ConnectionStatus.Status.Connecting));
    // 延迟发射Connected状态，模拟异步连接流程
    new Handler(Looper.getMainLooper()).postDelayed(() -> {
        ObservableFactory.sharedInstance.connectionStatusObservable.onNext(new ConnectionStatus(ConnectionStatus.Status.Connected));
    }, 100);
    return null;
}).when(mockSocket).connect();

// 执行测试逻辑
ObservableFactory.sharedInstance.connectionStatusObservable.blockingForEach(status -> {
    System.out.println(status.getStatus());
});

这种方式完全脱离真实网络，专注于测试你的RxJava流处理逻辑，也不会受环境差异影响。

3. 用CountDownLatch等待异步事件（若坚持真实连接） #

如果你一定要测试真实的Socket.IO连接，需要确保测试线程等待异步事件完成：

@Test
public void testConnectionStatus() throws InterruptedException {
    CountDownLatch latch = new CountDownLatch(2); // 等待Connecting和Connected两个状态

    ObservableFactory.sharedInstance.connectionStatusObservable.subscribe(status -> {
        System.out.println(status.getStatus());
        latch.countDown();
    }, error -> {
        error.printStackTrace();
        latch.countDown();
    });

    // 等待事件完成，设置合理超时时间
    assertTrue(latch.await(5, TimeUnit.SECONDS));
}

注意这种方式需要结合Robolectric使用，确保环境支持Socket.IO的网络操作。

总结 #

优先推荐第二种方案（模拟Socket.IO客户端），因为单元测试应该聚焦于你的代码逻辑，而非依赖外部服务或平台环境。如果需要测试真实的网络交互，再用Robolectric配合CountDownLatch来处理异步逻辑。

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