Linux网络编程--多线程实现echo服务器与客户端“一对多”功能，是网络编程的“Hello World!”

　　在linux平台下，用多线程实现echo服务器与客户端“一对多”（即是一台服务器可以响应多个客户端的请求）。本人写了个demo，和大家一起分享，有不足的地方，请多多指教，我是壮壮熊。

 

　　编译时，在后面加上-lpthread。例如：g++ service2.cpp -o service2 -lpthread。否则会提示线程方面的错误。

　　echo服务器端代码：

 

#include<stdio.h>
#include<stdlib.h>
#include<sys/socket.h>
#include<string.h>
#include<errno.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<unistd.h>
#include<iostream>
#include<pthread.h>
using namespace std;

#define SERVERIP "192.168.1.117"
#define SERVERPORT 12345
#define MAXBUFFER 256

pthread_t ntid;//线程
int connfd;//客户端连接的ID
struct sockaddr_in clientaddr;


void *printContext(void *arg)
{

    char ip[40]={0};//用来存放客户端连接的IP地址
    char readBuf[MAXBUFFER]={0};
    int ret;
    pthread_detach(ntid);//线程退出时，可以清理内存
    int pconnfd=connfd;//客户端连接的ID(main函数中的accept的返回值)
                        //线程自己要保存连接符 ID，因为进程在第二个客户端
                        //连接后，会覆盖connfd
    printf("%s
",inet_ntop(AF_INET,&clientaddr.sin_addr,ip,sizeof(ip)));
    cout<<"connectd to the servce"<<endl;

    while(ret=read(pconnfd,readBuf,MAXBUFFER))//读客户端发送的数据
    {
        write(pconnfd,readBuf,MAXBUFFER);//写回客户端
        printf("%s
",readBuf);//打印传输的内容
        bzero(readBuf,MAXBUFFER);
        
    }
    if(ret==0)
    {
        printf("the connection of client is close!
");
        
    }else
    {
        printf("read error:%s
",strerror(errno));
    }
    pthread_exit(0);
}

int main(int argc,char** argv)
{
    socklen_t len;//socket长度类型
    int serverFd,ret;
    struct sockaddr_in serveraddr;


    serverFd=socket(AF_INET,SOCK_STREAM,0);//创建socket
    if(serverFd<0)
    {
        printf("socket error:%s
",strerror(errno));
        exit(-1);
    }
    
    bzero(&serveraddr,sizeof(serveraddr));//serveraddr清零
    serveraddr.sin_family=AF_INET;
    serveraddr.sin_port=htons(SERVERPORT);
    inet_pton(AF_INET,SERVERIP,&serveraddr.sin_addr);//将C语言字节序转化成网络字节序

    ret=bind(serverFd,(struct sockaddr *)&serveraddr,sizeof(serveraddr));
    if(ret!=0)
    {
        close(serverFd);
        printf("bind error:%
",strerror(errno));
        exit(-1);        
    }
    
    ret=listen(serverFd,5);//监听
    if(ret!=0)
    {
        close(serverFd);
        printf("listen error:%s
",strerror(errno));
        exit(-1);
    }
    //clientaddr清零
    len=sizeof(clientaddr);
    bzero(&clientaddr,sizeof(clientaddr));
    while(1)
    {
        //接收客户端的连接,然后启动线程去处理客户端发送的
        //请求。线程只要保存connfd 即可。进程在第二个客户  端
        //连接进来的时候，会覆盖第一个客户端的connfd
        connfd=accept(serverFd,(struct sockaddr *) &clientaddr,&len);
        if(connfd<0)
        {
            printf("accept error:%s
",strerror(errno));
            continue;
        }
        
        int err;
        err=pthread_create(&ntid,NULL,printContext,NULL);
        if(err!=0)
        {
            cout<<"can't create pthread"<<endl;
        }
        //close(connfd);
    }
    close(serverFd);
    return 0;
}

 

　　客户端代码：

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

#define SERVERIP "192.168.1.117"
#define SERVERPORT 12345
#define MAXBUFFER 256

int main(int argc,char** argv)
{
    int clientFd,ret;
    struct sockaddr_in serveraddr;
    char buf[MAXBUFFER];
    clientFd=socket(AF_INET,SOCK_STREAM,0);//创建socket
    if(clientFd<0)
    {
        printf("socket error:%s 
",strerror(errno));
        exit(-1);
    }

    bzero(&serveraddr,sizeof(serveraddr));
    serveraddr.sin_family=AF_INET;
    serveraddr.sin_port=htons(SERVERPORT);
    inet_pton(AF_INET,SERVERIP,&serveraddr.sin_addr);

    //连接到服务器
    ret=connect(clientFd,(struct sockaddr *)&serveraddr,sizeof(serveraddr));

    if(ret!=0)
    {
        close(clientFd);
        printf("connect error:%s 
",strerror(errno));
        exit(-1);
    }
    while(1)
    {
        bzero(buf,sizeof(buf));
        scanf("%s",buf);
        write(clientFd,buf,sizeof(buf));//写数据
        bzero(buf,sizeof(buf));
        read(clientFd,buf,sizeof(buf));//读数据
        printf("echo:%s
",buf);
    }
    close(clientFd);
    return (EXIT_SUCCESS);
    
}

　　再次提醒，编译时，在后面加上-lpthread。例如：g++ service2.cpp -o service2 -lpthread。否则会提示线程方面的错误。

　　如有转载，请注明出处，谢谢！