1>.能正常发送接收的手机，向组播地址发送了组播消息后，同时会向组播地址发送一个 IGMP v2的协议
2>.能发送，接收不到组播消息的手机设备，可以发现设备没有向组播地址发送IGMP协议
3>.而查看手机设备，在 /proc/net/ 目录下，有igmp文件的设备会发送IGMP协议，能正常完成组播消息收发，而没有igmp文件的，就是不能完成组播消息收发的。igmp是IPv4下的协议文件，igmp6是IPv6的协议。可以看到所有设备都支持IPv6的igmp
4>.在Android系统下，编译Linux kernel时有一config CONFIG_IP_MULTICAST ，如果是定制系统在编译系统的时候配置这个选项 CONFIG_IP_MULTICAST=y ,就能enable组播功能。但是有很多系统厂商在编译的时候都默认把这个config给disable了。
参考：
How can I know if IP Multicast is enabled
Android App用MulticastSocket监听组播，为什么连接到不
Many devices have multicast disabled in the kernel
组播和广播相似,都可以将数据发送到多个客户端,但与广播不同,组播可以将数据只发给加入了组播的客户端,这样呢可以避免将数据发送到不想接受数据的客户端.
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <net/if.h>
#define SERV_PORT 8000
#define CLNT_PORT 9000
#define GROUP_IP "239.0.0.2"
int main()
{
struct sockaddr_in serv_addr, clnt_addr
int lfd, n
char buf[BUFSIZ]
struct ip_mreqn group
lfd = socket(AF_INET, SOCK_DGRAM, 0)
if(lfd >0){
printf("socket success\n")
}
bzero(&serv_addr, sizeof(serv_addr))
serv_addr.sin_family = AF_INET
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY)
serv_addr.sin_port = htons(SERV_PORT)
bind(lfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr))
inet_pton(AF_INET, GROUP_IP, &group.imr_multiaddr)//多播组IP地址
inet_pton(AF_INET, "0.0.0.0", &group.imr_address)//本地接口IP地址
group.imr_ifindex = if_nametoindex("eth0")
//赋予组播权限
setsockopt(lfd, IPPROTO_IP, IP_MULTICAST_IF, &group, sizeof(group))
bzero(&clnt_addr, sizeof(clnt_addr))
clnt_addr.sin_family = AF_INET
//clnt_addr.sin_addr.s_addr = htonl(GROUP_IP)
inet_pton(AF_INET, GROUP_IP, &clnt_addr.sin_addr.s_addr)
clnt_addr.sin_port = htons(CLNT_PORT)
int i = 1
while(1){
sprintf(buf, "hello multicast %d\n", i++)
n = sendto(lfd, buf, strlen(buf), 0, (struct sockaddr*)&clnt_addr, sizeof(clnt_addr))
sleep(1)
}
close(lfd)
return 0
}
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <net/if.h>
#define GROUP_IP "239.0.0.2"
#define CLNT_PORT 9000
int main()
{
struct sockaddr_in localaddr
int sockfd, n
char buf[BUFSIZ]
struct ip_mreqn group
sockfd = socket(AF_INET, SOCK_DGRAM, 0)
localaddr.sin_family = AF_INET
localaddr.sin_addr.s_addr = htonl(INADDR_ANY)
localaddr.sin_port = htons(CLNT_PORT)
bind(sockfd, (struct sockaddr*)&localaddr, sizeof(localaddr))
inet_pton(AF_INET, GROUP_IP, &group.imr_multiaddr)
inet_pton(AF_INET, "0.0.0.0", &group.imr_address)
group.imr_ifindex = if_nametoindex("etho0")
//加入组播
setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &group, sizeof(group))
while(1){
n = recvfrom(sockfd, buf, sizeof(buf), 0, NULL, 0)
if(n >0){
write(STDOUT_FILENO, buf, n)
}
}
close(sockfd)
return 0
}
编辑一个java组播应用程序的过程如下1. 创建一个用于发送和接收的MulticastSocket组播套接字对象
2. 创建一个指定缓冲区大小及组播地址和端口的DatagramPacket组播数据包对象
3. 使用组播套接字joinGroup(),将其加入到一个组播
4. 使用组播套接字的send()方法，将组播数据包对象放入其中，发送组播数据包.
或者
使用组播套接字的receive（）方法，将组播数据包对象放入其中，接收组播数据包
5. 解码组播数据包提取信息，并依据得到的信息作出响应String s = new String(dp.getData(), 0, dp.getLength())
6. 重复过程4和5，即在while循环中实现。
7. 使用组播套接字的leaveGroup()方法，离开组播组；关闭组播套接字
接收组播数据包程序：
Java代码
public class MulticastReceived {
public static void main(String[] args) throws Exception {
InetAddress group = InetAddress.getByName("224.0.0.4")// 组播地址
int port = 4006// 端口
MulticastSocket msr = null
try {
msr = new MulticastSocket(port)// 1.创建一个用于发送和接收的MulticastSocket组播套接字对象
msr.joinGroup(group)// 3.使用组播套接字joinGroup(),将其加入到一个组播
byte[] buffer = new byte[8192]
System.out.println("接收数据包启动！（启动时间：）" + new java.util.Date() + ")")
while (true) {
DatagramPacket dp = new DatagramPacket(buffer, buffer.length)// 2.创建一个指定缓冲区大小及组播地址和端口的DatagramPacket组播数据包对象
msr.receive(dp)// 4.使用组播套接字的receive（）方法，将组播数据包对象放入其中，接收组播数据包
String s = new String(dp.getData(), 0, dp.getLength())// 5.解码组播数据包提取信息，并依据得到的信息作出响应
System.out.println(s)
}
} catch (IOException e) {
e.printStackTrace()
} finally {
if (msr != null) {
try {
msr.leaveGroup(group)// 7.使用组播套接字的leaveGroup()方法，离开组播组
msr.close()// 关闭组播套接字
} catch (IOException e) {
}
}
}
}
}
发送组播数据包程序：
Java代码
public class MulticastSender {
public static void main(String[] args) throws Exception {
InetAddress group = InetAddress.getByName("224.0.0.1")// 组播地址
int port = 4000// 端口
MulticastSocket mss = null
try {
mss = new MulticastSocket(port)// 1.创建一个用于发送和接收的MulticastSocket组播套接字对象
mss.joinGroup(group)// 3.使用组播套接字joinGroup(),将其加入到一个组播
byte[] buffer = new byte[8192]
System.out.println("接收数据包启动！（启动时间：）" + new java.util.Date() + ")")
while (true) {
String message = "Hello" + new java.util.Date()
byte[] buffer2 = message.getBytes()// 2.创建一个指定缓冲区大小及组播地址和端口的DatagramPacket组播数据包对象
DatagramPacket dp = new DatagramPacket(buffer, buffer.length, group, port)
// msr.receive(dp)//接收组播数据包
mss.send(dp)// 4.使用组播套接字的send()方法，将组播数据包对象放入其中，发送组播数据包
// String s = new String(dp.getData(), 0, dp.getLength())//5.解码组播数据包提取信息，并依据得到的信息作出响应
System.out.println("发送数据包给" + group + ":" + port)
Thread.sleep(1000)
}
} catch (IOException e) {
e.printStackTrace()
} finally {
if (mss != null) {
try {
mss.leaveGroup(group)// 7.使用组播套接字的leaveGroup()方法，离开组播组
mss.close()// 关闭组播套接字
} catch (IOException e) {
}
}
}
}
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）