#include <sys/types.h>
#include <sys/socket.h>

int socket(int domain, int type, int protocol);

#include <stdio.h>      // 標(biāo)準(zhǔn)輸入輸出
#include <stdlib.h>     // 標(biāo)準(zhǔn)庫(kù)函數(shù)，如 exit
#include <sys/socket.h> // 套接字核心函數(shù)和數(shù)據(jù)結(jié)構(gòu)
#include <errno.h>      // 錯(cuò)誤碼 errno
#include <unistd.h>     // close 函數(shù)

int main() {
    int sockfd;

    // 創(chuàng)建一個(gè)用于 IPv4 TCP 通信的套接字
    // AF_INET: 指定使用 IPv4 協(xié)議族
    // SOCK_STREAM: 指定使用面向連接的字節(jié)流服務(wù) (TCP)
    // 0: 讓內(nèi)核自動(dòng)選擇合適的協(xié)議 (對(duì)于 AF_INET 和 SOCK_STREAM，通常是 IPPROTO_TCP)
    sockfd = socket(AF_INET, SOCK_STREAM, 0);

    // 檢查 socket() 調(diào)用是否成功
    if (sockfd == -1) {
        perror("socket 創(chuàng)建失敗"); // perror 會(huì)根據(jù)當(dāng)前的 errno 值打印錯(cuò)誤信息
        exit(EXIT_FAILURE);       // 異常退出程序
    }

    printf("套接字創(chuàng)建成功! 文件描述符: %d\n", sockfd);

    // 在實(shí)際應(yīng)用中，套接字使用完畢后應(yīng)顯式關(guān)閉
    // close(sockfd);

    return 0;
}

gcc create_socket_example.c -o create_socket_example
./create_socket_example
套接字創(chuàng)建成功! 文件描述符: 4

#include <netinet/in.h>

struct sockaddr_in {
    sa_family_t    sin_family; /* 地址族: 固定為 AF_INET */
    in_port_t      sin_port;   /* 端口號(hào) (網(wǎng)絡(luò)字節(jié)序) */
    struct in_addr sin_addr;   /* IPv4 地址 (網(wǎng)絡(luò)字節(jié)序) */
    // char           sin_zero[8]; /* 填充字節(jié)，通常不直接使用，應(yīng)清零 */
};

/* IPv4 地址結(jié)構(gòu) */
struct in_addr {
    uint32_t       s_addr;     /* 32位IPv4地址 (網(wǎng)絡(luò)字節(jié)序) */
};

#include <sys/socket.h>

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

#include <stdio.h>
#include <stdlib.h>
#include <string.h>       // 用于 memset
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>    // 用于 htons, htonl
#include <unistd.h>       // 用于 close

#define PORT 8080

int main() {
    int server_fd;
    struct sockaddr_in address;
    int opt = 1; // 用于 setsockopt

    // 創(chuàng)建套接字
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket 創(chuàng)建失敗");
        exit(EXIT_FAILURE);
    }

    // 可選: 設(shè)置套接字選項(xiàng)，允許地址重用，便于服務(wù)器快速重啟
    // SO_REUSEADDR 允許重用本地地址 (IP+端口)，尤其是在 TIME_WAIT 狀態(tài)下的端口
    // SO_REUSEPORT (需要內(nèi)核支持) 允許多個(gè)進(jìn)程綁定到同一 IP 和端口
    if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
        perror("setsockopt 失敗");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    // 準(zhǔn)備 sockaddr_in 結(jié)構(gòu)體
    memset(&address, 0, sizeof(address)); // 推薦清零結(jié)構(gòu)體
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = htonl(INADDR_ANY); // 監(jiān)聽(tīng)所有網(wǎng)絡(luò)接口
    address.sin_port = htons(PORT);              // 監(jiān)聽(tīng)指定端口 (轉(zhuǎn)換為網(wǎng)絡(luò)字節(jié)序)

    // 將套接字綁定到指定的地址和端口
    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind 失敗");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    printf("套接字成功綁定到端口 %d\n", PORT);

    // ... 后續(xù)步驟: listen() 和 accept() ...

    close(server_fd); // 完成后關(guān)閉監(jiān)聽(tīng)套接字

    return 0;
}

#include <sys/socket.h>

int listen(int sockfd, int backlog);

// ... bind() 成功后 ...

    // 開(kāi)始監(jiān)聽(tīng)傳入連接
    // backlog 設(shè)置為 10，意味著最多允許 10 個(gè)已完成三次握手的連接在隊(duì)列中等待 accept()
    if (listen(server_fd, 10) < 0) {
        perror("listen 失敗");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    printf("服務(wù)器正在端口 %d 上監(jiān)聽(tīng)...\n", PORT);

    // ... 下一步: accept() ...

#include <sys/socket.h>

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

// ... listen() 成功后 ...

    int new_socket;
    struct sockaddr_in client_address;
    socklen_t addrlen = sizeof(client_address); // 注意類(lèi)型是 socklen_t
    char client_ip[INET_ADDRSTRLEN]; // 用于存儲(chǔ)客戶(hù)端 IP 字符串

    printf("等待連接...\n");

    // 接受一個(gè)傳入連接
    // 默認(rèn)情況下，accept() 會(huì)阻塞，直到有客戶(hù)端連接進(jìn)來(lái)
    if ((new_socket = accept(server_fd, (struct sockaddr *)&client_address, &addrlen)) < 0) {
        perror("accept 失敗");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    // 將客戶(hù)端的 IP 地址從網(wǎng)絡(luò)字節(jié)序轉(zhuǎn)換為點(diǎn)分十進(jìn)制字符串以便打印
    inet_ntop(AF_INET, &client_address.sin_addr, client_ip, INET_ADDRSTRLEN);
    printf("接受來(lái)自 %s:%d 的連接\n", client_ip, ntohs(client_address.sin_port));
    printf("用于通信的新套接字描述符: %d\n", new_socket);

    // 現(xiàn)在可以使用 new_socket 與該客戶(hù)端進(jìn)行數(shù)據(jù)交換
    // 例如: send(new_socket, "歡迎!\n", 7, 0);
    // 例如: recv(new_socket, buffer, 1024, 0);

    // 完成與該客戶(hù)端的通信后，關(guān)閉連接套接字
    close(new_socket);

    // 服務(wù)器最終關(guān)閉時(shí)，關(guān)閉監(jiān)聽(tīng)套接字
    close(server_fd);

#include <sys/select.h>
#include <sys/time.h> // 對(duì)于 struct timeval

int select(int nfds, fd_set *readfds, fd_set *writefds,
           fd_set *exceptfds, struct timeval *timeout);

#include <sys/socket.h>

int shutdown(int sockfd, int how);

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

#define PORT 8080               // 服務(wù)器監(jiān)聽(tīng)端口
#define MAX_CLIENTS 30          // 最大并發(fā)客戶(hù)端數(shù)量
#define MAX_TOPICS 10           // 最大主題數(shù)量
#define MAX_SUBS_PER_TOPIC 10   // 每個(gè)主題最大訂閱者數(shù)量
#define BUFFER_SIZE 1024        // 接收緩沖區(qū)大小

// 主題訂閱數(shù)據(jù)結(jié)構(gòu)
typedef struct {
    char name[50];                       // 主題名稱(chēng)
    int subscribers[MAX_SUBS_PER_TOPIC]; // 訂閱該主題的客戶(hù)端套接字描述符數(shù)組
    int sub_count;                       // 當(dāng)前訂閱者數(shù)量
} Topic;

Topic topics[MAX_TOPICS]; // 全局主題數(shù)組
int topic_count = 0;      // 當(dāng)前主題數(shù)量

// 輔助函數(shù)：查找或創(chuàng)建主題
int find_or_create_topic(const char* topic_name) {
    // 查找現(xiàn)有主題
    for (int i = 0; i < topic_count; ++i) {
        if (strcmp(topics[i].name, topic_name) == 0) {
            return i; // 找到，返回索引
        }
    }
    // 如果未找到且還有空間，則創(chuàng)建新主題
    if (topic_count < MAX_TOPICS) {
        strncpy(topics[topic_count].name, topic_name, sizeof(topics[topic_count].name) - 1);
        topics[topic_count].name[sizeof(topics[topic_count].name) - 1] = '\0'; // 確保空字符結(jié)尾
        topics[topic_count].sub_count = 0; // 初始化訂閱者數(shù)量為0
        return topic_count++; // 返回新主題的索引，并增加主題計(jì)數(shù)
    }
    return -1; // 主題數(shù)組已滿(mǎn)，無(wú)法創(chuàng)建
}

// 輔助函數(shù)：將客戶(hù)端添加到主題的訂閱列表
void add_subscriber(int topic_index, int client_socket) {
    if (topic_index < 0 || topic_index >= topic_count) return; // 無(wú)效的主題索引
    Topic* topic = &topics[topic_index];
    if (topic->sub_count < MAX_SUBS_PER_TOPIC) {
        // 檢查是否已訂閱，避免重復(fù)添加
        for(int i = 0; i < topic->sub_count; ++i) {
            if (topic->subscribers[i] == client_socket) return; // 已存在，直接返回
        }
        // 添加新的訂閱者
        topic->subscribers[topic->sub_count++] = client_socket;
        printf("客戶(hù)端 %d 訂閱了主題 '%s'\n", client_socket, topic->name);
    } else {
        // 主題訂閱已滿(mǎn)
        printf("主題 '%s' 訂閱已滿(mǎn), 無(wú)法添加客戶(hù)端 %d\n", topic->name, client_socket);
        // 可選: 向客戶(hù)端發(fā)送錯(cuò)誤消息
        // send(client_socket, "ERR topic full\n", 15, 0);
    }
}

// 輔助函數(shù)：從所有主題中移除指定客戶(hù)端的訂閱
void remove_subscriber(int client_socket) {
    printf("正在移除客戶(hù)端 %d 的所有訂閱。\n", client_socket);
    for (int i = 0; i < topic_count; ++i) { // 遍歷所有主題
        int found_idx = -1;
        // 在當(dāng)前主題的訂閱者列表中查找該客戶(hù)端
        for (int j = 0; j < topics[i].sub_count; ++j) {
            if (topics[i].subscribers[j] == client_socket) {
                found_idx = j;
                break;
            }
        }
        // 如果找到該客戶(hù)端
        if (found_idx != -1) {
            // 將后續(xù)訂閱者向前移動(dòng)一位，覆蓋掉要移除的客戶(hù)端
            for (int k = found_idx; k < topics[i].sub_count - 1; ++k) {
                topics[i].subscribers[k] = topics[i].subscribers[k + 1];
            }
            topics[i].sub_count--; // 減少訂閱者計(jì)數(shù)
            printf("已將客戶(hù)端 %d 從主題 '%s' 中移除\n", client_socket, topics[i].name);
        }
    }
}

// 輔助函數(shù)：向指定主題發(fā)布消息
void publish_message(int topic_index, const char* message, int publisher_socket) {
    if (topic_index < 0 || topic_index >= topic_count) return; // 無(wú)效的主題索引
    Topic* topic = &topics[topic_index];
    char full_message[BUFFER_SIZE + 100]; // 預(yù)留足夠空間構(gòu)造 "MSG <topic> <data>\n" 格式的消息

    // 構(gòu)造完整的消息格式
    snprintf(full_message, sizeof(full_message), "MSG %s %s", topic->name, message);
     // 確保消息以換行符結(jié)束 (如果原始消息沒(méi)有的話(huà))
    if (full_message[strlen(full_message)-1] != '\n') {
         strncat(full_message, "\n", sizeof(full_message) - strlen(full_message) - 1);
    }


    printf("向主題 '%s' 發(fā)布消息: %s", topic->name, message); // 假設(shè)原始 message 可能已包含換行符
    // 遍歷該主題的所有訂閱者
    for (int i = 0; i < topic->sub_count; ++i) {
        int subscriber_socket = topic->subscribers[i];
        // 不將消息發(fā)回給發(fā)布者自己
        if (subscriber_socket != publisher_socket) {
            // 發(fā)送消息給訂閱者
            if (send(subscriber_socket, full_message, strlen(full_message), 0) < 0) {
                // 發(fā)送失敗，可能需要處理連接斷開(kāi)等問(wèn)題
                perror("向訂閱者發(fā)送消息失敗");
                // 注意: 健壯的實(shí)現(xiàn)應(yīng)在此處檢測(cè)到錯(cuò)誤后，可能也需要關(guān)閉并清理該訂閱者的連接
            } else {
                 printf("  -> 已發(fā)送至客戶(hù)端 %d\n", subscriber_socket);
            }
        }
    }
}


int main() {
    int listener_fd;                   // 監(jiān)聽(tīng)套接字描述符
    int new_socket;                    // 新接受的客戶(hù)端連接套接字描述符
    int client_sockets[MAX_CLIENTS];   // 存儲(chǔ)客戶(hù)端套接字描述符的數(shù)組
    int max_clients = MAX_CLIENTS;     // 最大客戶(hù)端數(shù) (冗余變量，可直接用宏)
    int activity;                      // select() 的返回值
    int i, valread, sd;                // 循環(huán)變量, read() 返回值, 當(dāng)前處理的套接字描述符
    int max_sd;                        // select() 需要的最大文件描述符值 + 1
    struct sockaddr_in address;        // 服務(wù)器地址結(jié)構(gòu)
    char buffer[BUFFER_SIZE + 1];      // 數(shù)據(jù)接收緩沖區(qū) (+1 用于空字符結(jié)尾)

    // 文件描述符集合
    fd_set readfds;

    // 初始化客戶(hù)端套接字?jǐn)?shù)組，全部置 0 (0 不是有效的文件描述符)
    for (i = 0; i < max_clients; i++) {
        client_sockets[i] = 0;
    }

    // 創(chuàng)建主監(jiān)聽(tīng)套接字
    if ((listener_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket 創(chuàng)建失敗");
        exit(EXIT_FAILURE);
    }

    // 設(shè)置監(jiān)聽(tīng)套接字選項(xiàng)，允許地址重用
    int opt = 1;
    if (setsockopt(listener_fd, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(opt)) < 0) {
        perror("setsockopt 失敗");
        exit(EXIT_FAILURE);
    }

    // 配置服務(wù)器地址結(jié)構(gòu)
    address.sin_family = AF_INET;         // IPv4
    address.sin_addr.s_addr = INADDR_ANY; // 監(jiān)聽(tīng)所有接口
    address.sin_port = htons(PORT);       // 指定端口（網(wǎng)絡(luò)字節(jié)序）

    // 將監(jiān)聽(tīng)套接字綁定到指定地址和端口
    if (bind(listener_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind 失敗");
        exit(EXIT_FAILURE);
    }
    printf("監(jiān)聽(tīng)器已啟動(dòng)在端口 %d \n", PORT);

    // 使套接字進(jìn)入監(jiān)聽(tīng)狀態(tài)，設(shè)定等待隊(duì)列長(zhǎng)度為 3
    if (listen(listener_fd, 3) < 0) {
        perror("listen 失敗");
        exit(EXIT_FAILURE);
    }

    // 等待客戶(hù)端連接
    socklen_t addrlen = sizeof(address);
    puts("等待連接中 ...");

    while (1) { // 服務(wù)器主循環(huán)
        // 清空讀文件描述符集合
        FD_ZERO(&readfds);

        // 將監(jiān)聽(tīng)套接字加入集合
        FD_SET(listener_fd, &readfds);
        max_sd = listener_fd; // 初始化 max_sd

        // 將所有活動(dòng)的客戶(hù)端套接字加入集合
        for (i = 0; i < max_clients; i++) {
            sd = client_sockets[i]; // 獲取客戶(hù)端套接字描述符

            // 如果是有效的套接字描述符 (大于 0)，則加入讀集合
            if (sd > 0)
                FD_SET(sd, &readfds);

            // 更新 max_sd 以跟蹤最大的文件描述符值
            if (sd > max_sd)
                max_sd = sd;
        }

        // 調(diào)用 select() 等待活動(dòng)發(fā)生，timeout 設(shè)置為 NULL 表示無(wú)限期阻塞
        activity = select(max_sd + 1, &readfds, NULL, NULL, NULL);

        // 檢查 select() 是否出錯(cuò) (忽略 EINTR 信號(hào)中斷)
        if ((activity < 0) && (errno != EINTR)) {
            perror("select 錯(cuò)誤");
            // 在實(shí)際應(yīng)用中可能需要更復(fù)雜的錯(cuò)誤處理邏輯
        }

        // 檢查監(jiān)聽(tīng)套接字是否就緒 (表示有新連接請(qǐng)求)
        if (FD_ISSET(listener_fd, &readfds)) {
            // 接受新連接
            if ((new_socket = accept(listener_fd, (struct sockaddr *)&address, &addrlen)) < 0) {
                perror("accept 失敗");
                // 嚴(yán)重錯(cuò)誤，通常需要退出或重啟服務(wù)
                exit(EXIT_FAILURE);
            }

            // 獲取并打印新客戶(hù)端的 IP 和端口信息
             char client_ip[INET_ADDRSTRLEN];
             inet_ntop(AF_INET, &address.sin_addr, client_ip, INET_ADDRSTRLEN);
             printf("新連接建立，套接字描述符為 %d，IP 為: %s，端口為: %d\n",
                   new_socket, client_ip, ntohs(address.sin_port));

            // 將新套接字添加到客戶(hù)端數(shù)組中
            for (i = 0; i < max_clients; i++) {
                // 找到數(shù)組中第一個(gè)空位
                if (client_sockets[i] == 0) {
                    client_sockets[i] = new_socket;
                    printf("已將套接字 %d 添加到列表位置 %d\n", new_socket, i);
                    break; // 添加成功后退出循環(huán)
                }
            }
            // 如果客戶(hù)端數(shù)組已滿(mǎn)
             if (i == max_clients) {
                printf("客戶(hù)端連接數(shù)已達(dá)上限，拒絕連接。\n");
                close(new_socket); // 關(guān)閉這個(gè)無(wú)法處理的連接
            }
        }

        // 檢查各個(gè)客戶(hù)端套接字是否有活動(dòng) (數(shù)據(jù)到達(dá)或連接關(guān)閉)
        for (i = 0; i < max_clients; i++) {
            sd = client_sockets[i]; // 當(dāng)前要檢查的客戶(hù)端套接字

            // 如果當(dāng)前客戶(hù)端套接字在就緒的讀集合中
            if (FD_ISSET(sd, &readfds)) {
                // 嘗試讀取數(shù)據(jù)
                // read() 返回值: >0 表示讀取的字節(jié)數(shù), 0 表示連接已關(guān)閉 (收到FIN), <0 表示錯(cuò)誤
                if ((valread = read(sd, buffer, BUFFER_SIZE)) <= 0) {
                    // 連接關(guān)閉或發(fā)生錯(cuò)誤
                    if (valread == 0) {
                        // 對(duì)端正常關(guān)閉連接 (FIN)
                        getpeername(sd, (struct sockaddr*)&address, &addrlen); // 獲取對(duì)端地址信息用于打印
                        char client_ip[INET_ADDRSTRLEN];
                        inet_ntop(AF_INET, &address.sin_addr, client_ip, INET_ADDRSTRLEN);
                        printf("主機(jī) %s:%d (套接字 %d) 斷開(kāi)連接\n", client_ip, ntohs(address.sin_port), sd);
                    } else {
                        // 讀取錯(cuò)誤
                        perror("read 錯(cuò)誤");
                        // 也可以在這里獲取對(duì)端信息打印
                    }

                    // 關(guān)閉套接字
                    close(sd);
                    // 從客戶(hù)端數(shù)組中移除 (標(biāo)記為 0)
                    client_sockets[i] = 0;
                    // 從所有主題訂閱中移除該客戶(hù)端
                    remove_subscriber(sd);

                } else {
                    // 成功讀取到數(shù)據(jù)，處理客戶(hù)端發(fā)送的命令
                    buffer[valread] = '\0'; // 添加空字符結(jié)尾，確保字符串處理安全

                    // 簡(jiǎn)單的命令解析 (生產(chǎn)環(huán)境需要更健壯的解析器)
                    char command[5];       // 存儲(chǔ)命令 (SUB/PUB)
                    char topic_name[50];   // 存儲(chǔ)主題名
                    char message[BUFFER_SIZE]; // 存儲(chǔ)消息內(nèi)容 (PUB 命令)
                    memset(message, 0, sizeof(message)); // 清空消息緩沖區(qū)

                    // 使用 sscanf 解析輸入，格式為 "CMD TOPIC [MESSAGE]"
                    // %4s: 讀取最多4個(gè)字符作為命令
                    // %49s: 讀取最多49個(gè)字符作為主題名 (防止溢出)
                    // %[^\n]: 讀取從主題名后到行尾的所有字符作為消息 (包括空格)
                    int parsed_items = sscanf(buffer, "%4s %49s %[^\n]", command, topic_name, message);

                    printf("收到來(lái)自客戶(hù)端 %d 的數(shù)據(jù): %s", sd, buffer); // buffer 可能自帶換行符

                    if (parsed_items >= 2 && strcmp(command, "SUB") == 0) {
                        // 處理 SUB 命令
                        int topic_idx = find_or_create_topic(topic_name);
                        if (topic_idx != -1) {
                            add_subscriber(topic_idx, sd);
                            // 可選: 向客戶(hù)端發(fā)送訂閱成功確認(rèn)
                            // send(sd, "SUB OK\n", 7, 0);
                        } else {
                            // 可選: 發(fā)送錯(cuò)誤（如主題數(shù)達(dá)到上限）
                            // send(sd, "ERR max topics\n", 15, 0);
                        }
                    } else if (parsed_items >= 3 && strcmp(command, "PUB") == 0) {
                         // 處理 PUB 命令
                         int topic_idx = find_or_create_topic(topic_name); // 查找主題，如果不存在，簡(jiǎn)單實(shí)現(xiàn)可以忽略或報(bào)錯(cuò)
                          if (topic_idx != -1) {
                             // 確保消息格式包含換行符，便于客戶(hù)端接收處理
                             // 注意: 這里假設(shè) message 已包含從 sscanf 讀取的內(nèi)容
                             // 這里對(duì) message 的處理可以省略，因?yàn)?publish_message 內(nèi)部會(huì)確保換行符
                             publish_message(topic_idx, message, sd);
                         } else {
                              printf("未找到用于發(fā)布的主題 '%s'.\n", topic_name);
                             // 可選: 發(fā)送錯(cuò)誤（主題不存在）
                             // send(sd, "ERR no such topic\n", 18, 0);
                         }
                    } else {
                        // 無(wú)效命令格式
                        printf("來(lái)自客戶(hù)端 %d 的無(wú)效命令: %s", sd, buffer);
                        // 可選: 發(fā)送錯(cuò)誤
                        // send(sd, "ERR invalid command\n", 20, 0);
                    }
                    // 清理緩沖區(qū)以便下次讀取 (可選，因?yàn)?read 會(huì)覆蓋)
                    memset(buffer, 0, BUFFER_SIZE + 1);
                }
            }
        }
    }

    // 理論上，服務(wù)器的無(wú)限循環(huán)不會(huì)到達(dá)這里，但在正常關(guān)閉流程中應(yīng)關(guān)閉監(jiān)聽(tīng)套接字
    close(listener_fd);

    return 0;
}

gcc pubsub_server_revised.c -o pubsub_server_revised

./pubsub_server_revised

(base) ?  back-end-notes git:(master) ? nc localhost 8080
^C
(base) ?  back-end-notes git:(master) ? nc localhost 8080
SUB TOPIC-1
MSG TOPIC-1 1,242.42,214\n

(base) ?  back-end-notes git:(master) ? nc localhost 8080
PUB TOPIC-1 1,242.42,214\n

piperliu@go-x86:~/code/socket$ ./pubsub_server_revised
監(jiān)聽(tīng)器已啟動(dòng)在端口 8080 
等待連接中 ...
新連接建立，套接字描述符為 5，IP 為: 127.0.0.1，端口為: 38910
已將套接字 5 添加到列表位置 0
主機(jī) 127.0.0.1:38910 (套接字 5) 斷開(kāi)連接
正在移除客戶(hù)端 5 的所有訂閱。
新連接建立，套接字描述符為 5，IP 為: 127.0.0.1，端口為: 38924
已將套接字 5 添加到列表位置 0
收到來(lái)自客戶(hù)端 5 的數(shù)據(jù): SUB TOPIC-1
客戶(hù)端 5 訂閱了主題 'TOPIC-1'
新連接建立，套接字描述符為 6，IP 為: 127.0.0.1，端口為: 58630
已將套接字 6 添加到列表位置 1
收到來(lái)自客戶(hù)端 6 的數(shù)據(jù): PUB TOPIC-1 1,242.42,214\n
向主題 'TOPIC-1' 發(fā)布消息: 1,242.42,214\n  -> 已發(fā)送至客戶(hù)端 5