SignalR在asp.net core下使用

 public IServiceProvider ConfigureServices(IServiceCollection services)
 {
services.AddSignalR();
｝


public void Configure(IApplicationBuilder app,IHostingEnvironment env,IConferenceService service,IBackgroundJobClient backgroundJobs)
{
app.UseSignalR(routes =>
            {
                routes.MapHub<DialogueHub>("/Hub"); 
 //这个定义的Hub就是虚拟出来的服务地址，我们的具体服务文件也会放这个路径
            });
｝

import n from ‘namespace‘;
import * as sg from ‘../../libs/signal/dist/browser/signalr‘;
n.namespace(‘cj.signalR‘);
cj.signalR = sg;

import n from ‘namespace‘;
n.namespace(‘cj.hub‘);

cj.hub = {
//构建页面元素
init: function (options) {
var self = this;
this.setting = {};
$.extend(this.setting,options || {});
self.bindEvent();

},
//绑定事件
bindEvent: function () {
var self = this;

var data = JSON.parse($(‘#djson‘).val());

if (typeof vm_dialogue === ‘undefined‘) {
window.vm_dialogue = cj.ko_data(data,‘vm_dialogue‘);
} else {
cj.ko_dataRebind(data,vm_dialogue);
}

console.info(‘dialogue‘,data);

var connection = new cj.signalR.HubConnectionBuilder().withUrl("/Hub").build();
//这个这样实例化，好处当然是全部归一到自己定义的cj命名空间了

//监听这个ReceiveMessage方法，这个是后台设置的第一个参数，这里对应名字就好
//至于第二个参数后，有多个重载，现在支持10个object,
//例子暂时返回一个item对象
connection.on("ReceiveMessage",(item) => {
//var msg = item.Context.replace(/&/g,"&amp;").replace(/</g,"&lt;").replace(/>/g,"&gt;");

var userid = $(‘#huserid‘).val();
var dias = cj.tojs(vm_dialogue);
var dia = { Id: item.id,Context: item.context,Name: item.name,Logo: item.logo };
if (item.id === $(‘#huserid‘).val()) {
dia.IsOwner = true;
dia.IsVisable = false;
//判断是否当前用户发送
}
else {
dia.IsOwner = false;
dia.IsVisable = true;
}

dias.Items.push(dia);
cj.ko_dataRebind(dias,vm_dialogue);
if (typeof $(‘.ps--active-y‘)[0] !== ‘undefined‘) {
$(‘.ps--active-y‘).scrollTop($(‘.ps--active-y‘)[0].scrollHeight);
}

});
//这里加载必须打开，然后这里的通讯才生效
connection.start().then(function () {
//document.getElementById("sendButton").disabled = false;
}).catch(function (err) {
return console.error(err.toString());
});

$(‘#msg_send‘).click(function (event) {
var userid = $(‘#huserid‘).val();
var message = $(‘#type_msg‘).val();
//这里可看出异步ajax,把对应的内容发送到hub里面
connection.invoke("SendMessageById",userid,message).catch(function (err) {
return console.error(err.toString());
});
event.preventDefault();
});

}
};

 public class DialogueHub : Microsoft.AspNetCore.SignalR.Hub
{
   /// <summary>
        /// 根据用户ID发送消息
        /// </summary>
        /// <param name="userid"></param>
        /// <param name="message"></param>
        /// <returns></returns>
        public async Task SendMessageById(string userid,string message)
        {
//具体service通过DI注入得到，
            var user = _service.UserBackById(Guid.Parse(userid));
            DialogueItem item = new DialogueItem();
            item.Context = message;
            item.Id = userid;
            item.Name = user.Name;
            item.Logo = user.Logo;
            await Clients.All.SendAsync("ReceiveMessage",item);
 //这个对应js的on方法，这个方法可支持10个obj参数

        }

 protected ICacheService _Cache;
        protected ILogger<DialogueHub> _logger;
        protected IConferenceService _service;
        public DialogueHub(ICacheService cache,ILogger<DialogueHub> logger,IConferenceService service
            )
        {
            _Cache = cache;
            _logger = logger;
            _service = service;
        }

}