NetCore SignalR 重連邏輯實現

1-配置連接

var connection = new signalR.HubConnectionBuilder() 
        .withUrl("http://localhost:5000/doopstream") 
        //重連函數，參數是重連間隔時間，單位毫秒
        .withAutomaticReconnect([0, 3000, 5000, 10000, 15000, 30000])
        .configureLogging(signalR.LogLevel.Information)
        .build();

2-啟動邏輯

//啟動模塊
    async function start(){ 
        connection.start().then(()=>getdata()).catch(err => {
        var msg="strat:"+err.toString();
        console.error(msg);
        setTimeout(()=>start(),5000);
    });
    }
    //觸發啟動
   start();

3-重連成功后的處理邏輯

//重連成功后的處理機制
    connection.onreconnected((connectionId)=>{
        
        console.log("onreconnected:"+connectionId);
        getdata();
    });

4-連接關閉后的處理邏輯

//連接關閉后的處理機制
    connection.onclose(async (error)=>{
        var msg="close:"+error.toString();
        console.error(msg);
         await start();
    });

5-數據接收處理邏輯

/接收數據邏輯
function getdata() {
        console.log("connected");
        connection.invoke("Subscribe", 'test').catch(err => console.error(err.toString()));
        connection.on("Receive", function (ch, message) {
            console.log(message);
            var p = document.createElement("p");
            p.innerHTML = ch + '#' + message;
            var div = document.getElementById("div");
            div.appendChild(p);
        }); 
    };

PS:SignalR js 庫需要用 @microsoft/signalr@3.x.x 庫，不然沒有 withAutomaticReconnect 這個函數

6-參考文檔

https://docs.microsoft.com/zh-cn/aspnet/core/signalr/javascript-client?view=aspnetcore-3.1

PS:不知道是我的理解能力太差了，還是微軟的中文文檔沒寫好，折騰了一小會搞懂了，記錄一下