Передача сообщения через SignalR. Как сделать однократное соединение с сервером?

Question

[Андрей]

Добрый день! Прошу вашего совета в таком моменте : существует приложение web api (.NET Core 3.1), которое при получении данных должно отобразить сообщение на сайте с помощью SignalR. Технически у меня всё получилось, но реализация мне не нравится, т.к. соединение с сервером где находится хаб устанавливается каждый раз.
Как правильно сделать, что бы соединение устанавливалось однократно при запуске приложения web api?

Спасибо!

public class SendToSignalR
{
    HubConnection connection;

    public SendToSignalR()
    {
        try
        {
            connection = new HubConnectionBuilder()
                 .WithUrl("http://localhost:5176/chat")
                 .Build();
            Console.WriteLine("Connect to signalr");

        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
    }
    public async Task SendMessage(string message)
    {
        try
        {
            await connection.StartAsync();
            await connection.InvokeAsync("Broadcast", message);
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
    }
}

Comments

[Sergey В.]

Не совсем понятно - в чём проблема? Насколько я понял, после соединения с сервером, соединение через некоторое время отваливается? Это штатное поведение. Чтобы соединение не отваливалось по таймауту - делайте периодический пинг отправкой сообщения. У меня методы так и названы: Ping и Pong

[Andrei SunnyPh]

Согласен с тем что, особых проблем, в установке нового соединения по тайм ауту вообще то и нет. Но кроме этого хотелось бы добавить, что SIgnalR это обертка над тремя типами соединений Long Polling, SSE и WebSockets, не каждый из них действительно поддерживает непрерывное соединение, подробнее об этом вот в этом видео. И можно конечно жестко настроить что соединение может быть установлено через WebSocket, и задать произвольное время для такого соединения, но тогда не все веб клиенты смогут получать обновления данных, так как может быть такая ситуация, что некоторые из клиентов используют веб-браузеры без поддержки веб сокетов.

[Андрей]

Sergey В., проблема в том, что на api идёт много запросов и при каждом запросе я устанавливаю соединение. Мне это решительно не нравится((

[Sergey В.]

Андрей, из описания задачи не совсем понятно - что у Вас выступает в роли клиента. Если web страница - можно установить соединение после загрузки страницы и передавать данные по мере необходимости. Чтобы соединение не разрывалось по таймауту, можно сделать таймер для пинга.

[Андрей]

Sergey В., в роли клиента web api, которая принимает данные от оборудования. Часть из этих данных я в реальном времени хочу отображать на сайте. И отображаю, но реализация хромала. Сейчас Lapish72 подсказал решение и у меня всё работает отлично! Одно соединение с сервером при запуске web api и всё.

Answer 1

[Lapish72]

Нет примера вызова методов из вашего класса, но могу предположить, что вы каждый раз инициализируете его. Вам нужно сделать ваш класс Singleton'ом. Для этого в Startup ConfigureServices зарегистрируйте ваш сервис:

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddSingleton<ВашСервис>();
    }
}

И затем в Program:

public class Program
{
    public static async Task Main(string[] args)
    {
        var host = CreateHostBuilder(args).Build();
        var service = host.Services.GetRequiredService<ВашСервис>();
        service.ConnectToServer(); //Подключаемся к SignalR

        host.Run();
    }
}

UPD:
Советую поменять название класса на более общее, например, SignalrService, а метод SendToSignalR на Connect.

Comments

[Андрей]

Добрый день! Спасибо, что откликнулись! Вы абсолютно правы, каждый раз, когда надо было отправить сообщение, я инициализировал класс. Идея с добавлением в сервис - супер! Я изменил название класса и методов в нём на более логичные, как вы и предложили.

public class SignalRService
{
    HubConnection connection;

    public void ConnectToSignalR()
    {
        try
        {
            connection = new HubConnectionBuilder()
                 .WithUrl("http://localhost:5176/chat")
                 .Build();
            Console.WriteLine("Connect to signalr");

        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
    }
    public async Task SendMessage(string message)
    {
        try
        {
            await connection.StartAsync();
            await connection.InvokeAsync("Broadcast", message);
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
    }
}

Добавил сервис :
services.AddSingleton<SignalRService>();

И его запуск.

public class Program
 {        
     public static void Main(string[] args)
     {            
         var host = CreateHostBuilder(args).Build();
         var service = host.Services.GetRequiredService<SignalRService>();
         service.ConnectToSignalR();
         host.Run(); 
     }        

     public static IHostBuilder CreateHostBuilder(string[] args) =>
         Host.CreateDefaultBuilder(args)
             .ConfigureWebHostDefaults(webBuilder =>
             {
                 webBuilder.UseStartup<Startup>();
             });
 }

Но никак не пойму, как мне вызвать метод SendMessage на уже инициализированном экземпляре?

[HttpPost]
public async Task<IActionResult> AddVehicleAsync(Root _root)
{
<Тут вызываю метод ....SendMessage(message) >
}

Спасибо!

[Андрей]

Разобрался!

Спасибо вам, всё заработало!

[Lapish72]

Андрей, рад помочь. Только сейчас заметил, что вы в подключаетесь к SignalR в SendMessage, а в ConnectToSignalR просто инициализируете класс. Этот код не подключает вас к серверу. Подключение происходит именно в StartAsync.

connection = new HubConnectionBuilder()
                 .WithUrl("http://localhost:5176/chat")
                 .Build();

Перенесите
await connection.StartAsync();
в метод ConnectToSignalR. Затем поменяйте возвращаемый тип на Task в ConnectToSignalR и в Main у Startup.

[Андрей]

Lapish72, Спасибо, попробую ваш вариант. Пока я сделал вот так :

if (connection.State == HubConnectionState.Disconnected)
 {
     await connection.StartAsync();
 }
 await connection.InvokeAsync("Broadcast", message);

в принципе работает))

Ещё раз большое спасибо за совет!

[Lapish72]

Андрей, если ваш вариант вас устраивает, то оставляйте его, но это нарушение SRP.

Метод отправки сообщения не должен вообще подключаться к серверу. Он должен именно отправлять сообщение и все. И что будете делать, если при отправке State == Disconnected в первый раз не получилось подключиться, а получится лишь на 5й? Вы потеряете 4 сообщения. Тут по-хорошему нужно отдельно постоянно переподключаться к серверу и если в момент разрыва соединения в ваш метод в Controller пришли сообщения, то нужно будет их отправить при подключении к хабу SignalR. Что-то вроде того.

[Андрей]

Lapish72, понял и согласен с вами. Буду переделывать и придерживаться правильных решений. Спасибо!