Javaネットワークプログラミングクライアントからデータを読み取る

Question

私はネットワークプログラミングの初心者です。私は、ソケットの基本を理解するために、単純なサーバ/クライアントプログラムを作りたいと思っています。しかし残念ながら私は一つの概念を理解できません。クライアントがメッセージを送信する前に、readUTF()メソッドに電話をかけることはできますか？私が2回目にこのメソッドを呼び出すと、プログラムがクラッシュするためです。

エラー：

java.net.SocketException: Connection reset 
at java.net.SocketInputStream.read(Unknown Source) 
at java.net.SocketInputStream.read(Unknown Source) 
at java.net.SocketInputStream.read(Unknown Source) 
at java.io.DataInputStream.readUnsignedShort(Unknown Source) 
at java.io.DataInputStream.readUTF(Unknown Source) 
at java.io.DataInputStream.readUTF(Unknown Source) 
at Messaging.ServerSideConnection.receiveData(ServerSideConnection.java:59) 
at Messaging.Server.printInputs(Server.java:88) 
at Messaging.Server$2.run(Server.java:35) 
at java.lang.Thread.run(Unknown Source) 

サーバー：

package Messaging; 

import java.io.IOException; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.util.ArrayList; 

public class Server { 

private static final String configId = "SERVER_CONFİG_ID_"; 

private static final int port = 6066; 
private volatile ArrayList<ServerSideConnection> connections; 

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

public Server(){ 
    connections = new ArrayList<>(); 

    Thread acceptConnections = new Thread(new Runnable(){ 
     public void run() { 
      try { 
       acceptConnections(port); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    }); 

    Thread printInputs = new Thread(new Runnable(){ 
     public void run() { 
      while(true){ 
       printInputs(); 
       try { 
        Thread.sleep(5000); 
       } catch (InterruptedException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 
      } 
     } 
    }); 

    acceptConnections.start(); 
    printInputs.start(); 

    try { 
     acceptConnections.join(); 
     printInputs.join(); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
    try { 
     Thread.sleep(5000); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
} 

public void acceptConnections(int port) throws IOException{ 
    ServerSocket serverSocket = new ServerSocket(port); 
    while(true){ 
     System.out.println("SERVER : Listening.."); 
     ServerSideConnection connection = new ServerSideConnection(serverSocket.accept()); 
     connection.sendData(configId + Integer.toString(connection.getId())); 
     connections.add(connection); 
     System.out.println("SERVER : Connected to " + connection.getSocket().getInetAddress()); 
    } 
} 

public void controlConnectionLife(){ 
    int instantSize = connections.size(); 
    for(int i=0;i<instantSize;i++){ 
     if(!connections.get(i).isConnected()){ 
      connections.get(i).killConnection(); 
      connections.remove(i); 
      i--; 
     } 
    } 
} 

public void printInputs(){ 
    for (ServerSideConnection connection : connections){ 
     System.out.println(connection.isConnected()); 
     try { 
      System.out.println(connection.receiveData()); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 
} 

} 

import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.ObjectInputStream; 
import java.io.ObjectOutputStream; 
import java.io.OutputStream; 
import java.net.Socket; 

public class ServerSideConnection { 

private static int count; 
private int id; 

private Socket socket; 
private DataInputStream input; 
private DataOutputStream output; 

public ServerSideConnection(Socket socket){ 
    this.socket = socket; 

    initOutputStream(); 
    initInputStream(); 

    count++; 
    id = count; 
} 

private void initInputStream(){ 
    try { 
     InputStream in = socket.getInputStream(); 
     input = new DataInputStream(in); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

private void initOutputStream(){ 
    try { 
     output = new DataOutputStream(socket.getOutputStream()); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

public void killConnection(){ 
    try { 
     output.close(); 
     input.close(); 
     socket.close(); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

public String receiveData() throws IOException{ 
    return input.readUTF(); 
} 

public void sendData(String msg) throws IOException{ 
    output.writeUTF(msg); 
    output.flush(); 
} 

public boolean isConnected(){ 
    return socket.isConnected(); 
} 

public int getId(){ 
    return id; 
} 

public Socket getSocket(){ 
    return socket; 
} 

public DataInputStream getInput() { 
    return input; 
} 

public DataOutputStream getOutput() { 
    return output; 
} 

} 

クライアント：

import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.IOException; 
import java.io.ObjectInputStream; 
import java.io.ObjectOutputStream; 
import java.net.ConnectException; 
import java.net.Socket; 
import java.net.UnknownHostException; 
import java.util.Scanner; 

public class ClientSideConnection { 

private static final String configId = "SERVER_CONFİG_ID_"; 

private static final int port = 6066; 
private static final String host = "localhost"; 

private int id; 

private Socket socket; 
private DataInputStream input; 
private DataOutputStream output; 

public static void main(String[] args){ 
    try { 
     new ClientSideConnection(port,host); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

public ClientSideConnection(int port, String host) throws UnknownHostException, IOException{ 
    boolean connected = false; 
    while(!connected){ 
     try{ 
      socket = new Socket(host,port); 
      connected = true; 
      System.out.println("CLIENT : Connected to " + socket.getInetAddress()); 
     } 
     catch(ConnectException e){ 
      connected = false; 
     } 
    } 
    initOutputStream(); 
    initInputStream(); 


    String receivedId = receiveData(); 
    if(receivedId.substring(0, 17).equals(configId)) 
     id = Integer.parseInt(receivedId.substring(17,receivedId.length())); 
    sendTestData(); 
} 

private void initInputStream(){ 
    try { 
     input = new DataInputStream(socket.getInputStream()); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

private void initOutputStream(){ 
    try { 
     output = new DataOutputStream(socket.getOutputStream()); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

public void killConnection(){ 
    try { 
     output.close(); 
     input.close(); 
     socket.close(); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

public String receiveData() throws IOException{ 
    return input.readUTF(); 
} 

public void sendData(String msg) throws IOException{ 
    output.writeUTF(msg); 
    output.flush(); 
} 

public int getId() { 
    return id; 
} 

public void sendTestData(){ 
    Scanner scan = new Scanner(System.in); 
    System.out.print("enter test msg: "); 
    String msg = scan.nextLine(); 
    try { 
     sendData(msg); 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
    System.out.println("msg sended!"); 
} 
} 

Answer 1

例外メッセージが表示されるため、クライアントによって接続が閉じられているため、readUTFへの2番目の呼び出しは失敗しています。

1. 接続
2. セットアップ入力と出力は、サーバ
3. から
4. 読み出しデータがデータを送信した後、サーバー

にデータを送信ストリーム確立します。クライアントを実行しているコードは、現在のシーケンスは、以下のサーバーにはコードが残っておらず、送受信のプロセスを繰り返すループもないので、クライアントは接続の終了を閉じて終了します。あなたはあなたの順序に第五ステップを追加する必要があります。

1. 接続
2. セットアップの入力と出力がされるまで、サーバー
3. から
4. 読み出しデータは3に、サーバ
5. ジャンプにデータを送信ストリームの確立します停止条件が満たされたこのシーケンスへ

一つのアプローチは次のようになります。

public class Client { 
    public static void main(String[] args) { 

     Client client = new Client(); 
     boolean sucessful; 

     do { 
      String data = client.receiveData(); 
      successful = client.sendData(data); 
     } while(successful); 

     client.close(); 
    } 

    public Client() { 
     //setup connection and in/output streams 
    } 

    public String receiveData() { 
     //read from input 
    } 

    public boolean sendData(String data) { 
     //send data 
    } 

    public void close() { 
    } 
}