通过 SignalR HubContext 从集线器所在的项目中的方法发送消息

Question

我有一个 WebAPI 项目，其中 API、服务和数据层都位于同一解决方案的不同项目中。作为我的服务项目中方法的一部分，我想向 API 项目中集线器的连接客户端发送消息。到目前为止，我发现的所有示例都在一个项目中包含所有内容，并使用控制器作为通过集线器发送消息的示例。

我已经尝试过依赖注入 (Autofac)，但是我无法获得对 MessageHub 的引用。

[HubName("messages")]
public class MessageHub : Hub
{
    public void ShowNewMessage(string message)
    {
        Clients.All.showMessageOnPage(message);
    }
}

可以在这里看到我的 Injecting 尝试：Inject SignalR IHubContext into service layer with Autofac

Answer 1

请查看此选项：

1. 在您的服务（或更好的域）层项目中定义通用集线器接口。类似IMessageBroker。
2. 在您的表示层 (WebAPI) 项目中实现此接口并使用 IConnectionManager 进行 HubContext 检索。
3. 在表示层的 IoC 容器 (Autofac) 中注册接口
4. 在应用服务中注入接口

伪代码：

域层：

public interface IMessageBroker
{
    void ShowNewMessage(string message)
}

服务层：

public class NotificationService: INotificationService
{
    private readonly IMessageBroker _messageBroker;

    public NotificationService(IMessageBroker messageBroker)
    {
        _messageBroker = messageBroker;
    }

    public void RunNotification(string message)
    {
        _messageBroker.ShowNewMessage(message);
    }
}

表示层：

[HubName("messages")]
public class MessageHub: Hub
{
    public void ShowNewMessage(string message)
    {
        Clients.All.showMessageOnPage(message);
    }
}


public class MessageBroker: IMessageBroker
{
    private readonly IConnectionManager _connectionManager;

    public MessageBroker(IConnectionManager connectionManager)
    {
        _connectionManager = connectionManager;
    }

    public void ShowNewMessage(string message)
    {
        var hub = _connectionManager.GetHubContext<MessageHub>();
        // Use Hub Context and send message
    }
}

Autofac 注册（表示层）：

// Register Hubs
builder.RegisterHubs(Assembly.GetExecutingAssembly());

// Register Autofac resolver into container to be set into HubConfiguration later
builder.RegisterType<AutofacDependencyResolver>().As<IDependencyResolver>().SingleInstance();

// Register ConnectionManager as IConnectionManager so that you can get hub context via IConnectionManager injected to your service
builder.RegisterType<ConnectionManager>().As<IConnectionManager>().SingleInstance();

// Register interface
builder.RegisterType<MessageBroker>().As<IMessageBroker>();

here 也有类似的 SO 主题。