mongols的反向代理和负载均衡功能

mongols是c++ 服务器基础设施库，它最近更新提供了反向代理和负载均衡功能。

以下为用mongols代理两个nodejs后端(8888和8889)并与nginx压测对比图：

压测显示mongols已经完全超过nginx。

以下是压测代码。

首先是nodejs：

var http = require('http');
var port = 8888;//8889

http.createserver(function (request, response) {
    response.writehead(200, {'content-type': 'text/plain'});

    response.end('hello world\n');
}).listen(port);

console.log('server running at http://127.0.0.1:'+port+'/');

然后是mongols:

#include <unistd.h>
#include <sys/wait.h>
#include <sys/signal.h>
#include <sys/prctl.h>

#include <mongols/util.hpp>
#include <mongols/tcp_proxy_server.hpp>

#include <cstring>
#include <iostream>
#include <functional>

int main(int, char**) {
    //    daemon(1, 0);
    auto f = [](const mongols::tcp_server::client_t & client) {
        return true;
    };
    int port = 9090;
    const char* host = "127.0.0.1";

    mongols::tcp_proxy_server server(host, port, 5000, 8192, 0/*2*/);

    server.set_enable_http_mode(true);
    server.set_enable_http_lru_cache(true);
    server.set_http_lru_cache_expires(1);
    server.set_default_http_content();

    //see example/nodejs
    server.set_backend_server(host, 8888);
    server.set_backend_server(host, 8889);

    //    server.run(f);


    std::function<void(pthread_mutex_t*, size_t*) > ff = [&](pthread_mutex_t* mtx, size_t * data) {
        server.run(f);
    };

    std::function<bool(int) > g = [&](int status) {
        std::cout << strsignal(wtermsig(status)) << std::endl;
        return false;
    };

    mongols::multi_process main_process;
    main_process.run(ff, g);
}

 

同样的后端，同样多的工作进程，如果比较于nginx的proxy_pass方案，无论是否开启缓存，mongols的并发性能都要强于nginx。

 

mongols还提供易开发的连接级的安全防护。比如上面的f，可重新写为：

 auto f = [](const mongols::tcp_server::client_t & client) {
        if(client.ip=="x.x.x.x"){
            return false;
        }
        if(client.u_size>100000){
            return false;
        }
        if(client.count/difftime(time(0),client.t)>50){
            return false;
        }
        return true;
    };

该functional以类client_t为参数。开发者可从该参数获取连接的系统唯一标识符sid，连接建立时间t，该连接已经发送数据的次数count，该连接的ip，以及服务器保持在线的连接总数u_size。

现在，f表示：如果服务器总连接数超过100000，或者单个连接发送数据的频率超过每秒50次，或者当前连接ip为x.x.x.x，就关闭当前连接。

关闭连接时，对tcp代理返回空字符串，对http代理返回403错误。开发者可通过set_default_content方法设置默认返回值。

 

仓库：https://github.com/webcpp/mongols

文档：https://mongols.hi-nginx.com/