Tag: 多播

如何在NIO.2中实现多播客户端?

使用Java 7 NIO.2多播客户端的示例如何? 我只能在MulticastChannel文档中找到一半示例。

Java NIO是否支持广播或多播?

我正在搜索Java NIO是否实现了广播。 我需要创建一个使用多播或广播向其他对等体发送消息的对等体。 我在API 1.6中搜索,但我在DatagramChannel类中找不到任何内容。 提前致谢。

为什么没有收到(UDP组播)数据包?

所以,我一直试图弄清楚为什么这不起作用,但我没有线索。 我已经设法从iPhone发送数据包并在我的Mac上接收它们。 根据tcpdump我的mac正确发送数据包。 另外,如果我在模拟器中运行它,它工作正常。 这让我相信这是一个网络问题,但我不知道那可能是什么,所以我希望(!)它是下面的东西。 CFSocketContext socketContext = {0, self, NULL, NULL, NULL}; advertiseSocket = CFSocketCreate(kCFAllocatorDefault, PF_INET, SOCK_DGRAM, IPPROTO_UDP, kCFSocketDataCallBack, (CFSocketCallBack)&advertiseCallBack, &socketContext); int yes = 1; setsockopt(CFSocketGetNative(advertiseSocket), SOL_SOCKET, SO_REUSEADDR, (void *)&yes, sizeof(yes)); u_char loop = 0; setsockopt(CFSocketGetNative(advertiseSocket), IPPROTO_IP, IP_MULTICAST_LOOP, &loop, sizeof(loop)); unsigned char ttl = 64; setsockopt(CFSocketGetNative(advertiseSocket), IPPROTO_IP, IP_MULTICAST_TTL, &ttl, sizeof(ttl)); struct sockaddr_in addressData; memset(&addressData, […]

MulticastSocket.joinGroup()出错

我正在尝试在Java上执行一个简单的多播套接字示例。 MulticastSocket s = new MulticastSocket(6789); InetAddress group = InetAddress.getByName(“230.1.1.1”); s.joinGroup(group); 此代码生成错误:IP_ADD_MEMBERSHIP失败(硬件filter?) 任何想法?

如何以编程方式为多播发现机制配置hazelcast?

如何以编程方式为多播发现机制配置hazelcast? 细节: 该文档仅提供TCP / IP的示例并且已过时:它使用不再存在的Config.setPort()。 我的配置看起来像这样,但发现不起作用(即我得到输出”Members: 1″ : Config cfg = new Config(); NetworkConfig network = cfg.getNetworkConfig(); network.setPort(PORT_NUMBER); JoinConfig join = network.getJoin(); join.getTcpIpConfig().setEnabled(false); join.getAwsConfig().setEnabled(false); join.getMulticastConfig().setEnabled(true); join.getMulticastConfig().setMulticastGroup(MULTICAST_ADDRESS); join.getMulticastConfig().setMulticastPort(PORT_NUMBER); join.getMulticastConfig().setMulticastTimeoutSeconds(200); HazelcastInstance instance = Hazelcast.newHazelcastInstance(cfg); System.out.println(“Members: “+hazelInst.getCluster().getMembers().size()); 更新1,考虑到asimarslan的答案 如果我偶然发现MulticastTimeout,我要么得到”Members: 1″或者 2013年12月5日下午8:50:42 com.hazelcast.nio.ReadHandler警告:[192.168.0.9]:4446 [dev] hz._hzInstance_1_dev.IO.thread-in-0关闭套接字到端点地址[192.168.0.7] :4446,原因:java.io.EOFException:远程套接字已关闭! 2013年12月5日下午8:57:24 com.hazelcast.instance.Node严重:[192.168.0.9]:4446 [dev]无法加入群集,关闭! com.hazelcast.core.HazelcastException:300秒内无法加入! 更新2,采取pveentjer关于使用tcp / ip的答案 如果我将配置更改为以下内容,我仍然只能获得1个成员: Config cfg = new Config(); […]