Java 多播接收数据和并行处理

Question

我正在用 Java 编写一个类来简化连接、加入、发送和接收多播组数据的过程。在我描述我的问题之前，请先看一下下面的示例，以便您了解我在做什么。

这是我正在做的事情的非常基本代码示例。请注意，它与我的实际代码完全不同，除了异常捕获、导入语句等之外...它只是显示了我的类如何利用 Java 多播功能的基本流程：

//Connect to the multicast host, and join the group
  MulticastSocket msConn = new MulticastSocket(5540);
  InetAddress netAddr = InetAddress.getByName("239.255.255.255");
  msConn.joinGroup(netAddr);

//Preapre a datagram packet in which to place recieved data
  byte buf[] = new byte[1024];
  DatagramPacket pack = new DatagramPacket(buf, buf.length);

//Code halts here until data is recieved
  msConn.recieve(pack);

请注意，在接收() 方法中，代码将暂停，直到多播器类收到数据包。我希望能够让 Java 持续侦听新数据，同时执行此代码：

int i = 0;

while(true) {
  System.out.print(i);
  i++;
}

这些过程可以并行完成吗？如果可以，您能否提供一个示例来说明如何做到这一点？如果没有，还有其他解决方法吗？

Answer 1

如果您希望程序同时执行操作，则需要使用线程。¹

最简单的方法（不涉及匿名类等）可能是将其中一个或另一个分开将您的流程放入一个实现 的单独类中可运行。例如，创建一个 Counter 类，如下所示：

public class Counter implements Runnable {
    public void run ( ) {
        int i = 0;
        while(true) {
            System.out.print(i);
            i++;
        }
    }
}

然后，在其他代码之前，您将创建一个新的 Thread 如下：

Counter counter = new Counter( );
Thread thread = new Thread(counter);
thread.start( );
...
// The rest of your code goes here...

这个额外的线程将与原始线程并行执行，原始线程现已移动处理您的套接字代码。当然，如果您愿意，您也可以为此启动一个新线程，但这有点多余，因为您已经有两个线程（新线程和原始线程）。

这实际上只是触及了线程的表面。它的内容远比我真正能给出的答案要多得多，所以我强烈建议阅读链接的文档，阅读 thread 文章，并查找其他信息以更好地了解这些东西的工作原理。

---

1：如果您的线程在同一个处理器上运行，它们实际上不会同时运行，它们只是看起来如此。