• C++ TCP通信

    TCP协议：

            服务器 Server                                                客户端 Client

    1.     确定协议版本                                           1.     确定协议版本

    2.      创建socket                                              2.      创建socket

    3.      确定协议地址簇                                       3.      获取服务器地址

    4.      绑定                                                    

    5.     监听

    6.     接受客户端连接                                        4.     连接服务器

    7.     通信                                                          5.     通信

    8.    关闭socket                                                 6.    关闭socket

    9.    清理协议版本信息                                      7.    清理协议版本信息       

    用vs2019写的

    单个服务器，单个客户端

    Server.cpp

    1. #define _WINSOCK_DEPRECATED_NO_WARNINGS
    2. #include
    3. #include
    4. #pragma comment(lib,"ws2_32.lib")
    5. #include
    6. #include
    7. #include
    8.  
    9. int main()
    10. {
    11. 	// 1. 确定协议版本
    12. 	WSADATA wsaData;
    13. 	WSAStartup(MAKEWORD(2, 2), &wsaData);
    14. 	if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
    15. 	{
    16. 		printf("请求的版本不是2.2版本！\n");
    17. 		WSACleanup();
    18. 		return -1;
    19. 	}
    20. 	printf("请求的版本为2.2版本！\n");
    21.  
    22.  
    23. 	// 2  创建socket
    24. 	SOCKET sSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);   //结构体
    25. 	if (SOCKET_ERROR == sSocket)
    26. 	{
    27. 		printf("创建socke失败 ：%d\n",GetLastError());
    28. 		return -2;
    29. 	}
    30. 	printf("创建socke成功！\n");
    31.  
    32.  
    33. 	// 3 确定服务器的协议地址簇
    34. 	std::string ip = "127.0.0.1";
    35. 	int port = 8080;
    36. 	SOCKADDR_IN addr = {0};
    37. 	addr.sin_family = AF_INET; // 和socket函数第一个参数保持一致
    38. 	addr.sin_addr.S_un.S_addr = inet_addr(ip.c_str()); // 
    39. 	addr.sin_port = htons(port);  // 
    40.  
    41.  
    42. 	// 4  绑定
    43. 	int r = bind(sSocket,(sockaddr*)&addr, sizeof(addr));
    44. 	if (-1 == r)
    45. 	{
    46. 		printf("绑定失败：%d\n",GetLastError());
    47. 		// 8 断开连接
    48. 		closesocket(sSocket);
    49. 		// 9 清理协议版本信息
    50. 		WSACleanup();
    51. 		return -2;
    52. 	}
    53. 	printf("绑定成功！\n");
    54.  
    55.  
    56. 	// 5.  监听
    57. 	r = listen(sSocket,10);
    58. 	if (-1 == r)
    59. 	{
    60. 		printf("监听失败：%d\n",GetLastError());
    61. 		// 8 断开连接
    62. 		closesocket(sSocket);
    63. 		// 9 清理协议版本信息
    64. 		WSACleanup();
    65. 		return -2;
    66. 	}
    67. 	printf("监听成功！\n");
    68.  
    69. 	// 6 等待客户端连接
    70. 	SOCKET cSocket = accept(sSocket,NULL,NULL);
    71. 	if (SOCKET_ERROR == cSocket)
    72. 	{
    73. 		printf("服务器崩溃：%d\n",GetLastError());
    74. 		// 8 断开连接
    75. 		closesocket(sSocket);
    76. 		// 9 清理协议版本信息
    77. 		WSACleanup();
    78. 		return -2;
    79. 	}
    80. 	printf("有客户端连接上服务器了！\n");
    81.  
    82. 	// 7 通信
    83. 	char buff[256] = {0};
    84. 	while (1)
    85. 	{
    86. 		r = recv(cSocket,buff,255,NULL);    // 从客户端接收数据
    87. 		if (r>0)
    88. 		{
    89. 			buff[r] = 0;  // 添加结束符号
    90. 			printf(">>%s\n",buff);  // 输出
    91. 		}
    92.  
    93. 	}
    94.  
    95.  
    96. 	while (1);
    97. 	return 0;
    98. }

    Client.cpp

    1. #define _WINSOCK_DEPRECATED_NO_WARNINGS
    2. #include
    3. #pragma comment(lib,"ws2_32.lib")
    4. #include
    5. #include
    6. #include
    7.  
    8. int main()
    9. {
    10. 	// 1. 确定协议版本
    11. 	WSADATA wsaData;
    12. 	WSAStartup(MAKEWORD(2, 2), &wsaData);
    13. 	if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
    14. 	{
    15. 		printf("请求的版本不是2.2版本！\n");
    16. 		WSACleanup();
    17. 		return -1;
    18. 	}
    19.  
    20. 	printf("请求的版本为2.2版本！\n");
    21.  
    22.  
    23. 	// 2  创建socket
    24. 	SOCKET sSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    25. 	if (SOCKET_ERROR == sSocket)
    26. 	{
    27. 		printf("创建socke失败 ：%d\n", GetLastError());
    28. 		return -2;
    29. 	}
    30. 	printf("创建socke成功！\n");
    31.  
    32.  
    33. 	// 3 确定服务器的协议地址簇
    34. 	std::string ip = "127.0.0.1";
    35. 	int port = 8080;
    36. 	SOCKADDR_IN addr = { 0 };
    37. 	addr.sin_family = AF_INET; // 和socket函数第一个参数保持一致
    38. 	addr.sin_addr.S_un.S_addr = inet_addr(ip.c_str()); // 服务器IP地址
    39. 	addr.sin_port = htons(port);  // 
    40.  
    41.  
    42. 	// 4  连接
    43. 	int r = connect(sSocket, (sockaddr*)&addr, sizeof(addr));
    44. 	if (-1 == r)
    45. 	{
    46. 		printf("连接失败：%d\n", GetLastError());
    47. 		return -2;
    48. 	}
    49. 	printf("连接成功！\n");
    50.  
    51. 	// 5.   通信
    52. 	char buff[256];
    53. 	while (1)
    54. 	{
    55. 		memset(buff, 0, 256); // 清空数组 
    56. 		printf("发送服务器信息：");
    57. 		scanf_s("%s", buff,sizeof(buff));
    58. 		send(sSocket, buff, strlen(buff), NULL);
    59. 	}
    60.  
    61.  
    62. 	while (1);
    63. 	return 0;
    64. }

    多个客户端连接同一个服务器

    Server.cpp

    1. #define _WINSOCK_DEPRECATED_NO_WARNINGS
    2. #include
    3. #include
    4. #pragma comment(lib,"ws2_32.lib")
    5. #include
    6. #include
    7. #include
    8.  
    9. #define NUM 1024  // 最大连接客户端
    10.  
    11. SOCKET cSocket[NUM];
    12.  
    13. int count;
    14.  
    15. // 和客户端通信的函数
    16. void tongxin(int idx);
    17.  
    18. int main()
    19. {
    20. 	count = 0;
    21.  
    22. 	// 1. 确定协议版本
    23. 	WSADATA wsaData;
    24. 	WSAStartup(MAKEWORD(2, 2), &wsaData);
    25. 	if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
    26. 	{
    27. 		printf("请求的版本不是2.2版本！\n");
    28. 		WSACleanup();
    29. 		return -1;
    30. 	}
    31. 	printf("请求的版本为2.2版本！\n");
    32.  
    33.  
    34. 	// 2  创建socket
    35. 	SOCKET sSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);   //结构体
    36. 	if (SOCKET_ERROR == sSocket)
    37. 	{
    38. 		printf("创建socke失败 ：%d\n",GetLastError());
    39. 		return -2;
    40. 	}
    41. 	printf("创建socke成功！\n");
    42.  
    43.  
    44. 	// 3 确定服务器的协议地址簇
    45. 	std::string ip = "127.0.0.1";
    46. 	int port = 8080;
    47. 	SOCKADDR_IN addr = {0};
    48. 	addr.sin_family = AF_INET; // 和socket函数第一个参数保持一致
    49. 	addr.sin_addr.S_un.S_addr = inet_addr(ip.c_str()); // 本机IP地址
    50. 	//addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); // 
    51. 	addr.sin_port = htons(port);  // 大小端转换  在10000左右
    52. 	//printf("addr =  %d \n",sizeof(addr));
    53.  
    54.  
    55.  
    56. 	// 4  绑定
    57. 	int r = bind(sSocket,(sockaddr*)&addr, sizeof(addr));
    58. 	if (-1 == r)
    59. 	{
    60. 		printf("绑定失败：%d\n",GetLastError());
    61. 		// 8 断开连接
    62. 		closesocket(sSocket);
    63. 		// 9 清理协议版本信息
    64. 		WSACleanup();
    65. 		return -2;
    66. 	}
    67. 	printf("绑定成功！\n");
    68.  
    69.  
    70. 	// 5.  监听
    71. 	r = listen(sSocket,10);
    72. 	if (-1 == r)
    73. 	{
    74. 		printf("监听失败：%d\n",GetLastError());
    75. 		// 8 断开连接
    76. 		closesocket(sSocket);
    77. 		// 9 清理协议版本信息
    78. 		WSACleanup();
    79. 		return -2;
    80. 	}
    81. 	printf("监听成功！\n");
    82.  
    83. 	// 6 等待客户端连接
    84. 	for(int i =0 ;i < NUM; i++)
    85. 	{
    86. 		cSocket[i] = accept(sSocket, NULL, NULL);
    87. 		if (SOCKET_ERROR == cSocket[i])
    88. 		{
    89. 			printf("服务器崩溃：%d\n", GetLastError());
    90. 			// 8 断开连接
    91. 			closesocket(sSocket);
    92. 			// 9 清理协议版本信息
    93. 			WSACleanup();
    94. 			return -3;
    95. 		}
    96. 		printf("有客户端连接上服务器了: %d \n",i);
    97.  
    98. 		count++;
    99.  
    100. 		// 创建线程和客户端通信
    101. 		CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)tongxin, (LPVOID)i, NULL, NULL);
    102. 	}
    103.  
    104.  
    105.  
    106.  
    107. 	while (1);
    108. 	return 0;
    109. }
    110.  
    111.  
    112. // 和客户端通信
    113. void tongxin(int idx)
    114. {
    115. 	// 7 通信
    116.  
    117. 	char buff[256] = { 0 };
    118. 	int r;
    119. 	char temp[256];
    120. 	while (1)
    121. 	{
    122. 		r = recv(cSocket[idx], buff, 255, NULL);    // 从客户端接收数据
    123. 		if (r > 0)
    124. 		{
    125. 			buff[r] = 0;  // 添加结束符号
    126. 			printf(">>%d:%s\n",idx, buff);  // 输出
    127.  
    128. 			// 发送给当前连上服务器的所有客户端
    129. 			memset(temp,0,256);
    130. 			sprintf(temp, "%d:%s",idx,buff);
    131. 			for (int i = 0; i < count; i++)
    132. 			{
    133. 				send(cSocket[i],temp,strlen(temp),NULL);
    134. 			}
    135. 		}
    136.  
    137. 	}
    138.  
    139. }

    Client.cpp

    1. #define _WINSOCK_DEPRECATED_NO_WARNINGS
    2. #include
    3. #pragma comment(lib,"ws2_32.lib")
    4. #include
    5. #include
    6. #include
    7.  
    8.  
    9. #include  // easyX
    10. SOCKET sSocket;
    11. void scanfAndSend();
    12.  
    13. int main()
    14. {
    15. 	initgraph(200,400,1); // 俩个窗口
    16.  
    17. 	// 1. 确定协议版本
    18. 	WSADATA wsaData;
    19. 	WSAStartup(MAKEWORD(2, 2), &wsaData);
    20. 	if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
    21. 	{
    22. 		printf("请求的版本不是2.2版本！\n");
    23. 		WSACleanup();
    24. 		return -1;
    25. 	}
    26.  
    27. 	printf("请求的版本为2.2版本！\n");
    28.  
    29.  
    30. 	// 2  创建socket
    31. 	sSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    32. 	if (SOCKET_ERROR == sSocket)
    33. 	{
    34. 		printf("创建socke失败 ：%d\n", GetLastError());
    35. 		return -2;
    36. 	}
    37. 	printf("创建socke成功！\n");
    38.  
    39.  
    40. 	// 3 确定服务器的协议地址簇
    41. 	std::string ip = "127.0.0.1";
    42. 	int port = 8080;
    43. 	SOCKADDR_IN addr = { 0 };
    44. 	addr.sin_family = AF_INET; // 和socket函数第一个参数保持一致
    45. 	addr.sin_addr.S_un.S_addr = inet_addr(ip.c_str()); // 服务器IP地址
    46. 	//addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); // 本机IP地址
    47. 	addr.sin_port = htons(port);  // 大小端转换  在10000左右
    48.  
    49.  
    50. 	// 4  连接
    51. 	int r = connect(sSocket, (sockaddr*)&addr, sizeof(addr));
    52. 	if (-1 == r)
    53. 	{
    54. 		printf("连接失败：%d\n", GetLastError());
    55. 		return -2;
    56. 	}
    57. 	printf("连接成功！\n");
    58.  
    59. 	CreateThread(NULL,NULL,(LPTHREAD_START_ROUTINE)scanfAndSend,NULL,NULL,NULL);
    60. 	char buff[256];
    61. 	int n = 0;
    62. 	while (1)
    63. 	{
    64. 		r = recv(sSocket,buff,255,NULL);  // 循环从服务器接收
    65. 		if (r>0)
    66. 		{
    67. 			buff[r] = 0;// 添加结束符号
    68. 			// 显示到图形界面窗口
    69. 			outtextxy(1,n*20,buff);
    70. 			n++;
    71. 			if (n>18)
    72. 			{
    73. 				n = 0;
    74. 				cleardevice(); //清屏
    75. 			}
    76. 		}
    77. 	}
    78.  
    79.  
    80. 	while (1);
    81. 	return 0;
    82.  
    83. }
    84.  
    85.  
    86. void scanfAndSend()
    87. {
    88. 	// 5.   通信
    89. 	char buff[256];
    90. 	while (1)
    91. 	{
    92. 		memset(buff, 0, 256);    // 清空数组 
    93. 		printf("发送服务器信息：");
    94. 		scanf_s("%s", buff, sizeof(buff));   // 从命令行窗口接收发给服务器
    95. 		send(sSocket, buff, strlen(buff), NULL);
    96. 	}
    97. }

    参考：

    https://www.bilibili.com/video/BV12u411r7J6/?spm_id_from=333.788.top_right_bar_window_custom_collection.content.click&vd_source=701c26bdba61a7e00f00852c31111c06

  • 相关阅读:
    大型网站系统架构演化实例_7.使用NoSQL和搜索引擎
    消息队列的实现
    Seata TCC、Saga、XA模式初识
    Spring 事务(测试)--在这个笔记中记录的是没有添加事务，数据库返回的效果。...
    线性反向传播（机器学习）
    【学习笔记】「JOISC 2017 Day 3」自然公园
    Vue.js+Node.js全栈开发教程：Vue.js指令详解
    【BI看板】superset api接口分析
    Java转义工具类StringEscapeUtils的学习笔记
    麒麟系统开发笔记（十三）：在国产麒麟系统上编译OSG库、搭建基础开发环境和移植测试Demo
  • 原文地址：https://blog.csdn.net/qq_42046837/article/details/133847022