记录Ocelot + SignalR 多服务端测试

2023-02-26 17:07:03

前言

分两个项目，一个Gatway，一个SignalR

贴代码

1、Gatway

1、引用Ocelot

2、添加一点点代码

Startup.cs

3、简单配置ocelot

ocelot.json

{

  "ReRoutes": [

    {

      "DownstreamPathTemplate": "/{catchAll}", //下游路径

      "DownstreamScheme": "ws", //https  //下游协议

      "DownstreamHostAndPorts": [ // 下游主机及端口

        {

          "Host": "127.0.0.1",	// 这里是我后面signalr地址

          "Port": 53353

        },

        {

          "Host": "127.0.0.1",

          "Port": 53354

        },

        {

          "Host": "127.0.0.1",

          "Port": 53355

        }

      ],

      "UpstreamPathTemplate": "/gateway/{catchAll}", // 上游路径

      "UpstreamHttpMethod": [ "GET", "POST", "PUT", "DELETE", "OPTIONS" ], //上游使用的http方法

      "LoadBalancerOptions": {

        "Type": "RoundRobin" //雨露均沾

        //LeastConnection 任务少的接客

        //NoLoadBalance 天将降大任于斯人也

      }

    }

  ],

  "GlobalConfiguration": {  //全局配置

    "BaseUrl": "http://127.0.0.1:5000"

  }

}

2、signalr

1、Startup.cs

2、chat.js

//const connection = new signalR.HubConnectionBuilder()

//    .withUrl("http://127.0.0.1:5000/gateway/chatHub")  // 这里使用http

//    .configureLogging(signalR.LogLevel.Information)

//    .build();

const connection = new signalR.HubConnectionBuilder()

    .withUrl("ws://127.0.0.1:5000/gateway/chatHub", {   // 这里使用WebSockets，不这样写连不上的

        skipNegotiation: true,

        transport: signalR.HttpTransportType.WebSockets

    })

    .configureLogging(signalR.LogLevel.Trace)

    .build();

connection.on("ReceiveMessage", (user, message) => {

    const encodedMsg = user + " says " + message;

    const li = document.createElement("li");

    li.textContent = encodedMsg;

    document.getElementById("messagesList").appendChild(li);

});

document.getElementById("sendButton").addEventListener("click", event => {

    const user = document.getElementById("userInput").value;

    const message = document.getElementById("messageInput").value;

    connection.invoke("SendMessage", user, message).catch(err => console.error(err.toString()));

    event.preventDefault();

});

connection.start().catch(err => console.error(err.toString()));