实现基于TCP协议的服务器与客户机间简朴通讯

服务器端步调

2. #include <myhead.h>
3. #define SER_PORT 6666         //服务器端口号
4. #define SER_IP "192.168.2.53" //服务器ip地址
6. int main(int argc, char const *argv[])
7. {
8.     /*创建套接字
9.      int socket(int domain, int type, int protocol);*/
10.     int sfd = socket(AF_INET, SOCK_STREAM, 0);
11.     //ipv4,TCP协议,默认0
12.     if (sfd == -1)
13.     {
14.         perror("socket error");
15.         return -1;
16.     }
17.     printf("套接字创建成功,sfd = %d\n", sfd);
19.     //端口快速重用
20.     int refuse = 1;
21.     if (setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &refuse, sizeof(refuse)) == -1)
22.     {
23.         perror("setsockopt error");
24.         return -1;
25.     }
26.     printf("端口快速重用成功,sfd = %d\n", sfd);
28.     //为套接字绑定IP地址和端口号
29.     struct sockaddr_in sin;                  //地址信息结构体
30.     sin.sin_family = AF_INET;                //通信域
31.     sin.sin_port = htons(SER_PORT);          //端口号
32.     sin.sin_addr.s_addr = inet_addr(SER_IP); //ip地址
34.     //绑定工作
35.     if (bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) == -1)
36.     //套接字名,地址信息结构体,结构体大小
37.     {
38.         perror("bind error");
39.         return -1;
40.     }
41.     printf("bind success\n");
43.     //将套接字设置为被动监听状态
44.     if (listen(sfd, 128) == -1)
45.     //套接字描述符,容纳连接的队列的最大长度，一般填128
46.     {
47.         perror("listen error");
48.         return -1;
49.     }
50.     printf("listen success\n");
52.     struct sockaddr_in cin;          //用于接受地址信息
53.     socklen_t addrlen = sizeof(cin); //用于接收长度
54.     //阻塞等待客户端连接请求
55.     int newfd = accept(sfd, (struct sockaddr *)&cin, &addrlen);
56.     //套接字,接收对端地址信息结构体的指针,接收对端地址信息的长度
57.     if (newfd == -1)
58.     {
59.         perror("accept error");
60.         return -1;
61.     }
62.     printf("[%s,%d]已成功连接一个客户端\n",
63.            inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));
65.     //数据收发
66.     char buf[128];
67.     while (1)
68.     {
69.         //清空容器
70.         bzero(buf, sizeof(buf));
71.         //接收套接字数据
72.         int res = recv(newfd, buf, sizeof(buf), 0);
73.         /*
74.        参数1:   用于通信的套接字文件描述符
75.        参数2：接收数据后的容器地址
76.        参数3：接收的数据的大小
77.        参数4：是否阻塞接收*/
78.         if (res == -1)
79.         {
80.             perror("recv error");
81.             return -1;
82.         }
83.         else if (res == 0)
84.         {
85.             printf("客户端已经下线\n");
86.             close(newfd); //关闭客户端套接字
87.             break;
88.         }
89.         //正常收到发来的信息
90.         printf("[%s:%d]:%s\n",
91.                inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), buf);
92.         //操作消息
93.         strcat(buf, "*v*");
94.         //将消息回复给客户端
95.         if (send(newfd, buf, strlen(buf), 0) == -1)
96.         /* 
97.         参数1：通信的套接字文件描述符
98.        参数2：要发送数据的起始地址
99.        参数3：要发送数据的大小
100.        参数4：是否阻塞接收*/
101.         {
102.             perror("send error");
103.             return -1;
104.         }
105.         printf("发送成功\n");
106.     }
107.     //关闭监听
108.     close(sfd);
110.     return 0;
111. }

复制代码

客户机端步调

2. #include <myhead.h>
4. #define SER_PORT 6666          //与服务器保持一致
5. #define SER_IP "192.168.0.130" //服务器ip地址
6. #define CLI_PORT 8888          //客户端端口号
7. #define CLI_IP "192.168.0.130" //客户端ip地址
9. int main(int argc, const char *argv[])
10. {
11.     //1、创建用于通信的套接字文件描述符
12.     int cfd = socket(AF_INET, SOCK_STREAM, 0);
13.     if (cfd == -1)
14.     {
15.         perror("socket error");
16.         return -1;
17.     }
18.     printf("cfd = %d\n", cfd);
20.     //2、绑定IP地址和端口号
21.     //2.1 填充地址信息结构体
22.     struct sockaddr_in cin;
23.     cin.sin_family = AF_INET;                //通信域
24.     cin.sin_port = htons(CLI_PORT);          //端口号
25.     cin.sin_addr.s_addr = inet_addr(CLI_IP); //ip地址
27.     //2.2 绑定工作
28.     if (bind(cfd, (struct sockaddr *)&cin, sizeof(cin)) == -1)
29.     {
30.         perror("bind error");
31.         return -1;
32.     }
33.     printf("bind success\n");
35.     //3、连接到服务器
36.     //3.1 填充服务器地址信息结构体
37.     struct sockaddr_in sin;
38.     sin.sin_family = AF_INET;                //通信域
39.     sin.sin_port = htons(SER_PORT);          //服务器端口号
40.     sin.sin_addr.s_addr = inet_addr(SER_IP); //服务器ip地址
42.     //3.2 连接服务器
43.     if (connect(cfd, (struct sockaddr *)&sin, sizeof(sin)) == -1)
44.     {
45.         perror("connect error");
46.         return -1;
47.     }
48.     printf("连接服务器成功\n");
50.     //4、数据收发
51.     char buf[128] = "";
52.     while (1)
53.     {
54.         printf("请输入>>>");
55.         fgets(buf, sizeof(buf), stdin); //从终端获取一个字符串
56.         buf[strlen(buf) - 1] = 0;
58.         //将数据发送给服务器
59.         send(cfd, buf, strlen(buf), 0);
60.         printf("发送成功\n");
62.         //接受服务器发来的数据
63.         //清空容器
64.         bzero(buf, sizeof(buf));
65.         recv(cfd, buf, sizeof(buf), 0);
66.         printf("收到服务器消息为：%s\n", buf);
67.     }
69.     //5、关闭套接字
70.     close(cfd);
72.     return 0;
73. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！qidao123.com:ToB企服之家，中国第一个企服评测及软件市场,开放入驻,技术点评得现金