while循环中的两个服务器线程相互阻塞

Question

每个人希望您能在这方面帮助我：我有两个线程，负责处理来自客户端的连接。

这是我的密码

ServerSocket loginSocket = new ServerSocket(8000);
ServerSocket fileSocket = new ServerSocket(7000);

while (running) {
  new LoginThread(loginSocket.accept(),loginInormation).start();
  new LoaderThread(fileSocket.accept()).start();
}

当我尝试两次连接到loginSocket时，服务器将阻塞并停止工作，从而阻塞客户端，但如果我删除以下内容，则不会发生这种情况：

new LoginThread(loginSocket.accept(),loginInormation).start();

我没有收到任何错误消息，那么为什么会发生这种情况，我如何修复？

Answer 1

在不同的线程中启动fileSocket和登录套接字

package com.ca.training.task.app;

import java.io.IOException;
import java.net.ServerSocket;

public class App {

    public void execute() {
        LoginRunnable loginRunnable = new LoginRunnable();
        loginRunnable.setLoginInformation(new Object());//Login information

        FileRunnable fileRunnable = new FileRunnable();//Data for loaded runnable.
        fileRunnable.setParams(new Object());

        startLoginThread(loginRunnable);
        startFileThread(fileRunnable);
    }

    private static void startLoginThread(LoginRunnable loginRunnable) {
        Thread loginThread = new Thread(loginRunnable);
        loginThread.start();
    }

    private static void startFileThread(FileRunnable fileRunnable) {
        Thread loadedThread = new Thread(fileRunnable);
        loadedThread.start();
    }

    class LoginRunnable implements Runnable {

        private Object loginInformation;

        @Override
        public void run() {
            try {
                ServerSocket loginSocket = new ServerSocket(8000);
                loginSocket.accept();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        public Object getLoginInformation() {
            return loginInformation;
        }

        public void setLoginInformation(Object loginInformation) {
            this.loginInformation = loginInformation;
        }
    }

    class FileRunnable implements Runnable {

        private Object params;

        @Override
        public void run() {
            try {
                ServerSocket fileSocket = new ServerSocket(7000);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        public Object getParams() {
            return params;
        }

        public void setParams(Object params) {
            this.params = params;
        }
    }
}

Answer 2

新登录读取（loginSocket.accept（），LoginInformation）行。开始（）包含方法调用loginSocket。accept（），它将在创建此线程之前调用。此方法调用将被阻止，直到客户端登录。（此外，第二个线程将被fileSocket.accept（）阻塞）。

至于解决方案，我会将接受（）调用移动到每个线程内部。您需要将套接字传递给线程，以便它们执行此操作。

Answer 3

接受（）方法是一种阻塞方法，这意味着您的程序在使用loginSocket（）建立连接之前不会继续。

当您创建LoginThread时，程序会等待连接来设置对象的第一个参数，并且在建立连接之前不会继续执行。