初次接触node js 时，看到node js 异步io性能很高，并发很强，当时就认为很强，用了一段时间，，后来某天又看到以性能著称的golang，于是又学习了一波，，并对两者进行了性能对比，，果不其然，node js败下阵来。。后来对并发产生了浓厚兴趣，于是自己使用unix系统的api写了个tcp服务，来测试并发，然而水平有限，分别使用了单线程阻塞，多线程，io多路复用，，性能一个比一个差，，因为写的简单只返回hello world，也许性能差的原因和此有关，不同的情况适合不同的io模型，，以后会尝试io密集型，计算密集型测试，现在先将使用ab 工具测试的node js 服务，golang服务，单线程阻塞服务，recv多线程服务，mac下kqueue 服务的ab测试结果及测试的代码贴出来，供大家吐槽指点。
node js，1000请求100并发，平均每秒处理请求数量 12000左右
代码
let http = require("http");
http.createServer(function(req,res){
res.writeHead(200);
res.end("hello world");
}).listen(8003);golang，1000请求100并发，平均每秒处理请求数量 14000左右
代码
package mainimport( "net/http")
func main(){
http.HandleFunc("/",func(w http.ResponseWriter,r*http.Request){
w.Write([]byte("hello world"))
})
http.ListenAndServe(":8020",nil)
}单线程阻塞，1000请求100并发，平均每秒请求数量 8000左右
代码
#include <stdio.h>#include <netdb.h>#include <sys/socket.h>char resdata[205] = "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\nhello world";int main(int argc, const char * argv[]) { struct sockaddr_in bindaddr;
bindaddr.sin_family = AF_INET;
bindaddr.sin_addr.s_addr = htonl(INADDR_ANY);
bindaddr.sin_port = htons(3001);
int listenfd = socket(AF_INET, SOCK_STREAM, 0); if(listenfd>0){ printf("创建socket成功"); if (bind(listenfd, (struct sockaddr *)&bindaddr, sizeof(bindaddr)) != -1){ printf("绑定端口号成功"); if (listen(listenfd, SOMAXCONN) != -1){ printf("初始化成功"); while (1) { int clientfd = accept(listenfd, NULL, NULL); char buf[200]; //5. 从客户端接受数据
int ret = recv(clientfd, buf, 200, 0); if(ret >0){ int ret2 = send(clientfd, resdata, 200, 0); if(ret2 > 0){ printf("发送数据成功");
close(clientfd);
} else{ printf(ret2);
}
} else{ printf("123");
}
}
}
}
};
}多线程阻塞，1000请求100并发，平均每秒处理请求数量3000左右
代码（打印了许多文字来追踪流程勿喷)
#include <stdio.h>#include <netdb.h>#include <sys/socket.h>#include <pthread.h>pthread_t ntid;char resdata[205] = "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\nhello world";void deal(int clientfd){ char buf[999]; //5. 从客户端接受数据
int ret = recv(clientfd, buf, 999, 0); if(ret >0){
int ret2 = send(clientfd, resdata, strlen(resdata), 0); if(ret2 > 0){ printf("发送数据成功");
close(clientfd);
} else{ printf(ret2);
}
pthread_exit((void *)2);
}
}int main(int argc, const char * argv[]) { struct sockaddr_in bindaddr;
bindaddr.sin_family = AF_INET;
bindaddr.sin_addr.s_addr = htonl(INADDR_ANY);
bindaddr.sin_port = htons(3000);
int listenfd = socket(AF_INET, SOCK_STREAM, 0); if(listenfd>0){ printf("创建socket成功"); if (bind(listenfd, (struct sockaddr *)&bindaddr, sizeof(bindaddr)) != -1){ printf("绑定端口号成功"); if (listen(listenfd, SOMAXCONN) != -1){ printf("初始化成功"); while (1) { printf("第二轮循环开始"); int clientfd = accept(listenfd, NULL, NULL); int err;
err = pthread_create(&ntid,NULL,deal,clientfd); if(err == 0){ printf("一轮循环结束\n");
}
}
}
}
};
}kqueue 多路复用（因为我是mac电脑）1000请求100并发大量socket 54 错误，可能代码有问题，，改为1000请求10并发，每秒处理3000左右请求
代码
#include <sys/types.h>#include <sys/socket.h>#include <sys/event.h>#include <sys/time.h>#include <netinet/in.h>#include <arpa/inet.h>#include <errno.h>#define PORT 3000#define MAX_EVENT_COUNT 100000void dealwrite(int sock,int kq){ printf("写h数据"); char buffer[]="HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\nhello world"; ssize_t sendlen = send(sock, buffer, sizeof(buffer), 0); printf("%d",sendlen); printf("&"); printf("%d",sock); if (sendlen <= 0)
{ //链接断开
close(sock); struct kevent event = {sock,EVFILT_READ,EV_DELETE,0,0,NULL};
kevent(kq, &event, 1, NULL, 0, NULL); printf("write broken!\n"); return;
} //struct kevent event = {sock,EVFILT_READ,EV_DELETE,100,0,NULL};
//kevent(kq, &event, 1, NULL, 0, NULL);
//struct kevent event2 = {sock,EVFILT_WRITE,EV_DELETE,200,0,NULL};
//kevent(kq, &event2, 1, NULL, 0, NULL);
close(sock);
}void dealread(int sock,int kq){ char buffer[100]; printf("读数据"); printf("%d",sock); printf("&"); //memset(buffer, '\0', data);
ssize_t recvlen = recv(sock, buffer, 100, 0); printf("%d",recvlen); if(recvlen == 100){ return;
} if (recvlen <= 0)
{ //链接断开
close(sock); struct kevent event = {sock,EVFILT_READ,EV_DELETE,0,0,NULL};
kevent(kq, &event, 1, NULL, 0, NULL); printf("read broken!\n"); return;
} struct kevent changelist2[1];
EV_SET(&changelist2[0], sock, EVFILT_WRITE, EV_ADD, 0, 200, NULL);
kevent(kq, changelist2, 1, NULL, 0, NULL);
}int createSocket(){ int sock = socket(PF_INET, SOCK_STREAM, 0); if (sock == -1)
{ printf("socket() failed:%d\n",errno); return -1;
}
struct sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_port = htons(PORT);
addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
int optval = 1;
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval));
optval = 1;
setsockopt(sock, SOL_SOCKET, SO_NOSIGPIPE, &optval, sizeof(optval));
if (bind(sock, (struct sockaddr*)&addr, sizeof(struct sockaddr)) == -1)
{ printf("bind() failed:%d\n",errno); return -1;
}
if (listen(sock, 5) == -1)
{ printf("listen() failed:%d\n",errno); return -1;
}
return sock;
}int main(int argc, const char * argv[]){ int listenfd = createSocket(); if (listenfd == -1) return -1;
int kq = kqueue(); if (kq == -1)
{ printf("kqueue failed:%d",errno); return -1;
}
struct kevent event = {listenfd,EVFILT_READ,EV_ADD,0,0,NULL}; int ret = kevent(kq, &event, 1, NULL, 0, NULL); if (ret == -1)
{ printf("kevent failed:%d",errno); return -1;
} printf("%c",EVFILT_WRITE); while (1)
{ struct kevent eventlist[MAX_EVENT_COUNT];
struct timespec timeout = {5,0}; int ret = kevent(kq, NULL, 0, eventlist, MAX_EVENT_COUNT, &timeout); if (ret <= 0) continue;
for (int i=0; i<ret; i++)
{ struct kevent event = eventlist[i];
int sock = (int)event.ident; int16_t filter = event.filter; uint32_t flags = event.flags; intptr_t data = event.data; printf("重新开始"); printf("%c",filter);
//有新的客户端链接
if (sock == listenfd)
{ printf("新链接"); printf("%d",sock); socklen_t client_addrlen = 4; struct sockaddr client_addrlist[client_addrlen];
int clientfd = accept(listenfd, client_addrlist, &client_addrlen); if (clientfd > 0)
{ struct kevent changelist[1];
EV_SET(&changelist[0], clientfd, EVFILT_READ, EV_ADD, 0, 100, NULL);
kevent(kq, changelist, 1, NULL, 0, NULL);
kevent(kq, changelist, 1, NULL, 0, NULL);
} continue;
}
//异常事件
if (flags & EV_ERROR)
{ printf("异常");
close(sock); struct kevent event = {sock,EVFILT_READ,EV_DELETE,0,0,NULL};
kevent(kq, &event, 1, NULL, 0, NULL); printf("socket broken,error:%ld\n",data); continue;
}
//数据可读
if (filter == EVFILT_READ)
{
dealread(sock,kq);
}
//数据可写s
if (filter == EVFILT_WRITE)
{
dealwrite(sock,kq);
}
}
}
return 0;
}如有kqueue错误使用之处请指出。
所有代码都在本机上运行通过，socket服务是用c语言写的，需要编译运行，kqueue需要在mac机上运行，golang需要安装对应环境及设置对应变量
如果要安装golang环境并对golang感兴趣可以给我留言，
附一张压测截图
压测截图