通过 Azure SignalR 连接 .net6 Web 服务和 .net6 wpf 应用程序

Question

我正在 Azure 上运行一个 Web 服务，它连接到 SignalR，如下所示：

我的 Hub 类：

public class ChangeRequest : Hub
{
    protected IHubContext<ChangeRequest> _context;

    public ChangeRequest(IHubContext<ChangeRequest> context) => _context = context;
    public Task? Send(Guid id) =>
        _context.Clients?.All?.SendAsync("SendMessage", id);
}

我的 Programm.cs

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.
builder.Services.AddControllers();
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();
builder.Services.AddDbContext<CPLopsEntities>(options => options.UseSqlServer(@"Server=tcp:noris.database.windows.net,1433;Initial Catalog=CPLopsTest;Persist Security Info=False;User ID=user;Password=!Pw12345;MultipleActiveResultSets=False;Encrypt=True;TrustServerCertificate=False;Connection Timeout=30;"));
builder.Services.AddTransient<ChangeRequest>();

builder.Services.AddSignalR().AddAzureSignalR("Endpoint=https://xxxxxxx.service.signalr.net;AccessKey=xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx;Version=1.0;");

var app = builder.Build();

// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
    app.UseSwagger();
    app.UseSwaggerUI();
}

app.UseHttpsRedirection();
app.UseAuthorization();
app.MapControllers();

app.UseAzureSignalR(r => r.MapHub<ChangeRequest>("/com"));

using (var scope = app.Services.CreateScope())
    scope.ServiceProvider.GetRequiredService<CPLopsEntities>().Database.Migrate();

app.Run();

当通过调用 Web 服务添加新条目时，我调用 _hub.Send()

private readonly CPLopsEntities _context;
private readonly ChangeRequest _hub;
public CompanyController(CPLopsEntities context, ChangeRequest hub)
{
    _context = context;
    _hub = hub;
}

public IActionResult Insert(Entry entry)
{
    Guid newId = CompanyDB.Instance.InsertEntry(entry);
    _hub.Send(newId);
    return Ok();
}

：客户端是一个WPF应用程序，我没有找到很多关于实现的信息。到目前为止，我发现的是：

private const string host = "https://xxxxxxxx.service.signalr.net";
private HubConnection connection;
private Thread thread;
public MainViewModel()
{
    thread = new Thread(() =>
    {
        connection = new HubConnectionBuilder()
        .WithUrl(host + "/com")
        .WithAutomaticReconnect()
        .Build();
        
        connection.On<Guid>("ReceiveMessage", g => ExternalLoadCompany(g));
        connection.StartAsync();
    });
    thread.Start();
}

private void ExternalLoadCompany(Guid id)
{
    if (ApiCall.GetCompany(id).Result is Company c)
    {
        Companies.Clear();
        Companies.Add(c);
    }
}

到目前为止，我的 WPF 应用程序无法识别 Web 服务发送的任何消息，这是有道理的，因为我没有对其进行身份验证，但是，我没有找到有关如何传递完整连接字符串的信息包括尝试注册我的 WPF 应用程序时的 AccessKey，到目前为止我发现的所有信息都是 blazor 应用程序或其他类型的 Web 应用程序。

Answer 1

您的服务器端代码正在调用“SendMessage”，而客户端正在查找“ReceiveMessage”。服务器端正在调用客户端上的方法，但该方法不存在。

PS：您不需要启动该线程。 Task.Run 会更好。