5

私はスレッドとソケットの問題に直面しています。私はそれを理解できません。誰かが私を助けてくれるなら、私は本当に感謝します。

事実があります

私はサービスクラスNetworkServiceを持っており、このクラス内にSocket属性があります。サービスのライフサイクル全体で接続された状態にしたいと思います。

ソケットを接続するためにスレッドで接続するので、サーバーがタイムアウトする必要がある場合でも、UIスレッドがブロックされることはありません。

問題は、ソケットを接続するスレッドにすべてが正常に接続され、サーバーと通信できることです。このスレッドが終了してソケットを再利用しようとすると、別のスレッドでエラーメッセージが表示されますSocket is not connected

質問は次のとおりです:-ソケットはスレッドの終わりで自動的に切断されますか?-とにかく、呼び出されたスレッドから呼び出し元に値を返すことができますか?

どうもありがとう、

これが私のコードです

  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();}

        }
    }
4

1 に答える 1

2

出力ストリームをメンバー変数として定義し、それをスレッドにアタッチし、完了したらそのストリームのみを閉じます...

現在、スレッド内で出力ストリームを開いています (そして暗黙的に閉じています)。スレッドが終了すると、その出力ストリームが閉じられ、ソケット/接続が強制終了される可能性があります。

スレッドの外部でストリームを定義する場合は、スレッド内でストリームをアタッチし、後でサービスの終了を求められたときなどにストリームを閉じることができます。

于 2010-05-04T15:42:18.750 に答える