尝试将两个客户端套接字连接到服务器时未设置 ObjectoutStram

Question

我有 Class 像下面这样尝试将两个客户端套接字连接到服务器但是当它们被服务器接受时我只能通过第一个套接字（代码中名为 s1）和第二个套接字将数据发送到服务器socket不能向服务器发送数据

public class Client_1 {
    public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {
    Socket s1 = new Socket("localhost", 8888);
    Socket s2 = new Socket("localhost", 8888);
    BufferedOutputStream bos1 = new BufferedOutputStream(s1.getOutputStream());
    ObjectOutputStream oos1 = new ObjectOutputStream(bos1);
    oos1.flush();
    BufferedOutputStream bos2 = new BufferedOutputStream(s2.getOutputStream());
    ObjectOutputStream oos2 = new ObjectOutputStream(bos2);
    oos2.flush();
    BufferedInputStream bis1 = new BufferedInputStream(s1.getInputStream());
    ObjectInputStream ois1 = new ObjectInputStream(bis1);
    BufferedInputStream bis2 = new BufferedInputStream(s2.getInputStream());
    ObjectInputStream ois2 = new ObjectInputStream(bis2);


        oos1.writeObject("a message from first client s1");
        oos1.flush();
        oos2.writeObject("a message from second client s2"); // sever does not receive this one
        oos2.flush();
}
}

这是等待客户端的服务器代码

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

        WaitForClient();
    }

    public static void WaitForClient() throws IOException {
        ServerSocket serverSocket = new ServerSocket(8888);
        int i = 0;
        while(true) {
            Socket client = serverSocket.accept();
            i++;
            System.out.println(i + " client connected");
            ClientThread clientThread = new ClientThread(client);
            Thread thread = new Thread(clientThread);
            thread.setDaemon(true);
            thread.start();
        }

    }

这是从套接字获取信息的 ClientThread

public class ClientThread implements Runnable {
    
    Socket clientSocket;
    ObjectInputStream oIStream;
    ObjectOutputStream oOStream;
    Object inputObject;
    BufferedInputStream bIS;
    BufferedOutputStream bOS;
    

    public ClientThread(Socket clientSocket) {
        this.clientSocket = clientSocket;
    }

    @Override
    public void run() {
        try {
            bOS = new BufferedOutputStream(clientSocket.getOutputStream());
            bIS = new BufferedInputStream(clientSocket.getInputStream());
            oOStream = new ObjectOutputStream(bOS);
            oOStream.flush();
            oIStream = new ObjectInputStream(bIS);

            while (clientSocket.isConnected()) {
                if (bIS.available() > 0) {
                    inputObject = oIStream.readObject();
                    doService(inputObject);
                    System.out.println(inputObject.toString());
                    inputObject = null;
                }
            }
            System.out.println("connection is closed!!!");
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("socket exception" + e.getMessage());
        }

    }
}

这是打印到控制台的内容

1 client connected
2 client connected
a message from first client s1   // input from the first socket but nothing from the second socket

Answer 1

这段代码应该可以工作，你在 doService 方法中遇到任何错误吗？。如果出现任何异常，while 循环将中断并且不会执行 print 语句。否则它应该从两个客户端打印数据

尝试将两个客户端套接字连接到服务器时未设置 ObjectoutStram

ObjectoutStram not set when trying to connect two client Socket to a server

java

sockets

serversocket

objectoutputstream