https://blog.csdn.net/aspnet_lyc/article/details/28937229

MSG_PEEK標志可以用來讀取套接字接收隊列中可讀的數據，一些情況會用到它，比如為了避免不阻塞而先檢查套接字接收隊列中可讀的數據長度，再采取相應操作。
當然，不阻塞也可采取其他的方法，例如非阻塞式I/O。

MSG_PEEK標志會將套接字接收隊列中的可讀的數據拷貝到緩沖區，但不會使套接子接收隊列中的數據減少，常見的是：例如調用recv或read后，導致套接字接收隊列中的數據被讀取后而減少，而指定了MSG_PEEK標志，可通過返回值獲得可讀數據長度，并且不會減少套接字接收緩沖區中的數據，所以可以供程序的其他部分繼續讀取。

注意：假設指定MSG_PEEK標志，以一個長度為1024字節的緩沖區對一個TCP套接字調用recv，返回100，如果再次調用recv，返回值可能超過100，因為兩次調用之間可能有新的數據到達，導致長度增加。

下面是一個客戶-服務程序，客戶向服務端發送"Hello Server",服務器端指定MSG_PEEK標志獲得可讀的長度后，并再次調用不指定MSG_PEEK的recv讀取，兩次讀取都能得到數據，因為指定了MSG_PEEK后套接字接收緩沖區不會減少。

net.h

1. #ifndef MY_NET_H
2. #define MY_NET_H
4. #include <sys/types.h>
5. #include <sys/socket.h>
6. #include <stdio.h>
7. #include <stdlib.h>
8. #include <arpa/inet.h>
9. #include <unistd.h>
10. #include <time.h>
11. #include <string.h>
12. #include <sys/select.h>
13. #include <sys/time.h>
14. #include <errno.h>
15. #include <signal.h>
16. #include <iostream>
17. #include <sys/stat.h>
18. #include <fcntl.h>
20. using namespace std;
22. #define SA struct sockaddr
24. /*
25. *Init_sockaddr 初始化地址結構
26. *stru 指向地址結構的指針
27. *protoc 要采用的地址族
28. *addr ip地址,不能為INADDR_ANY
29. *port 端口號
30. *返回值：成功返回0，出錯返回-1
31. *提示：不對protoc(地址族)參數進行檢查
32. */
33. int Init_sockaddr(struct sockaddr_in *stru, const int protoc, const char *addr,const unsigned int port)
34. {
35. if (stru == NULL || addr == NULL)
36. return -1;
38. /*ip地址格式不正確*/
39. if (inet_addr(addr) == INADDR_NONE)
40. return -1;
42. /*端口超出65535*/
43. if (port > 65535)
44. return -1;
46. bzero((void*)stru, sizeof(*stru));
47. stru->sin_family = protoc;
48. (stru->sin_addr).s_addr = inet_addr(addr);
49. stru->sin_port = htons(port);
51. return 0;
52. }
54. /*
55. *tcp_connect 建立一個TCP套接字并連接到指定ip地址的指定端口(阻塞版本，connect會一直阻塞，直到到達默認超時時間)
56. *addr ip地址
57. *port 端口
58. *返回值：連接成功返回描述符，出錯返回-1
59. */
60. int Tcp_connect(const char *addr,const unsigned int port)
61. {
62. int sockfd;
63. struct sockaddr_in saddr;
65. /*參數不合法*/
66. if((Init_sockaddr(&saddr, AF_INET, addr, port)) == -1)
67. return -1;
69. /*socket異常*/
70. if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
71. return -1;
73. /*連接不成功或超時*/
74. if(connect(sockfd, (SA*)&saddr, sizeof(saddr)) == -1)
75. {
76. close(sockfd);
77. return -1;
78. }
80. return sockfd;
81. }
83. /*
84. *tcp_listen 建立一個套接字，并且綁定，監聽
85. *addr 要綁定的ip地址 INADDR_ANY或ipv4地址
86. *port 要監聽的端口
87. *backlog listen函數的監聽排隊數
88. *返回值：成功返回套接字描述符，出錯返回-1
89. */
90. int Tcp_listen(const char *addr,const unsigned int port,const int backlog)
91. {
92. int sockfd;
93. struct sockaddr_in saddr;
95. if (addr == NULL)
96. return -1;
98. if (strcmp(addr, "INADDR_ANY") == 0)
99. {
100. /*端口超出65535*/
101. if (port > 65535)
102. return -1;
104. /*排隊數不合法*/
105. if (backlog < 0)
106. return -1;
108. bzero((void*)&saddr, sizeof(saddr));
109. saddr.sin_family = AF_INET;
110. saddr.sin_addr.s_addr = htonl(INADDR_ANY);
111. saddr.sin_port = htons(port);
112. }
113. else
114. {
115. /*參數不合法*/
116. if (Init_sockaddr(&saddr, AF_INET, addr, port) == -1)
117. return -1;
118. }
120. /*socket異常*/
121. if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
122. return -1;
124. /*bind*/
125. if (bind(sockfd, (SA*)&saddr, sizeof(saddr)) == -1)
126. {
127. close(sockfd);
128. return -1;
129. }
131. /*listen*/
132. if (listen(sockfd, backlog) == -1)
133. {
134. close(sockfd);
135. return -1;
136. }
138. return sockfd;
139. }
141. #endif

1. #include <iostream>
2. #include "net.h"
3. using namespace std;
5. int main()
6. {
7. int sockfd;
8. sockfd = Tcp_connect("127.0.0.1", 9999);
9. if (sockfd == -1)
10. {
11. cout << "Tcp_connect error" << endl;
12. return -1;
13. }
14. char send_buf[] = "Hello Server";
15. char *p = send_buf;
16. int r;
17. int count = 0;
18. while (1)
19. {
20. r = write(sockfd, p, strlen(p));
21. if (r == -1)
22. {
23. perror("write error");
24. return -1;
25. }
26. p += r;
27. count += r;
28. if (count == strlen(send_buf))
29. break;
30. }
31. while(1);
32. return 0;
33. }

服務器程序

1. #include <iostream>
2. #include <unistd.h>
3. #include "net.h"
4. using namespace std;
6. int main()
7. {
8. int sockfd;
9. sockfd = Tcp_listen("INADDR_ANY", 9999, 5);
10. if (sockfd == -1)
11. {
12. cout << "Tcp_listen error" << endl;
13. return -1;
14. }
16. int clifd;
17. if ((clifd = accept(sockfd, NULL, NULL)) == -1)
18. {
19. cout << "accept error" << endl;
20. return -1;
21. }
22. cout << "有新連接" << endl;
24. //確保客戶端有數據發送到服務端（本地測試可行）
25. sleep(5);
27. char buf[100];
28. int r;
29. //利用MSG_PEEK標志讀取套接子接收隊列中可讀的數據長度，
30. r = recv(clifd, buf, sizeof(buf), MSG_PEEK);
31. cout << "接收隊列中可讀的數據長度:" << r << endl;//此處"Hello Server"的長度為12，由于采用tcp,不一定所有數據都會到達服務端，所以值應<=12
32. cout << "buf:" << buf << endl;
33. r = recv(clifd, buf, sizeof(buf), 0);
34. cout << "讀取長度:" << r << endl; //該長度可能會大于上一個recv返回的長度，因為在此期間可能又有來自客戶的數據到達
35. cout << "buf:" << buf << endl;
36. return 0;
37. }

執行結果