生活随笔
收集整理的這篇文章主要介紹了
多线程使用SO_REUSEPORT来实现多个socket监听同一个端口
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
在十幾年前的 FreeBSD 中就存在 SO_REUSEPORT 參數來實現多個 socket 監聽同一個端口，來提升服務器的負載，在 Linux 3.9 開始也引入了這個功能，下面就看一下例子。
?
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <stdbool.h>
#include <arpa/inet.h>
#include <pthread.h>void* do_work(void *arg)
{int *port = (int *) arg;int listen_socket = socket(AF_INET, SOCK_STREAM, 0);int one = 1;setsockopt(listen_socket, SOL_SOCKET, SO_REUSEPORT, &one, sizeof(one));struct sockaddr_in serv_addr;memset(&serv_addr, 0, sizeof(serv_addr));serv_addr.sin_family = AF_INET;serv_addr.sin_addr.s_addr = INADDR_ANY;serv_addr.sin_port = htons(*port);int ret = bind(listen_socket, (struct sockaddr *) &serv_addr, sizeof(serv_addr)); listen(listen_socket, 5);struct sockaddr_in cli_addr;memset(&cli_addr, 0, sizeof(cli_addr));int addr_length = sizeof(cli_addr);do{int cli_sock = accept(listen_socket, (struct sockaddr *) &cli_addr, (socklen_t *) &addr_length);close(cli_sock);} while (true);close(listen_socket);return 0;
}int main(int ac, const char *av[])
{ int port = atoi(av[1]);const int MAX_THREADS = 10;pthread_t tid[MAX_THREADS];for (int i = 0; i < MAX_THREADS; i++) {pthread_create(&tid[i], NULL, do_work, &port);}for (int i = 0; i < MAX_THREADS; i++) {pthread_join(tid[i], NULL);}return 0;
}
總結
以上是生活随笔為你收集整理的多线程使用SO_REUSEPORT来实现多个socket监听同一个端口的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
