Как получить соединение TransportType в клиенте SignalR?

ОБНОВЛЯТЬ

После тщательного исследования этой проблемы мы обнаружили, что, поскольку HubConnectionBuilder не предоставляет методы, которые могут напрямую обращаться к Transport, если нам необходимо реализовать его на стороне клиента signalr, нам нужно самим инкапсулировать HubConnection для доступа к Transport, но мы потеряем более продвинутое прослушивание. такие методы, как Connection.on, которые необходимо переписать самим.

Для клиента и сервера signalr протокол установления соединения должен быть согласован обеими сторонами. Метод сервера OnConnectedAsync обязательно будет выполнен, поэтому я предпочитаю, чтобы сервер реализовал эту функцию. Вы можете выбрать, отправлять его на сторону клиента или нет.

Вот мой образец.

Серверная часть

public override async Task OnConnectedAsync()
{
    ...
    var transportType = Context.Features.Get<IHttpTransportFeature>()?.TransportType.ToString();

    await Clients.Caller.SendAsync("ReceiveTransportType", transportType);

    await base.OnConnectedAsync();
}

Сторона клиента

connection.On<string>("ReceiveTransportType", transportType =>
{
    Console.WriteLine($"Transport Type: {transportType}");
});

Поскольку этот протокол представления предполагается использовать на этапе отладки разработчика, я не думаю, что этот метод повлияет на производительность.

После отладки и просмотра свойств я наконец нашел TransportType с помощью следующего метода GetTransportType.

Важно отметить, что мы должны объявить протокол при подключении.

options.Transports = HttpTransportType.LongPolling;

Если не объявлено, по умолчанию будут выведены три протокола.

using Microsoft.AspNetCore.Http.Connections;
using Microsoft.AspNetCore.SignalR.Client;
using System.Reflection;
using System.Text;

Console.OutputEncoding = Encoding.UTF8;
System.Console.OutputEncoding = System.Text.Encoding.UTF8;
//Console.WriteLine("Hello, World!");
// URL of the SignalR server
string url = "https://23p1z4dk-7189.euw.devtunnels.ms/mainhub?nickname=consoleapp1";

// Create connection
var connection = new HubConnectionBuilder()
    .WithUrl(url, options =>
    {
        options.Headers.Add("Authorization", "consoleapp1");
        options.Transports = HttpTransportType.LongPolling;
    })
    .Build();

// Connect to the server
try
{
    await connection.StartAsync();
    Console.WriteLine("Connection successful!");

    var transportType = Test.GetTransportType(connection);
    Console.WriteLine($"Transport type: {transportType}");
}
catch (Exception ex)
{
    Console.WriteLine($"Connection failed: {ex.Message}");
}

// Listen for messages from the server
connection.On<string>("ReceiveMessage", message =>
{
    Console.WriteLine($"Received message: {message}");
});

// Send a message to the server
await connection.InvokeAsync("SendMessage", "Hello from console app");

// Wait for user input to prevent console from closing
Console.WriteLine("Press any key to exit...");
Console.ReadKey();

// Close the connection
await connection.StopAsync();

public static class Test
{
    public static string GetTransportType(HubConnection connection)
    {
        // Get the _connectionFactory private field
        var connectionFactoryField = typeof(HubConnection).GetField("_connectionFactory", BindingFlags.NonPublic | BindingFlags.Instance);
        if (connectionFactoryField == null)
        {
            throw new InvalidOperationException("Could not find _connectionFactory field.");
        }

        var connectionFactoryValue = connectionFactoryField.GetValue(connection);

        // Get the _httpConnectionOptions private field
        var httpConnectionOptionsField = connectionFactoryValue.GetType().GetField("_httpConnectionOptions", BindingFlags.NonPublic | BindingFlags.Instance);
        if (httpConnectionOptionsField == null)
        {
            throw new InvalidOperationException("Could not find _httpConnectionOptions field.");
        }

        var httpConnectionOptionsValue = httpConnectionOptionsField.GetValue(connectionFactoryValue);

        // Get the Transports property
        var transportsProperty = httpConnectionOptionsValue.GetType().GetProperty("Transports", BindingFlags.Public | BindingFlags.Instance);
        if (transportsProperty == null)
        {
            throw new InvalidOperationException("Could not find Transports property.");
        }

        var transportsValue = (HttpTransportType)transportsProperty.GetValue(httpConnectionOptionsValue);

        return transportsValue.ToString();
    }
}

Я также хотел прокомментировать другое решение, с которым я экспериментировал.

Если вы включите вход в SinglaR, добавив это в построитель соединений:

.ConfigureLogging(loggingConfig =>
{
    loggingConfig.SetMinimumLevel(LogLevel.Debug);
    loggingConfig.AddConsole();
})

На уровне отладки вы увидите информацию о транспортировке в журнале. Это действительно помогает, но я хотел отобразить это диагностически и в своем приложении, что потребует сопоставления строк и т. д.