我使用Netty发送和接收UDP组播消息,当我在同一个节点上创建多个服务器时,它有时会停止,停止接收来自其他服务器的数据包。然而,即使它们没有从其他服务器接收到任何数据包,它们仍然不断地接收到使用同一组播服务器发送的数据包。
以下是服务器代码:
multicastAddress = new InetSocketAddress("239.255.27.1", 14878);
Bootstrap a = new Bootstrap()
.group(group)
.channelFactory(() -> new NioDatagramChannel(InternetProtocolFamily.IPv4))
.localAddress(multicastAddress)
.option(ChannelOption.IP_MULTICAST_IF, NetUtil.LOOPBACK_IF)
.option(ChannelOption.SO_REUSEADDR, true)
.handler(new ChannelInitializer<NioDatagramChannel>() {
@Override
public void initChannel(NioDatagramChannel ch) throws Exception {
h.pipeline().addLast(new ChannelInboundHandler() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println(msg);
}
});
}
});
multicastServer = (NioDatagramChannel) a.bind().sync().channel();
multicastServer.joinGroup(multicastAddress, NetUtil.LOOPBACK_IF).sync();
客户端定期发送相同的字节Buf:
multicastServer.writeAndFlush(new DatagramPacket(Unpooled.copyInt(1), multicastAddress));
当我启动节点上的服务器时,它开始接收从该服务器发送的数据包。然后,如果在同一节点上创建第二个服务器,则通常工作,并且服务器接收从第一和第二服务器发送的数据包。但是,当我创建更多绑定到相同端口的服务器时(我使用
问题就在这里:
.option(ChannelOption.IP_MULTICAST_IF, NetUtil.LOOPBACK_IF)
这告诉UDP只向本地主机发送成员报告,因此其他主机不知道该主机是成员。把它取下来就行了。