cmrom官方中文网:多进程服务端实现

来源：百度文库编辑：中财网时间：2024/04/26 00:39:02

多进程服务端实现-共享socket

　来源：小明思考 - C++博客　 2011-09-10

分享到：新浪微博腾讯微博豆瓣网人人网开心网 QQ空间搜狐微博更多 0-

众所周知，使用多进程的服务端模型有利于程序的健壮性。传统的做法是主进程负责收发数据，然后传给子进程来处理。这种做法的缺陷是需要大量的父子进程IPC，对效率来说是一种损失。

这里，我提出另外一种比较独特的做法，就是多个进程share socket，每次进程都可以accept，然后来自己处理。

几个关键点:
1) CreateProcess使用InheritHandle标记来share socket handle
2) 通过command line直接向子进程来传递父socket的值
3）使用Global Mutext来实现子进程互斥的accept

可以改进的地方
1) 使用动态进程池来程序具有更大的伸缩性
2）监控子进程的状态，处理僵死进程

下面是一个echo server 的例子来展示这项技术, FYI

父进程(SSParent.cpp)

#include
#include
#include
#include

#define MUTEX_NAME "sschild"

int main(int argc, char* argv[])
{
    { //init
        WORD wVersionRequested;
        WSADATA wsaData;
        wVersionRequested = MAKEWORD( 2, 2 );
        WSAStartup( wVersionRequested, &wsaData );
    }

    SOCKET s = socket(AF_INET,SOCK_STREAM,0);
    if(s==INVALID_SOCKET)
    {
        printf("create socket failed!\n");
        return -1;
    }

    { //bind&listen
        sockaddr_in sa;
        sa.sin_family = AF_INET;
        sa.sin_port = htons( 1500 );
        sa.sin_addr.s_addr = 0 ;
        int rc = bind(s,(sockaddr *)&sa,sizeof(sa));
        if(rc == SOCKET_ERROR)
        {
            printf("bind failed:%d\n",::WSAGetLastError());
            return -1;
        }
        listen(s,SOMAXCONN);
    }

    HANDLE hSocketMutex;
    { //create mutex
        hSocketMutex = ::CreateMutex(NULL,FALSE,MUTEX_NAME);
        if(hSocketMutex==NULL)
        {
            printf("fail CreateMutex:%d\n",::GetLastError());
            return -1;
        }
    }

    const int CHILD_NUMBER = 5;
    HANDLE hProcess[CHILD_NUMBER];
    { //create child process
       STARTUPINFO si = { sizeof(si) };
       PROCESS_INFORMATION piProcess[CHILD_NUMBER];
       char pCmdLine[256];
       sprintf(pCmdLine,"SSChild %d",s);
       for(int i=0;i       {
           if(!CreateProcess(NULL,pCmdLine,NULL,NULL,TRUE,0, NULL, NULL, &si, &piProcess[i]))
           {
               printf("fail CreateProcess:%d\n",::GetLastError());
               return -1;
           }
           hProcess[i] = piProcess[i].hProcess;
           CloseHandle(piProcess[i].hThread);
       }
    }

    ::WaitForMultipleObjects(CHILD_NUMBER,hProcess,TRUE,INFINITE);

    {//close all child handle
       for(int i=0;i       {
           CloseHandle(hProcess[i]);
       }
    }

    //clean
    CloseHandle(hSocketMutex);
    closesocket(s);
    WSACleanup( );
    return 0;
}

子进程(SSChild.cpp)

#include
#include
#include
#include

#define MUTEX_NAME "sschild"

int main(int argc, char* argv[])
{
    printf("sschild startup!\n");

    { //init
        WORD wVersionRequested;
        WSADATA wsaData;
        wVersionRequested = MAKEWORD( 2, 2 );
        WSAStartup( wVersionRequested, &wsaData );
    }

    DWORD pid = ::GetCurrentProcessId();

    HANDLE hSocketMutex;
    { //open mutex
        hSocketMutex = ::OpenMutex(MUTEX_ALL_ACCESS,FALSE,MUTEX_NAME);
        if(hSocketMutex==NULL)
        {
            printf("fail OpenMutex:%d\n",::GetLastError());
            return -1;
        }
    }

    SOCKET s;
    {  //get socket handle from cmdline
        if(argc<=1)
        {
            printf("usage: sschild socket_handle\n");
            return -1;
        }
        s = (SOCKET) atoi(argv[1]);
    }

    while(1)
    {
        WaitForSingleObject(hSocketMutex,INFINITE);
        sockaddr_in sa;
        int add_len = sizeof(sa);
        SOCKET c = accept(s,(sockaddr*)&sa,&add_len);
        ReleaseMutex(hSocketMutex);
        if(c!=INVALID_SOCKET)
        {
            printf("[%d],client:%s port:%d connected!\n",pid,inet_ntoa(sa.sin_addr),sa.sin_port);
            while(1)
            {
                char buffer[256]={0};
                int rc= recv(c,buffer,255,0);
                if(rc>0)
                {
                    printf("[%d]recv msg:%s\n",pid,buffer);
                    send(c,buffer,strlen(buffer)+1,0);
                }
                else if(rc == SOCKET_ERROR)
                {
                    printf("[%d]recv msg failed:%d\n",pid,::WSAGetLastError());
                    closesocket(c);
                    break;
                }
                else
                {
                    printf("[%d]connection close\n",pid);
                    closesocket(c);
                    break;
                }
            }
        }
        else
        {
            printf("[%d]fail accept:%d\n",pid,::WSAGetLastError());
        }
    }

    CloseHandle(hSocketMutex);
    return 0;
}

服务端??? 服务端?? 怎样实现服务器访问客户端,而客户端无法访问服务端? unix进程管理的设计和实现怎么才能实现进程不会被中止讯雷实现P2P的进程是什么? 如何实现进程管理模拟算法宽带用户为什么在没有安装宽带进程的时候可以上宽带服务端我要在win2000专业版里面安装远程桌面服务端。。。能不能实现高手请进!!!!! 明星三缺一如何实现局域网联机??可否有专用服务端下载??? 怎然实现一台计算机既能是客户端，也能是服务端。谢谢～！请问用什么软件如何在win下面实现进程管理子系统求: 用c语言实现进程控制的源码请问VB如何通过程序实现调整进程的优先级？用VC 怎么实现自动监测系统中某个进程 c# 对某些进程的限制如何实现结束进程是如何实现的，原理是什么？如何实现等程序进程的后台隐藏，以及如何查看隐藏在后台的进程~？谁有好的服务端~~要有100多衣服的~ 服务端是什么传奇服务端服务端是什么？奇迹服务端传奇服务端