Java 多播套接字。如何停止/暂停 "receive"方法

Question

如何停止该方法的执行？

multSocket.receive(multPacket);    

我正在尝试使用 Java 通过 UDP 多播连接两台或多台计算机(或同一台计算机上的应用程序)。问题是我不使用客户端-服务器，而更像是分布式对象，因此客户端和服务器之间没有真正的区别。

理想情况下，打开的第一个应用程序将开始每 x 秒发送多播消息，并且当另一个应用程序启动时将调用接收消息或数据包的方法。但由于每个应用程序都可以是客户端或服务器，因此很难确定哪个应用程序要发送，另一个应用程序要接收。

我目前解决此问题的想法是让每个应用程序发送多播数据包 10 秒，如果没有人响应，则监听多播数据包 10 秒，如果没有收到任何内容，则重新开始发送并保持循环。当其中一个最终收到消息时，向发送者发送确认，然后双方都可以停止监听和发送。

但是我的问题是接收方法。它持续监听传入的多播数据包，但我不知道如何停止或暂停它。

这就是我初始化套接字的方式，以防万一

MulticastSocket multSocket = new MulticastSocket(5001);
multSocket.joinGroup(230.0.0.1);
private byte[] multBuf = new byte[256];
DatagramPacket multPacket = new DatagramPacket(multBuf, multBuf.length);

感谢您聆听我的发言。

-------------------------------------------------------------- 编辑----------------------------------------------------------------------------

-------------------------------------------------------------- 编辑----------------------------------------------------------------------------

@EJP 感谢您的回答!这就是我在接收多播方法上实现 setSoTimeout 的方法:

public void receiveMulticast() throws IOException{

    multAddress = InetAddress.getByName("230.0.0.1");
    multSocket = new MulticastSocket(multPort);
    multSocket.joinGroup(multAddress);
    multBuf = new byte[256];
    multPacket = new DatagramPacket(multBuf, multBuf.length);

    multSocket.setSoTimeout(10000);

    try {
        // This is the sentence I had trouble with
        multSocket.receive(multPacket);

        receivedPacket = true;
        System.out.println("Received something");

    } catch (SocketTimeoutException s) {
        System.out.println("Socket timed out!");
    }

}

这里有更多代码，以防有人好奇:

这是我的发送多播方法，它使用 sleep 每 10 秒发送一次:

public void sendMulticast() throws IOException, InterruptedException{

    multAddress = InetAddress.getByName("230.0.0.1");
    multSocket = new MulticastSocket();
    multSocket.joinGroup(multAddress);
    int tcpPort = 5001;
    String data = String.valueOf(tcpPort);
    multBuf = data.getBytes();
    multPacket = new DatagramPacket(multBuf, multBuf.length, multAddress, multPort);

    int count = 0;
    while (count < 10) {
        Thread.sleep(1000);
        multSocket.send(multPacket);
        count++;
    }

}

这就是我无限调用这两个方法的地方(在另一个类上):

messageThread = new Thread() {
    @Override
    public void run() {
        while(true){
            try {
                stateLabel.setText("Sending");
                socket.sendMulticast();
                stateLabel.setText("Listening");
                socket.receiveMulticast();
            } catch (IOException ex) {
                Logger.getLogger(NumerosAmigosView.class.getName()).log(Level.SEVERE, null, ex);
            } catch (InterruptedException ex) {
                Logger.getLogger(NumerosAmigosView.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
};
messageThread.start();

所以结果是程序无限地运行，发送数据包 10 秒，接收 10 秒，然后重新开始。当我同时运行两个程序时，会收到数据包:)。

Answer 1

使用setSoTimeout()设置读取超时，并捕获抛出的SocketTimeoutException。