3

我用 Java 写了一个简单的 TCP 客户端类。它用于连接到用 Python 编写的 TCP 服务器并在新线程中处理传入的消息。它看起来像这样：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.net.Socket;

public class TCPTestClient {
    private String mHost;
    private int mPort;

    private Socket mSocket;
    private PrintWriter mWriter;
    private BufferedReader mReader;

    public TCPTestClient(String host, int port) {
        mHost = host;
        mPort = port;
    }

    public void connect() throws IOException {
        if (mSocket == null || mSocket.isClosed()) {
            mSocket = new Socket();
            mSocket.connect(new InetSocketAddress(mHost, mPort), 5000);
            mWriter = new PrintWriter(mSocket.getOutputStream());
            mReader = new BufferedReader(new InputStreamReader(mSocket
                    .getInputStream()));
            new Thread(new InputHandler(mReader, this)).start();
        }
    }

    public void close() throws IOException {
        if (mSocket != null && !mSocket.isClosed()) {
            mSocket.close();
        }
    }

    class InputHandler implements Runnable {
        BufferedReader mReader;
        TCPTestClient mClient;

        public InputHandler(BufferedReader reader, TCPTestClient client) {
            mReader = reader;
            mClient = client;
        }

        public void run() {
            String line = null;
            try {
                while ((line = mReader.readLine()) != null) {
                    System.out.println(line);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

如果新客户端已连接或断开连接，TCP 服务器只需将“客户端连接”和“客户端断开连接”打印到标准输出。这在普通 java 应用程序中运行 TCPTestClient 时效果很好：调用 connect() 时建立连接，调用 close() 时关闭，并且 InputHandler 内等待的 readLine() 将失败，因为 SocketException 表示套接字是关闭（java.net.SocketException: Socket closed）。这是我所期望的行为。

但是，当我在 Android 上运行此代码时，连接不会关闭：readLine() 仍然会阻塞而不抛出 SocketException，并且服务器不会显示“客户端已断开连接”消息。

这是我的活动：

import java.io.IOException;

import android.app.Activity;
import android.util.Log;

public class Foo extends Activity {
    private TCPTestClient mClient;

    private static final String TAG = "Foo";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.foo);

        mClient = new TCPTestClient("192.168.1.2", 3456);
    }

    @Override
    protected void onPause() {
        super.onPause();
        Log.d(TAG, "onPause");

        try {
            mClient.close();
        } catch (IOException e) {
            Log.d(TAG, "Disconnect failed", e);
        }
    }

    @Override
    protected void onResume() {
        super.onResume();
        Log.d(TAG, "onResume");

        try {
            mClient.connect();
        } catch (IOException e) {
            Log.d(TAG, "Connect failed", e);
        }
    }
}

因此，当 Activity 启动/恢复时，将建立连接。当用户点击后退按钮时，连接应该被关闭。然而，onPause() 和 close() 被调用，但是套接字并没有关闭，因为 BufferedReader 仍然阻塞等待输入。类似mReader.close()close-method 块内部的调用也是如此。

有谁知道如何解决此问题，以便在 Activity 暂停时成功关闭连接？

4

2 回答 2

0

您如何验证客户端套接字未关闭？

在服务器端检测关闭连接的唯一可靠方法是写入数据，并将心跳添加到协议中。

于 2011-05-07T10:29:45.913 回答
0

是的，在 2.3 之前，您必须使用 mSocket.shutdownInput() 和 mSocket.shutdownOutput() 才能抛出异常。但目前在 2.2.2 中，它对我不起作用。:( 仍在寻找抛出异常的方法。

于 2011-05-18T01:31:03.170 回答