linux socketµÄselectº¯ÊýʾÀý
ʹÓÃselectº¯Êý¿ÉÒÔÒÔ·Ç×èÈûµÄ·½Ê½ºÍ¶à¸ösocketͨÐÅ¡£³ÌÐòÖ»ÊÇÑÝʾselectº¯ÊýµÄʹÓ㬹¦Äܷdz£¼òµ¥£¬¼´Ê¹Ä³¸öÁ¬½Ó¹Ø±ÕÒÔºóÒ²²»»áÐ޸ĵ±Ç°Á¬½ÓÊý£¬Á¬½ÓÊý´ïµ½×î´óÖµºó»áÖÕÖ¹³ÌÐò¡£
1. ³ÌÐòʹÓÃÁËÒ»¸öÊý×éfd_A£¬Í¨ÐÅ¿ªÊ¼ºó°ÑÐèҪͨÐŵĶà¸ösocketÃèÊö·û¶¼·ÅÈë´ËÊý×é¡£
2. Ê×ÏÈÉú³ÉÒ»¸ö½Ðsock_fdµÄsocketÃèÊö·û£¬ÓÃÓÚ¼àÌý¶Ë¿Ú¡£
3. ½«sock_fdºÍÊý×éfd_AÖв»Îª0µÄÃèÊö·û·ÅÈëselect½«¼ì²éµÄ¼¯ºÏfdsr¡£
4. ´¦ÀífdsrÖпÉÒÔ½ÓÊÕÊý¾ÝµÄÁ¬½Ó¡£Èç¹ûÊÇsock_fd£¬±íÃ÷ÓÐÐÂÁ¬½Ó¼ÓÈ룬½«Ð¼ÓÈëÁ¬½ÓµÄsocketÃèÊö·û·ÅÖõ½fd_A¡£
ȱµã£º Á¬½ÓÊýûÓж¯Ì¬¹ÜÀí£¬µ±½áÊøÒ»¸öÁ¬½ÓʱҪִÐÐconn_amount--;
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define MYPORT 1234 // the port users will be connecting to
#define BACKLOG 5 // how many pending connections queue will hold
#define BUF_SIZE 200
int fd_A[BACKLOG]; // accepted connection fd
int conn_amount; // current connection amount
void showclient()
{
int i;
printf("client amount: %d\n", conn_amount);
for (i = 0; i < BACKLOG; i++) {
printf("[%d]:%d ", i, fd_A[i]);
}
printf("\n\n");
}
int main(void)
{
int sock_fd, new_fd; // listen on sock_fd, new connection on new_fd
struct sockaddr_in server_addr; // server address information
struct sockaddr_in client_addr; // connector's address information
socklen_t sin_size;
int yes = 1;
char buf[BUF_SIZE];
int ret;
int i;
if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
perror("socket");
exit(1);
}
if (setsockopt(sock_fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {
perror("setsockopt");
exit(1);
}
server_addr.sin_family = AF_INET; // host byte order
server_addr.sin_port = htons(MYPORT); // short, network byte order
server_
Ïà¹ØÎĵµ£º
²âÊÔϵͳÔÚLinuxÉϵÄÐÔÄÜ·¢ÏÖ¶ª°üÂʼ«ÎªÑÏÖØ£¬·¢210000ÌõÊý¾Ý£¬¶ª°ü´ï110000Ö®¾Þ£¬¶ª°üÂʳ¬¹ý50%¡£Í¬µÈÇéÐÎÏÂWindowsÉϲâÊÔ£¬½ö¶ª¼¸ÌõÊý¾Ý¡£ÐÎÊÆÑϾþ£¬±ØÐë½â¾ö¡£¿¼ÂÇ¿ÉÄÜÊÇÒòΪÐÒéÕ»BufferÌ«µÍËùÖ£¬ÓÚÊÇÏÈ¿´¿´Ä¬ÈÏÇé¿ö£º
sysctl -a |grep net.core
·¢ÏÖ
net.core.rmem_max = 131071
net.core.rmem_default = 11264 ......
ÿһÖÖÌõ¼þÓï¾äµÄ»ù´¡¶¼ÊÇÅжÏʲôÊÇÕæÊ²Ã´ÊǼ١£ÊÇ·ñÁ˽âÆä¹¤×÷ÔÀí½«¾ö¶¨Äú±àдµÄÊÇÖÊÁ¿Ò»°ãµÄ½Å±¾»¹ÊÇÄú½«ÒýÒÔΪÈٵĽű¾¡£
Shell ½Å±¾µÄÄÜÁ¦Ê±³£±»µÍ¹À£¬µ«Êµ¼ÊÉÏÆäÄÜÁ¦µÄ·¢»ÓÊÜÖÆÓڽű¾×«Ð´ÕßµÄÄÜÁ¦¡£ÄúÁ˽âµÃÔ½¶à£¬Äú¾ÍÔ½ÄÜÏñ±äÏ··¨ËƵØ×«Ð´Ò»¸öÎļþÀ´Ê¹ÈÎÎñ×Ô¶¯»¯ºÍ¼ò»¯ÄúµÄ¹ÜÀí¹¤×÷¡£
ÔÚ shell ½Å±¾ÖнøÐеÄÃ¿Ò»Ö ......
ʹÓõĽŲ½ÓÐËĸö£º¡¾backup_unasyn.sh //±¸·ÝËùÒÔÖ´ÐеĽŲ½
host_ip.sh &n ......
#pragma once
#include <pthread.h>
class ThreadWrapper
{
public:
virtual ~ThreadWrapper();
static void EnterFunc(void *p);
int Open();
int Close();
bool TestCancel();
void ......