多线程编写回射客户端程序

用多线程实现回射客户端程序
int pthread_detach(pthread_t thread);

客户端不变：

#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<string.h>
#include<stdlib.h>
#include<stdio.h>
#include<errno.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#define ERR_EXIT(m)
    do
    {
        perror(m);
        exit(EXIT_FAILURE);
    }while(0)
int main(void)
{
    int sock;//客户端创建套接字
    if((sock=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP))<0)
        ERR_EXIT("socket error");
    
    struct sockaddr_in servaddr;//本地协议地址赋给一个套接字
    memset(&servaddr,0,sizeof(servaddr));
    servaddr.sin_family=AF_INET;
    servaddr.sin_port=htons(5188);
    
    servaddr.sin_addr.s_addr=inet_addr("127.0.0.1");//服务器段地址
    //inet_aton("127.0.0.1",&servaddr.sin_addr);
    
    if(connect(sock,(struct sockaddr*)&servaddr,sizeof(servaddr))<0)
        ERR_EXIT("connect");
    char sendbuf[1024]={0};
    char recvbuf[1024]={0};
    while(fgets(sendbuf,sizeof(sendbuf),stdin)!=NULL)//默认有换行符
    {
        write(sock,sendbuf,strlen(sendbuf));
        read(sock,recvbuf,sizeof(recvbuf));
        fputs(recvbuf,stdout);

        memset(sendbuf,0,sizeof(sendbuf));
        memset(recvbuf,0,sizeof(recvbuf));
    }
    close(sock);
    
    return 0;
}

服务器端当有新连接到来的时候，新建一个线程，并且在这个线程的入口函数中来处理连接：

#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<stdlib.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<pthread.h>
#define ERR_EXIT(m)
    do
    {
        perror(m);
        exit(EXIT_FAILURE);
    }while(0)

void echo_srv(int conn)
{
    char recvbuf[1024];
    while(1)
    {
        memset(recvbuf,0,sizeof(recvbuf));
        int ret=read(conn,recvbuf,sizeof(recvbuf));
        if(ret==0)
        {
            printf("client close
");
            break;
        }
        else if(ret==-1)
        {
            ERR_EXIT("read");
        }
        fputs(recvbuf,stdout);
        write(conn,recvbuf,ret);
    }

}
void*  thread_routine(void* arg)
{
    //当前新线程设置为分离状态，防止僵死
    pthread_detach(pthread_self());
    //int conn=(int)arg;
    int conn=*(int*)arg;
    free(arg);
    echo_srv(conn);
    printf("exiting thread...
");
    return NULL;
}
int main(void)
{
    int listenfd;
    if((listenfd=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP))<0)
        ERR_EXIT("socket");
    struct sockaddr_in servaddr;
    memset(&servaddr,0,sizeof(servaddr));
    servaddr.sin_family=AF_INET;
    servaddr.sin_port=htons(5188);
    servaddr.sin_addr.s_addr=htonl(INADDR_ANY);
    
    int on=1;
    if(setsockopt(listenfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on))<0)
        ERR_EXIT("setsockopt");
    
    if(bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr))<0)
        ERR_EXIT("bind");
    if(listen(listenfd,SOMAXCONN)<0)
        ERR_EXIT("listen");

    struct sockaddr_in peeraddr;
    socklen_t peerlen=sizeof(peeraddr);
    int conn;
    while(1)
    {
        if((conn=accept(listenfd,(struct sockaddr*)&peeraddr,&peerlen))<0)
            ERR_EXIT("accept");
        printf("ip=%s port=%d
",inet_ntoa(peeraddr.sin_addr),ntohs(peeraddr.sin_port));
        pthread_t tid;
        int ret;
        //不传递(void*)&conn的原因，有新的连接的话conn发生改变，如过新的线程没有把conn取走的话，conn就改变了
        //较好的方案
        int * p=malloc(sizeof(int));
        *p=conn;
        ret=pthread_create(&tid,NULL,thread_routine,(void*)p);
        //ret=pthread_create(&tid,NULL,thread_routine,(void*)conn);
        
        if(ret!=0)
        {
            fprintf(stderr,"pthread_create%s
",strerror(ret));
            exit(EXIT_FAILURE);
        }
        
    }
    return 0;
}