Android - 별도의 스레드에서 소켓에 연결

Android에서 매우 간단한 서버 - 클라이언트 응용 프로그램을 만들려고합니다. 서버가 내 PC에서 실행 중이며, Python으로 작성되었습니다. (문자열을 받고 응답을 다른 문자열과 함께 보내는 while (true) 루프). 문제는 Android 클라이언트에 있습니다. 그래서 별도의 스레드에서 싱글 톤 클래스를 만들려고 :Android - 별도의 스레드에서 소켓에 연결

는
는
다른하는 행동이에서 연결할 수있는 소켓에 연결 소켓을 만듭니다
쓰기
읽 소켓하기 소켓

다른 asynctask에서 쓰고 읽으려고합니다. 소켓에 다시 쓰려고 할 때까지 작동합니다. (1 쓰기 괜찮아요, 다른 시도가 실패했습니다.) 나는 예외가 없으면, 소켓이 닫혀 있는지 또는 작성자 null 등을 확인했다. 메시지가 소켓에 쓰지 않았다.

이 솔루션의 문제점은 무엇입니까? :/

도와 주시겠습니까? 여기

스레드입니다 :

public class ConnectThread extends Thread 
{ 
// singleton Part 


private static class ThreadHolder { 
    static final ConnectThread instance = new ConnectThread(); 
} 
public static synchronized ConnectThread getInstance(){ 
    if(ThreadHolder.instance == null) 
     Log.d("mytag", "NEW INSTANCE CREATED"); 
    // return (ThreadHolder.instance == null) ? ThreadHolder.instance = new ConnectThread() : ThreadHolder.instance; 
    return ThreadHolder.instance; 
} 

private ConnectThread(){ 
} 

// implementation part 
private Socket mSocket; 
private BufferedWriter socketWriter; 
private BufferedReader socketReader; 

public Socket getSocket() { 
    return mSocket; 
} 


public void WriteToSocket(String msg) 
{ 
    try{ 
     if(!(mSocket.isClosed())) 
     { 
      Log.d("mytag", "Writing to socket"); 
      if(socketWriter == null) 
       Log.d("mytag", "Writer closed - in write to socket"); 
      socketWriter.write(msg); 
      socketWriter.flush(); 
     }else 
      Log.d("mytag", "CANT write to socket"); 
    }catch(IOException e) 
    { 
     e.printStackTrace(); 
     Log.d("mytag", e.toString()); 
    } 
} 

public String ReadFromSocket() 
{ 
    try 
    { 
     if(!(mSocket.isClosed())) { 
      Log.d("mytag", "Reading from socket"); 
      if(socketReader == null) 
      { 
       Log.d("mytag", "Reader closed - in read from socket"); 
      } 
      return socketReader.readLine(); 
     }else 
     { 
      Log.d("mytag", "CANT from socket"); 
      return null; 
     } 
    }catch (IOException e) 
    { 
     e.printStackTrace(); 
     return null; 

    } 
} 

@Override 
public void run() { 
    try 
    { 
     mSocket = new Socket(); 
     mSocket.setKeepAlive(true); 
     try 
     { 
      mSocket.setTcpNoDelay(true); 
     } 
     catch (SocketException e) 
     { 
     } 

     mSocket.connect(new InetSocketAddress("192.168.0.128", 8888), 2000); 
     if(!(mSocket.isClosed())) 
     { 
      Log.d("mytag", "SOCKET IS RUNNING"); 
      socketWriter = new BufferedWriter(new OutputStreamWriter(this.mSocket.getOutputStream())); 
      socketReader = new BufferedReader(new InputStreamReader(this.mSocket.getInputStream())); 
      if(socketWriter == null) 
      { 
       Log.d("mytag", "WRITER NOT CREATED"); 
      }else 
       Log.d("mytag", "WRITER READY"); 
      if(socketReader == null) 
      { 
       Log.d("mytag", "READER NOT CREATED"); 
      }else 
       Log.d("mytag", "READER READY"); 
     } 
    }catch (IOException e) 
    { 
     e.printStackTrace(); 
    } 


}

}

그리고 여기에 읽을 수있는 시도이며, 쓰기 :

 @Override 
    protected Void doInBackground(Void... params) 
    { 
     PrintDebugMsg("do in background"); 



     //-------------------------------------------------------------------------------------- 
     changeProgressMsg(progressDialog, "Checking network availability..."); 
     //progressDialog.setTitle("Checking network availability..."); 
     //check network: 

     ConnectivityManager cm = (ConnectivityManager) getApplicationContext().getSystemService(parentContext.CONNECTIVITY_SERVICE); 
     NetworkInfo netInfo = cm.getActiveNetworkInfo(); 

     if(netInfo != null && netInfo.isConnected()) 
     { 
      networkAvail = true; 
      response += "| Network available |"; 
     } 

     PrintDebugMsg("do in background 2"); 


     try { 
      Thread.sleep(2000); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 

     changeStatusImg(imgvNetworkStatus, networkAvail?R.drawable.online:R.drawable.offline); 


     //-------------------------------------------------------------------------------------- 
     changeProgressMsg(progressDialog, "Pinging server"); 
     //progressDialog.setTitle("Pinging server..."); 


     //check server status 
     try { 
      PrintDebugMsg("do in background 3"); 


      if(!(ConnectThread.getInstance().getSocket().isClosed())) 
      { 

       ConnectThread.getInstance().WriteToSocket(PING_FROM_DROID); 

       String line  = ""; 
       line = ConnectThread.getInstance().ReadFromSocket(); 

       if(line.equals(PING_ACK)) 
       { 
        serverAvail = true; 
        response += " | pinged |"; 
        PrintDebugMsg("do in background 4", true); 

       } 

      } 
      else{ 
       response += " | NOT pinged |"; 
       PrintDebugMsg("do in background 5", true); 
       throw new UnknownHostException(); 
      } 


      PrintDebugMsg("do in background 6", true); 
     } catch (UnknownHostException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
      response += " | UnknownHostException: " + e.toString() + " - during server check |"; 
      PrintDebugMsg("do in background 7", true); 
     } finally{ 
      PrintDebugMsg("do in background 9", true); 
      if(ConnectThread.getInstance().getSocket() != null){ 

      } 
     } 

     PrintDebugMsg("do in background 10", true); 
     if(serverAvail) 
     { 
      try { 
       Thread.sleep(2000); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
     } 

     changeStatusImg(imgvServerStatus, serverAvail?R.drawable.online:R.drawable.offline); 


     //-------------------------------------------------------------------------------------- 
     changeProgressMsg(progressDialog, "Connectiong to server..."); 

     //connect to server: 

     try { 


      PrintDebugMsg("do in background 11",true); 
      //socket = new Socket(dstAddress, dstPort); 
      //socket = ConnectThread.getInstance().getSocket(); 


      PrintDebugMsg("do in background 12",true); 
      if(!(ConnectThread.getInstance().getSocket().isClosed())) { 
       PrintDebugMsg("do in background 13",true); 

       PrintDebugMsg("do in background 14",true); 

       PrintDebugMsg("do in background 15",true); 

       ConnectThread.getInstance().WriteToSocket(CONN_REQ_FROM_DROID); 

       String line  = ""; 
       line = ConnectThread.getInstance().ReadFromSocket(); 
       PrintDebugMsg("conn line = " + line, true); 
       if(line != null && line.equals(CONN_ACK)) 
       { 
        connected = true; 
        response += "| connected |"; 
        PrintDebugMsg("do in background 12"); 
       } 
      }else 
      { 
       response += "| NOT connected |"; 
       PrintDebugMsg("do in background 13"); 
       throw new UnknownHostException(); 
      } 
     } catch (UnknownHostException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
      response += " | UnknownHostException: " + e.toString() + " - during connecting |"; 
     }finally{ 

      PrintDebugMsg("connection finished"); 
      } 

     if(connected) { 
      try { 
       Thread.sleep(2000); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
     } 
     changeStatusImg(imgvConnectionStatus, connected?R.drawable.online:R.drawable.offline); 


//-------------------------------------------------------------------------- 
------------ 

     return null; 
     }

은 "UTIL"기능 :

private void PrintDebugMsg(String msg, boolean b) 
    { 
     if(b) 
      Log.d("mytag", msg); 
    } 

    private void changeProgressMsg(final ProgressDialog dialog,final String value){ 
     runOnUiThread(new Runnable() { 
      @Override 
      public void run() { 
       dialog.setMessage(value); 
      } 
     }); 
    } 

    private void changeStatusImg(final ImageView imgView, final int imgId){ 
     runOnUiThread(new Runnable() { 
      @Override 
      public void run() { 
       imgView.setImageResource(imgId); 
      } 
     }); 
    }

출처

2017-04-25 user1036555

Sever.java

public class Server { 

    public static void main(String[] args) { 
     new Server().startServer(); 
    } 

    public void startServer() { 
     final ExecutorService clientProcessingPool = Executors.newFixedThreadPool(10); 

     Runnable serverTask = new Runnable() { 
      @Override 
      public void run() { 
       try { 
        ServerSocket serverSocket = new ServerSocket(8000); 
        System.out.println("Waiting for clients to connect..."); 
        while (true) { 
         Socket clientSocket = serverSocket.accept(); 
         clientProcessingPool.submit(new ClientTask(clientSocket)); 
        } 
       } catch (IOException e) { 
        System.err.println("Unable to process client request"); 
        e.printStackTrace(); 
       } 
      } 
     }; 
     Thread serverThread = new Thread(serverTask); 
     serverThread.start(); 

    } 

    private class ClientTask implements Runnable { 
     private final Socket clientSocket; 

     private ClientTask(Socket clientSocket) { 
      this.clientSocket = clientSocket; 
     } 

     @Override 
     public void run() { 
      System.out.println("Got a client !"); 

      // Do whatever required to process the client's request 

      try { 
       clientSocket.close(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 

}

출처

2017-04-25 09:34:13

Android - 별도의 스레드에서 소켓에 연결

답변

관련 문제