TCP并发服务器/客户端简单模型

服务器TCP模型

///< #include "..."

///< #include "..."

///< #include "..."

#define  SERVER_PORT

#define  MAX_LISTEN

int TCPServerModel (unsigned short publicPort)

{

    int sockListen;

    int sockAccept;

    sockaddr_in serverAddr;

    sockaddr_in clientAddr;

    pid_t childPid;

    int addrLen = sizeof(sockaddr_in);

    

    // XXX 初始化监听套接口

    sockListen  = socket (AF_INET, SOCK_STREAM, 0);

    // XXX 初始化sockaddr_in

    memset (&serverAddr, 0, addrLen);

    serverAddr.sin_family = AF_INET;

    serverAddr.sin_port = htons(publicPort);

    serverAddr.sin_addr.s_addr = htons(INADDR_ANY);

    // XXX 绑定 - bind()

    bind   (sockListen, (sockaddr *)&serverAddr, addrLen);

    // XXX 监听 - listen()

    listen (sockListen, MAX_LISTEN);

    while(true)

    {

        // XXX 接收连接 - accept()

        sockAccept = accept(sockListen, (sockaddr *)&clientAddr, &addrLen);

        if (!(childPid = fork()))

        {

            close(sockListen);

            // XXX 处理客户端数据

            exit(0);

        }

        close(sockAccept);

    }

}

客户端TCP模型

///< #include "..."

///< #include "..."

///< #include "..."

#define  SERVER_IP

#define  SERVER_PORT

#define  MAX_LISTEN

int TCPClientModel (unsigned long serverIP)

{

    int sockFd;

    sockaddr_in serverAddr;

    int addrLen = sizeof(serverAddr);

    // XXX 初始化套接口

    sockFd = socket (AF_INET, SOCK_STREAM, 0);

    // XXX 初始化sockaddr_in

    memset (&serverAddr, 0, addrLen);

    serverAddr.sin_family = AF_INET;

    serverAddr.sin_port = htons(SERVER_PORT);

    serverAddr.sin_addr.s_addr = htonl(serverIP);

    // XXX 连接 - connect()

    connect (sockFd, (sockaddr *)&serverAddr, addrLen);

    // XXX 处理服务器数据 - 可根据实际情况具体实现

    exit (0);

}