后端C# .net 前端uni-app 集成SignalR做即时通讯

        后端集成SignalR比较简单，首先要在解决方案中依赖几个SignalR的库，SignalR的库就是做即时通讯的主要库，我们建立连接、收发信息都需要用这个库来进行。

        除了这几个库以外，还要还有几个依赖库要一并依赖进来。

        Owin库的作用主要是为了在项目StartUp时将SignalR库的几个Hub文件注册起来，Hub文件就相当于是我们接口中的Controller文件。

        然后在项目下创建一个文件夹Hubs，Hubs下创建文件ChatHub

using Common.Log;
using Microsoft.Ajax.Utilities;
using Microsoft.AspNet.SignalR;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Web;
using WebGrease;
using WinexHK.Hubs.ConectionOperate;

namespace WinexHK.Hubs
{
    /// <summary>
    /// ChatHub
    /// </summary>
    public class ChatHub : PersistentConnection
    {
        private ConnectionManagement summaryTableCon = new ConnectionManagement();

        /// <summary>
        /// 连接成功后调用
        /// </summary>
        /// <param name="request"></param>
        /// <param name="connectionId"></param>
        /// <returns></returns>
        protected override Task OnConnected(IRequest request, string connectionId)
        {
            //获得SignalR的连接id
            var connid = connectionId;
            //获得用户id
            var userid = "123321";
            Console.Write($"【{connid}】：已建立连接！");

            //判断一下用户是不是已经链接了
            var checkUserConn = summaryTableCon.IsConn(connid, userid);
            if (!checkUserConn)
            {
                //添加一个新的连接
                summaryTableCon.AddConnInfo(new SignalRConn()
                {
                    UserId = userid,
                    ConnectionId = connid
                });
            }
            //更新连接
            else
            {
                summaryTableCon.UpdateConnInfo(userid, connid);
            }

            return Connection.Send(connectionId, $"【用户：{connectionId}】真正连接成功！");
            //return base.OnConnected(request, connectionId);
        }

        /// <summary>
        /// 接收到请求的时候调用
        /// </summary>
        /// <param name="request"></param>
        /// <param name="connectionId"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        protected override async Task OnReceived(IRequest request, string connectionId, string data)
        {
            var keys = new Dictionary<string, string>
            {
                { "葡萄酒", "wine" },
                { "红酒", "wine" },
                { "白酒", "wine" },
                { "霞多丽", "grapery" },
                { "雷司令", "grapery" }
            };

            var values = new Dictionary<string, string>
            {
                { "wine", "这是一款葡萄酒" },
                { "grapery", "这是一串葡萄" }
            };

            //获得用户id
            var userid = "123321";
            await Task.Factory.StartNew(async () =>
            {
                var key = "";
                for (int i = 0; i < keys.Keys.Count; i++)
                {
                    if (data.Contains(keys.Keys.ToList()[i]))
                    {
                        key = keys.Values.ToList()[i];
                        break;
                    }
                }
                var value = "未找到匹配条目";
                if (values.ContainsKey(key))
                {
                    value = values[key];
                }

                await Connection.Send(connectionId, value);
            }, TaskCreationOptions.LongRunning);
        }

        /// <summary>
        /// 连接中断的时候调用
        /// </summary>
        /// <param name="request"></param>
        /// <param name="connectionId"></param>
        /// <param name="stopCalled"></param>
        /// <returns></returns>
        protected override Task OnDisconnected(IRequest request, string connectionId, bool stopCalled)
        {
            Console.Write($"【{connectionId}】：已断开连接！");
            //获得SignalR的连接id
            var connid = connectionId;
            //关闭连接
            summaryTableCon.DelConnInfo(connid);
            return base.OnDisconnected(request, connectionId, stopCalled);
        }

        /// <summary>
        /// 连接超时重新连接的时候调用
        /// </summary>
        /// <param name="request"></param>
        /// <param name="connectionId"></param>
        /// <returns></returns>
        protected override Task OnReconnected(IRequest request, string connectionId)
        {
            return base.OnReconnected(request, connectionId);
        }
    }
}

        文件里有几个回调方法，OnConnected用户连接时，OnReceived收到信息时、OnDisconnected用户断开连接，OnReconnected用户重连，也可以通过Connection.Send方法给连接用户发送消息。

        下面是Hub里用到的用到的ConnectionManagement的代码，用来保存并管理用户的连接状态。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

namespace WinexHK.Hubs.ConectionOperate
{
    /// <summary>
    /// 连接管理
    /// </summary>
    public class ConnectionManagement
    {
        /// <summary>
        /// 用户连接集合
        /// </summary>
        public static List<SignalRConn> SignalRConns { get; set; } = new List<SignalRConn>();

        /// <summary>
        /// 添加连接
        /// </summary>
        /// <param name="conn"></param>
        public void AddConnInfo(SignalRConn conn)
        {
            SignalRConns.Add(conn);
        }

        /// <summary>
        /// 删除连接
        /// </summary>
        /// <param name="connid"></param>
        public void DelConnInfo(string connid)
        {
            var signalRConns = SignalRConns.FirstOrDefault(u => u.ConnectionId == connid);
            if (signalRConns != null)
            {
                SignalRConns.Remove(signalRConns);
            }
        }

        /// <summary>
        /// 更新链接（老的链接不起作用了）
        /// 场景：客户端重连了，userid没变，但是connid变了
        /// </summary>
        /// <param name="userId">用户id</param>
        /// <param name="newConnsId">新的链接id</param>
        public void UpdateConnInfo(string userId, string newConnsId)
        {
            var signalRConns = SignalRConns.FirstOrDefault(u => u.UserId.ToLower() == userId.ToLower());
            if (signalRConns != null)
            {
                signalRConns.ConnectionId = newConnsId;
            }
        }

        /// <summary>
        /// 判断用户是否已经链接
        /// </summary>
        /// <param name="connid">连接id</param>
        /// <param name="userid">用户id</param>
        /// <returns></returns>
        public bool IsConn(string connid, string userid)
        {
            var userConn = SignalRConns.FirstOrDefault(u => u.ConnectionId.ToLower() == connid.ToLower() && u.UserId.ToLower() == userid.ToLower());
            return userConn == null ? false : true;
        }
    }
}

        最后是用到的一个类，保存用户id及连接id

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

namespace WinexHK.Hubs.ConectionOperate
{
    /// <summary>
    /// 连接
    /// </summary>
    public class SignalRConn
    {
        /// <summary>
        /// 系统用户id
        /// </summary>
        public string UserId { get; set; }

        /// <summary>
        /// SignleR链接Id（每次链接SignalR都会分配一个id）
        /// </summary>
        public string ConnectionId { get; set; }
    }
}

        这几个类定义好，基本上后端的代码就完成了，然后开始做前端部分。前端部分分两个版本，一个是PC版的网页，一个是uni-app版的网页，由于uni-app对于SignalR框架的适配性不好，我们暂时先不开发微信小程序及app版的SignalR，等后面技术成熟了在进行开发。

        PC版跟uni-app网页版比较类似，基本上依赖3个js文件就可以搞定了，页面自己看着改改。

        一个是js的库，版本应该都ok，不挑。一个是signalR的库，还有一个是做聊天要用的调用方法的库。下面是chat_hub.js的代码

// 连接服务，xxxx里直接填后端的地址即可
var connection = $.connection("http://xxxx/chathub");

// 建立链接
connection.start(function () {
    //连接成功
    console.log("【" + new Date().toLocaleString() + "】连接成功！");
    //发送消息
    connection.send("给我一杯葡萄酒吧");
});

// 连接断开
connection.disconnected(function () {
    console.log("【" + new Date().toLocaleString() + "】连接断开！");
});

// 接收服务器发来的消息
connection.received(function (data) {
    console.log("【" + new Date().toLocaleString() + "】接收服务器发来的消息：");
    console.log(data);
});

        uni-app版跟PC版有些不一样的，因为uni-app不是实时编译运行的，所以PC的模式对uni-app并不奏效，配进去后发现JQuery加载不出来，SignalR的js会报错。

        解决办法有两步，首先在main.js中就将JQuery直接依赖上，并配进window对象中

        其次要对SignalR中所有用到JQuery的地方进行修改，所有对$的使用都要从window对象中获取

好比说这个地方，改之前是上面这样的，改之后是下面这样的

        这么改的原因是因为SignalR的js对于uni-app的项目来说属于外部文件，你在uni-app项目内全局引入的JQuery在外部js中并不生效，但window对象是通用的，所以可以在uni-app项目初始化时把JQuery对象保存在window对象中，使用的时候调window中的$即可。

        整个文件改完基本就通了，不通你再来问我。

        文章来源地址https://www.toymoban.com/news/detail-854132.html

到了这里，关于后端C# .net 前端uni-app 集成SignalR做即时通讯的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！