初次接触node js 时,看到node js 异步io性能很高,并发很强,当时就认为很强,用了一段时间,,后来某天又看到以性能著称的golang,于是又学习了一波,,并对两者进行了性能对比,,果不其然,node js败下阵来。。后来对并发产生了浓厚兴趣,于是自己使用unix系统的api写了个tcp服务,来测试并发,然而水平有限,分别使用了单线程阻塞,多线程,io多路复用,,性能一个比一个差,,因为写的简单只返回hello world,也许性能差的原因和此有关,不同的情况适合不同的io模型,,以后会尝试io密集型,计算密集型测试,现在先将使用ab 工具测试的node js 服务,golang服务,单线程阻塞服务,recv多线程服务,mac下kqueue 服务的ab测试结果及测试的代码贴出来,供大家吐槽指点。
代码
let http = require("http");
http.createServer(function(req,res){
res.writeHead(200);
res.end("hello world");
}).listen(8003);
代码
package mainimport( "net/http")
func main(){
http.HandleFunc("/",func(w http.ResponseWriter,r*http.Request){
w.Write([]byte("hello world"))
})
http.ListenAndServe(":8020",nil)
}
代码
#include <stdio.h>#include <netdb.h>#include <sys/socket.h>char resdata[205] = "HTTP/1.1 200 OKrnContent-Type: text/htmlrnrnhello 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");
}
}
}
}
};
}
代码(打印了许多文字来追踪流程勿喷)
#include <stdio.h>#include <netdb.h>#include <sys/socket.h>#include <pthread.h>pthread_t ntid;char resdata[205] = "HTTP/1.1 200 OKrnContent-Type: text/htmlrnrnhello 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");
}
}
}
}
};
}
代码
#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 OKrnContent-Type: text/htmlrnrnhello 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, '
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/4484/viewspace-2821307/ ,如需转载,请注明出处,否则将追究法律责任。