我最近使用AspBoilerplate (Abp)启动了一个新项目，并使用 SignalR 作为某种广播机制来告诉连接的客户端数据库中的某些记录是否更改或添加或删除。如果我使用 SignalR Hub 作为我的 AppService 的代理，一切正常并通知客户端
public class TestHub : Hub
{
IMyAppService = _service
public TestHub(IMyAppService service)
{
_service = service;
}
public void CreateEntry(EntryDto entry)
{
_service.Create(entry);
Clients.All.entryCreated(entry);
}
}
但是，如果我尝试利用 Abp 的EventBus的优势，那么我实现了我的 AppService 以将事件发送到 EventBus：
class MyAppService : ApplicationService, IMyAppService
{
public IEventBus EventBus { get; set; }
private readonly IMyRepository _myRepository;
public LicenseAppService(ILicenseRepository myRepository)
{
EventBus = NullEventBus.Instance;
_myRepository = myRepository;
}
public virtual EntryDto CreateLicense(EntryDto input)
{
var newEntry = Mapper.Map<EntryDto >(_myRepository.Insert(input));
EventBus.Trigger(new EntryCreatedEventData { Entry = newEntry});
return newEntry;
}
}
然后我尝试将集线器直接用作 EventHandler，但这失败了，因为 abp 在需要处理事件时创建自己的 EventHandler 类实例。但这里的代码只是为了完整性：
public class TestHub : Hub,
IEventHandler<EntryCreatedEventData>
{
public void Handle(EntryCreatedEventData data)
{
Clients.All.entryCreated(data.Entry);
}
}
在此之后，我创建了一个单独的 Listener 类并尝试像这样使用集线器上下文并使用一个非常空的集线器：
public class TestHub : Hub
{
}
public class EntryChangeEventHandler : IEventHandler<EntryCreatedEventData>
{
private IHubContext _hubContext;
public EntryChangeEventHandler()
{
_hubContext = GlobalHost.ConnectionManager.GetHubContext<TestHub>();
public void Handle(EntryCreatedEventData data)
{
_hubContext.Clients.All.entryCreated(eventData.Entry);
}
}
在最后一个解决方案中，一切都跑到了这条线上
_hubContext.Clients.All.entryCreated(eventData.Entry);
但是在我的javascript实现的客户端，该方法永远不会被调用。客户端（基于 DurandalJs）在使用 Hub 作为代理和我想走的新方式之间没有改变。
用于使用信号器的客户端插件
define(["jquery", "signalr.hubs"],
function ($) {
var myHubProxy
function connect(onStarted, onCreated, onEdited, onDeleted) {
var connection = $.hubConnection();
myHubProxy = connection.createHubProxy('TestHub');
connection.connectionSlow(function () {
console.log('We are currently experiencing difficulties with the connection.')
});
connection.stateChanged(function (data) {
console.log('connectionStateChanged from ' + data.oldState + ' to ' + data.newState);
});
connection.error(function (error) {
console.log('SignalR error: ' + error)
});
myHubProxy .on('entryCreated', onCreated);
myHubProxy .on('updated', onEdited);
myHubProxy .on('deleted', onDeleted);
connection.logging = true;
//start the connection and bind functions to send messages to the hub
connection.start()
.done(function () { onStarted(); })
.fail(function (error) { console.log('Could not Connect! ' + error); });
}
return signalr =
{
connect: connect
};
});
使用插件查看：
define(['jquery', 'signalr/myHub],
function ($, myHubSR) {
return function () {
var that = this;
var _$view = null;
that.attached = function (view, parent) {
_$view = $(view);
}
that.activate = function () {
myHubSR.connect(that.onStarted, that.onCreated, that.onEdited, that.onDeleted);
}
that.onStarted= function () {
//do something
}
that.onCreated= function (data) {
//do something
}
that.onEdited = function (data) {
//do something
}
that.onDeleted= function (data) {
//do something
}
}
});
所以有人知道为什么我打电话时永远不会调用 onCreated
_hubContext.Clients.All.entryCreated(eventData.Entry);
?
为了测试 signalR 通信是否有效，我添加了一个直接调用客户端方法的方法。调用此方法更新成功推送到客户端。所以我认为问题在于使用 IHubContext 对所有客户端进行远程调用有任何线索在使用 IHubContext 时会出现什么问题？
public class TestHub : Hub
{
public TestHub ()
:base()
{ }
public void Test()
{
this.Clients.All.entryCreated(new EntryDto());
}
}