由对等方重置连接或无需关闭套接字

Question

到目前为止，每当我遇到问题时，我都会使用这个网站，我也找到了解决方案，但这次我甚至不知道发生了什么。

我正在开发一款基于1对1多人模式的游戏。到目前为止，我已经创建了一个服务器和我的客户端程序。

我的服务器为每个与服务器连接的客户端创建一个带有套接字的新线程，当在游戏中按下“新游戏”按钮时，线程会搜索另一个正在寻找新游戏的线程，一旦它找到他，创建一个单独的线程，向两个线程发送消息，向它们发出游戏已经开始的信号，然后通过它们的套接字发送到相应反应的程序。

这是我的代码：

线程：

    public void run() {

    try {

        out = new ObjectOutputStream(socket.getOutputStream());
        in = new ObjectInputStream(socket.getInputStream());
        ServerNachricht inputLine, outputLine;
        LabyrinthProtocol prot = new LabyrinthProtocol();


        while (socket.isConnected()) {

ServerNachricht是一个由类型（int）、发送者（player）和消息（String）组成的类。当线程收到一条新的游戏消息时，协议会将玩家状态值更改为“搜索”，然后查看是否存在另一个“搜索”玩家，然后将两个玩家的值更改为“播放”，并返回一个Kampfbeginn类型的新服务器Nachricht，找到的玩家作为发送方。协议返回outputLine后，线程将执行以下操作：

                    if (outputLine.getArt() == ServerNachricht.KAMPFBEGINN) {
                    System.out.println(outputLine.getSender().getSname()+" ist da");    
                    server.kampfbeginn(this, outputLine.getSender());
                }

sysout只是验证协议是否真的找到了另一个玩家，并且正在打印该玩家的名字以确定。到目前为止，这一直有效。以下是服务器中需要新游戏的部分：

    public void kampfbeginn(LabyrinthThread t, Spieler gegner) {
    KampfThread kampf = null;
    System.out.println(gegner.getSname()+" anerkannt");
    for(int i = 0;i<threads.size();i++){
        if(threads.get(i)!=null){
            System.out.println(threads.get(i).getSpieler().getSname());
            if(threads.get(i).getSpieler().getSname().equals(gegner.getSname())){
                LabyrinthThread gegnert = threads.get(i);
                kampf = new KampfThread(t,gegnert);
                t.setKampf(kampf);
                gegnert.setKampf(kampf);
                break;
            }
        }
    }

此代码搜索每个现有线程（服务器将它们存储在向量中）并检查该线程连接的播放器是否是协议返回的播放器。当找到线程时，两个线程都会被提供给一个新创建的线程，该线程存储它们两个，同时将该新线程存储在两个线程中。新线程甚至使用两个系统验证连接：

    public KampfThread(LabyrinthThread spieler1, LabyrinthThread spieler2) {
    super();
    this.spieler1 = spieler1;
    this.spieler2 = spieler2;
    System.out.println(spieler1.getSpieler().getSname() + "ist drin");
    System.out.println(spieler2.getSpieler().getSname() + "ist drin");

}

我每次都收到。两个连接建立后，该线程向两个线程发送一条消息，以便它们通知它们的程序开始：

        case(ServerNachricht.KAMPFBEGINN):
        spieler1.ThreadNachricht(new ServerNachricht(ServerNachricht.KAMPFBEGINN,spieler2.getSpieler(),""));
        spieler2.ThreadNachricht(new ServerNachricht(ServerNachricht.KAMPFBEGINN,spieler1.getSpieler(),""));
        break;

在线程中调用此方法：

    public void ThreadNachricht(ServerNachricht s) {

    if(socket.isConnected()) {
        try {
            out.writeObject(s);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

奇怪的是，这在80%的情况下都是绝对完美的（所以两个程序都进入“游戏开始”模式），但有时它只对一个或两个程序都不起作用，服务器要么被对等方重置连接，要么在服务器中发生套接字关闭错误

    public void ThreadNachricht(ServerNachricht s) {

    if(socket.isConnected()) {
        try {
            out.writeObject(s);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

在外面。书面对象；线任何地方都没有关闭任何东西的线条（我甚至从任何地方拿出了每一个close（），以确保没有任何东西可以干扰），而且似乎根本没有任何模式来确定它何时工作和何时不工作（不工作会关闭服务器和程序clientsocket，因此在这种情况下程序无法工作）。我有没有办法保证我的程序正常运行，或者我有没有出错？我非常绝望，因为我甚至不能做主要的测试来找出一个模式，因为用完全相同的设置启动程序两次仍然会导致它大部分时间都工作。

编辑：我确实遇到了这样一种情况，一个玩家进入了新的游戏模式，而另一个玩家留在了主菜单中（导致对等点重置连接：服务器的套接字写入错误），连续两次，然后第三次在同一运行中没有任何问题。所以我和两个玩家一起搜索，但只有一个进入了游戏屏幕（另一个得到了错误）。然后我按回进入主菜单，并以相同的结果再次执行相同的操作。当我第三次尝试时，它起作用了，两个玩家都进入了游戏屏幕并开始相互交互。

Answer 1

• “连接重置”通常意味着您写入了已被对等方关闭的连接：换句话说，是应用程序协议错误

所有这些都只表明了编码错误。发布更多的代码，我会给你看更多的代码。

Answer 2

这实际上是我犯的一个相当有趣的错误：我的服务器将线程存储在他的向量中，即使它们的套接字断开。因此，使用上次重启后就已经连接到服务器的帐户登录（我在测试外观时用来保持服务器运行）会导致

   for(int i = 0;i<threads.size();i++){
    if(threads.get(i)!=null){
        System.out.println(threads.get(i).getSpieler().getSname());
        if(threads.get(i).getSpieler().getSname().equals(gegner.getSname())){

循环以确定其他玩家的线程，以找到较旧且已经关闭的线程，而不是其他玩家目前连接的线程。