队列中的Java套接字连接 - java

我已经设置了客户端/服务器。服务器（Provider.java）将接受2个套接字连接。连接后，将询问每个客户端他们想玩哪种游戏-井字棋，国际象棋或Connect5。然后根据套接字的答案将Socket连接存储在特定的游戏队列中。因此，井字游戏有一个队列，而Connect 5有一个队列，依此类推。

队列的实现如下：

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

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

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)

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

感谢你的帮助！

参考方案

老实说，这个问题看起来像是解决大学任务的方法。

提示：首先编写简单的发布者/订阅者。设置一个将向套接字写入hello world的进程，并设置第二个将从该套接字读取的进程。然后从那里拿走。我敢打赌，您缺少明显的东西:-)

JAVA 8具有任何匹配属性的对象的过滤器列表 - java

我的要求是通过匹配任何属性的字符串来过滤对象列表。例如，假设Contact类具有三个属性：街道，城市，电话。我知道java流过滤器是如何工作的，在这里我必须将输入字符串与每个属性进行比较，如下所示：contactList.stream().filter(contact -> contact.getStreet().equals("dubai&…

Java:线程池如何将线程映射到可运行对象 - java

试图绕过Java并发问题，并且很难理解线程池，线程以及它们正在执行的可运行“任务”之间的关系。如果我创建一个有10个线程的线程池，那么我是否必须将相同的任务传递给池中的每个线程，或者池化的线程实际上只是与任务无关的“工人无人机”可用于执行任何任务？无论哪种方式，Executor / ExecutorService如何将正确的任务分配给正确的线程？ 参考方案 …

JAVA:字节码和二进制有什么区别？ - java

java字节代码（已编译的语言，也称为目标代码）与机器代码（当前计算机的本机代码）之间有什么区别？我读过一些书，他们将字节码称为二进制指令，但我不知道为什么。 参考方案 字节码是独立于平台的，在Windows中运行的编译器编译的字节码仍将在linux / unix / mac中运行。机器代码是特定于平台的，如果在Windows x86中编译，则它将仅在Win…

检查Optional中是否存在null属性，并返回String Java Stream API - java

我有以下class Person private String firstName; private String familyName; // Setters and Getters 我有以下方法public String getFullName(Optional<Person> persons) { return persons .map(p…

java:继承 - java

有哪些替代继承的方法？ java大神给出的解决方案 有效的Java：偏重于继承而不是继承。 （这实际上也来自“四人帮”）。他提出的理由是，如果扩展类未明确设计为继承，则继承会引起很多不正常的副作用。例如，对super.someMethod()的任何调用都可以引导您通过未知代码的意外路径。取而代之的是，持有对本来应该扩展的类的引用，然后委托给它。这是与Eric…