Linux编写一个TCP通信客户端,包含服务器和客户端代码,服务器端实现多线程编程。
时间: 2024-03-19 19:46:21 浏览: 75
LINUX下的一个多线程的服务器和客户端的网络传输程序
5星 · 资源好评率100%
以下是一个简单的TCP通信客户端和多线程服务器端代码,可以供参考:
TCP通信客户端代码:
```c
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
int main(int argc, char *argv[]) {
// 创建socket
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
perror("socket");
exit(1);
}
// 设置服务器地址
struct sockaddr_in serv_addr;
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(8888);
serv_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
// 连接服务器
int ret = connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr));
if (ret < 0) {
perror("connect");
exit(1);
}
// 发送数据
char buf[1024] = {0};
strcpy(buf, "Hello, server!");
ret = write(sockfd, buf, strlen(buf));
if (ret < 0) {
perror("write");
exit(1);
}
// 接收数据
memset(buf, 0, sizeof(buf));
ret = read(sockfd, buf, sizeof(buf));
if (ret < 0) {
perror("read");
exit(1);
}
printf("Received message from server: %s\n", buf);
// 关闭socket
close(sockfd);
return 0;
}
```
多线程TCP通信服务器端代码:
```c
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
void *handle_client(void *arg);
int main(int argc, char *argv[]) {
// 创建socket
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
perror("socket");
exit(1);
}
// 设置服务器地址
struct sockaddr_in serv_addr;
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(8888);
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
// 绑定socket和地址
int ret = bind(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr));
if (ret < 0) {
perror("bind");
exit(1);
}
// 监听socket
ret = listen(sockfd, 5);
if (ret < 0) {
perror("listen");
exit(1);
}
// 处理客户端连接
while (1) {
struct sockaddr_in client_addr;
socklen_t len = sizeof(client_addr);
int connfd = accept(sockfd, (struct sockaddr *)&client_addr, &len);
if (connfd < 0) {
perror("accept");
continue;
}
// 创建线程处理客户端请求
pthread_t tid;
ret = pthread_create(&tid, NULL, handle_client, (void *)&connfd);
if (ret != 0) {
perror("pthread_create");
continue;
}
}
// 关闭socket
close(sockfd);
return 0;
}
void *handle_client(void *arg) {
int connfd = *(int *)arg;
// 接收数据
char buf[1024] = {0};
int ret = read(connfd, buf, sizeof(buf));
if (ret < 0) {
perror("read");
close(connfd);
pthread_exit(NULL);
}
printf("Received message from client: %s\n", buf);
// 发送数据
strcpy(buf, "Hello, client!");
ret = write(connfd, buf, strlen(buf));
if (ret < 0) {
perror("write");
close(connfd);
pthread_exit(NULL);
}
// 关闭连接
close(connfd);
pthread_exit(NULL);
}
```
在服务器端代码中,使用pthread_create函数创建一个新的线程,该线程将调用handle_client函数处理客户端请求。在handle_client函数中,使用accept函数接收客户端连接,然后使用read和write函数与客户端进行通信。通信完成后,关闭连接并退出线程。
阅读全文