从存储库项目中调用Signalr Hub方法

问题描述

我有一个webapi项目，在其中配置了SignalR集线器。我可以从api项目中向客户端发送消息，但是我必须从存储库项目中发送消息。

MyAAPIProject>控制器：

[HttpGet]
[Route("test")]
public IHttpActionResult UpdateEmployees()
{
    _empRepo.Update();
    // This is working fine =>
    // MessageHub hub = new MessageHub();
    // hub.SendMessage("something");
}

MyAPIProject> SignalR集线器：

namespace MyAPIProject.Hubs
{
    public class MessageHub : Hub
    {
        public async void SendMessage(MessageDto p,string connectionId)
        {
            await Context.Clients.Client(connectionId).OnProgress(p);
        }
    }
}

我已经在WebApi项目中添加了SignalRHub，因为根据文档，我们需要在OWIN Startup类中配置signalr，该类只能在Web项目（例如我的webapi项目）中调用，而不能在类库（例如我的存储库项目）中调用。 / p>

MyAPIProject>启动：

public class Startup
{
    public void Configuration(IAppBuilder app)
    {
        app.MapAzureSignalR(this.GetType().FullName);
    }
}

RepositoryProject> EmpRepo：

public void Update()
{
    <<some task>>
    // This is what I want to do =>
    // MessageHub hub = new MessageHub();
    // hub.SendMessage("something");
    <<some task>>
}

基本上，从我的webapi控制器方法中，我正在调用存储库（单独的项目）方法，该方法可以完成整个任务，并且必须定期发送任务进度。为了使用SignalRHub发送消息，我必须从存储库中引用webapi项目。

但是我担心这会造成循环依赖。

有人可以建议我如何在没有循环依赖的情况下实现此功能吗？

解决方法

听起来您需要使用Microsoft.AspNet.SignalR.Client实现SignalR client。您可以从nuget中添加它。

假设您的SignlaR集线器实现了NotifyUpdateMethod。作为简化示例，您可以创建一个Messenger服务。

public class MessengerService : IDisposable
    {
        private readonly HubConnection hubConnection;
        private readonly IHubProxy hubProxy;

        public MessengerService(HubConnection hubConnection)
        {
            this.hubConnection = hubConnection ?? throw new ArgumentNullException(nameof(hubConnection));
            hubProxy = hubConnection.CreateHubProxy(HubName);
        }

        public void Connect()
        {
            hubConnection.Start().Wait();
        }

        public void NotifyUpdate(int id)
        {
            hubProxy.Invoke(NotifyUpdateMethod,id);
        }
    }
}

您可以创建此服务的实例以连接到集线器并发送消息。