提问者:小点点

当我在同一节点上创建多个服务器时,服务器停止接收UDP多播数据包


我使用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));

当我启动节点上的服务器时,它开始接收从该服务器发送的数据包。然后,如果在同一节点上创建第二个服务器,则通常工作,并且服务器接收从第一和第二服务器发送的数据包。但是,当我创建更多绑定到相同端口的服务器时(我使用,因此这应该是一个问题),有时所有服务器都停止接收来自其他服务器的数据包,而只接收来自同一服务器的数据包。


共1个答案

匿名用户

问题就在这里:

.option(ChannelOption.IP_MULTICAST_IF, NetUtil.LOOPBACK_IF)

这告诉UDP只向本地主机发送成员报告,因此其他主机不知道该主机是成员。把它取下来就行了。