nl(INADDR_ANY);
?
?bzero(&caddr,sizeof(caddr));
?caddr.sin_family? = AF_INET;
?caddr.sin_port? ? = htons(8000);
?
?//创建套接字
?if( (udpfd = socket(AF_INET,SOCK_DGRAM, 0)) < 0)
?{
? perror("socket error");
? exit(-1);
?}
?
?//套接字端口绑字
?if(bind(udpfd, (struct sockaddr*)&saddr, sizeof(saddr)) != 0)
?{
? perror("bind error");
? close(udpfd);?
? exit(-1);
?}
?printf("input: \"sayto 192.168.220.X\" to sendmsg to somebody\033[32m\n");?
?while(1)
?{?
? char buf[100]="";?
? fd_set rset;?//创建文件描述符的聚合变量?
? FD_ZERO(&rset); //文件描述符聚合变量清0
? FD_SET(0, &rset);//将标准输入添加到文件描述符聚合变量中
? FD_SET(udpfd, &rset);//将udpfd添加到文件描述符聚合变量中?
? write(1,"UdpQQ:",6);
?
? if(select(udpfd + 1, &rset, NULL, NULL, NULL) > 0)
? {
? ?if(FD_ISSET(0, &rset))//测试0是否可读写
? ?{? ?
? ? fgets(buf, sizeof(buf), stdin);
? ? buf[strlen(buf) - 1] = '\0';
? ? if(strncmp(buf, "sayto", 5) == 0)
? ? {
? ? ?char ipbuf[16] = "";
? ? ?inet_pton(AF_INET, buf+6, &caddr.sin_addr);//给addr套接字地址再赋值.
? ? ?printf("\rsay to %s\n",inet_ntop(AF_INET,&caddr.sin_addr,ipbuf,sizeof(ipbuf)));
? ? ?continue;
? ? }
? ? else if(strcmp(buf, "exit")==0)
? ? {
? ? ?close(udpfd);
? ? ?exit(0);
? ? }
? ? sendto(udpfd, buf, strlen(buf),0,(struct sockaddr*)&caddr, sizeof(caddr));
? ?}
? ?if(FD_ISSET(udpfd, &rset))//测试udpfd是否可读写
? ?{
? ? struct sockaddr_in addr;
? ? char ipbuf[INET_ADDRSTRLEN] = "";
? ? socklen_t addrlen = sizeof(addr);
? ?
? ? bzero(&addr,sizeof(addr));
? ?
? ? recvfrom(udpfd, buf, 100, 0, (struct sockaddr*)&addr, &addrlen);
? ? printf("\r\033[31m[%s]:\033[32m%s\n",inet_ntop(AF_INET,&addr.sin_addr,ipbuf,sizeof(ipbuf)),buf);
? ?}
? }
?}
?
?return 0;
}
?运行结果：
?
本文代码可以到Linux公社资源站下载：
------------------------------------------分割线------------------------------------------
具体下载目录在 /2017年资料/2月/13日/Linux网络编程：IO复用之select详解/
------------------------------------------分割线------------------------------------------