Appearance
code/hqyj/network/04_多点通信/02_broadRcv.c
c
#include <arpa/inet.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#define ERR_MSG(msg) \
do { \
fprintf(stderr, "line %d\n", __LINE__); \
perror(msg); \
} while (0)
#define PORT 6666
#define IP "192.168.31.255"
int main(int argc, char const *argv[]) {
// 创建报式套接字
int sfd = socket(AF_INET, SOCK_DGRAM, 0);
if (sfd < 0) {
ERR_MSG("socket");
return -1;
}
printf("socket create success sfd=%d __%d__\n", sfd, __LINE__);
// 填充服务器的地址信息结构体,绑定到套接字上
struct sockaddr_in sin;
sin.sin_family = AF_INET; // 必须填充 AF_INET
sin.sin_port = htons(PORT); // 1024~49151
sin.sin_addr.s_addr = inet_addr(IP); // ifconfig 出来的本机 IP
// 绑定 -- 必须绑定
if (bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) < 0) {
ERR_MSG("bind");
return -1;
}
printf("bind success __%d__\n", __LINE__);
char buf[128] = "";
ssize_t res = 0;
struct sockaddr_in cin;
socklen_t addrlen = sizeof(cin);
while (1) {
bzero(buf, sizeof(buf));
// 接收数据
res = recvfrom(sfd, buf, sizeof(buf), 0, (struct sockaddr *)&cin, &addrlen);
if(res < 0) {
ERR_MSG("recvfrom");
return -1;
}
printf("[%s : %d]: %s\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), buf);
}
// 关闭套接字
close(sfd);
return 0;
}