ITPub博客

首页 > IT职业 > IT生活 > node js,golang,socket服务返回hello worl

node js,golang,socket服务返回hello worl

IT生活 作者:pheonix_wan 时间:2021-09-09 10:23:07 0 删除 编辑

初次接触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 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");
                    }
                }
            }
        }
    };
    
}

多线程阻塞,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 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");
                    }
                }
            }
        }
    };
    
}

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 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/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2019-10-10

  • 博文量
    99
  • 访问量
    875