基于SignalR的服务端和客户端通讯处理

signalr是一个.net core/.net framework的实时通讯的框架，一般应用在asp.net上，当然也可以应用在winform上实现服务端和客户端的消息通讯，本篇随笔主要基于signalr的构建一个基于winform的服务端和客户端的通讯处理案例，介绍其中的处理过程。

1、signalr基础知识

signalr是一个.net core/.net framework的开源实时框架. signalr的可使用web socket, server sent events 和 long polling作为底层传输方式。

signalr基于这三种技术构建, 抽象于它们之上, 它让你更好的关注业务问题而不是底层传输技术问题。

signalr将整个信息的交换封装起来，客户端和服务器都是使用json来沟通的，在服务端声明的所有hub信息，都会生成javascript输出到客户端，.net则依赖proxy来生成代理对象，而proxy的内部则是将json转换成对象。

rpc

rpc (remote procedure call). 它的优点就是可以像调用本地方法一样调用远程服务.

signalr采用rpc范式来进行客户端与服务器端之间的通信.

signalr利用底层传输来让服务器可以调用客户端的方法, 反之亦然, 这些方法可以带参数, 参数也可以是复杂对象, signalr负责序列化和反序列化.

 

hub

hub是signalr的一个组件, 它运行在asp.net core应用里. 所以它是服务器端的一个类.

hub使用rpc接受从客户端发来的消息, 也能把消息发送给客户端. 所以它就是一个通信用的hub.

在asp.net core里, 自己创建的hub类需要继承于基类hub。在hub类里面, 我们就可以调用所有客户端上的方法了. 同样客户端也可以调用hub类里的方法.

 

signalr可以将参数序列化和反序列化. 这些参数被序列化的格式叫做hub 协议, 所以hub协议就是一种用来序列化和反序列化的格式.

hub协议的默认协议是json, 还支持另外一个协议是messagepack。messagepack是二进制格式的, 它比json更紧凑, 而且处理起来更简单快速, 因为它是二进制的.

此外, signalr也可以扩展使用其它协议。

 

2、基于signalr构建的winform服务端和客户端案例

服务单界面效果如下所示，主要功能为启动服务、停止服务，广播消息和查看连接客户端信息。

 客户端主要就是实时获取在线用户列表，以及发送、应答消息，消息可以群发，也可以针对特定的客户端进行消息一对一发送。

 客户端1：

客户端2：

构建的项目工程，包括服务端、客户端和两个之间的通讯对象类，如下所示。

服务端引用

客户端引用

服务端启动代码，想要定义一个startup类，用来承载signalr的入口处理。

[assembly: owinstartup(typeof(signalrserver.startup))]
namespace signalrserver
{
    public class startup
    {
        public void configuration(iappbuilder app)
        {
            var config = new hubconfiguration();
            config.enabledetailederrors = true;

            //设置可以跨域访问
            app.usecors(microsoft.owin.cors.corsoptions.allowall);
            //映射到默认的管理
            app.mapsignalr(config);
        }
    }
}

 我们前面介绍过，服务端使用winform程序来处理它的启动，停止的，如下所示。

因此界面上通过按钮事件进行启动，启动服务的代码如下所示。

        private void btnstart_click(object sender, eventargs e)
        {
            this.btnstart.enabled = false;
            writetoinfo("正在连接中....");

            task.run(() =>
            {
                serverstart();
            });
        }

 这里通过启动另外一个线程的处理，通过webapp.start启动入口类，并传入配置好的端口连接地址。

        /// <summary>
        /// 开启服务
        /// </summary>
        private void serverstart()
        {
            try
            {
                //开启服务
                signalr = webapp.start<startup>(serverurl);

                initcontrolstate(true);
            }
            catch (exception ex)
            {
                //服务失败时的处理
                writetoinfo("服务开启失败,原因:" + ex.message);
                initcontrolstate(false);
                return;
            }

            writetoinfo("服务开启成功 : " + serverurl);
        }

连接地址我们配置在xml文件里面，其中的 serverurl 就是指向下面的键url, 配置的url如下所示：

<?xml version="1.0" encoding="utf-8"?>
<configuration>
    <startup> 
        <supportedruntime version="v4.0" sku=".netframework,version=v4.6.2"/>
    </startup>
  <appsettings>
    <add key="url" value="http://localhost:17284"/>
  </appsettings>

停止服务代码如下所示，通过一个异步操作停止服务。

        /// <summary>
        /// 停止服务
        /// </summary>
        /// <returns></returns>
        private async task stopserver()
        {
            if (signalr != null)
            {
                //向客户端广播消息
                hubcontext = globalhost.connectionmanager.gethubcontext<signalrhub>();
                await hubcontext.clients.all.sendclose("服务端已关闭");

                //释放对象
                signalr.dispose();
                signalr = null;

                writetoinfo("服务端已关闭");
            }
        }

服务端对signalr客户端的管理是通过一个继承于hub的类signalrhub进行管理，这个就是整个signalr的核心了，它主要有几个函数需要重写，如onconnected、ondisconnected、onreconnected、以及一个通用的消息发送addmessage函数。

 

 客户端有接入的时候，我们会通过参数获取连接客户端的信息，并统一广播当前客户的状态信息，如下所示是服务端对于接入客户端的管理代码。

        /// <summary>
        /// 在连接上时
        /// </summary>
        public override task onconnected()
        {
            var client = jsonconvert.deserializeobject<clientmodel>(context.querystring.get("param"));
            if (client != null)
            {
                client.connid = context.connectionid;
                //将客户端连接加入列表
                if (!portal.gc.clientlist.exists(e => e.connid == client.connid))
                {
                    portal.gc.clientlist.add(client);
                }
                groups.add(client.connid, "client");

                //向服务端写入一些数据
                portal.gc.mainform.writetoinfo("客户端连接id:" + context.connectionid);
                portal.gc.mainform.writetoinfo(string.format("客户端 【{0}】接入: {1} ,  ip地址: {2} \n 客户端总数: {3}", client.name, context.connectionid, client.ipaddress, portal.gc.clientlist.count));

                //先所有连接客户端广播连接客户状态
                var imcp = new statemessage()
                {
                    client = client,
                    msgtype = msgtype.state,
                    fromconnid = client.connid,
                    success = true
                };
                var jsonstr = jsonconvert.serializeobject(imcp);
                clients.group("client", new string[0]).addmessage(jsonstr);

                return base.onconnected();

            }
            return task.fromresult(0);
        }

客户端的接入，需要对相应的hubconnection事件进行处理，并初始化相关信息，如下代码所示。

        /// <summary>
        /// 初始化服务连接
        /// </summary>
        private void inithub()
        {
            。。。。。。

            //连接的时候传递参数param
            var param = new dictionary<string, string> {
                { "param", jsonconvert.serializeobject(client) }
            };
            //创建连接对象，并实现相关事件
            connection = new hubconnection(serverurl, param);

            。。。。。。//实现相关事件
            connection.closed += hubconnection_closed;
            connection.received += hubconnection_received;
            connection.reconnected += hubconnection_succeed;
            connection.transportconnecttimeout = new timespan(3000);

            //绑定一个集线器
            hubproxy = connection.createhubproxy("signalrhub");
            addprotocal();
        }

        private async task startconnect()
        {
            try
            {
                //开始连接
                await connection.start();
                await hubproxy.invoke<commonresult>("checklogin", this.txtuser.text);

                hubconnection_succeed();//处理连接后的初始化

                。。。。。。
            }
            catch (exception ex)
            {
                console.writeline(ex.stacktrace);
                this.richtextbox.appendtext("服务器连接失败：" + ex.message);

                initcontrolstatus(false);
                return;
            }
        }

客户端根据收到的不同协议信息，进行不同的事件处理，如下代码所示。

        /// <summary>
        /// 对各种协议的事件进行处理
        /// </summary>
        private void addprotocal()
        {
            //接收实时信息
            hubproxy.on<string>("addmessage", dealmessage);

            //连接上触发connected处理
            hubproxy.on("logined", () =>
                this.invoke((action)(() =>
                {
                    this.text = string.format("当前用户:{0}", this.txtuser.text);
                    richtextbox.appendtext(string.format("以名称【" + this.txtuser.text + "】连接成功!" + environment.newline));
                    initcontrolstatus(true);
                }))
            );

            //服务端拒绝的处理
            hubproxy.on("rejected", () =>
                this.invoke((action)(() =>
                {
                    richtextbox.appendtext(string.format("无法使用名称【" + this.txtuser.text + "】进行连接!" + environment.newline));
                    initcontrolstatus(false);
                    closehub();
                }))
            );

            //客户端收到服务关闭消息
            hubproxy.on("sendclose", () =>
            {
                closehub();
            });
        }

例如我们对收到的文本信息，如一对一的发送消息或者广播消息，统一进行展示处理。

        /// <summary>
        /// 处理文本消息
        /// </summary>
        /// <param name="data"></param>
        /// <param name="basemsg"></param>
        private void dealtext(string data, basemessage basemsg)
        {
            //json转换为文本消息
            var msg = jsonconvert.deserializeobject<textmessage>(data);
            var ownerclient = clientlist.firstordefault(f => f.connid == basemsg.fromconnid);
            var ownername = ownerclient == null ? "系统广播" : ownerclient.name;

            this.invoke(new action(() =>
            {
                richtextbox.appendtext(string.format("{0} - {1}:\n {2}" + environment.newline, datetime.now, ownername, msg.message));
                richtextbox.scrolltocaret();
            }));
        }

客户端对消息的处理界面

而客户端发送消息，则是统一通过调用hub的addmessage方法进行发送即可，如下代码所示。

        private void btnsendmessage_click(object sender, eventargs e)
        {
            if (txtmessage.text.length == 0)
                return;

            var message = new textmessage() {
                msgtype = msgtype.text,
                fromconnid = client.connid,
                toconnid = this.toid,
                message = txtmessage.text,
                success = true };

            hubproxy.invoke("addmessage", jsonconvert.serializeobject(message));
            txtmessage.text = string.empty;
            txtmessage.focus();
        }

其中的hubproxy是我们前面连接服务端的时候，构造出的一个代理对象

hubproxy = connection.createhubproxy("signalrhub");

客户端关闭的时候，我们销毁相关的对象即可。

        private void form1_formclosing(object sender, formclosingeventargs e)
        {
            if (connection != null)
            {
                connection.stop();
                connection.dispose();
            }
        }

以上就是signalr的服务端和客户端的相互配合，相互通讯过程。