通过 Nginx 反向代理 DolphinDB 集群节点

首先，确保系统已安装编译所需的基本工具和库开发包。在 CentOS 下可以使用 yum 安装，在 Debian/Ubuntu 下使用 apt 安装。例如，在 CentOS 执行：

yum -y install gcc zlib zlib-devel pcre-devel openssl openssl-devel

上述命令安装了GNU 编译器，以及 zlib、OpenSSL、PCRE 等库的开发头文件。特别地，PCRE（Perl Compatible Regular Expression） 是 Nginx 用于处理正则匹配（如 rewrite 和 location）的必要依赖。安装 pcre 和 pcre-devel 可以提供 PCRE 支持；若不安装，在编译 Nginx 时会报错找不到 PCRE。在本教程中我们也展示如何通过源码编译方式集成 PCRE。

从官方源获取 Nginx 和 PCRE 压缩包：

mkdir -p /usr/local/webserver && cd /usr/local/webserver

wget https://nginx.org/download/nginx-1.22.0.tar.gz && wget http://downloads.sourceforge.net/project/pcre/pcre/8.45/pcre-8.45.tar.gz

解压安装包：

tar -zxvf nginx-1.22.0.tar.gz && tar -zxvf pcre-8.45.tar.gz 

上述下载了 Nginx 1.22.0 和 PCRE 8.45 的源码压缩包并解压。通过源码编译 PCRE，我们可以在编译 Nginx 时静态链接该库，从而无需依赖系统已安装的 PCRE。

进入解压后的 Nginx 源码目录，配置编译选项并编译。

编译 PCRE ：

cd /usr/local/webserver/pcre-8.45 && ./configure

make && make install

查看pcre-8.45 的版本：

pcre-config --version

编译 Nginx：

cd /usr/local/webserver/nginx-1.22.0 && ./configure --prefix=/usr/local/webserver/nginx --with-http_stub_status_module --with-http_ssl_module --with-pcre=/usr/local/webserver/pcre-8.45 --with-stream --with-stream_ssl_module

make && make install

在 ./configure 中，--with-pcre=../pcre-8.45 指定了 PCRE 源码路径，配置系统会自动编译该 PCRE 并将其静态链接到 Nginx 二进制中。另外我们启用了 stub_status_module（可选，用于状态监控）、 http_ssl_module（如将来需要支持 HTTPS）stream 和 stream_ssl_module（如需要TCP连接和SSL加密）。--prefix=/usr/local/nginx 指定了安装目录。make install 完成后，Nginx 文件将安装到该目录下：

• 主配置文件：/usr/local/webserver/nginx/conf/nginx.conf
• 可执行文件：/usr/local/webserver/nginx/sbin/nginx
• 日志目录：/usr/local/webserver/nginx/logs/

通常位于:

/usr/local/webserver/nginx/conf/nginx.conf

可以直接复制下面配置内容：

worker_processes auto;  # 工作进程数量，auto 表示自动检测CPU核心数
error_log /usr/local/webserver/nginx/logs/error.log;
pid /usr/local/webserver/nginx/logs/nginx.pid;

include /usr/share/nginx/modules/*.conf;

events {
    worker_connections 1024;  # 每个工作进程最大并发连接数
}

http {
    log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                      '$status $body_bytes_sent "$http_referer" '
                      '"$http_user_agent" "$http_x_forwarded_for"';

    access_log  /usr/local/webserver/nginx/logs/access.log  main;

    sendfile            on;
    tcp_nopush          on;
    tcp_nodelay         on;
    keepalive_timeout   65;
    types_hash_max_size 2048;

    include             /etc/nginx/mime.types;
    default_type        application/octet-stream;

    proxy_http_version 1.1;
    proxy_set_header Host $host;
    proxy_set_header X-Real-IP $remote_addr;
    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
    proxy_set_header X-Forwarded-Proto $scheme;
    proxy_set_header Connection "";

    proxy_connect_timeout 5s;
    proxy_read_timeout 60s;
    proxy_send_timeout 60s;
    proxy_buffers 16 32k;
    proxy_buffer_size 64k;
    proxy_busy_buffers_size 128k;

    include /etc/nginx/conf.d/*.conf;

}

此配置是全局配置和 HTTP 连接性能优化部分，包括：

• proxy_http_version 设置 HTTP/1.1，以支持 WebSocket 协议升级和长连接。
• proxy_set_header 是为了保留客户端 IP 和 Host 头信息，以便 DolphinDB 后端做记录/鉴权/日志分析。
• proxy_read_timeout 在 http {} 块中设置的是全局默认值，表示超过该时间无消息传入则断开连接。如果在某个 server {} 或 location {} 块中重新指定了该参数，那么该局部设置会覆盖全局配置。对于 WebSocket 连接，建议设置更长的超时时间，以避免因静止时间过长而中断。

这些配置需要根据实际 DolphinDB 节点 IP 和代理端口填写，添加到上述的 http {} 块中：

# 定义上游服务器集群
upstream dolphindb_data {
    least_conn;
    server 192.168.1.10:8902;
    server 192.168.1.11:8902;
}

upstream dolphindb_control {
    server 192.168.1.12:8902;
}
    
server {
    listen 80;                # 监听端口80
    server_name  _;                 # 匹配任意主机名（下划线表示默认主机）
    location / {
        proxy_pass http://dolphindb_data;   # 转发请求到上游数据节点
        proxy_http_version 1.1;                # 使用HTTP/1.1与后端通信
        proxy_set_header Host $host;           # 保留原始Host头
        proxy_set_header X-Real-IP $remote_addr;        # 传递客户端真实IP
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;  # 记录代理链IP
        # WebSocket 配置：
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        # 超时配置：
        proxy_connect_timeout 30s;
        proxy_read_timeout 7d;
        proxy_send_timeout 7d;
    }
}

server {
    listen 81;                # 监听端口81
    server_name  _;                 # 匹配任意主机名（下划线表示默认主机）
    location / {
        proxy_pass http://dolphindb_control;   # 转发请求到上游控制节点
        proxy_http_version 1.1;                # 使用HTTP/1.1与后端通信
        proxy_set_header Host $host;           # 保留原始Host头
        proxy_set_header X-Real-IP $remote_addr;        # 传递客户端真实IP
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;  # 记录代理链IP
        # WebSocket 配置：
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        # 超时配置：
        proxy_connect_timeout 30s;
        proxy_read_timeout 7d;
        proxy_send_timeout 7d;
    }
}

配置说明：

• upstream定义了一个上游服务器集群，名称为 dolphindb_cluster。里面列出了三台后端 DolphinDB 节点的地址和端口。默认情况下，不指定策略即为轮询（round-robin）方式，每个请求依次轮流分配到不同节点上。设定least_conn表示选择较少连接的服务器（least_conn）优先。
• server 定义了前端代理服务的监听行为。listen 80; 指定在 80 端口接受客户端请求。server_name _; 使用下划线 _ 作为服务名，表示一个通配的默认主机（意味着无论请求的 Host 为何，都由此虚拟主机处理）。在实际部署中，如果有特定域名，可在此处指定。
• location / 来匹配所有以/开头的请求路径（即对整个站点的请求都处理）。
  • proxy_pass 指定了请求转发的目标：http://dolphindb_cluster。这里使用了上面定义的上游集群名称。
  • proxy_set_header 和相关指令用于配置当前server块代理转发时的HTTP请求头和连接参数，与上一步中的http全局配置含义相同。为了提高代理的健壮性，我们设置了一些超时参数：
  • proxy_connect_timeout 30s; 定义连接后端 DolphinDB 的超时时间（握手超时）。如果在10秒内无法建立与任一后端的TCP连接，Nginx 将返回错误。
  • proxy_send_timeout 7d; 定义向后端发送请求数据的超时时间。
  • proxy_read_timeout 7d; 定义从后端读取响应的静默超时时间。默认值为60秒，如果超过60秒后端没有任何响应数据发送，Nginx 将关闭该连接。对于 WebSocket 长连接场景，建议将此值适当延长，否则当连接空闲超过60秒时，Nginx 会认为后端不响应而切断连接，导致 WebSocket 意外断开（浏览器会收到 1006 异常码）。本例将其延长至7d。总之，proxy_read_timeout 要根据业务情况（如数据推送频率）进行调整，以平衡及时释放闲置连接和保持长连接不断开的需求。

在浏览器中输入:

http://nginx地址IP:配置中的监听端口

或在 VSCode DolphinDB 插件中Connection的配置中添加:

"dolphindb.connections": [
    {
        "name": "nginx",
        "url": "ws://nginx地址IP:配置中的监听端口",
        "autologin": true,
        "username": "admin",
        "password": "123456"
    }
]

与 http {} 同级下方，添加 stream {} 块，用82和83端口反向代理数据和控制节点：

stream {
    upstream dolphindb_data {
        server 192.168.1.10:8902;
        server 192.168.1.11:8902;
    }
    server {
        listen 82;
        proxy_pass dolphindb_data;
    }

    upstream dolphindb_control {
        server 192.168.1.12:8902;
    }
    server {
        listen 83;
        proxy_pass dolphindb_control;
    }
}

/usr/local/webserver/nginx/sbin/nginx -s reload

import dolphindb as ddb
s = ddb.session()
s.connect("192.168.1.20", 82)  # 或 83

--with-http_ssl_module --with-stream_ssl_module

http{
    upstream dolphindb_control {
        server 192.168.1.12:8902;
    }
    
    server {
        listen 81 ssl; 
        ssl_protocols       TLSv1 TLSv1.1 TLSv1.2;
        ssl_ciphers         AES128-SHA:AES256-SHA:RC4-SHA:DES-CBC3-SHA:RC4-MD5;
        ssl_certificate     /path/to/server.crt;
        ssl_certificate_key /path/to/server.key;
        
        location / {
            proxy_pass http://dolphindb_control;
            proxy_http_version  1.1;
            
            proxy_set_header    Host            $host;
            proxy_set_header    X-Real-IP       $remote_addr;
            proxy_set_header    X-Forwarded-For $proxy_add_x_forwarded_for;
            
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection $connection_upgrade;
            
            proxy_connect_timeout 30s;
            proxy_read_timeout 7d;
            proxy_send_timeout 7d;
        }
    }
}   

和无SSL加密时的主要配置区别：

• listen 81 后增加了 ssl
• 指定了 SSL 协议和加密方法
• 指定了必要的 SSL 证书与头信息的地址，可以无需CA，使用openssl以下指令自颁发生成自签名证书和私钥:

  openssl req -x509 -nodes -days 365 -newkey rsa:2048 -keyout server.key -out server.crt

stream {
    upstream dolphindb_control {
        server 192.168.1.12:8902;
    }
    
    server {
        listen 83 ssl; 
        ssl_protocols       TLSv1 TLSv1.1 TLSv1.2;
        ssl_ciphers         AES128-SHA:AES256-SHA:RC4-SHA:DES-CBC3-SHA:RC4-MD5;
        ssl_certificate     /path/to/server.crt;
        ssl_certificate_key /path/to/server.key;
        proxy_pass dolphindb_control;
    }
}

/usr/local/webserver/nginx/sbin/nginx -s reload

端口 81：用于 Web HTTPS访问控制节点，https://192.168.1.20:81/。

端口 83：用于 API 访问控制节点，TCP over SSL 的代理转发，此时的ddb连接配置需加一项 enableSSL=True。

import dolphindb as ddb
s = ddb.session(enableSSL=True)
s.connect("192.168.1.20", 83)