一次接收来自多个套接字的数据（多线程）

Question

我是网络编程的新手，我一直在寻找解决方案来解决我的问题，但找不到一个。我想要的是有一台服务器可以同时接收来自多个套接字的文件。当服务器接受新的连接套接字时，它会用ClientThread类包装该套接字。以下是代码：

public class Server extends Thread { 
    private ServerSocket server; 
    private Vector<ClientThread> clients; 

    @Override 
    public void run() { 
     listen(); 
    } 

    private void listen() { 

    new Thread("Listening Thread") { 

     @Override 
     public void run() { 
      while (true) { 
       try { 
        Socket socket = server.accept(); 

        ClientThread newClient = new ClientThread(socket); 
        newClient.start(); 
        clients.addElement(newClient); 

       } catch (IOException | ClassNotFoundException e) { 
        e.printStackTrace(); 
       } 
      } 
     } 
    }.start(); 
} 

ClientThread是Server类中的私有类。它总是从ObjectInputStream监听Object，但我希望能够在对象之后接收到一个大文件。这就是为什么我认为我应该使用多线程。下面是代码：（？我猜）

private class ClientThread extends Thread { 

    public Socket socket; 
    private boolean loggedIn; 
    private ObjectInputStream ois; 
    private BufferedInputStream bis; 

    public ClientThread(Socket socket) { 
     this.socket = socket; 
     loggedIn = true; 

     InputStream is = socket.getInputStream(); 
     ois = new ObjectInputStream(is); 
     bis = new BufferedInputStream(is); 
    } 

    @Override 
    public void run() { 
     receive(); 
    } 

    private void receive() { 

     while (loggedIn) { 
      try { 
       // this method blocks i guess 
       Object object = ois.readObject(); 

       // after the object comes the large file 
       byte[] bytes = new byte[SOME_SIZE]; 

       int bytesRead; 
       int totalRead = 0; 

       // reading the large file into memory 
       while ((bytesRead = bis.read(bytes, totalRead, bytes.length - totalRead)) > -1) { 
        totalRead += bytesRead; 
       } 

       // rest of the code for handling received bytes....... 

      } catch (ClassNotFoundException | IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 

} 

我不知道如果接受这样的数据，因为所有这些客户端套接字在此服务器上发送数据到同一个端口，甚至有可能。如果客户端同时发送数据，服务器需要知道哪个数据是针对哪个客户端的。这已经被照顾了，或者我需要完全不同的方法吗？

我不知道这是一个愚蠢的问题，但就像我说我刚刚开始学习这些东西。另外我无法测试我的程序，因为我甚至没有客户端的代码。只是想确保我一开始就不会出错。如果这是错误的，随时发表一些想法。 ：） 谢谢！

Answer 1

首先它不坏:) 您可以稍后改进使用Selector但这是另一个话题。

虽然有些说明：ServerSocket在特定的端口上侦听。当远程客户端连接到它时，将创建一个通信通道（即套接字）。如果另一个客户端连接，则创建另一个套接字两个插座都是不同的通道，不会互相干扰，因为它们连接到不同的远程IP 和端口。

这一切都与如何形成TCP headers并IP headers做：一个TCP数据包与包含源和目的地端口，在包含源和目的地IP IP首部的开头其标头中发送。这些用于区分不同的套接字。

---

关于“播出”你想这样做（按在@ Rajesh的回答您的评论），您可以选择：

• 自己做，在纯TCP与ServerSocket和Socket像你开始
• 切换到UDP并使用MulticastSocket，它具有发送单个发送的优势，但是您必须处理客户端代码中的丢失/无序数据报（UDP不保证像TCP那样提供或排序）
• 检查NIO与Selector和SocketChannel
• 像jGroups或Netty这对于你

做I/O的东西，你在学习调查框架，我建议你做的是，在上述顺序。使用框架是很好的，但通过编码自己会教你更多。

Answer 2

这将在功能上起作用。每个线程正在从连接到不同客户端（地址+端口）的单独套接字读取。它们是分开的流，因此在阅读这些内容时没有问题。

但是，使用异步套接字会更好。

，可以在当前的实现被照顾几件事情：

1）作为一个很好的做法，关闭流/插座传送完毕。

2）对于每个新连接，都会创建一个新线程。这不会扩展。甚至有人可以发送很多请求，并打开你的应用程序。会更好地使用线程池。 “ClientThread”只能实现“Runnable”，并且在收到新连接时，只需将新的“ClientThread”提交给线程池即可。 （在这种情况下，最好将其命名为ClientTask而不是ClientThread）

如前所述，使用异步套接字将会更加高效和可扩展，但需要一些时间掌握它。有了这个，你可以只使用一个线程并行读取所有套接字，并且可以使用相同的线程或一组线程来处理从所有套接字接收到的数据。请注意，即使使用一个池，也不需要单独的线程来处理每个套接字......只是为了充分利用多个CPU内核，可以使用多个线程来处理数据。

你可以尝试java nio（Selector + SocketChannels）或netty库。与nio相比，Netty更容易使用。