请教一个关于组播的问题：）

jamesman_xu

工作需要写一段组播的程序，上网下了个例程，编译过后发现几个问题,请高手指点：）

代码如下：
客户端代码

1. 
   
2. /*
   
3. * listen.c - An IP multicast client */
   
4. #include <stdio.h>
   
5. #include <sys/socket.h>
   
6. #include <netinet/in.h>
   
7. #include <arpa/inet.h>
   
8. #include <netdb.h>
   
9. #include <stdlib.h>
   
10. #include <unistd.h>
    
11. char * host_name = "224.0.0.1";
    
12. /* 多播IP地址 */
    
13. int port = 6789;
    
14. int main(void)
    
15. {
    
16.    struct ip_mreq command;
    
17.    int loop = 1;
    
18. /* 多播循环 */
    
19.   int iter = 0;
    
20.   int sin_len;
    
21.   char message[256];
    
22.   int socket_descriptor;
    
23. struct sockaddr_in sin;
    
24. struct hostent *server_host_name;
    
25. if((server_host_name = gethostbyname(host_name)) == 0)
    
26. {
    
27.    perror("gethostbyname");
    
28.    exit(EXIT_FAILURE);
    
29.     }   
    
30. /*bzero(&sin, sizeof(sin));*/
    
31. memset(&sin, 0, sizeof(sin));
    
32.   sin.sin_family = AF_INET;
    
33.   sin.sin_addr.s_addr = htonl(INADDR_ANY);
    
34.   sin.sin_port = htons(port);
    
35.   if((socket_descriptor = socket(PF_INET, SOCK_DGRAM, 0)) == -1)
    
36. { perror("socket");
    
37. exit(EXIT_FAILURE);
    
38. }
    
39. /* 调用bind之前，设置套接口选项启用多播IP支持*/
    
40. loop = 1;
    
41. if(setsockopt(socket_descriptor,
    
42. SOL_SOCKET, SO_REUSEADDR,
    
43. &loop, sizeof(loop)) < 0)
    
44. {
    
45. perror("setsockopt:SO_REUSEADDR");
    
46. exit(EXIT_FAILURE);
    
47.   }
    
48. if(bind(socket_descriptor,
    
49. (struct sockaddr *)&sin, sizeof(sin)) < 0)
    
50. {
    
51.    perror("bind");
    
52.    exit(EXIT_FAILURE);
    
53.     }
    
54. /* 在同一个主机上进行广播设置套接口，
    
55. 作用是方便单个开发系统上测试多播IP广播 */
    
56. loop = 1;
    
57. if(setsockopt(socket_descriptor,
    
58. IPPROTO_IP, IP_MULTICAST_LOOP,
    
59.   &loop, sizeof(loop)) < 0)
    
60. {   
    
61. perror("setsockopt:IP_MULTICAST_LOOP");
    
62. exit(EXIT_FAILURE);
    
63.    }
    
64. /* 加入一个广播组。进一步告诉Linux内核，
    
65. 特定的套接口即将接受广播数据*/
    
66. command.imr_multiaddr.s_addr = inet_addr("224.0.0.1");
    
67. command.imr_interface.s_addr = htonl(INADDR_ANY);
    
68. if(command.imr_multiaddr.s_addr == -1)
    
69. {  
    
70. perror("224.0.0.1 not a legal multicast address");
    
71. exit(EXIT_FAILURE);
    
72. }
    
73. if (setsockopt(socket_descriptor, IPPROTO_IP, IP_ADD_MEMBERSHIP,
    
74.   &command, sizeof(command)) < 0)
    
75. {   
    
76.   perror("setsockopt:IP_ADD_MEMBERSHIP");
    
77.     }
    
78. while(iter++ < 8)
    
79. {   
    
80.   sin_len = sizeof(sin);
    
81.   if(recvfrom(socket_descriptor, message, 256, 0,
    
82.   (struct sockaddr *)&sin, &sin_len) == -1) {
    
83.    perror("recvfrom");   
    
84.     }  
    
85. printf("Response #%-2d from server: %s\n", iter, message);
    
86.      sleep(2);    }
    
87.    /* 接受8个广播后退出 */
    
88. if(setsockopt(socket_descriptor, IPPROTO_IP, IP_DROP_MEMBERSHIP,
    
89.      &command, sizeof(command)) < 0) {
    
90.      perror("setsockopt:IP_DROP_MEMBERSHIP");
    
91.    }   
    
92. close(socket_descriptor);
    
93. exit(EXIT_SUCCESS);}
    
94. 
    
95. 服务端代码：
    
96. /*
    
97. * broadcast.c - An IP multicast server
    
98. */
    
99. #include <stdio.h>
    
100. #include <sys/socket.h>
     
101. #include <netinet/in.h>
     
102. #include <arpa/inet.h>
     
103. #include <netdb.h>#include <unistd.h>
     
104. #include <stdlib.h>int port = 6789;
     
105. int main(void)
     
106. {   
     
107. int socket_descriptor;  
     
108. struct sockaddr_in address;  
     
109.   /*  首先建立套接口 */
     
110.     socket_descriptor = socket(AF_INET, SOCK_DGRAM, 0);  
     
111.   if (socket_descriptor == -1)
     
112. {      
     
113.   perror("Opening socket");
     
114.        exit(EXIT_FAILURE);  
     
115.   }   
     
116. /* 初始化IP多播地址 */
     
117. memset(&address, 0, sizeof(address));   
     
118. address.sin_family = AF_INET;  
     
119. address.sin_addr.s_addr = inet_addr("224.0.0.1");
     
120. address.sin_port = htons(port);  
     
121.   /* 开始进行IP多播 */  
     
122. while(1) {
     
123. if(sendto(socket_descriptor, "test from broadcast",
     
124. sizeof("test from broadcast"), 0,   
     
125. (struct sockaddr *)&address, sizeof(address)) < 0)
     
126. {  
     
127. perror("sendto");  
     
128. exit(EXIT_FAILURE);
     
129. }   
     
130. sleep(2);  
     
131. }  
     
132. exit(EXIT_SUCCESS);}

复制代码

编译过后会出现几个问题：
     第一个  服务器的组地址改变后，比如改成了224.0.1.1，只有本地能受到信息 ，而局网内的另一台pc收不到（他们的组地址也改成224.0.1.1）。
      第二个   服务器的组地址和本地的客户端的组地址不一样，也可以受到信息。

      上述两个问题彻底扰乱了我的思维，请高手指点一下，谢谢：）

[ 本帖最后由 jamesman_xu 于 2007-9-15 17:58 编辑 ]

jamesman_xu

天啊，怎么出了几个笑脸 ，晕

maluyao

原帖由 jamesman_xu 于 2007-9-15 14:26 发表
天啊，怎么出了几个笑脸 ，晕

写代码的时候用［ＣＯＤＥ］　　［／ＣＯＤＥ］即可

jamesman_xu

ok! thank u 改过来了 ：）

jamesman_xu

顶一下，高手帮帮忙啊