前沿拓展：

kb4020102

1、Windows10創(chuàng)意者版積累性更新15063.332（KB4020過試料客長雙礦員待護富102）已經(jīng)于5月26日向創(chuàng)意者正式版用戶推送，該補丁包含了很多問題的問題。

前言

實現(xiàn)一臺服務器的百萬并發(fā)，服務器支撐百萬連接會出現(xiàn)哪些問題，如何排查與解決這些問題 是本文的重點

服務器能夠同時建立連接的數(shù)量 不是 并發(fā)量，它只是并發(fā)量一個基礎。服務器的并發(fā)量：一個服務器能夠同時承載客戶端的數(shù)量；承載：服務器能夠穩(wěn)定的維持這些連接，能夠響應請求，在200ms內(nèi)返回響應就認為是ok的，其中這200ms包括數(shù)據(jù)庫的**作，網(wǎng)絡帶寬，內(nèi)存**作，日志等時間。測試介紹

服務器 采用 1臺 centos7 12G 1核虛擬機

客戶端 采用 2臺 centos7 3G 1核虛擬機

服務器代碼：單reactor單線程，IO多路復用使用epoll

客戶端代碼：IO多路復用使用epoll，每個客戶端發(fā)51w個連接，每個連接發(fā)送一次數(shù)據(jù)，讀取一次數(shù)據(jù)之后不再發(fā)送數(shù)據(jù)

服務器代碼

由于fd的數(shù)量未知，這里設計ntyreactor 里面包含 eventblock ，eventblock 包含1024個fd。每個fd通過 fd/1024**到在第幾個eventblock，通過fd%1024**到在eventblock第幾個位置。

struct ntyevent {
int fd;
int events;
void *arg;

NCALLBACK callback;

int status;
char buffer[BUFFER_LENGTH];
int length;
};
struct eventblock {
struct eventblock *next;
struct ntyevent *events;
};

struct ntyreactor {
int epfd;
int blkcnt;
struct eventblock *evblk;
};

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/epoll.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>

#define BUFFER_LENGTH 4096
#define MAX_EPOLL_EVENTS 1024
#define SERVER_PORT 8081
#define PORT_COUNT 100

typedef int (*NCALLBACK)(int, int, void *);

struct ntyevent {
int fd;
int events;
void *arg;

NCALLBACK callback;

int status;
char buffer[BUFFER_LENGTH];
int length;
};
struct eventblock {
struct eventblock *next;
struct ntyevent *events;
};

struct ntyreactor {
int epfd;
int blkcnt;
struct eventblock *evblk;
};

int recv_cb(int fd, int events, void *arg);

int send_cb(int fd, int events, void *arg);

struct ntyevent *ntyreactor_find_event_idx(struct ntyreactor *reactor, int sockfd);

void nty_event_set(struct ntyevent *ev, int fd, NCALLBACK *callback, void *arg) {
ev->fd = fd;
ev->callback = callback;
ev->events = 0;
ev->arg = arg;
}

int nty_event_add(int epfd, int events, struct ntyevent *ev) {
struct epoll_event ep_ev = {0, {0}};
ep_ev.data.ptr = ev;
ep_ev.events = ev->events = events;
int op;
if (ev->status == 1) {
op = EPOLL_CTL_MOD;
}
else {
op = EPOLL_CTL_ADD;
ev->status = 1;
}
if (epoll_ctl(epfd, op, ev->fd, &ep_ev) < 0) {
printf("event add failed [fd=%d], events[%d]n", ev->fd, events);
return -1;
}
return 0;
}

int nty_event_del(int epfd, struct ntyevent *ev) {
struct epoll_event ep_ev = {0, {0}};
if (ev->status != 1) {
return -1;
}
ep_ev.data.ptr = ev;
ev->status = 0;
epoll_ctl(epfd, EPOLL_CTL_DEL, ev->fd, &ep_ev);
return 0;
}

int recv_cb(int fd, int events, void *arg) {
struct ntyreactor *reactor = (struct ntyreactor *) arg;
struct ntyevent *ev = ntyreactor_find_event_idx(reactor, fd);
int len = recv(fd, ev->buffer, BUFFER_LENGTH, 0); //
nty_event_del(reactor->epfd, ev);

if (len > 0) {
ev->length = len;
ev->buffer[len] = '