[个人原创]C++学习之多进程并发服务器实例学习

jackxiang 2011-8-19 17:14

近来学习了一下C++在Linux下的多进程并发服务器的模型，听专搞C++服务器的兄弟们说这个也不行，需要Epoll，Select模型，还需要FiFo队列的结合，链表，共享内存等同时起多个进程后循环去共享内存里去取数据，去循环的读FIFO才会高效更有效形成一个更高更强更快的多并发的服务器，本质就是异步服务。
我也想学，但苦于基础不好，于是否给我顺手抓了一本Unix网络编程实用技术与实例分析，这一章节，代码错误较多，还好有兄弟帮忙调试，在此感谢，看来还是需要把书写好才能省下不少时间啊，写书的人或排版的也许太匆忙罢，和兄弟沟通后说错误多是为了让初学者多调试，写错了也有理由，我倒。
近来事情不多也就了解了下他们的架构，画画图什么的，其实Mysql长连接这块我觉得应该做进PHP中，现在PHP都FastCGI开自己的端口了，长连接也做进去不是难事哇，期待加到下一个PHP扩展中，直接整成可配置的连接池得了，上图：

原始Edraw Max 源文件：

下载文件

点击这里下载文件

multiproserver.cpp

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

#define  PORT  1234
#define  BACKLOG  10
#define MAXDATASIZE  1000
void process_cli(int connectfd, struct sockaddr_in client);
int main(void)
{
    int   listenfd, connectfd;
    pid_t  pid;
    struct sockaddr_in server,client;
    int sin_size;

/* Create TCP Socket */
    if((listenfd=socket(AF_INET, SOCK_STREAM, 0))==-1)
    {
        perror("Create socket failed");
        exit(-1);
    }
    int opt = SO_REUSEADDR;
    setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

bzero(&server, sizeof(server));
    server.sin_family = AF_INET;
    server.sin_port = htons(PORT);
    server.sin_addr.s_addr = htonl(INADDR_ANY);

if (bind(listenfd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1)
    {
        perror("Bind error");
        exit(-1);
    }

if (listen(listenfd, BACKLOG) == -1) 
    {
        perror("listen error");
        exit(-1);
    }
    sin_size = sizeof(struct sockaddr_in);

while(1) 
    {

if((connectfd = accept(listenfd, (struct sockaddr *)&client, (socklen_t *)&sin_size)) == -1) 
        {
            perror("accept error");
            exit(-1);
        }
        if ((pid=fork())>0) 
        {
            /* parent process */
            close(connectfd);
            continue;
        }
        else if (pid==0) 
        {
            /*child process*/
            close(listenfd);
            process_cli(connectfd, client);
            exit(0);
        }
        else 
        {
            printf("fork error\n");
            exit(0);
        }
    }/*while()*/
    close(listenfd);   /* close listenfd */
}

void process_cli(int connectfd, struct sockaddr_in client) 
{
    int   num;
    char     recvbuf[MAXDATASIZE], sendbuf[MAXDATASIZE], cli_name[MAXDATASIZE];
    printf("You got a connection from %s.\n", inet_ntoa(client.sin_addr));
    num = recv(connectfd, cli_name, MAXDATASIZE, 0);
    if (num == 0) 
    {
        close(connectfd);
        printf("cllient disconnected.\n");
        return;
    }
    cli_name[num - 2] = '\0';
    printf("Client name is %s.\n",cli_name);
    while (num = recv(connectfd, recvbuf, MAXDATASIZE,0)) 
    {
        recvbuf[num] = '\0';
        printf("Received client (%s) message: %s", cli_name, recvbuf);
        for(int i=0; i < num ; i++)
        {
            sendbuf[i] = recvbuf[num - i - 1];
        }
        sendbuf[num] = '\0';
        send(connectfd, sendbuf, strlen(sendbuf), 0);
    }
    close(connectfd);
}

测试情况，就是把输入字符倒置后发送给客户端：

PPT下载，来自百度文库：

下载文件

点击这里下载文件

按这个PPT编写的代码下载：

下载文件

点击这里下载文件

最后编辑： jackxiang 编辑于2011-8-28 22:17

[个人原创]VC6.0两大插件Visual Assist X Add-i