1

我有这个代码：

 Socket incomingConnection = serverSocket.accept();
 String strategy = "1";
 Client client = new Client(incomingConnection, this, strategy);

客户端的构造函数：

  public Client(Socket socket, ChatServer chatServer, String strategy) throws IOException{
        this.socket = socket;
        this.inputStream = socket.getInputStream();
        this.outputStream = socket.getOutputStream();

        this.chatServer = chatServer;
        this.instance1 = new Strategy1(chatServer, this);
        this.instance2 = new Strategy2(chatServer, this);
        this.strategy = (this.instance1.getName().equals(strategy1) ? this.instance1 : this.instance2);
        this.strategy.setStreams();
    }

现在看起来像Strategy1：

public class Strategy1{
public Strategy1(ChatServer server, Client client) throws IOException{
    this.chatServer = server;
    this.client = client;
}

public void setStreams() throws IOException{
    inputStream = new ObjectInputStream(client.getInputStream());
    outputStream = new ObjectOutputStream(client.getOutputStream());
}

和相同的Strategy2。 客户端类中的方法：

client.getInputStream() {
    return inputStream;
}
// similar for outputStream

问题是：当Client构造函数试图执行strategy.setStreams()时，程序阻塞new ObjectInputStream()。

当我将setStream()方法的包含移动到构造函数中时，Strategy1它就起作用了！

为什么？

4

1 回答 1

5

交换这些行：

inputStream = new ObjectInputStream(client.getInputStream());
outputStream = new ObjectOutputStream(client.getOutputStream());

从套接字创建ObjectInputStream读取。如果你先在连接的两端创建输入流，它会死锁。最安全的是始终首先创建输出流。

于 2013-06-10T13:50:53.783 回答