java - android中的套接字、线程和服务，如何让它们协同工作？

Question

我遇到了线程和套接字的问题，我无法解决，如果有人能帮助我，我将不胜感激。

有事实:

我有一个服务类 NetworkService，在这个类中我有一个 Socket 属性。 我希望它在服务的整个生命周期内都处于连接状态。

为了连接套接字，我在一个线程中进行，所以如果服务器必须超时，它不会阻塞我的 UI 线程。

问题是，在我连接套接字的线程中，一切都很好，它已连接，我可以与我的服务器通信，一旦这个线程结束，我尝试重用套接字，在另一个线程中，我有错误消息 Socket 未连接。

问题是: - 套接字是否在线程结束时自动断开连接？ - 无论如何我们可以将一个值从被调用线程传回给调用者吗？

非常感谢，

这是我的代码

  public class NetworkService extends Service {

        private Socket  mSocket = new Socket();


  private void _connectSocket(String addr, int port) {
        Runnable connect = new connectSocket(this.mSocket, addr, port);
        new Thread(connect).start();

  }

  private void _authentification() {
        Runnable auth = new authentification();
        new Thread(auth).start();
  }


  private INetwork.Stub mBinder = new INetwork.Stub() {

        @Override
        public int doConnect(String addr, int port) throws RemoteException {
            _connectSocket(addr, port);
            _authentification();
            return 0;
        }
    };


class connectSocket implements Runnable {
        String  addrSocket;
        int portSocket;
        int TIMEOUT=5000;

        public connectSocket(String addr, int port) {
            addrSocket = addr;
            portSocket = port;
        }

        @Override
        public void run() {

            SocketAddress socketAddress = new InetSocketAddress(addrSocket, portSocket);
            try {
                mSocket.connect(socketAddress, TIMEOUT);
                PrintWriter out = new PrintWriter(mSocket.getOutputStream(), true);
                out.println("test42");
                            Log.i("connectSocket()", "Connection Succesful");
            } catch (IOException e) {
                Log.e("connectSocket()", e.getMessage());
                e.printStackTrace();
            }       
        }
    }

    class authentification implements Runnable {

        private String constructFirstConnectQuery() {
            String query = "toto";
            return query;
        }

        @Override
        public void run() {
            BufferedReader  in;
            PrintWriter out;
            String      line = "";

            try {

                in = new BufferedReader(new InputStreamReader(mSocket.getInputStream()));
                out = new PrintWriter(mSocket.getOutputStream(), true);
                out.println(constructFirstConnectQuery());


                while (mSocket.isConnected()) {
                    line = in.readLine();
                    Log.e("LINE", "[Current]- " + line);
                }
            } 
            catch (IOException e) {e.printStackTrace();}

        }
    }

Answer 1

将输出流定义为成员变量，将其附加到您的线程中，并仅在完成后关闭该流...

当前您正在线程中打开(并隐式关闭)输出流。当线程死亡时，它将关闭该输出流，这反过来可能会终止套接字/连接。

如果您在线程外定义流，您可以将其附加到线程内，并在稍后关闭它，例如当服务被要求终止时。