使用带有套接字的循环时，Java进入另一个线程

Question

我需要一个帮助，我正在试图使客户服务器应用程序复制文件在Java...我有一个MainWnd对象，它创建了TCPServer对象，在send按钮上，它将创建TCPClient对象，它将初始数据发送给对手TCPServer并将打开给定数量的侦听线程（让它是n个）（这个侦听线程在这里只是因为它们接受一个文件）（每个线程在不同的端口上侦听发送回TCPClient）TCPClient然后创建n个其他TCPClients线程发送文件...这是我的，它正在运行。问题是，当接收方点击“中断”按钮时，文件接收会被中断。我无法获得对接收者的TCPServer线程的这种中断的信息，这应该会杀死正在下载文件的这n个线程。

我想问题出在TCPServer上，那里是infinit循环，但是这个套接字会造成循环阻塞，所以我不能进入Connection类，杀死这n个线程。

TCP服务器

public void setSendInterruption() {
    this.interruptedSending = true;
    //c.setSendInterruption();
}

public TCPServer(int port, int socketNums, Map<Byte, LinkedList<Byte>> realData, File file, int fileLength) {
    this.serverPort = port;
    this.socketNums = socketNums;
    if(file != null)
        this.file = file;
    if(fileLength != -1)
        this.fileLength = fileLength;
    if(realData != null)
        this.realData = realData;

    if(tmpData != null)
        this.tmpData = tmpData;
}

@Override
public void run() {
    try { 
        System.out.println(this.getId());
        listenSocket = new ServerSocket(serverPort); 

        System.out.println("server start listening... ... ...");

        while(true) {
            if(interruptedSending)
                System.out.println("Here I never come");
            Socket clientSocket = listenSocket.accept(); 
            Connection c = new Connection(clientSocket, socketNums, realData, file, fileLength); 
        } 
} 
catch(IOException e) {
        System.out.println("Listen :"+e.getMessage());} 
}

连接

while (true)
                {
                    byteRead = input.read();
                    //Thread.sleep(100);
                    if(interruptedSending) {
                        TCPClient tcpClient = new TCPClient(clientSocket.getPort(), clientSocket.getInetAddress().getHostAddress());
                        tcpClient.sendInterruptedData();
                        interruptedSending = false;
                    }
                    char lowChar;

                    if(byteRead == -1) {
                        break;
                    } else
                        lowChar = (char)byteRead;

                    lowData += lowChar;

                    if(lowData.length() >= 2) {
                        if (lowData.substring(lowData.length()-2).compareTo("//") == 0) {
                            break;
                        } else if (lowData.length() > 6) {
                            byteData.add((byte)byteRead);
                        }
                    }
                }

在连接方面，有更多的行，但它们只是主要解析一个协议。谢谢你的帮助。我希望我写得干净...

Answer 1

据我所知，每个连接都有一个运行它的线程。您想要中断这些线程中的每一个线程，但无法从线程内部执行，因为线程被困在input.read（）中。

如果这是你的意思，就这么做：

在Connection的构造函数中保存线程，以便以后可以访问它。制作一个killThread（）-方法或therelike，这样您就可以从外部访问线程：

public void killThread() {
    thread.interrupt(); //thread is the thread you saved in the constructor
}

当您想要终止连接线程时，调用killThread（）。这将导致线程抛出一个java.lang.InterruptedException，无论此时它在哪里。您可以忽略这一个（因为您希望线程无论如何都死掉），也可以使用

try {
    //your loop
} catch (InterruptedException e) {
    return;
}

这将很好地结束线程而不会抛出异常。