基于SuperSocket的IIS主动推送消息给android客户端

简介: 在上一篇文章《基于mina框架的GPS设备与服务器之间的交互》中,提到之前一直使用superwebsocket框架做为IIS和APP通信的媒介,经常出现无法通信的问题,必须一天几次的手动回收程序池,甚至重起服务器,通常周末接到一个陌生电话,就是说客户端无法登录了,说多了都是泪。

      在上一篇文章《基于mina框架的GPS设备与服务器之间的交互》中,提到之前一直使用superwebsocket框架做为IIS和APP通信的媒介,经常出现无法通信的问题,必须一天几次的手动回收程序池,甚至重起服务器,通常周末接到一个陌生电话,就是说客户端无法登录了,说多了都是泪。痛定思痛,开始找解决方案,其实superwebsocket以IIS做为宿主,就注定他可能不稳定了,当然,它部署非常方便;为了稳定,我开始尝试使用SuperSocket,当然,这也注定了后期部署会麻烦些;生活就是这样哈,鱼和熊掌难兼得。学习一个新东西,就如同一个打怪升级做任务的历程,其中有数不清的陷阱,当然也有绚丽景色。关于服务,WCF等几乎都是第一次运用,其中肯定有很多不对的地方,还请了解的朋友们指出来,以免误了别人。对于SuperSocket之前也只是听说过,本次也只是简单的应用,如有应用不对,或者说得不对的地方,还请江大渔同学指出。另外,江大牛做的事让我的开发变得简单了,在此,对其表示由衷的感谢和敬佩!

消息传递流程

  消息传递流程如图1所示,创建一个Windows Service,并启动superSocket,发布一个WCF,以Windows Service做为宿主,随服务启动与关闭。 IIS通过WCF传递消息给Windows Service,然后再传给superSocket,再传递给android客户端;客户端上传坐标处理给superSocket,再保存于数据库。

                (图1)

 

 

SuperSocket

  以下内容是摘自其官网,大家可以自行查看:SuperSocket 是一个轻量级, 跨平台而且可扩展的 .Net/Mono Socket 服务器程序框架。你无须了解如何使用 Socket, 如何维护 Socket 连接和 Socket 如何工作,但是你却可以使用 SuperSocket 很容易的开发出一款 Socket 服务器端软件,例如游戏服务器,GPS 服务器, 工业控制服务和数据采集服务器等等。-- http://www.supersocket.net/

 

实现自己的AppSession,AppServer

   下载最新版源码,目前最新版应该是1.6.3,好像是马上要发布1.6.4了吧。解决方案如图2,目前我只是简单的应用,源码就没细看了,其实也看不懂,哈哈。

    

          (图2)

      其文档中如下描述:

         AppSession 代表一个和客户端的逻辑连接,基于连接的操作应该定于在该类之中。你可以用该类的实例发送数据到客户端,接收客户端发送的数据或者关闭连接。

     AppServer 代表了监听客户端连接,承载TCP连接的服务器实例。理想情况下,我们可以通过AppServer实例获取任何你想要的客户端连接,服务器级别的操作和逻辑应该定义在此类之中。

   所以,通常情况要根据自己的业务来实现自己的AppSession,AppServer。如,我需求在session断开时,修改app状态;或者我的AppSession有自己特殊的属性。
下面是我实现的自己的AppSession(NoticeSession),AppServer(NoticeServer),有兴趣可以瞥下。

NoticeSession代码如下:

using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Linq;
using System.Text;

using SuperSocket.Common;
using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System.Threading;
using Hangjing.SQLServerDAL.serverinterface;


namespace SuperSocket.SocketService
{
    public class MESSAGETYPE
    {
        /// 
        /// 1表示消息
        /// 
        public const uint MSG = 1;
        /// 
        /// 0表示订单
        /// 
        public const uint ORDER = 0;
    }

    /// 
    /// 自定义连接类MySession,继承AppSession,并传入到AppSession  
    /// 
    public class NoticeSession : AppSession
    {
        bool isSendMessage = false;
        public StringDictionary Cookies { get; private set; }

        /// 
        /// 数据编号,配送员,或者商家编号等
        /// 
        public int DataID
        {
            get;
            set;
        }

        /// 
        /// 类型:1表示骑士,2表示商家
        /// 
        public int Type
        {
            set;
            get;
        }
        /// 
        /// 用户名;
        /// 
        public String UserName
        {
            get;
            set;
        }

        /// 
        /// 密码
        /// 
        public String Password
        {
            get;
            set;
        }

        protected override void OnSessionStarted()
        {

        }

        protected override void HandleUnknownRequest(StringRequestInfo requestInfo)
        {
            //Logger.Debug("NoticeSession.OnSessionStarted:Unknow request");
        }

        protected override void HandleException(Exception e)
        {
            //Logger.Debug("NoticeSession.OnSessionStarted:Unknow request");
        }

        protected override void OnSessionClosed(CloseReason reason)
        {
            Logout();
            base.OnSessionClosed(reason);
        }

        /// 
        /// 根据登录的参数,保存cookie ,并设置属性
        /// 
        public void SetCookie(string cookieValue)
        {
            var cookies = new StringDictionary();

            if (!string.IsNullOrEmpty(cookieValue))
            {
                string[] pairs = cookieValue.Split(';');

                int pos;
                string key, value;

                foreach (var p in pairs)
                {
                    pos = p.IndexOf('=');
                    if (pos > 0)
                    {
                        key = p.Substring(0, pos).Trim();
                        pos += 1;
                        if (pos < p.Length)
                            value = p.Substring(pos).Trim();
                        else
                            value = string.Empty;

                        cookies[key] = Uri.UnescapeDataString(value);
                    }
                }
            }

            this.Cookies = cookies;

            this.UserName = Cookies["name"];
            this.Password = Cookies["password"];
            this.Type = Convert.ToInt32(Cookies["type"]);
        }

        /// 
        /// 向客户端发送消息(0 表示订单 ,1表示消息)
        /// 
        /// 
(0 表示订单 ,1表示消息) /// 消息内容(json) public void SendMessage( uint type, String message) { while (isSendMessage) { Thread.Sleep( 1 ); } isSendMessage = true ; String value = "" ; switch (type) { case MESSAGETYPE.ORDER: value = " ORDER:: " + message; break ; case MESSAGETYPE.MSG: value = " MSG:: " + message; break ; } this .Send(value); isSendMessage = false ; } /// /// session退出,对应骑士下线 /// public void Logout() { if (DataID != 0 && Type == 1 ) { APPUser user = new APPUser( this.UserName, this.Password, this.SessionID, this .Type); if (user.app != null ) { user.app.UpdateLoginState( this.SessionID, 0 ); } } } /// /// 根据编号为类型获取session /// /// /// /// public NoticeSession GetSession( int id, int type) { NoticeSession session = this.AppServer.GetAllSessions().Where(a => a.DataID == id && a.Type == type).FirstOrDefault(); if (session != null ) { return session; } else { return null ; } } } } View Code

 

NoticeServer代码如下:

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 using SuperSocket.SocketBase;
 6 using SuperSocket.SocketBase.Config;
 7 using SuperSocket.SocketBase.Protocol;
 8 using Hangjing.SQLServerDAL.serverinterface;
 9 
10 namespace SuperSocket.SocketService
11 {
12     /// 
13     /// 自定义服务器类MyServer,继承AppServer,并传入自定义连接类MySession 
14     /// 
15     public class NoticeServer : AppServer
16     {
17         protected override bool Setup(IRootConfig rootConfig, IServerConfig config)
18         {
19             return base.Setup(rootConfig, config);
20         }
21 
22         protected override void OnStarted()
23         {
24             base.OnStarted();
25         }
26 
27         protected override void OnStopped()
28         {
29             base.OnStopped();
30         }
31 
32         ///   
33         /// 输出新连接信息  
34         ///   
35         /// 
36 protected override void OnNewSessionConnected(NoticeSession session) 37 { 38 base .OnNewSessionConnected(session); 39 // 输出客户端IP地址 40 // session.Logger.Debug("\r\n NoticeServer.OnNewSessionConnected->" + session.LocalEndPoint.Address.ToString() + ":连接"); 41 42 } 43 44 /// 45 /// 输出断开连接信息 46 /// 47 /// 48 /// 49 protected override void OnSessionClosed(NoticeSession session, CloseReason reason) 50 { 51 // 输出客户端IP地址 52 // session.Logger.Debug("\r\n NoticeServer.OnSessionClosed->" + session.LocalEndPoint.Address.ToString() + ":断开 dataid=" + session.DataID + "&Type=" + session.Type); 53 // 退出 54 if (session.DataID != 0 ) 55 { 56 APPUser user = new APPUser(session.UserName, session.Password, session.SessionID, session.Type); 57 if (user.app != null ) 58 { 59 user.app.UpdateLoginState(session.SessionID, 0 ); 60 } 61 } 62 base .OnSessionClosed(session, reason); 63 } 64 65 } 66 } View Code

 

实现自己的消息处理机制

   消息都会进到MainService.NewRequestReceived 方法中,所以我在这里处理自己的消息。默认消息机制里,会把消息序列化为 StringRequestInfo,这个对像包含Key和Body,默认是用空格分隔的。我主要实现app登录(建立链接),和app上传坐标等两个消息,NewRequestReceived 方法代码如下

  

/// 
        /// 收到新的消息
        /// 
        /// 
/// void NewRequestReceived(NoticeSession session, StringRequestInfo requestInfo) { // session.Logger.Debug("Key=" + requestInfo.Key + "|body=" + requestInfo.Body); switch (requestInfo.Key) { case " Cookie: ": // 这里为了兼容原来的app登录发送的数据 { session.SetCookie(requestInfo.Body); User user = new User(session); Thread thdProcess = new Thread(user.LoginThread); thdProcess.Start(); } break ; case " GPS " : { string json = requestInfo.Body; if (session.DataID == 0 && json == "" ) { return ; } User user = new User(session,json); Thread thdProcess = new Thread(user.UploadGPS); thdProcess.Start(); } break ; } } View Code

 

 LoginThread 主要实现验证用户名,密码后,返回用户相关信息,具体代码如下:

 /// 
        /// 登录函数
        /// 
        public void LoginThread()
        {
            String state = "";
            String message = "";
            APPUser user = new APPUser(session.UserName, session.Password, session.SessionID, session.Type);
            if (user.app == null)
            {
                session.Logger.Debug("登录:" + session.UserName + " type=" + session.Type+"  对像为空");
                return;
            }

            int userid = user.app.APPLogin(session.UserName, session.Password, session.SessionID);

            if (userid > 0)
            {
                NoticeSession ol = session.GetSession(userid, session.Type);
                if (ol != null)
                {
                    state = "-2";
                    message = "Login::{\"userid\":\"" + session.DataID.ToString() + "\",\"state\":\"" + state + "\"}";
                    ol.Send(message);
                    Thread.Sleep(2);
                    ol.Close();
                }
                session.DataID = userid;
                state = "1";
                message = user.app.getLoginJSON(userid,state);
                message = Utils.ToUTF8(message);
                session.Send(message);
                return;
            }
            else
            {
                state = "-1";
                message = "Login::{\"userid\":\"" + session.DataID.ToString() + "\",\"state\":\"" + state + "\"}";
            }
         
            session.Send(message);
            Thread.Sleep(2);
            session.Close();

        }
View Code

  考虑到可能会有骑士,商家,取餐员等对像同时存在,为了保证服务程序的通用性,抽象出每个对像的相同操作。面向接口进行编程,如下图

 

 

  经过,以上简单步骤,运行InstallService.bat,即可创建服务,监听指定端口了。可用TCP&UDP测试工具,简单测试下,看效果,如下图:

  

  

  android客户端方面,是我同事基于mina实现的,这里我就不介绍了,其实我也不太懂,我只是简单的把他原来以websocket协议实现的,修改成了纯数据的了。

创建WCF服务库

  当时在考虑如果把消息(如把订单调度给某个配送员了)传给Windows Service时,考虑了多个方法:想过用数据库,想过用消息队列;但是都觉得不太好,当WCF飘过脑海时,一下子觉得这个可行,其实在此之前,我也只是听过说而已,也许就是因为不熟悉,觉得神奇,才让我觉得稀奇吧。说干就干,看了几篇文章,实现了一个简单的WCF。UserNoticeService.cs实现代码如下,只有一个简单的方法

using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;

namespace Hangjing.WCFService
{
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]
    public class UserNoticeService : IUserNoticeService
    {
        /// 
        /// 添加消息
        /// 
        /// 
用户编号 /// 用户类型 1表示骑士,2表示商家 /// 消息类型 消息类型:0表示订单,1表示纯消息。 /// 消息json public void AddMessage( int userid, int usertype, int messagetype, string message) { NoticeInfo model = new NoticeInfo(); model.UserId = userid; model.UserType = usertype; model.MessageType = messagetype; model.Message = message; NoticeManager nm = NoticeManager.GetInstance(); nm.Add(model); } } } View Code

 

使用委托及时传递消息

  当UserNoticeService.AddMessage 接收到消息后,如何传递给 Windows Service时,也纠结了好久,直到就快放弃思考,准备用消息队列来实现时,才想到委托。这个东西吧,一直觉得很多神奇,之前也花了很多时间去理解,一直觉得似懂非懂的感觉,原来是没有真正的应用。代码部分就比较简单了,以下是NoticeManager.cs相关代码,在UserNoticeService.AddMessage中执行添加的方法。

   

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace Hangjing.WCFService
{
    /// 
    /// 对消息的管理
    /// 
    public class NoticeManager
    {
        public static List NoticeList = new List();
        public static object m_SessionSyncRoot = new object();

        public event AddHandler AddEvent = null;

        private static NoticeManager instance;

        static NoticeManager()  //类型构造器,确保线程安全
        {
            instance = new NoticeManager();
        }

        private NoticeManager() //构造方法为private,这就堵死了外界利用new创建此类型实例的可能
        {
            Thread.Sleep(50);//此处模拟创建对象耗时
        }

        public static NoticeManager GetInstance() //次方法是获得本类实例的唯一全局访问点
        {
            return instance;
        }

        /// 
        /// 添加方法
        /// 
        /// 
public void Add(NoticeInfo model) { // 后期再考虑消息的存储 // foreach (var item in NoticeManager.NoticeList) // { // if (item.UserId == model.UserId && item.UserType == model.UserType) // { // lock (NoticeManager.m_SessionSyncRoot) // { // NoticeManager.NoticeList.Remove(item); // } // } // } // lock (NoticeManager.m_SessionSyncRoot) // { // NoticeManager.NoticeList.Add(model); // } if ( this.AddEvent != null ) { this .AddEvent(model); } } } public delegate void AddHandler(NoticeInfo notice); } View Code

 

在MainService中注册委托

    NoticeManager nm = NoticeManager.GetInstance();
    nm.AddEvent += nm_AddEvent;

IIS通过WCF发送消息

  网站中引用WCF,比较方便,VS 中网站右键,添加-》服务引用,如下图,

  

    调用也非常简单,两行代码:

        wcfnotice.UserNoticeServiceClient unsc = new wcfnotice.UserNoticeServiceClient();
        ///发订单
        unsc.AddMessage(id, se, type, msg);

 

感谢

  这篇文章,写到一半时,特别纠结,觉得自己做的事件,好像没有什么技术含量,只是基于superSocket框架,做了简单的应用,一度想放弃这篇文章,但转念一想,我用这个程序替换原来的 SuperWebSocket后,确实稳定了,app任何时间都可以登录了,也许能对那些正在和我们一样用SuperWebSocket的有所帮助,也希望能共同交流。当然,还有一个原因让我坚持写完了,那就是对江大牛的感谢和敬佩,也希望他能继续完善这个框架。

  

      成为一名优秀的程序员!

版权声明:
作者:J²
有事儿Q我
有事儿W我
编辑: 妞妞
妞妞主页
出处:http://www.cnblogs.com/jijunjian/
本文版权归作者和博客园共有,欢迎转载,大家好,才是真的好!
 
目录
相关文章
|
Linux Android开发 iOS开发
基于.Net开发的ChatGPT客户端,兼容Windows、IOS、安卓、MacOS、Linux
基于.Net开发的ChatGPT客户端,兼容Windows、IOS、安卓、MacOS、Linux
257 0
|
4月前
|
前端开发 Java Shell
【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
287 20
【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
|
4月前
|
Dart 前端开发 Android开发
【09】flutter首页进行了完善-采用android studio 进行真机调试开发-增加了直播间列表和短视频人物列表-增加了用户中心-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
【09】flutter首页进行了完善-采用android studio 进行真机调试开发-增加了直播间列表和短视频人物列表-增加了用户中心-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
101 4
【09】flutter首页进行了完善-采用android studio 进行真机调试开发-增加了直播间列表和短视频人物列表-增加了用户中心-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
|
5月前
|
缓存 前端开发 Android开发
【04】flutter补打包流程的签名过程-APP安卓调试配置-结构化项目目录-完善注册相关页面-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程
【04】flutter补打包流程的签名过程-APP安卓调试配置-结构化项目目录-完善注册相关页面-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程
257 12
【04】flutter补打包流程的签名过程-APP安卓调试配置-结构化项目目录-完善注册相关页面-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程
|
5月前
|
Dart 前端开发 Android开发
【02】写一个注册页面以及配置打包选项打包安卓apk测试—开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草央千澈
【02】写一个注册页面以及配置打包选项打包安卓apk测试—开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草央千澈
116 1
【02】写一个注册页面以及配置打包选项打包安卓apk测试—开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草央千澈
|
XML API PHP
Android使用XML-RPC实现blog客户端
Android使用XML-RPC实现blog客户端
104 2
|
Android开发
Android WindowFeature小探究,Android客户端Web页面通用性能优化实践
Android WindowFeature小探究,Android客户端Web页面通用性能优化实践
|
XML JSON Java
Android App开发即时通信中通过SocketIO在客户端与服务端间传输文本和图片的讲解及实战(超详细 附源码)
Android App开发即时通信中通过SocketIO在客户端与服务端间传输文本和图片的讲解及实战(超详细 附源码)
652 0
|
Java Android开发
Android HIDL客户端构建
Android HIDL客户端构建
76 0
|
缓存 安全 Android开发
[Android 毕业设计/课程设计] 小而美的阅读客户端 App
[Android 毕业设计/课程设计] 小而美的阅读客户端 App