SylixOS組播使用
本文主要介紹如何在SylixOS上使用組播功能。
2. SylixOS組播設置
組播傳輸，即在發送者和每一接收者之間實現點對多點網絡連接通信。正常大家會參考Linux使用組播的方法：把本機加入組播地址，即本機網卡作為組播成員，只有加入組才能收到組播消息。通過setsockopt設置加入組播，這樣便可以接收組播信息。Linux參考代碼如程序清單 2.1和程序清單 2.2所示。
程序清單 2.1 mcastserver
#include <sys/types.h> #include <sys/socket.h> #include <arpa/inet.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <netdb.h> #include <errno.h> #define BUFLEN 255 int main(int argc, char **argv) { struct sockaddr_in peeraddr; struct in_addr ia; int sockfd; char recmsg[BUFLEN + 1]; unsigned int socklen, n; struct hostent *group; struct ip_mreq mreq; /* * 創建 socket 用於UDP通訊 */ sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (sockfd < 0) { printf("socket creating err in udptalk\n"); exit(1); } /* * 設置要加入組播的地址 */ bzero(&mreq, sizeof(struct ip_mreq)); if (argv[1]) { if ((group = gethostbyname(argv[1])) == (struct hostent *) 0) { perror("gethostbyname"); exit(errno); } } else { printf( "you should give me a group address, 224.0.0.0-239.255.255.255\n"); exit(errno); } bcopy((void *) group->h_addr, (void *) &ia, group->h_length); /* * 設置組地址 */ bcopy(&ia, &mreq.imr_multiaddr.s_addr, sizeof(struct in_addr)); /* * 設置發送組播消息的源主機的地址信息 */ mreq.imr_interface.s_addr = htonl(INADDR_ANY); /* * 把本機加入組播地址，即本機網卡作為組播成員，只有加入組才能收到組播消息 */ if (setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(struct ip_mreq)) == -1) { perror("setsockopt"); exit(-1); } socklen = sizeof(struct sockaddr_in); memset(&peeraddr, 0, socklen); peeraddr.sin_family = AF_INET; if (argv[2]) { peeraddr.sin_port = htons(atoi(argv[2])); } else { peeraddr.sin_port = htons(7838); } if (argv[1]) { if (inet_pton(AF_INET, argv[1], &peeraddr.sin_addr) <= 0) { printf("Wrong dest IP address!\n"); exit(0); } } else { printf("no group address given, 224.0.0.0-239.255.255.255\n"); exit(errno); } /* * 綁定自己的端口和IP信息到socket上 */ if (bind(sockfd, (struct sockaddr *) &peeraddr, sizeof(struct sockaddr_in)) == -1) { printf("Bind error\n"); exit(0); } /* * 循環接收網絡上來的組播消息 */ for (;;) { bzero(recmsg, BUFLEN + 1); n = recvfrom(sockfd, recmsg, BUFLEN, 0, (struct sockaddr *) &peeraddr, &socklen); if (n < 0) { printf("recvfrom err in udptalk!\n"); exit(4); } else { /* * 成功接收到數據 */ recmsg[n] = 0; printf("peer:%s", recmsg); } } return 0; } |
程序清單 2.2 mcastclient
#include <sys/types.h> #include <sys/socket.h> #include <arpa/inet.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #define BUFLEN 255 int main(int argc, char **argv) { struct sockaddr_in peeraddr, myaddr; int sockfd; char recmsg[BUFLEN + 1]; unsigned int socklen; /* * 創建 socket 用於UDP通訊 */ sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (sockfd < 0) { printf("socket creating error\n"); exit(1); } socklen = sizeof(struct sockaddr_in); /* * 設置對方的端口和IP信息 */ memset(&peeraddr, 0, socklen); peeraddr.sin_family = AF_INET; if (argv[2]) { peeraddr.sin_port = htons(atoi(argv[2])); } else { peeraddr.sin_port = htons(7838); } if (argv[1]) { /* * 註意這裏設置的對方地址是指組播地址，而不是對方的實際IP地址 */ if (inet_pton(AF_INET, argv[1], &peeraddr.sin_addr) <= 0) { printf("wrong group address!\n"); exit(0); } } else { printf("no group address!\n"); exit(0); } /* * 設置自己的端口和IP信息 */ memset(&myaddr, 0, socklen); myaddr.sin_family = AF_INET; if (argv[4]) { myaddr.sin_port = htons(atoi(argv[4])); } else { myaddr.sin_port = htons(23456); } if (argv[3]) { if (inet_pton(AF_INET, argv[3], &myaddr.sin_addr) <= 0) { printf("self ip address error!\n"); exit(0); } } else myaddr.sin_addr.s_addr = INADDR_ANY; /* * 綁定自己的端口和IP信息到socket上 */ if (bind(sockfd, (struct sockaddr *) &myaddr, sizeof(struct sockaddr_in)) == -1) { printf("Bind error\n"); exit(0); } /* * 循環接受用戶輸入的消息發送組播消息 */ for (;;) { /* * 接受用戶輸入 */ bzero(recmsg, BUFLEN + 1); if (fgets(recmsg, BUFLEN, stdin) == (char *) EOF) { exit(0); } /* * 發送消息 */ if (sendto(sockfd, recmsg, strlen(recmsg), 0,(struct sockaddr *) &peeraddr, sizeof(struct sockaddr_in))< 0) { printf("sendto error!\n"); exit(3); } printf("'%s' send ok\n", recmsg); } return 0; } |
把Linux的組播程序移植到SylixOS上編譯，導入運行SylixOS的板卡上，運行結果如圖 2.1所示。
圖 2.1 組播運行結果
根據圖 2.1所示mcastclient組播信息沒有被mcastserver接收到，而該測試代碼在Linux上運行正常。經過分析發現Linux在網絡協議棧中默認打開IP_MULTICAST_LOOP，即允許組播進行本地回環通信，而SylixOS的網絡協議棧默認沒有打開該選項。所以在SylixOS的組播代碼中添加使用setsockopt設置IP_MULTICAST_LOOP，即允許組播本地回環的選項。在mcastclient程序中添加代碼如程序清單 2.3所示。
程序清單 2.3 setsockopt設置
int loop = 1; if (setsockopt(sockfd, IPPROTO_IP, IP_MULTICAST_LOOP, &loop, sizeof(loop)) == -1) { perror("setsockopt"); exit(-1); } |
重新編譯mcastclient上傳運行，結果如圖 2.2所示。
圖 2.2 組播運行正常
3. 參考資料
《RealEvo-IDE使用手冊》
SylixOS組播使用