SignalR: real-time коммуникации в .NET

1dotnet add package Microsoft.AspNetCore.SignalR

1public class ChatHub : Hub
2{
3    public async Task SendMessage(string user, string message)
4    {
5        await Clients.All.SendAsync("ReceiveMessage", user, message);
6    }
7
8    public async Task SendToGroup(string groupName, string message)
9    {
10        await Clients.Group(groupName).SendAsync("ReceiveMessage", message);
11    }
12
13    public async Task JoinGroup(string groupName)
14    {
15        await Groups.AddToGroupAsync(Context.ConnectionId, groupName);
16        await Clients.Group(groupName).SendAsync("UserJoined", Context.User?.Identity?.Name);
17    }
18
19    public async Task LeaveGroup(string groupName)
20    {
21        await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
22    }
23
24    public override async Task OnConnectedAsync()
25    {
26        await Clients.All.SendAsync("UserConnected", Context.ConnectionId);
27        await base.OnConnectedAsync();
28    }
29
30    public override async Task OnDisconnectedAsync(Exception? exception)
31    {
32        await Clients.All.SendAsync("UserDisconnected", Context.ConnectionId);
33        await base.OnDisconnectedAsync(exception);
34    }
35}

1// Program.cs
2builder.Services.AddSignalR();
3
4app.MapHub<ChatHub>("/chathub");

1import * as signalR from "@microsoft/signalr";
2
3const connection = new signalR.HubConnectionBuilder()
4    .withUrl("/chathub")
5    .configureLogging(signalR.LogLevel.Information)
6    .build();
7
8connection.on("ReceiveMessage", (user, message) => {
9    console.log(`${user}: ${message}`);
10});
11
12connection.start().catch(err => console.error(err));
13
14// Отправка сообщения
15await connection.invoke("SendMessage", "User", "Hello!");

1var connection = new HubConnectionBuilder()
2    .WithUrl("https://localhost:5001/chathub")
3    .Build();
4
5connection.On<string, string>("ReceiveMessage", (user, message) =>
6{
7    Console.WriteLine($"{user}: {message}");
8});
9
10await connection.StartAsync();
11await connection.InvokeAsync("SendMessage", "User", "Hello!");

1// Добавление в группу
2await Groups.AddToGroupAsync(Context.ConnectionId, "developers");
3
4// Отправка в группу
5await Clients.Group("developers").SendAsync("Notify", "New deploy!");
6
7// Удаление из группы
8await Groups.RemoveFromGroupAsync(Context.ConnectionId, "developers");

1[Authorize]
2public class SecureHub : Hub
3{
4    public async Task SendPrivateMessage(string userId, string message)
5    {
6        await Clients.User(userId).SendAsync("ReceivePrivate", message);
7    }
8}
9
10// Настройка авторизации
11builder.Services.AddSignalR()
12    .AddHubOptions<SecureHub>(options =>
13    {
14        options.ClientTimeoutInterval = TimeSpan.FromSeconds(30);
15        options.KeepAliveInterval = TimeSpan.FromSeconds(15);
16    });

1builder.Services.AddSignalR()
2    .AddStackExchangeRedis("localhost:6379", options =>
3    {
4        options.Configuration.ChannelPrefix = "MyApp";
5    });

1builder.Services.AddSignalR()
2    .AddAzureSignalR(builder.Configuration["AzureSignalR:ConnectionString"]);