MSG_OOB : 仅仅是通过tcp头的urgent 模式传送的,
且只会读取一个字节作为oob数据 例如:send(sockfd,"1234",strlen("1234"),MSG_OOB); 只有最后一个字节:4 将被当作oob数据 ,其他数据"123"将被当作普通数据读取 需要注意:
此类数据通过信号 SIGURG 来通知 ,所以需要使用 signal / sigaction 来注册一个信号处理函数.
在signal 之前首先需要 fcntl(clientfd,F_SETOWN,getpid())
由于此信号是由套接字产生的, 而套接字的拥有者是操作系统 . 只有把套接字的拥有者设置为当前进程, SIGURG才会被
传递到此进程, 否则将接受不到SIGURG信号,只能接受普通数据.
MSG_PEEK : 偷窥一下缓冲区中有没有数据, recv(clientfd,buf,BUFSIZ,MSG_PEEK) ,并不会从缓冲区移除数据.
MSG_DONTWAIT : 不阻塞
oob_recv.c
#include "util.h"#includestatic void urg_handler(int sig);int clientfd = 0;int main(int argc, char ** argv){ int listenfd = socket(AF_INET, SOCK_STREAM,0); struct sockaddr_in serv_addr,client_addr; memset(&serv_addr,0,sizeof(serv_addr)); memset(&client_addr,0,sizeof(client_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_port = htons(PORT); serv_addr.sin_addr.s_addr = INADDR_ANY; if(bind(listenfd,(SA*)&serv_addr,sizeof(serv_addr)) < 0){ perror("bind"); return 0; } if(listen(listenfd,BACKLOG) < 0){ perror("listen"); return 0; } socklen_t client_socklen =sizeof(client_addr); clientfd = accept(listenfd,(SA*)&client_addr,&client_socklen); //注意, 如果不设置套接字拥有者, 此进程将收不到SIGURG 信号. fcntl(clientfd,F_SETOWN,getpid()); //注册信号函数 signal(SIGURG,urg_handler); int n = 0; char buf[BUFSIZ]; // while(1){// printf("检查数据是否存在\n");// n = recv(clientfd,buf,BUFSIZ,MSG_PEEK|MSG_DONTWAIT);// printf("数据长度 ： %d ,errno:%d\n", n,errno);// if(n > 0){// puts("有数据了");// break;// }//// } //接受普通数据. while((n = recv(clientfd,buf,BUFSIZ,0)) != 0){ if( -1 == n){ perror("recv error"); printf("error no : %d\n" ,errno); continue; } buf[n] = 0; printf("normal buf:%s\n",buf); } close(clientfd); close(listenfd); return 0;}static void urg_handler(int sig){ char buf[30]; //接受OOB数据, 只能接受最后一个字节, 其他字节作为普通数据接受 int n = recv(clientfd ,buf,30,MSG_OOB); printf("oob len : %d\n" , n); buf[n] = 0; printf("oob data:%s\n" , buf);}
oob_send.c
#include "util.h" int main(int argc, char ** argv){ if ( argc != 3){ puts(" ip port"); return 0; } int sockfd = socket(AF_INET,SOCK_STREAM,0); struct sockaddr_in sin; memset(&sin,0,sizeof(sin)); sin.sin_port = htons(atoi(argv[2])); sin.sin_addr.s_addr = inet_addr(argv[1]); sin.sin_family = AF_INET; connect(sockfd,(SA*)&sin,sizeof(sin)); char data[] = "data1" , data2[] = "data2"; char oob_data1[] = "oobdata1" , oob_data2[] = "oob_data2"; write(sockfd,data,strlen(data)); //发送oob数据 , 只有最后一个字节将被当作oob数据 send(sockfd,oob_data1,strlen(oob_data1),MSG_OOB); write(sockfd,data2,strlen(data2)); //发送oob数据 , 只有最后一个字节将被当作oob数据 send(sockfd,oob_data2,strlen(oob_data2),MSG_OOB); close(sockfd); return 0;}