同时将客户端连接到多个服务器,并通过连接在所有服务器中执行代码


connecting client to several servers in the same time, and execute a code in all the servers by the connection

我想知道如何:

  • 同时连接多个服务器

  • 将一种编程语言的脚本代码执行到另一种编程语言的服务器,示例:

    我们在3个服务器之间创建连接,其中两个使用相同的编程语言(c++),另一个使用不同的编程语言(PHP),然后,当一个c++服务器做某事时,它也通知另一个c++服务器和PHP服务器。

int startOthers (char* host, unsigned int port, char* msg) {
    int sockfd;
    struct sockaddr_in serv_addr;
    sockfd = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (sockfd > 0) {
        memset ((void *) &serv_addr, 0, sizeof (serv_addr));
        serv_addr.sin_family = AF_INET;
        serv_addr.sin_addr.s_addr = inet_addr (host);
        serv_addr.sin_port = htons (port);
        if (connect(sockfd, (struct sockaddr *) &serv_addr, sizeof (serv_addr)) == 0) {
            write(sockfd, msg, strlen(msg));
            close (sockfd);
            return 0;
        }
    }
    return -1;
}
int startServer(unsigned int port) {
    int n, sockfd, cl_sockfd;
    socklen_t clilen;
    char buffer[256 + 1];
    struct sockaddr_in server_addr, client_addr;
    sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (sockfd > 0) {
        memset((void *) &server_addr, 0, sizeof(server_addr));
        server_addr.sin_family = AF_INET;
        server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
        server_addr.sin_port = htons(port);
        if (bind(sockfd, (sockaddr *) & server_addr, sizeof(server_addr)) == 0) {
            listen(sockfd, 5);
            clilen = sizeof(client_addr);
            cl_sockfd = accept(sockfd, (struct sockaddr *) &client_addr, &clilen);
            if (cl_sockfd > 0) {
                while ( (n = read(cl_sockfd, buffer, 256)) <= 0); /* a client communicated with me */
                /* Do something */
                /* Inform others */
                startOthers(/* other C++ host */, /* port */, buffer);
                startOthers(/* php host */, /* port */, buffer);
                close(cl_sockfd);
                close(sockfd);
                return 0;
            }
        }
        close(sockfd);
    }
    return -1;
}

startOthers函数可以与pthreads一起使用,以同时启动多个连接。它也可以连接到使用php创建的套接字。

不管实现细节如何,重要的是所有服务器都遵循一个通信协议。