2

首先，我不太确定如何解释这一点而不会让人感到困惑，所以我会尽量让它简单。作为两人游戏的一部分，我有一个服务器应用程序将两个客户端“配对”在一起。发生的方式是，当第一个客户端连接到服务器时，接受套接字连接，使用该客户端创建一个新的 ClientProtocol 线程但未启动。当另一个客户端连接到服务器时，他被添加到前一个线程中，然后启动该线程。线程知道两个输入流和两个输出流，每个客户端一个。但是，当我尝试从客户端或服务器端读取时，什么都没有发生。这适用于单个线程中的单个客户端。这是一些代码：

服务器端（主线程）

public static Queue<ContestProtocol> contesters;

public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = null;
    contesters = new LinkedList<ContestProtocol>();

    try {
        serverSocket = new ServerSocket(4444);
    } catch (IOException e) {
        System.err.println("Could not listen on port: 4444.");
        System.exit(-1);
    }

    while (true) {
        Socket socket = serverSocket.accept();

        ObjectInputStream ois;
        ObjectOutputStream oos;

        try {
            ois = new ObjectInputStream(socket.getInputStream());
            oos = new ObjectOutputStream(socket.getOutputStream());

            synchronized (contesters) {
                if (contesters.size() == 0) {
                    Contester contester1 = new contester(ois, oos);
                    contesters.add(new ContestProtocol(contester1));
                } else {
                    Contester contester2 = new Contester(ois, oos);
                    contesters.poll().hook(contester2).start();
                }
            }
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

服务器端（竞赛协议）

private Contester contester1, contester2;

public ContestProtocol(Contester contester1) {
    super("ContestProtocol");
}

public ContestProtocol hook(Contester contester2) {
    this.contester2 = contester2;
    return this;
}

public void run() {
    try {
        contester1.getOOS().writeInt(-1);
        contester2.getOOS().writeInt(-2);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

服务器端（竞赛者）：

public Contester(ObjectInputStream ois, ObjectOutputStream oos) {
    this.ois = ois;
    this.oos = oos;
}

public ObjectInputStream getOIS() {
    return ois;
}

public ObjectOutputStream getOOS() {
    return oos;
}

客户端：

try {
            socket = new Socket(serverAddr, 4444);
            oos = new ObjectOutputStream(socket.getOutputStream());
            ois = new ObjectInputStream(socket.getInputStream());
            int selectedChampion = ois.readInt();
} catch (Exception e) {
                e.printStackTrace();
}

ContestProtocol 线程没有问题地完成执行，但两个客户端都挂在 readInt() 上。我不明白为什么。

4

2 回答 2

0

您应该循环您的客户端输入流。

while(true){
if(ois.avaible() > 0)
ois.readInt();
}

提示：使用 netty 研究异步网络以获得更好的性能。

于 2012-04-25T14:42:48.570 回答
0

这在访问资源时必须执行互斥锁或信号量问题：您正在使用的流（在这种情况下是输出流和输入流）正在读取和写入相同的资源。因为所有这些进程都发生在一个继续的线程上，所以它们的线程相互中断，并在另一个线程上创建等待进程。
一种解决方案是，您在流对象上注册事件监听器，以便每当一个完成时，另一个只会启动。

于 2012-04-25T15:02:18.920 回答