ObjectInputStream 阻塞我的套接字

Question

我想利用 ObjectInputStream 和 ObjectOutputStream 通过 Socket 发送数据。我在网上看了看，但即使有几个解释，我也无法解决我的问题。

这是我的继承人：

public class Server {
    //Entry point of the application
    public static void main(String[] args) {
        Integer port;
        if(args.length<=0) 
            port=new Integer("3000"); // si pas d'argument : port 3000 par d�faut
        else 
            port = new Integer(args[0]); // sinon il s'agit du num�ro de port pass� en argument

        ClientListener server = new ClientListener(port); // instance de la classe principale
    }
}

public ClientListener(Integer port) { // THIS IS THE MAIN THREAD
        try
        {
          server = new ServerSocket(port.intValue()); // ouverture d'un socket serveur sur port
          new IOCommande(this); // RUN IN ANOTHER THREAD
          while (true) // attente en boucle de connexion (bloquant sur ss.accept)
          {
            new ClientSocketStream(server.accept(),this); // un client se connecte, un nouveau thread client est lanc�
          }
        }
        catch (Exception e) {
            //server.close();
        }
    }

public ClientSocketStream(Socket incomingClient, ClientListener ref) { // THIS IS NOT A THREAD
        this.client = incomingClient;
        this.server = ref;

        //Ajout des IO et generation d'un UID
        try{
            out = new ClientOutputWriter(client.getOutputStream());
            in = new ClientInputReader(((MessageReader)this),client.getInputStream());

            // ajoute du client dans la liste
            id = server.addClient(this);
        }catch (IOException e){ 
            e.printStackTrace();
        }finally {// En cas de probl�me (que le client s'est d�connect�)
            try {
                server.removeClient(id);
                client.close();
            }catch(IOException e) {

            }
        }
    }

public ClientInputReader(MessageReader client, InputStream in) throws IOException { //THIS IS A THREAD
        this.client = client;
        try {
            this.in = new ObjectInputStream(in);
        }catch(Exception e){
            e.printStackTrace();
        }
        this.runtime = new Thread(this);
        this.runtime.start();
    }

public ClientOutputWriter(OutputStream out) throws IOException { //THIS IS NOT A THREAD
        this.out = new ObjectOutputStream(out);
    }

请假设套接字完全正常工作，所以我可以使用 Telnet 连接。

所以我在 ClientInputReader class 中实例化 ObjectInputStream 时卡住了。构造函数似乎被阻塞了，我无法正确使用它。

解决方案：

不要使用 telnet 进行测试，而是尝试创建另一个可运行的项目。不要忘记 在 ObjectInputStream 之前声明 objectOutputStream 并执行如下操作：

public class TestClient {
    //Entry point of the application
    public static void main(String[] args) {
        try {
            Socket socket = new Socket("127.0.0.1", 3000);
            ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
            ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
            out.writeObject(new Message("test"));
            Message msg = (Message)in.readObject();
            socket.close();
        }catch(Exception e){}
    }
}

Answer 1

您的客户端未构建 ObjectOutputStream，因此您的 ObjectInputStream 构造函数因 Javadoc 中解释的原因而阻塞。

ObjectInputStream 阻塞我的套接字

ObjectInputStream block my socket

java

sockets

multithreading

objectoutputstream

objectinputstream

解决方案：