php - 客户端同时连接多个服务器，通过连接在所有服务器执行一段代码

Question

<分区>

Answer 1

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 创建的套接字。

不管实现细节如何，所有服务器都遵循通信协议(protocol)很重要。