vxworks下的多播程序问题

wangbaiqing

vxworks下的多播程序问题 [复制链接]

 

1. 
   
2. #include "sockLib.h"
   
3. #include "iostream.h"
   
4. #include "vxWorks.h"
   
5. #include "inetLib.h"
   
6. #include "taskLib.h"
   
7. 
   
8. #define MCastAddr "234.5.6.7"
   
9. #define MaxLine 1024
   
10. 
    
11. void main()
    
12. {
    
13.         struct sockaddr_in local;
    
14. 
    
15.         int recvsocket;
    
16.         struct ip_mreq mcast;
    
17.         recvsocket=socket(AF_INET,SOCK_DGRAM,0);
    
18. 
    
19.         local.sin_family=AF_INET;
    
20.         local.sin_port=htons(2009);
    
21.         local.sin_addr.s_addr=htonl(INADDR_ANY);
    
22.         mcast.imr_interface.s_addr=htonl(INADDR_ANY);
    
23.         mcast.imr_multiaddr.s_addr=inet_addr(MCastAddr);
    
24. 
    
25.         bind(recvsocket,(struct sockaddr*)&local,sizeof(local));
    
26. 
    
27.         setsockopt(recvsocket,IPPROTO_IP,IP_ADD_MEMBERSHIP,(char*)&mcast,sizeof(mcast));
    
28. 
    
29.         char RecvBuffer[MaxLine]={0};
    
30.         int i=1;
    
31.         while(1)
    
32.         {
    
33.                 int n=recvfrom(recvsocket,RecvBuffer,MaxLine,0,NULL,NULL);
    
34.                 RecvBuffer[n]='\0';
    
35.                 cout<<"receive:"<
36.         }
    
37. }
    

复制代码

为何程序在recvfrom老是不阻塞，一直的死循环输出。我并没有send数据给它啊。
发送程序为：

1. 
   
2. #include
   
3. #include
   
4. 
   
5. #define MCastAddr "234.5.6.7"
   
6. #define MaxLine 1024
   
7. 
   
8. 
   
9. void main()
   
10. {
    
11.         WSADATA wsadata;
    
12.         int ret=WSAStartup(MAKEWORD(1,0),&wsadata);
    
13.         if(ret!=0)
    
14.                 return;
    
15.        
    
16.         struct sockaddr_in mcastaddr;
    
17.         SOCKET sendsocket;
    
18.        
    
19.         sendsocket=socket(AF_INET,SOCK_DGRAM,0);
    
20.        
    
21.         mcastaddr.sin_family=AF_INET;
    
22.         mcastaddr.sin_port=htons(2009);
    
23.         mcastaddr.sin_addr.s_addr=inet_addr(MCastAddr);
    
24. 
    
25.         char SendBuffer[MaxLine]="hello";
    
26.         for(int i=0;i<1000;i++)
    
27.         {
    
28.                 cout<
29.                 int n=sendto(sendsocket,SendBuffer,strlen(SendBuffer),0,(struct sockaddr *) &mcastaddr,sizeof(mcastaddr));
    
30.                 Sleep(500);
    
31.         }
    
32. }
    

复制代码

发送端在windows系统下，接收端在vxworks系统下。

lihui19850618

为何程序在recvfrom老是不阻塞，一直的死循环输出。我并没有send数据给它啊。 ？

应该有超时等情况的。

recvfrom的返回值的含义都有哪些？

正确的处理方法应该是根据返回值来进行相应的处理。

while(1)
    {
        int n;
         
        n = recvfrom(recvsocket,RecvBuffer,MaxLine,0,NULL,NULL);
        
        if (XXX == n) /* 接收到数据对应的返回值 */
             cout<<"receive:"<
        ... ...
        
    }

maky

楼上的兄弟说的对，定义有问题的

zzqqking

你的情况是自发自收。
改个端口号试试。接收端口号和发送端口号不同。
应该就会阻塞。

szgaoju

经典 酷！