代理服务器

tcp_proxy_server 主要是为需要反向代理和负载均衡的场景准备的。

它既能做tcp代理，也能作http代理。内置负载均衡算法为轮询法。

HTTP反向代理

来看一个http反向代理的例子：

  2. #include <unistd.h>
  3. #include <sys/wait.h>
  4. #include <sys/signal.h>
  5. #include <sys/prctl.h>
  7. #include <mongols/util.hpp>
  8. #include <mongols/tcp_proxy_server.hpp>
  10. #include <cstring>
  11. #include <iostream>
  12. #include <functional>
  14. int main(int, char**) {
  15.     //    daemon(1, 0);
  16.     auto f = [](const mongols::tcp_server::client_t & client) {
  17.         return true;
  18.     };
  20.     auto h = [&](const mongols::request & req) {
  21.         return true;
  22.     };
  24.     int port = 9090;
  25.     const char* host = "127.0.0.1";
  27.     mongols::tcp_proxy_server server(host, port, 5000, 8192, 0/*2*/);
  30.     server.set_enable_http_lru_cache(true);
  31.     server.set_http_lru_cache_expires(1);
  32.     server.set_default_http_content();
  34.     //see example/nodejs
  35.     server.set_backend_server(host, 8888);
  36.     server.set_backend_server(host, 8889);
  37.     if (!server.set_openssl("openssl/localhost.crt", "openssl/localhost.key")) {
  38.         return -1;
  39.     }
  41.     //    server.run(f,h);
  44.     std::function<void(pthread_mutex_t*, size_t*) > ff = [&](pthread_mutex_t* mtx, size_t * data) {
  45.         server.run(f, h);
  46.     };
  48.     std::function<bool(int) > g = [&](int status) {
  49.         std::cout << strsignal(WTERMSIG(status)) << std::endl;
  50.         return false;
  51.     };
  53.     mongols::multi_process main_process;
  54.     main_process.run(ff, g);
  55. }

上例以多进程方式运行一个http反向代理服务器，服务器本身监听9090端口，代理两个后端服务器，后端服务器端口分别是8888和8889。如果访问后端需要安全连接，可通过set_backend_server的第三个参数（bool值）进行配置，默认是false即无需使用安全连接。

两个后端服务器都是输出helloworld的nodejs程序，代码很简单：

  2. var http = require('http');
  3. var port = 8888;//8889
  5. http.createServer(function (request, response) {
  6.     response.writeHead(200, {'Content-Type': 'text/plain'});
  7.     response.end('Hello World\n');
  8. }).listen(port);
  10. console.log('Server running at http://127.0.0.1:'+port+'/');

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

tcp_proxy_serverVSnginx_proxy_pass.png

实际上，从 web server 到 reverse proxy，对比于mongols，nginx其实是一款很慢的服务器软件。

缓存加速

仅对http代理有效。

tcp_proxy_server通过lru算法+过期时间的策略实现加速。因为缓存在内存中，非常快。只有当请求方法、URI和参数都相同的请求，才会对应到同一个缓存内容。

安全防护

tcp_proxy_server可配置连接级的安全防护，通过run方法的参数。该参数是一个需要返回布尔值的functional,返回false则意味着直接关闭连接。

该functional以类client_t为参数。开发者可从该参数获取连接的系统唯一标识符sid，连接建立时间t，该连接已经发送数据的次数count，该连接的ip，以及服务器保持在线的连接总数u_size。有了这些量，开发者很轻易即可写出负责安全防护的functional,比如上例中的f可重写如下:

  2.     auto f = [](const mongols::tcp_server::client_t & client) {
  3.         if(client.ip=="x.x.x.x"){
  4.             return false;
  5.         }
  6.         if(client.u_size>100000){
  7.             return false;
  8.         }
  9.         if(client.count/difftime(time(0),client.t)>50){
  10.             return false;
  11.         }
  12.         return true;
  13.     };

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

如果开启http代理模式，还可以配置请求过滤的functional。例如上例中的h，可根据HTTP请求头信息实现自定义过滤。

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

TCP 反向代理

例子:

  1. #include <unistd.h>
  2. #include <sys/wait.h>
  3. #include <sys/signal.h>
  4. #include <sys/prctl.h>
  6. #include <mongols/util.hpp>
  7. #include <mongols/tcp_proxy_server.hpp>
  9. #include <cstring>
  10. #include <iostream>
  11. #include <functional>
  13. int main(int, char**) {
  14.     //    daemon(1, 0);
  15.     auto f = [](const mongols::tcp_server::client_t & client) {
  16.         return true;
  17.     };
  19.     int port = 9090;
  20.     const char* host = "127.0.0.1";
  22.     mongols::tcp_proxy_server server(host, port, 5000, 8192, 0/*2*/);
  24.     server.set_enable_tcp_send_to_other(true);
  25.     //see example/nodejs
  26.     server.set_backend_server(host, 8886);
  27.     server.set_backend_server(host, 8887);
  28.     if (!server.set_openssl("openssl/localhost.crt", "openssl/localhost.key")) {
  29.         return -1;
  30.     }
  32.     server.run(f);
  34. }

set_enable_tcp_send_to_other决定消息是否转发其他在线客户端。

原文: https://mongols.hi-nginx.com/doc/proxy.html