c语言多线程服务器

2021-02-26 04:32:28 阅读：151 来源： 互联网

标签：多线程语言 recv send targs 服务器 include buf addr

服务器

#include <stdlib.h>
#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <string.h>
#include <unistd.h>
#define PORT 8887
#define QUEUE 10
const char *pattern = "Hello, I am the server. Your msg is received, which is: %s";

typedef struct  // 定义一个结构体，保存线程参数
{
    struct sockaddr_in addr;
    socklen_t addr_len;
    int connectfd;
} thread_args;

void *handle_thread(void *arg)
{
    thread_args *targs = (thread_args *)arg;
    pthread_t tid = pthread_self();
    printf("tid = %u and socket = %d\n", tid, targs->connectfd);
    char send_buf[BUFSIZ] = {0}, recv_buf[BUFSIZ] = {0};// 定义接受和发送缓冲区
    while (1)
    {
        int len = recv(targs->connectfd, recv_buf, BUFSIZ, 0);  // 读取数据
        printf("[Client %d] %s", targs->connectfd, recv_buf);
        
        if (strcmp("q\n", recv_buf) == 0)
            break;
        
        sprintf(send_buf, pattern, recv_buf);  //  将字符串pattern 和 recv_buf 合并
        send(targs->connectfd, send_buf, strlen(send_buf), 0);  // 发送数据

        memset(send_buf, 0, BUFSIZ), memset(recv_buf, 0, BUFSIZ);  // 清空缓存
    }
    close(targs->connectfd);
    free(targs);
    pthread_exit(NULL);
}

int main()
{
    int listenfd = socket(AF_INET, SOCK_STREAM, 0);  // 创建一个socket
    printf("server is listening at socket fd = %d\n", listenfd);
    struct sockaddr_in addr;  // 创建一个结构体
    addr.sin_family = AF_INET;
    addr.sin_port = htons(PORT);
    addr.sin_addr.s_addr = htonl(INADDR_ANY);

    if (bind(listenfd, (struct sockaddr *)&addr, sizeof(addr)) == -1)  // 绑定套接字和套接字结构体
    {
        perror("bind error\n");
        exit(-1);
    }

    if (listen(listenfd, QUEUE) == -1)   // 开启监听功能
    {
        perror("listen error\n");
        exit(-1);
    }

    while (1)  // 开启循环
    {
        thread_args *targs = malloc(sizeof(thread_args));  // 线程参数
        targs->connectfd = accept(listenfd, (struct sockaddr *)&targs->addr, &targs->addr_len);// 获取连接号 
        // int newfd = accept(sockfd, NULL, NULL);
        pthread_t tid;
        pthread_create(&tid, NULL, handle_thread, (void *)targs);  // 创建线程

/*线程是joinable状态，当线程函数自己返回退出时或pthread_exit时都不会释放线程所占用堆栈和线程描述符（总计8K多）。只有当你调用了pthread_join之后这些资源才会被释放。若是unjoinable状态的线程，这些资源在线程函数退出时或pthread_exit时自动会被释放。
*/
        pthread_detach(tid);  // 
    }
    close(listenfd);
}

客户端

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#define PORT 8887
const char *target_ip = "127.0.0.1";

int main()
{
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    printf("client socket = %d\n", sockfd);
    struct sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(PORT);
    addr.sin_addr.s_addr = inet_addr(target_ip);

    if (connect(sockfd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) < 0)
    {
        perror("connect error\n");
        exit(-1);
    }

    char send_buf[BUFSIZ], recv_buf[BUFSIZ];
    while (fgets(send_buf, BUFSIZ, stdin) != NULL) //接受终端输入
    {
        if (strcmp(send_buf, "q\n") == 0)
            break;

        send(sockfd, send_buf, strlen(send_buf), 0);  // 发送数据
        printf("[Client] %s\n", send_buf);

        recv(sockfd, recv_buf, BUFSIZ, 0);           // 接受数据
        printf("[Server] %s\n", recv_buf);

        memset(send_buf, 0, BUFSIZ);// 清空发送
        memset(recv_buf, 0, BUFSIZ);  // 清空接受
    }
    close(sockfd);
    exit(0);
}

标签：多线程,语言,recv,send,targs,服务器,include,buf,addr
来源： https://www.cnblogs.com/countryboy666/p/14450300.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

c语言多线程服务器