Linux網(wǎng)絡(luò)編程組播測(cè)試代碼?(轉(zhuǎn)載)

組播客戶端代碼如下：

#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; /* 創(chuàng)建 socket 用于UDP通訊 */ sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (sockfd < 0) { printf("socket creating error\n"); exit(1); } socklen = sizeof(struct sockaddr_in); /* 設(shè)置對(duì)方的端口和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]) { /* 注意這里設(shè)置的對(duì)方地址是指組播地址，而不是對(duì)方的實(shí)際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); } /* 設(shè)置自己的端口和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); } /* 循環(huán)接受用戶輸入的消息發(fā)送組播消息 */ for (;;) { /* 接受用戶輸入 */ bzero(recmsg, BUFLEN + 1); if (fgets(recmsg, BUFLEN, stdin) == (char *) EOF) exit(0); /* 發(fā)送消息 */ 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); } }

組播服務(wù)器端程序源代碼為：

#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; /* 創(chuàng)建 socket 用于UDP通訊 */ sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (sockfd < 0) { printf("socket creating err in udptalk\n"); exit(1); } /* 設(shè)置要加入組播的地址 */ 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); /* 設(shè)置組地址 */ bcopy(&ia, &mreq.imr_multiaddr.s_addr, sizeof(struct in_addr)); /* 設(shè)置發(fā)送組播消息的源主機(jī)的地址信息 */ mreq.imr_interface.s_addr = htonl(INADDR_ANY); /* 把本機(jī)加入組播地址，即本機(jī)網(wǎng)卡作為組播成員，只有加入組才能收到組播消息 */ 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); } /* 循環(huán)接收網(wǎng)絡(luò)上來的組播消息 */ 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 { /* 成功接收到數(shù)據(jù)報(bào) */ recmsg[n] = 0; printf("peer:%s", recmsg); } } }

編譯程序用下列命令：
gcc -Wall mcastclient.c -o mcastclient
gcc -Wall mcastserver.c -o mcastserver
運(yùn)行程序用如下命令：
./mcastserver 230.1.1.1 7838
客戶端程序運(yùn)行命令為：
./mcastclient 230.1.1.1 7838 192.168.100.1 12345

轉(zhuǎn)載于:https://www.cnblogs.com/Charles-Zhang-Blog/archive/2012/12/17/2822052.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的Linux网络编程组播测试代码的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。