Android端基于Java后端的一对一聊天客户端实现问题排查

我来帮你拆解下当前遇到的问题，先直接回答你的两个疑问，再一步步帮你修复代码里的核心问题：

疑问解答 #

1. 参考Java客户端的写法不正确：桌面Java程序没有Android的主线程限制和UI操作规则，直接照搬会触发Android的网络操作和UI更新的安全机制，导致异常。
2. socket对象为空的原因：
   • 你用了127.0.0.1作为连接地址，在Android模拟器中这个IP指向模拟器自身，而非你的电脑服务端；如果是真机，手机和电脑不在同一局域网也会连接失败。
   • 连接失败时仅打印异常栈，未处理socket为空的情况，导致后续操作时socket还是null。

核心异常分析：NetworkOnMainThreadException #

这个异常是因为你在主线程中执行了网络写操作：sendMsg的点击事件回调是在主线程触发的，而你在回调里直接调用dos.writeUTF(msg)，违反了Android禁止主线程做网络操作的规则。

具体修复步骤 #

1. 修正Socket连接的IP地址 #

• 如果用Android模拟器：把new Socket("127.0.0.1", 1234)中的127.0.0.1替换为10.0.2.2（这是模拟器默认指向宿主电脑的IP）。
• 如果用真机：确保手机和电脑在同一WiFi下，把IP换成电脑的局域网IP（比如通过ipconfig/ifconfig查看的IPv4地址）。

2. 修复发送消息的线程逻辑 #

不要在子线程的死循环中重复绑定点击事件，这会导致多次注册回调，还会把网络操作留在主线程。正确的做法是在onCreate中一次性绑定点击事件，点击时开启子线程执行网络写操作：

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    this.initializeWidgets();
    // 提前绑定点击事件
    sendMsg.setOnClickListener(v -> sendMessage());
    this.createSocket();
}

private void sendMessage() {
    String msg = enterMsg.getText().toString().trim();
    if (msg.isEmpty() || socket == null || !socket.isConnected()) {
        runOnUiThread(() -> viewMsg.append("无法发送：连接未建立或消息为空\n"));
        return;
    }
    // 开启子线程执行网络写操作
    new Thread(() -> {
        try {
            DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
            dos.writeUTF(msg);
            // 清空输入框要在主线程执行
            runOnUiThread(() -> enterMsg.setText(""));
        } catch (IOException e) {
            e.printStackTrace();
            runOnUiThread(() -> viewMsg.append("发送失败：" + e.getMessage() + "\n"));
        }
    }).start();
}

3. 修复UI更新的线程问题 #

Android不允许子线程直接更新UI，所以在接收消息后，必须用runOnUiThread包裹UI更新操作：

private Runnable receiveMessageFromClient() throws IOException {
    DataInputStream dis = new DataInputStream(socket.getInputStream());
    Runnable readMessage = () -> {
        while (socket != null && socket.isConnected()) {
            try {
                String msg = dis.readUTF();
                String finalMsg = msg;
                // 切换到主线程更新UI
                runOnUiThread(() -> viewMsg.append(finalMsg + "\n"));
            } catch (IOException e) {
                e.printStackTrace();
                runOnUiThread(() -> viewMsg.append("连接断开：" + e.getMessage() + "\n"));
                break;
            }
        }
    };
    return readMessage;
}

4. 完善资源释放与异常提示 #

在Activity销毁时关闭Socket和流资源，避免内存泄漏：

@Override
protected void onDestroy() {
    super.onDestroy();
    try {
        if (socket != null && !socket.isClosed()) {
            socket.close();
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}

额外注意事项 #

• 确保服务端程序已经启动，并且监听的端口（1234）没有被防火墙拦截。
• 真机测试时，要在Android 6.0及以上版本动态申请INTERNET等权限（虽然你在Manifest里加了，但动态权限是必要的）。

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