java - ObjectInputStream 阻止我的套接字

Question

这个问题已经有答案了:

ObjectInput and Output streams are not being accepted by client/server (2 个回答)

已关闭 5 年前。

我想利用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 类中实例化 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 中解释的原因而阻塞。