队列中的 Java 套接字连接

Question

我有一个客户端/服务器设置。服务器 (Provider.java) 将接受 2 个 Socket 连接。每个客户端在连接后都会被询问他们想玩什么类型的游戏 - Tic Tac Toe、Chess 或 Connect 5。根据他们的回答，Socket 连接然后存储在特定的游戏队列中。所以，Tic Tac Toe 有一个 Queue，Connect 5 有一个 Queue，等等。

队列实现如下:

Queue<Socket> qTTT = new LinkedList<Socket>();
Queue<Socket> qC5 = new LinkedList<Socket>();
Queue<Socket> qChess = new LinkedList<Socket>();

每次添加连接时，都会检查队列以查看是否有两个连接。如果在特定队列中有两个连接，则将使用这两个连接启动该类型的游戏。 (采用工厂设计模式设计)。

if (qTTT.size() == 2) {
    ObjectOutputStream out = null, out2 = null; // Client 1, Client 2
    ObjectInputStream in = null, in2 = null; // Client 1, Client 2

    Socket connection1 = null, connection2 = null;

    connection1 = qTTT.remove();
    connection2 = qTTT.remove();

    try {
        out = new ObjectOutputStream(connection1.getOutputStream());
        out2 = new ObjectOutputStream(connection2.getOutputStream());

        in = new ObjectInputStream(connection1.getInputStream());
        in2 = new ObjectInputStream(connection2.getInputStream());
    } catch (IOException e) {
        e.printStackTrace();
    }

    SimpleGameFactory factory = new SimpleGameFactory();
    GameStore store = new GameStore(factory);

    Game game = store.orderGame("TTT");
    System.out.println("We ordered a " + game.getName() + "\n");
    tgame.setObject(game);
    tgame.setSockets(connection1, connection2);
    tgame.setStreams(in, out, in2, out2);

    // Start the threaded game
    tgame.start();
}

以上是抛出某种流损坏错误。这是我的问题:

首先，当客户端首次连接时，套接字连接与 ObjectInputStream 和 ObjectOutputStream 相关联。这些流不会与连接一起传递到队列中，因此在上面的代码中，新流被分配给连接。然后，这些流被传递到线程游戏中以启动游戏。我可以这样做(为连接分配新流)吗？在流已经分配给他们之后？

其次，我是否正确地存储/删除了队列中的套接字连接？

感谢您的帮助!

更新:

---

这是我遇到的错误:

java.io.EOFException
        at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2232)
        at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2698)
        at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:750)
        at java.io.ObjectInputStream.<init>(ObjectInputStream.java:268)
        at Pools.check_pools(Pools.java:34)
        at Provider.start(Provider.java:85)
        at StartServer.main(StartServer.java:16)

---

事实证明，我无法为已经分配了一组流的套接字连接分配一组额外的输入/输出流。

感谢大家的帮助!

Answer 1

老实说，这个问题看起来像是大学作业的解决方案。

提示:先写简单的发布者/订阅者。设置一个将 hello world 写入套接字的进程和第二个将从该套接字读取的进程。然后从那里拿走。我打赌你错过了一些明显的东西:-)