0

私はソケットプログラミングが初めてで、ばかげた間違いを犯していることをよく知っています。残念ながら、何が起こっているのかを把握することはできません。同じマシンでJavaソケットを使用して基本的なマルチクライアントサーバーシステムを作成しました（違いはありません）が、驚いたことに、

  • サーバーからクライアントにメッセージを送信し、クライアントで読み取ります。 また
  • クライアントからサーバーにメッセージを送信し、サーバーで読み取ります。

私が達成できないのは

  • サーバーからクライアントにメッセージを送信し、クライアントで読み取ります。 と
  • クライアントからサーバーにメッセージを送信し、サーバーで読み取ります。

コードを添付しています。

import java.io.IOException;
import java.net.ServerSocket;

public class ServerSocketMain {

public static void main(String[] args) throws IOException {

    @SuppressWarnings("resource")
    ServerSocket serverSocket = new ServerSocket(1234);

    while(true){
        System.out.println("Server Waiting for Client to Connect ....");
        Thread thread = new Thread(new ServerReaderWriter(serverSocket.accept()));
        System.out.println("Client connected....");
        thread.start();

    }



}

}


import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

public class ServerReaderWriter implements Runnable {

private Socket socket;

public ServerReaderWriter(Socket socket) {
    this.socket = socket;
}

@Override
public void run() {
    try {

        readFromClient();
        writeToClient();

    } catch (IOException e) {
        e.printStackTrace();
    }

}

private void writeToClient() throws IOException {
    DataOutputStream writeToClient = new DataOutputStream(this.socket.getOutputStream());
    writeToClient.writeBytes("Communication from Client Thread "
            + Thread.currentThread().getName() + "\n");

}

private void readFromClient() throws IOException {
    BufferedReader inFromClient = new BufferedReader(new InputStreamReader(
            this.socket.getInputStream()));

    System.out.println("Client Communication : " + inFromClient.readLine());

}

}


import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ClientSocketMain {

public static void main(String[] args) throws UnknownHostException, IOException {
    ExecutorService executorService = Executors.newFixedThreadPool(10);
    for (int i = 0; i < 10; i++) {
        executorService.submit(new ClientReaderWriter(new Socket("localhost", 1234)));
    }

    executorService.shutdown();

}

}




import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

public class ClientReaderWriter implements Runnable {

private Socket socket;

public ClientReaderWriter(Socket socket) {
    this.socket = socket;
}

@Override
public void run() {

    try {

        readFromServer(socket.getInputStream());
        writeToServer(socket.getOutputStream());

    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            socket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}

private void writeToServer(OutputStream outputStream) throws IOException {
    DataOutputStream writeToServer = new DataOutputStream(outputStream);

    writeToServer.writeBytes("Communication from Client Thread "
            + Thread.currentThread().getName() + "\n");

}

private void readFromServer(InputStream inputStream) throws IOException {
    BufferedReader inFromServer = new BufferedReader(new InputStreamReader(
            inputStream));

    System.out.println(inFromServer.readLine());

}

}

読み取りおよび書き込み操作が完了する前であっても、クライアントソケットが閉じているかどうか疑問に思っています..大声で推測しているだけではわかりません。助けてください！！

4

1 に答える 1