的简单socket编程，（简单1v1，简易服务器v多客户端

漠水

好久没有发帖了，来一发，很早之前我就想写个1v1，1v多的聊天工具(1v多服务端如果用MVC或者其他的界面语言，可以通过带入的线程结构体参数直接进行回复到客户端，有兴趣的可以自己试试修改写下)，死活搞不定，前段时间无聊，百度自己东拼西凑的可以运行的程序，与诸君共勉。
单人聊天代码：

1. /******************************************************************************************************/
   
2. //更改接收端端口ip（RecvPort )和发送端端口ip (SendPort ）即可互联（7000-》6000，6000-》）
   
3. //设置窗口隐藏
   
4. /******************************************************************************************************/
   
5. #include<WINSOCK2.H>
   
6. #include<stdio.h>
   
7. #include<time.h>
   
8. #include <windows.h>
   
9. #pragma comment(lib,"ws2_32.lib")
   
10. //#pragma comment( linker, "/subsystem:"windows" /entry:"mainCRTStartup"")    //-- 对应main函数(隐藏窗口)
    
11. #pragma warning(disable:4996)
    
12. DWORD WINAPI  thread_recv(PVOID pParam);
    
13. DWORD WINAPI  thread_send(PVOID pParam);
    
14. DWORD WINAPI  thread_accept(PVOID pParam);
    
15. const int  SendPort = 7000;
    
16. const int  RecvPort = 6000;
    
17. const char* SendIp = "127.0.0.1";
    
18. const char* RecvdIp = "127.0.0.1";
    
19. #define BUFFER_SIZE 1024            //注意：此Server端数据接收缓冲区 >= Client端数据发送缓冲区 ，否则造成缓冲区溢出  
    
20. struct THreadRecv  { SOCKET ser; };
    
21. struct THreadSend  { SOCKET ser;  HANDLE Handle; char buf[100]; };
    
22. struct THreadAccept  { SOCKET ser; };
    
23. int main(int argc,char *argv[])
    
24. {
    
25.         //ShowWindow(FindWindow("ConsoleWindowClass",argv[0]),0); //查找窗口隐藏自身 ..
    
26.         //MessageBox(NULL,TEXT("您选择了NO"),TEXT("NO"),MB_OK);
    
27.     HANDLE Handle_accept = CreateThread(NULL, 0, thread_accept, NULL, 0, NULL);  //创建接收端
    
28.     HANDLE Handle_send = CreateThread(NULL, 0, thread_send, NULL, 0, NULL);      //创建发送端
    
29.         while(true){
    
30. 
    
31.         }
    
32.         printf("结束程序");
    
33.         return 0;
    
34. }
    
35. 
    
36. //创建线程连接
    
37. DWORD WINAPI  thread_accept(PVOID pParam) {
    
38.         WORD version;
    
39.         WSADATA data;
    
40.         version = MAKEWORD(1, 1);
    
41.         int err;
    
42.         err = WSAStartup(version, &data);
    
43.         if (!err)
    
44.         {
    
45.                 printf("套接字一打开\n");
    
46.         }
    
47.         SOCKET ser = socket(AF_INET, SOCK_STREAM, 0);
    
48.         SOCKADDR_IN addr;
    
49.         addr.sin_family = AF_INET;
    
50.         addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);                //ip地址  INADDR_ANY指接收任意数据
    
51.         addr.sin_port = htons(RecvPort);                                                                //端口6000
    
52.         bind(ser, (SOCKADDR*)&addr, sizeof(SOCKADDR));                            //绑定端口
    
53.         listen(ser, 10);                                                                                        //最大连接数
    
54.         printf("开始监听\n");
    
55.         //绑定开始监听
    
56.     //SOCKET  ser;
    
57.     SOCKADDR_IN client;
    
58.         int len = sizeof(SOCKADDR);
    
59.         //THreadAccept* acceptParam = (THreadAccept*)pParam;//获取参数结构体ss
    
60.         //ser = acceptParam->ser;
    
61.         THreadRecv * recvParam = new THreadRecv();
    
62.         while (true)
    
63.         {
    
64.             SOCKET        connect        = accept(ser, (SOCKADDR*)&client, &len);
    
65.                 recvParam ->ser=connect;
    
66.                 //SOCKET        connect = accept(ser, (SOCKADDR*)&client, &len);
    
67.                 HANDLE Handle = CreateThread(NULL, 0, thread_recv, recvParam, 0, NULL); //创建接收线程
    
68.         }
    
69. 
    
70. 
    
71.         return 0;
    
72. }
    
73. 
    
74. //创建线程接收消息
    
75. DWORD WINAPI  thread_recv(PVOID pParam) {
    
76.         printf("接收消息\n");
    
77.         //绑定开始监听
    
78.         SOCKET  connect;
    
79.         THreadRecv* recvParam = (THreadRecv*)pParam;//获取参数结构体ss
    
80.         connect = recvParam->ser;
    
81.         while (true)
    
82.         {
    
83.                 char buf[BUFFER_SIZE];
    
84.         memset(buf,0,sizeof(buf));                                          //初始化数据接收缓冲区  
    
85.                 int length;
    
86.                 //最后一个参数一般设置为0
    
87.                 length = recv(connect, buf, BUFFER_SIZE, 0);
    
88.                 if (length != -1){
    
89.                         printf("对方说：%s\n", buf);
    
90.                 }       
    
91.                 //if(buf=="dir") system(buf);
    
92.                  
    
93.         }
    
94. 
    
95.         return 0;
    
96. }
    
97. 
    
98. //创建线程发送消息
    
99. DWORD WINAPI  thread_send(PVOID pParam) {
    
100.         printf("启动发送线程\n");
     
101.         int err;
     
102.         WORD verson;
     
103.         WSADATA data;
     
104.         verson = MAKEWORD(1, 1);
     
105.         err = WSAStartup(verson, &data);
     
106.         //system("pause");
     
107.         SOCKET client = socket(AF_INET, SOCK_STREAM, 0);
     
108.         SOCKADDR_IN in;
     
109.         in.sin_addr.S_un.S_addr = inet_addr(SendIp);
     
110.         in.sin_family = AF_INET;
     
111.         in.sin_port = htons(SendPort);
     
112.         int i = -1;
     
113.         bool myconn = false;
     
114.         while (i == -1)  //连接失败
     
115.         {
     
116.                 i = connect(client, (SOCKADDR*)&in, sizeof(SOCKADDR)); //套接字连接成功
     
117.                 if (i == -1) {
     
118.                         printf("socket连接失败，是否重连（y/n）\n");
     
119.                         if (getchar() != 'y') i = 0;
     
120.                         Sleep(1000);
     
121. 
     
122.                 }
     
123.                 else{
     
124.                         printf("连接成功\n");
     
125.                         myconn = true;
     
126.                         i = 0;
     
127.                 }
     
128.         }
     
129.         char  sendchar[1000] = {};
     
130.         //char  * sendchar = {};
     
131.         //char sendchar;
     
132.                 time_t timep;
     
133.                 time(&timep);
     
134.         if (myconn == true){
     
135.                         printf("请输入消息\n");
     
136.                 while (true){
     
137.                         fflush(stdin);  //清除缓存
     
138.                         scanf("%s", sendchar);  //输入字符串。
     
139.        
     
140.                         int sendback = send(client, sendchar, strlen(sendchar) + 1, 0);
     
141.                         if (sendback > 0)        {
     
142.                         //        printf("消息发送成功，返回值为：%d\n", sendback);
     
143.                                 printf("%s",ctime(&timep));
     
144.                                 //printf("消息发送成功，返回值为：%d\n", sendback);
     
145.                         }
     
146.                         else{ printf("消息发送失败\n"); }
     
147.                         //system("pause");
     
148.                 }
     
149.         }
     
150.         closesocket(client);                        //关闭套接字连接
     
151.         printf("消息发送线程关闭\n");
     
152.         return 0;
     
153. }

复制代码

漠水

@拈花小仙

～风介～

请这位大牛点评！@无符号整形

mindySun

不错的分享

1147548072

学习学习，谢谢分享

SmallDream

有这个方面的书籍吗？非常感兴趣

C剑客

来到鱼C一天的萌新前来学习！

1653359716

有没有UDP的呀