syxdevcode博客

Nginx配置SignalR负载

发表于 更新于 分类于
本文字数： 2.7k 阅读时长 ≈ 2 分钟 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
upstream apiclusterhealthy{
    server 10.10.0.17:30000;
    server 10.10.0.19:30000;
    server 10.10.0.39:30000;

    ip_hash;
}

map $http_connection $connection_upgrade {
    "~*Upgrade" $http_connection;
    default keep-alive;
}

## server 内配置
    #
    location /cloud/hubs/ {
        proxy_pass   http://apiclusterhealthy;   #转发请求的地址
        rewrite      ^/cloud/(.*)$ /$1 break;

        # include      /etc/nginx/nginxconfig.io/proxy.conf;
        # Configuration for WebSockets
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection $connection_upgrade;
        proxy_cache off;
        # WebSockets were implemented after http/1.0
        proxy_http_version 1.1;

        # Configuration for ServerSentEvents
        proxy_buffering off;

        # Configuration for LongPolling or if your KeepAliveInterval is longer than 60 seconds
        proxy_read_timeout 100s;

        proxy_set_header Host $host;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import * as SignalR from '@microsoft/signalr';
import { ElNotification } from 'element-plus';
import { getToken } from '/@/utils/axios-utils';

// 初始化SignalR对象
// WebSockets配置
const connection = new SignalR.HubConnectionBuilder()
    .configureLogging(SignalR.LogLevel.Information)
    .withUrl(`${import.meta.env.VITE_API_URL}/hubs/onlineUser?access_token=${getToken()}`, { transport: SignalR.HttpTransportType.WebSockets, skipNegotiation: true })
    .withAutomaticReconnect({
        nextRetryDelayInMilliseconds: () => {
            return 5000; // 每5秒重连一次
        },
    })
    .build();
connection.keepAliveIntervalInMilliseconds = 15 * 1000; // 心跳检测15s
connection.serverTimeoutInMilliseconds = 2 * 60 * 1000; // 超时时间2m
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
services.AddSignalR(hubOptions =>
    {
        hubOptions.EnableDetailedErrors = true;
        hubOptions.ClientTimeoutInterval= TimeSpan.FromMinutes(2);
        hubOptions.KeepAliveInterval = TimeSpan.FromMinutes(1);
    })
    .AddMessagePackProtocol()
    .AddStackExchangeRedis(options =>
    {
        options.Configuration.ChannelPrefix = signalRRedisOpt.Prefix;
        options.ConnectionFactory = async writer =>
        {
            var config = new ConfigurationOptions
            {
                AbortOnConnectFail = false,
                ServiceName = signalRRedisOpt.ServiceName,
                AllowAdmin = true,
                DefaultDatabase = signalRRedisOpt.DefaultDb,
                Password = signalRRedisOpt.Password
            };
            signalRRedisOpt.EndPoints.ForEach(o => config.EndPoints.Add(o));
            //config.SetDefaultPorts();
            var connection = await ConnectionMultiplexer.ConnectAsync(config, writer);
            connection.ConnectionFailed += (_, e) =>
            {
                "Connection to Redis failed.".LogError();
            };

            if (!connection.IsConnected)
            {
                "Did not connect to Redis.".LogError();
            }
            return connection;
        };
    });