Linux下的TCP聊天之旅（linux聊天tcp）

在非常火热的Linux学习社区，Linux用户们讨论热点技术的时候，多谈的也是TCP/IP的网络编程，一般开发者们常用的就是TCP网络编程技术来构建自己的应用。接下来我们就来具体看看，在Linux下怎么实现一对多的TCP聊天？

首先服务器端的实现：

#include   
#include   
#include   
#include   
#include   
#include   
using namespace std;  
#define SERVER_PORT 9090
#define MAX_CLIENTS 65535

int main() 
{
    const int server_port = SERVER_PORT;  

    int listenfd = socket(AF_INET, SOCK_STREAM, 0);  

    //将socket和socket地址结构联系起来  
    struct sockaddr_in servaddr;  
    bzero(&servaddr, sizeof(servaddr));  
    servaddr.sin_family = AF_INET;  
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);  
    servaddr.sin_port = htons(server_port);
    if ( bind(listenfd, (struct sockaddr*) &servaddr, sizeof(servaddr)) == -1 ) 
    {  
      cout 
      return -1;  
    }  

    //开始监听
    if (listen(listenfd, MAX_CLIENTS) == -1) 
    {  
      cout 
      return -1;  
    }
    
    return 0; 
}

客户端代码实现：

#include 
#include 
#include 
#include 
#include 
#include 
using namespace std; 
#define MAX_RECV_LEN 1024
int main(int argc, char *argv[])
{
    if (argc != 3 ) 
    {
        cout 
        return -1;
    } 

    string server_ip = argv[1];
    int server_port = atoi(argv[2]); 
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if ( sockfd 
    {
        cout 
        return -1;
    }
    struct sockaddr_in servaddr;
    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_port = htons(server_port);
    inet_pton(AF_INET, server_ip.c_str(), &servaddr.sin_addr);

    if (connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) 
    {
        cout 
        return -1;
    }

    char recvbuf[MAX_RECV_LEN] = {0};

    while (1) 
    {
        int numbytes = read(sockfd, recvbuf, MAX_RECV_LEN); 
        if ( numbytes == -1 ) 
        {
            cout 
            continue;
        }
        if ( numbytes == 0 ) 
        {
            cout 
            break;
        }
        string recv_str = string(recvbuf, numbytes);
        cout 
    }
    close(sockfd);
    return 0;
}

实现TCP聊天后，服务器端可以采用epoll+线程池模型来处理客户端的消息，而客户端可以实现一对多的TCP聊天，耐心和在线的客户保持和服务器的长连接，当有客户发送消息的时候，服务器可以将消息群发给已经连接到服务器上的其他客户端，从而实现一对多的聊天模式。

实现聊天服务器的步骤总结一下就是：

1、服务器【socket()】、【bind()】、【listen()】

2、客户端【socket()】、【connect()】

3、服务器【accept()】

4、服务器【epoll()】

5、线程池【多线程处理消息】

6、服务器【群发消息】

完成这些步骤后，就可以实现一对多的TCP聊天服务了。