Android中如何通过Socket.IO实现同步调用获取响应？

你的问题核心在于没正确处理Socket.IO的异步回调机制——原来的代码里，request方法会在Ack回调执行前就返回空的responseObj，所以Future拿到的自然是null。我给你一个基于CountDownLatch的可行方案，这是Java中处理异步转同步场景的常用工具。

问题分析 #

你之前的代码逻辑里，Ack回调是在Socket.IO的内部线程中执行的，而request方法会立即返回初始化的空responseObj，此时回调还没来得及给它赋值。所以当Callable的call方法返回这个对象时，它依然是空的，这就是respObj始终为null的原因。

解决方案：用CountDownLatch实现同步等待 #

CountDownLatch可以让当前线程等待，直到其他线程完成指定操作（这里就是Ack回调执行完毕）。具体代码修改如下：

1. 修改request方法，加入CountDownLatch等待回调 #

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import org.json.JSONException;
import org.json.JSONObject;
import io.socket.client.Ack;

public JSONObject request(final String method, final String url, final JSONObject data) {
    final JSONObject responseObj = new JSONObject();
    final CountDownLatch latch = new CountDownLatch(1); // 初始化计数器为1，代表要等待1个操作完成

    if (mSocket.connected()) {
        try {
            // 构造请求对象（根据你的实际业务调整）
            JSONObject reqObj = new JSONObject();
            reqObj.put("url", url);
            reqObj.put("data", data);

            mSocket.emit(method, reqObj, new Ack() {
                @Override
                public void call(Object... objects) {
                    System.out.println("get Ack");
                    try {
                        if (objects.length > 0 && objects[0] instanceof JSONObject) {
                            responseObj.put("body", (JSONObject) objects[0]);
                        }
                    } catch (JSONException e) {
                        e.printStackTrace();
                    } finally {
                        latch.countDown(); // 回调执行完成，计数器减1，通知等待的线程可以继续
                    }
                }
            });

            // 等待回调执行完成，最多等待10秒（可根据业务需求调整超时时间）
            boolean isCompleted = latch.await(10, TimeUnit.SECONDS);
            if (!isCompleted) {
                // 处理超时情况，添加错误信息到responseObj
                responseObj.put("error", "Request timeout");
            }
        } catch (JSONException | InterruptedException e) {
            e.printStackTrace();
            try {
                responseObj.put("error", e.getMessage());
            } catch (JSONException ex) {
                ex.printStackTrace();
            }
        }
    } else {
        // Socket未连接时的处理
        try {
            responseObj.put("error", "Socket not connected");
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }

    return responseObj;
}

2. 调整Activity中的调用代码 #

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import org.json.JSONException;
import org.json.JSONObject;

// 在Activity的合适位置执行（务必放在子线程）
ExecutorService executor = Executors.newCachedThreadPool();
Future<JSONObject> response = executor.submit(() -> 
    request("get", "https://my-chat-server/user/exist", new JSONObject())
);
executor.shutdown();

JSONObject respObj = new JSONObject();
JSONObject respBody = new JSONObject();
try {
    respObj = response.get();
    if (respObj.has("body")) {
        respBody = respObj.getJSONObject("body");
        // 这里处理服务器返回的有效数据，比如判断用户是否存在
    } else if (respObj.has("error")) {
        // 处理错误情况，比如超时、Socket未连接等
        String errorMsg = respObj.getString("error");
        // 提示用户或者做相应的错误处理
    }
} catch (ExecutionException e) {
    e.printStackTrace();
} catch (InterruptedException e1) {
    e1.printStackTrace();
} catch (JSONException e2) {
    e2.printStackTrace();
}

关键注意事项 #

• 避免主线程阻塞：一定要把同步请求放到子线程中执行（比如用ExecutorService），如果在Android主线程调用latch.await()会导致ANR（应用无响应）。
• 超时设置：不要无限等待，设置合理的超时时间可以避免线程长时间挂起。
• 异常处理：完善的异常处理能帮你排查Socket连接失败、JSON解析错误等问题。

内容的提问来源于stack exchange，提问作者徐智通