在 signalR 核心启动时设置自定义 ID

Setting custom ID on signalR core start

我正在构建一个涉及 1:1 客户和管理员会话的应用程序。 我正在使用 opentok 将客户与管理员联系起来,并为他们的会话创建一个唯一的 ID。 将有多个 customer:administrator 会话,但每个会话都应该是唯一的。

我正在使用 React 和 asp.net core 3.

我希望能够在客户和管理员之间建立私人 Signal R 连接。没有授权设置,它全部基于他们将在他们的查询字符串中给出的唯一 ID。

目前我正在像这样连接到 React 中的 Signal R:

import { HubConnectionBuilder } from '@aspnet/signalr';
import { useState, useEffect } from "react";
import config from "config.js";

export default function useSignalR() {
    const [hubConnection, setHubConnection] = useState(null);  

    useEffect(() => {
        //ideally ill supply the connection a guid here
        let connectionBuilder = new HubConnectionBuilder()
            .withUrl(config.signalRServerUrl)
            .build();

        setHubConnection(connectionBuilder);
        connectionBuilder.start()
            .then(() => console.log("signalr connection started"))
            .catch((err) => console.log("Error while establishihng connection ", err));
    }, []);

    return hubConnection;
}

管理员和客户正在使用相同的功能连接到 asp.net 核心信号 R 集线器,目前看起来像这样:

public class PhotoHub : Hub
{
    public async Task TakeSnapShot()
    {
        await Clients.All.SendAsync("takeSnapShot");
    }
}

我想它看起来像这样:

仅伪代码

 //in javascript connection
  let connectionBuilder = new HubConnectionBuilder()
        .withProperty(uniqueId)   //pseudo code
        .withUrl(config.signalRServerUrl)
        .build();

<-- 在下面的服务器上 -->

public class PhotoHub : Hub
{
    public async Task TakeSnapShot(uniqueId)
    {
       var clientsInSession = Clients.where(customId == uniqueId); //pseudo code  
       foreach (var client in clientsInSession){
           await client.SendAsync("takeSnapShot");   //pseudo code
       }
    }
}

当您在集线器中使用此代码连接到集线器时,SignalR 已经提供了唯一的连接 ID

    public string GetConnectionId()
    {
        return Context.ConnectionId;
    }

所以你可以这样调用

 var connection = new signalR.HubConnectionBuilder().withUrl("/connectionHub").build();

        connection.start().then(function () {
            console.log("connected");

            connection.invoke('getConnectionId')
                .then(function (connectionId) {
                    console.log(connectionId)
                }).catch(err => console.error(err.toString()));;

        });