Linux select TCP并發服務器與客戶端編程

http://blog.csdn.net/szkbsgy/article/details/10558881

[cpp]?view plain?copy
  1. <span?style="font-size:18px;">服務端：??
  2. #include?<stdio.h>??
  3. #include?<stdlib.h>??
  4. #include?<string.h>??
  5. #include?<sys/time.h>??
  6. #include?<sys/types.h>??
  7. #include?<sys/socket.h>??
  8. #include?<netinet/in.h>??
  9. #include?<sys/select.h>??
  10. #include?<errno.h>??
  11. ??
  12. ??
  13. #define?SERVER_IP?"127.0.0.1"??
  14. #define?SERVER_PORT?8000??
  15. ??
  16. ??
  17. #define?MAX_RECV_LEN?1024??
  18. #define?MAX_CLIENT_NUM?30??
  19. #define?BACK_LOG?20??
  20. ??
  21. ??
  22. static?int?running?=?1;??
  23. ??
  24. ??
  25. int?main(int?argc,?char?*argv[])??
  26. {??
  27. ????int?sock_fd?=?-1;??
  28. ????int?ret?=?-1;??
  29. ????struct?sockaddr_in?serv_addr;??
  30. ????struct?sockaddr_in?cli_addr;??
  31. ????socklen_t?serv_addr_len?=?0;??
  32. ????socklen_t?cli_addr_len?=?0;??
  33. ????int?client_fd[MAX_CLIENT_NUM];??
  34. ????char?recv_buf[MAX_RECV_LEN];??
  35. ????int?new_conn_fd?=?-1;??
  36. ????int?i?=?0;??
  37. ????int?max_fd?=?-1;??
  38. ????int?num?=?-1;??
  39. ????struct?timeval?timeout;??
  40. ??
  41. ??
  42. ????fd_set?read_set;??
  43. ????fd_set?write_set;??
  44. ????fd_set?select_read_set;??
  45. ??
  46. ??
  47. ????FD_ZERO(&read_set);??
  48. ????FD_ZERO(&write_set);??
  49. ????FD_ZERO(&select_read_set);??
  50. ??
  51. ????for?(i?=?0;?i?<?MAX_CLIENT_NUM;?i++)??
  52. ????{??
  53. ????????client_fd[i]?=?-1;??
  54. ????}???
  55. ??
  56. ????memset(&serv_addr,?0,?sizeof(serv_addr));??
  57. ????memset(&cli_addr,?0,?sizeof(cli_addr));??
  58. ??
  59. ??
  60. ????sock_fd?=?socket(AF_INET,?SOCK_STREAM,?0);??
  61. ????if?(sock_fd?<?0)??
  62. ????{??
  63. ????????perror("Fail?to?socket");??
  64. ????????exit(1);??
  65. ????}??
  66. ??
  67. ??
  68. ????serv_addr.sin_family?=?AF_INET;??
  69. ????serv_addr.sin_port?=?htons(SERVER_PORT);??
  70. ????serv_addr.sin_addr.s_addr?=?inet_addr(SERVER_IP);??
  71. ??
  72. ??
  73. ????unsigned?int?value?=?1;??
  74. ????if?(setsockopt(sock_fd,?SOL_SOCKET,?SO_REUSEADDR,??
  75. ????????????????(void?*)&value,?sizeof(value))?<?0)??
  76. ????{??
  77. ????????perror("Fail?to?setsockopt");??
  78. ????????exit(1);??
  79. ????}??
  80. ??
  81. ??
  82. ????serv_addr_len?=?sizeof(serv_addr);??
  83. ????if?(bind(sock_fd,?(struct?sockaddr*)&serv_addr,?serv_addr_len)?<?0)??
  84. ????{??
  85. ????????perror("Fail?to?bind");??
  86. ????????exit(1);??
  87. ????}??
  88. ????if?(listen(sock_fd,?BACK_LOG)?<?0)??
  89. ????{??
  90. ????????perror("Fail?to?listen");??
  91. ????????exit(1);??
  92. ????}??
  93. ??
  94. ????char?buf[1024];??
  95. ????max_fd?=?sock_fd;??
  96. ????int?len;??
  97. ????FD_SET(sock_fd,?&read_set);??
  98. ????while?(running)??
  99. ????{??
  100. ????????timeout.tv_sec?=?5;??
  101. ????????timeout.tv_usec?=?0;??
  102. ??
  103. ??
  104. ????????max_fd?=?sock_fd;??
  105. ????????for?(i?=?0;?i?<?MAX_CLIENT_NUM;?i++)??
  106. ????????{??
  107. ????????????if?(max_fd?<?client_fd[i])??
  108. ????????????{??
  109. ????????????????max_fd?=?client_fd[i];??
  110. ????????????}??
  111. ????????}??
  112. ??
  113. ??
  114. ????????select_read_set?=?read_set;??
  115. ????????ret?=?select(max_fd?+?1,?&select_read_set,?NULL,?NULL,?&timeout);??
  116. ????????if?(ret?==?0)??
  117. ????????{??
  118. ????????????printf("timeout\n");??
  119. ????????}??
  120. ????????else?if?(ret?<?0)??
  121. ????????{??
  122. ????????????printf("error?occur\n");??
  123. ????????}??
  124. ????????else??
  125. ????????{??
  126. ????????????if?(FD_ISSET(sock_fd,?&select_read_set))??
  127. ????????????{??
  128. ????????????????printf("new?client?comes\n");??
  129. ????????????????len?=?sizeof(cli_addr);??
  130. ????????????????new_conn_fd?=?accept(sock_fd,?(struct?sockaddr*)&cli_addr,?&len);??
  131. ????????????????if?(new_conn_fd?<?0)??
  132. ????????????????{??
  133. ????????????????????perror("Fail?to?accept");??
  134. ????????????????????exit(1);??
  135. ????????????????}??
  136. ????????????????else??
  137. ????????????????{??
  138. ????????????????????for?(i?=?0;?i?<?MAX_CLIENT_NUM;?i++)??
  139. ????????????????????{??
  140. ????????????????????????if?(client_fd[i]?==?-1)??
  141. ????????????????????????{??
  142. ????????????????????????????client_fd[i]?=?new_conn_fd;??
  143. ????????????????????????????FD_SET(new_conn_fd,?&read_set);??
  144. ????????????????????????????break;??
  145. ????????????????????????}??
  146. ????????????????????????if?(max_fd?<?new_conn_fd)??
  147. ????????????????????????{??
  148. ????????????????????????????max_fd?=?new_conn_fd;??
  149. ????????????????????????}??
  150. ????????????????????}??
  151. ????????????????}??
  152. ????????????}??
  153. ????????????else??
  154. ????????????{??
  155. ????????????????for?(i?=?0;?i?<?MAX_CLIENT_NUM;?i++)??
  156. ????????????????{??
  157. ????????????????????if?(-1?==?client_fd[i])?{??
  158. ????????????????????????continue;??
  159. ????????????????????}??
  160. ????????????????????memset(recv_buf,?0,?MAX_RECV_LEN);??
  161. ????????????????????if?(FD_ISSET(client_fd[i],?&select_read_set))??
  162. ????????????????????{??
  163. ????????????????????????num?=?read(client_fd[i],?recv_buf,?MAX_RECV_LEN);??
  164. ????????????????????????if?(num?<?0)??
  165. ????????????????????????{??
  166. ????????????????????????????printf("Client(%d)?left\n",?client_fd[i]);??
  167. ????????????????????????????FD_CLR(client_fd[i],?&read_set);??
  168. ????????????????????????????close(client_fd[i]);??
  169. ????????????????????????????client_fd[i]?=?-1;??
  170. ????????????????????????}??
  171. ????????????????????????else?if?(num?>?0)??
  172. ????????????????????????{??
  173. ????????????????????????????recv_buf[num]?=?'\0';??
  174. ????????????????????????????printf("Recieve?client(%d)?data\n",?client_fd[i]);??
  175. ????????????????????????????printf("Data:?%s\n\n",?recv_buf);??
  176. ????????????????????????}?if?(num?==?0)??
  177. ????????????????????????{??
  178. ????????????????????????????printf("Client(%d)?exit\n",?client_fd[i]);??
  179. ????????????????????????????FD_CLR(client_fd[i],?&read_set);??
  180. ????????????????????????????close(client_fd[i]);??
  181. ????????????????????????????client_fd[i]?=?-1;??
  182. ????????????????????????}??
  183. ????????????????????}??
  184. ????????????????}??
  185. ????????????}??
  186. ????????}??
  187. ????}??
  188. ????return?0;??
  189. }??
  190. ??
  191. 客戶端：??
  192. #include?<stdio.h>??
  193. #include?<stdlib.h>??
  194. #include?<string.h>??
  195. #include?<unistd.h>??
  196. #include?<sys/time.h>??
  197. #include?<sys/types.h>??
  198. #include?<sys/socket.h>??
  199. #include?<netinet/in.h>??
  200. #include?<sys/select.h>??
  201. ??
  202. ??
  203. #define?SERVER_IP?"127.0.0.1"??
  204. #define?SERVER_PORT?8000??
  205. ??
  206. ??
  207. #define?MAX_RECV_LEN?1024??
  208. ??
  209. ??
  210. static?int?running?=?1;??
  211. ??
  212. ??
  213. int?main(int?argc,?char?*argv[])??
  214. {??
  215. ????int?sock_fd?=?-1;??
  216. ????int?ret?=?-1;??
  217. ????struct?sockaddr_in?serv_addr;??
  218. ????struct?sockaddr_in?cli_addr;??
  219. ????socklen_t?serv_addr_len?=?0;??
  220. ??
  221. ????memset(&serv_addr,?0,?sizeof(serv_addr));??
  222. ??
  223. ??
  224. ????sock_fd?=?socket(AF_INET,?SOCK_STREAM,?0);??
  225. ????if?(sock_fd?<?0)??
  226. ????{??
  227. ????????perror("Fail?to?socket");??
  228. ????????exit(1);??
  229. ????}??
  230. ??
  231. ??
  232. ????serv_addr.sin_family?=?AF_INET;??
  233. ????serv_addr.sin_port?=?htons(SERVER_PORT);??
  234. ????serv_addr.sin_addr.s_addr?=?inet_addr(SERVER_IP);??
  235. ??
  236. ??
  237. ????serv_addr_len?=?sizeof(serv_addr);??
  238. ????if?(connect(sock_fd,?(struct?sockaddr?*)&serv_addr,?serv_addr_len)?<?0)??
  239. ????{??
  240. ????????perror("Fail?to?connect");??
  241. ????????exit(1);??
  242. ????}??
  243. ????char?buf[1024];??
  244. ????int?num?=?0;??
  245. ????while?(running)??
  246. ????{??
  247. ????????num?=?read(STDIN_FILENO,?buf,?MAX_RECV_LEN);??
  248. ????????if?(num?>?0)??
  249. ????????{??
  250. ????????????buf[num]?=?'\0';??
  251. ????????????printf("buf:?%s\n",?buf);??
  252. ????????????num?=?write(sock_fd,?buf,?num);??
  253. ????????????if?(num?<?0)??
  254. ????????????{??
  255. ????????????????printf("write?failed\n");??
  256. ????????????????exit(1);??
  257. ????????????}??
  258. ??
  259. ??
  260. ????????????if?(strncmp(buf,?"exit",?strlen("exit"))?==?0)??
  261. ????????????{??
  262. ????????????????printf("Client?exit\n");??
  263. ????????????????close(sock_fd);??
  264. ????????????????return?0;??
  265. ????????????}???
  266. ????????}??
  267. ????}??
  268. ????return?0;??
  269. }?</span> ?

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/383894.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/383894.shtml
英文地址，請注明出處：http://en.pswp.cn/news/383894.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

BZOJ - 2186 歐拉函數

BZOJ - 2186 歐拉函數

題目的意思大概是求1~N!中和M&#xff01;互質的數的個數 因為對歐拉函數理解不夠深刻所以我是分析得到結果的&#xff1a; 當N<M的時候顯然符合要求的數的個數為0&#xff1b; 當N>M的時候我們要求的是1~N!中不含1 ~M的素因子的的數的個數&#xff0c;結合歐拉函數的…
閱讀更多...
多態相關概念

多態相關概念

多態相關注意事項 所謂的多態就是指函數有多中狀態, 在C中通常是通過父類指針指向子類對象的方法實現多態, 這樣父類可以通過子類的類型調用不同的方法. 即實現一個接口多種方法, 多態的引用是為了實現接口復用 在 C中多態是通過虛函數來實現的. 子類通過對父類相關接口進行重…
閱讀更多...
模板實現棧隊列以及鏈表

模板實現棧隊列以及鏈表

模板實現鏈表 //test.h #include <iostream> #include <cstdio> #include <assert.h> using namespace std;template <class T> struct ListNode {ListNode* _prev;ListNode* _next;T _data;ListNode(const T& x):_prev(NULL),_next(NULL),_data(…
閱讀更多...
基于Visual C++2013拆解世界五百強面試題--題5-自己實現strstr

基于Visual C++2013拆解世界五百強面試題--題5-自己實現strstr

http://blog.csdn.net/itcastcpp/article/details/12907371 請用C語言實現字符串的查找函數strstr&#xff0c; 找到則返回子字符串的地址&#xff0c;沒有找到返回為空&#xff0c;請用數組操作與指針操作實現 看到題目想到最簡單的方法就是母字符串和子字符串比較&#xff0c…
閱讀更多...
卡特蘭數

卡特蘭數

卡特蘭數的引入與n邊形分成三角形的個數有關&#xff1a; 我們令f[n]表示n邊形可以分成的三角形的個數&#xff0c;特殊的&#xff0c;令f[2]1 我們考慮以頂點1頂點的一個三角形&#xff0c;假設用的是n邊形的k-k1邊&#xff0c;那么這種情況的方案數就是f[k]?f[n?k1]f[k]*…
閱讀更多...
軟件測試相關概念

軟件測試相關概念

什么叫軟件測試 軟件測試就是測試產品沒有錯誤,同時又證明軟件是可以正確運行的 測試和調試的區別 調試一般都在開發期間 ,測試是伴隨著整個軟件的生命周期, 調試是發現程序中問題并且解決問題, 測試是發現程序中的缺陷 軟件測試的目的和原則 目的:驗證軟件有沒有問題 原…
閱讀更多...
Linux 線程信號量同步

Linux 線程信號量同步

https://www.cnblogs.com/jiqingwu/p/linux_semaphore_example.html 信號量和互斥鎖(mutex)的區別&#xff1a;互斥鎖只允許一個線程進入臨界區&#xff0c;而信號量允許多個線程同時進入臨界區。 不多做解釋&#xff0c;要使用信號量同步&#xff0c;需要包含頭文件semaphore.…
閱讀更多...
本原勾股數組

本原勾股數組

勾股數我們都很熟悉&#xff0c;a2b2c2&#xff0c;可是如何快速找到所有的勾股數組呢&#xff1f; 本原勾股數組a2b2c2性質&#xff1a; 1. a,b奇偶不同&#xff0c;c一定是奇數 2. 若b為偶數&#xff0c;c-b和cb一定是完全平方數 3. 設t>s>1,且均為奇數&#xff0c;則…
閱讀更多...
C++靜態成員函數訪問非靜態成員的幾種方法

C++靜態成員函數訪問非靜態成員的幾種方法

https://www.cnblogs.com/rickyk/p/4238380.html 大家都知道C中類的成員函數默認都提供了this指針&#xff0c;在非靜態成員函數中當你調用函數的時候&#xff0c;編譯器都會“自動”幫你把這個this指針加到函數形參里去。當然在C靈活性下面&#xff0c;類還具備了靜態成員和靜…
閱讀更多...
費馬大定理

費馬大定理

當n>3時方程 xnynzn沒有正整數解 結論很簡潔&#xff0c;剛才看了一下證明的歷史&#xff0c;我勒個去。。。。
閱讀更多...
類中的靜態成員函數訪問非靜態成員變量

類中的靜態成員函數訪問非靜態成員變量

http://blog.csdn.net/u011857683/article/details/52294353 1.思路&#xff1a; 靜態成員函數屬于類(通過類訪問&#xff0c;調用函數時沒有提供this指針)&#xff0c; 非靜態成員函數屬于實例&#xff08;通過對象訪問&#xff09;&#xff08;默認都提供了this指針&#xf…
閱讀更多...
Pollar Rho算法

Pollar Rho算法

原本是想把這個算法搞懂的&#xff0c;然后在網上看了又看&#xff0c;覺得&#xff0c;還是有時間再來看吧&#xff0c;我錯了。 看到了一個大佬的博客&#xff0c;順帶收集一下板子 這個板子可以求大數的最大的因子。 #define LL long long bool IsPrime(LL);//返回素性測…
閱讀更多...
小知識點總結

小知識點總結

用戶輸入一個url之后到整個頁面返回給客戶這個過程都經歷了一些什么 首先url是為了讓人記憶方便的,計算機在進行網絡傳輸的過程中只能通過ip地址找到對應的主機,所以當輸入一個ip地址的時候,此時就需要找對應的url,首先從瀏覽器中取查找ip地址,再到系統中去查找,再到域名解析服…
閱讀更多...
C++學習之普通函數指針與成員函數指針

C++學習之普通函數指針與成員函數指針

http://blog.csdn.net/lisonglisonglisong/article/details/38353863 函數指針&#xff08;function pointer&#xff09;是通過指向函數的指針間接調用函數。相信很多人對指向一般函數的函數指針使用的比較多&#xff0c;而對指向類成員函數的函數指針則比較陌生。我最近也被問…
閱讀更多...
HDU2683——歐拉完全數

HDU2683——歐拉完全數

題目要求符合等式的數&#xff0c;我們首先要做的就是分析這個數&#xff1a; 對于這個等式&#xff0c;我們可能什么都看不出來&#xff0c;左邊很難化簡的樣子&#xff0c;所以我們就要想到通過變化怎么樣把右邊化成和左邊形式差不多的樣子。結合組合數我們想到二項式定理&am…
閱讀更多...
BZOJ-2005能量采集-數論函數

BZOJ-2005能量采集-數論函數

很入門的數論函數題目。我還是wa了一發&#xff08;爆long long 了&#xff09; 對于每個位置x,y&#xff0c;在他們和能量采集器中間的植物為gcd(x,y)-1&#xff0c;【在他們之間說明斜率相同&#xff0c;而和他們斜率相同的就是所有gcd(x/gcd(x,y),y/gcd(x,y))1的并且比他們小…
閱讀更多...
網絡五層模型

網絡五層模型

TCP/IP五層模型 應用層: HTTP,HTTPS協議,其中HTTP沒有對數據進行加密操作,但是HTTPS對數據進行了加密操作 其中HTTP端口號一般是80/8080等等,HTTPS端口號是443,SSH端口號一般是22,ftp是21 HTTP協議報頭: 首行:請求方法,url,協議版本 請求報頭: HOST:主機 Connection:長連接…
閱讀更多...
C++的靜態成員函數指針

C++的靜態成員函數指針

http://blog.csdn.net/sky453589103/article/details/47276789 先簡單的說說非靜態的成員函數。非靜態成員函數指針的類型&#xff1a;類的非靜態成員是和類的對象相關的。也就是說&#xff0c;要通過類的對象來訪問變量。成員函數的類型定義為&#xff1a;typedef void (A::*p…
閱讀更多...
從一個字符串中刪除另一個字符串中出現過的字符

從一個字符串中刪除另一個字符串中出現過的字符

http://blog.csdn.net/walkerkalr/article/details/39001155 定義一個函數&#xff0c;輸入兩個字符串&#xff0c;從第一個字符串中刪除在第二個中出現過的所偶字符串。例如從第一個字符串"We are students."中刪除第二個字符中“auiou”中出現過的字符得到的結果是…
閱讀更多...
SPOJ-VLATTICE Visible Lattice Points-莫比烏斯反演

SPOJ-VLATTICE Visible Lattice Points-莫比烏斯反演

需要將問題分解一下。 我們需要求的是這個立方體從(0,0,0)能看到的點的個數。可是在三個含有(0,0,0)的面上我們沒有辦法和其他的一起進行分析&#xff08;因為含有坐標是0&#xff0c;而我們的數論工具都是從1開始的&#xff09;&#xff0c;所以我們可以將那三個面分開考慮&a…
閱讀更多...
最新文章

Copyright @ 2022~2023