欢迎光临小豌豆知识网!
当前位置:首页 > 电学技术 > 电通讯技术> 一种简单轻量的消息实时推送系统及其实施方法独创技术22917字

一种简单轻量的消息实时推送系统及其实施方法

2021-02-22 02:50:41

一种简单轻量的消息实时推送系统及其实施方法

  技术领域

  本发明涉及移动互联网即时消息推送技术领域,特别涉及一种简单轻量的消息实时推送系统及其实施方法。

  背景技术

  移动互联网是PC互联网发展的必然产物,将移动通信和互联网二者结合起来,成为一体。它是互联网的技术、平台、商业模式和应用与移动通信技术结合并实践的活动的总称。继承了移动随时、随地、随身和互联网开放、分享、互动的优势,是一个全国性的、以宽带IP为技术核心的,可同时提供话音、传真、数据、图像、多媒体等高品质电信服务的新一代开放的电信基础网络,由运营商提供无线接入,互联网企业提供各种成熟的应用。

  伴随移动互联网高速发展的近十年、无线移动办公已然成为时代潮流、“信息互通消息必达”是一款移动办公软件的最低“门槛”。

  由于手机系统的限制任何一款APP停留在后台一定时间内都会被系统回收,这时如何做到“信息互通消息必达”是一个必须要攻克的技术问题,目前尚没有解决上述技术问题的方法,因此,急需一种简单轻量的消息实时推送系统及其实施方法来解决上述问题。

  发明内容

  本发明的目的在于提供一种简单轻量的消息实时推送系统及其实施方法,避免移动端被回收后消息不可达或断网重连后消息丢失等问题,可提供消息推送平台确保任何情况下消息都可必达,业务对接简易,服务轻量快捷,消息实时必达,以解决上述背景技术中提出的问题。

  为实现上述目的,本发明提供如下技术方案:

  一种简单轻量的消息实时推送系统,包括APP客户端、即时消息系统和消息推送平台,所述APP客户端通过无线网络按照全双工通信方式与即时消息系统进行通信,所述即时消息系统通过无线网络按照全双工通信方式与消息推送平台进行通信;

  其中,APP客户端为用户移动设备APP;

  即时消息系统为提供通信服务的后端服务器系统;

  消息推送平台为APP客户端甲方在即时消息系统中生成好的消息体经过消息推送平台推送到APP客户端乙方的后台服务器系统。

  进一步地,所述APP客户端携带有终端设备信息标识及用户信息标识,即时消息系统携带有设备信息标识。

  进一步地,所述消息推送平台上设置有微处理器、存储模块、判断单元和执行单元,所述即时消息系统与微处理器电连接,所述微处理器的输出端与存储模块的输入端电连接,所述存储模块的输出端与判断单元的输入端电连接,所述判断单元与微处理器电连接,所述微处理器的输出端与执行单元的输入端电连接。

  进一步地,所述消息推送平台上设置有检测单元和清理单元,所述微处理器与检测单元电连接,所述检测单元的输出端与存储模块的输入端电连接,所述微处理器的输出端还与清理单元的输入端电连接,所述清理单元的输出端与存储模块的输入端电连接。

  根据本发明的另一个方面,提供了一种简单轻量的消息实时推送系统的实施方法,包括如下步骤:

  S10:将即时消息系统与APP客户端建立连接,APP客户端携带终端设备信息标识及用户信息标识登录即时消息系统;

  S20:将消息推送平台与即时消息系统建立连接,即时消息系统携带设备信息注册消息推送平台;

  S30:消息推送平台中以设备ID唯一标识分组存储设备信息、且生成无序的唯一序列标识后、经国密算法生成身份鉴权唯一标识;

  S40:将即时消息系统与消息推送平台建立连接,即时消息系统得到消息推送平台响应后记录设备唯一标识及身份鉴权唯一标识;

  S50:将APP客户端与即时消息系统建立连接,即时消息系统返回身份鉴权唯一标识到APP客户端。

  进一步地,S30包括如下步骤:

  S301:将微处理器与即时消息系统建立连接,微处理器接收即时消息系统携带的设备信息标识;

  S302:将判断单元分别与存储模块和微处理器建立连接,通过判断单元来判断微处理器接收的即时消息系统携带的设备信息标识在存储模块中是否为身份鉴权唯一标识;

  S303:将微处理器与判断单元建立连接,判断单元判断后将其判断结果反馈给微处理器;

  S304:将执行单元与微处理器建立连接,微处理器接收的即时消息系统携带的设备信息标识为身份鉴权唯一标识,则执行单元将执行存储模块存储身份鉴权唯一标识的命令;

  S305:将执行单元与微处理器建立连接,微处理器接收的即时消息系统携带的设备信息标识不为身份鉴权唯一标识,则执行单元将清理微处理器接收的即时消息系统携带的设备信息标识。

  进一步地,S304包括如下步骤:

  S3041:将检测单元与微处理器建立连接,微处理器控制检测单元检测存储模块的存储空间;

  S3042:将存储模块与检测单元建立连接,通过检测单元对存储模块的存储空间进行检测,并将其检测的结果反馈给微处理器。

  S3043:检测单元检测后,若存储模块的存储空间未满,则执行单元将执行存储模块存储身份鉴权唯一标识的命令。

  S3044:检测单元检测后,若存储模块的存储空间已满,则清理单元按照优先级算法清理存储模块的存储空间,并将新的身份鉴权唯一标识存储在存储模块内。

  进一步地,所述消息推送平台推送信息给APP客户端时,APP客户端收到信息后,触发ACK确认事件,并向消息推送平台发送ACK确认事件,消息推送平台收到ACK确认事件后清理周期重发时效队列。

  与现有技术相比,本发明的有益效果是:

  本发明的简单轻量的消息实时推送系统及其实施方法,用户APP客户端甲方向用户APP客户端乙方发送即时消息,即时消息系统会识别到用户APP客户端乙方的当前状态,如用户APP客户端乙方验证用户信息标识为后台状态时,即时消息系统组装消息,消息推送平台固定消息体后送达到消息推送平台,消息推送平台从消息体中提炼到设备唯一标识序列号验证设备信息,如健康存在则根据设备标识信息把消息推送到用户APP客户端乙方,消息推送平台推送信息给APP客户端时,APP客户端收到信息后,触发ACK确认事件,并向消息推送平台发送ACK确认事件,消息推送平台收到ACK确认事件后清理周期重发时效队列,避免移动端被回收后消息不可达或断网重连后消息丢失等问题,可提供消息推送平台确保任何情况下消息都可必达,业务对接简易,服务轻量快捷,消息实时必达。

  附图说明

  图1为本发明的简单轻量的消息实时推送系统的装置图;

  图2为本发明的简单轻量的消息实时推送系统的模块图;

  图3为本发明的用户APP客户端注册时序图;

  图4为本发明的用户APP客户端注册流程图;

  图5为本发明的用户APP客户端身份鉴权流程图;

  图6为本发明的消息确认时序图;

  图7为本发明的消息推送整体流程图;

  图8为本发明的推送平台内部详细流程图;

  图9为本发明的用户APP客户端身份鉴权模块图;

  图10为本发明的身份鉴权唯一标识存储模块图。

  图中:1、APP客户端;2、即时消息系统;3、消息推送平台;31、微处理器;32、存储模块;33、判断单元;34、执行单元;35、检测单元;36、清理单元。

  具体实施方式

  下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。

  实施例一

  参阅图1-图2,一种简单轻量的消息实时推送系统,包括APP客户端1、即时消息系统2和消息推送平台3,APP客户端1通过无线网络按照全双工通信方式与即时消息系统2进行通信,即时消息系统2通过无线网络按照全双工通信方式与消息推送平台3进行通信,APP客户端1携带有终端设备信息标识及用户信息标识,即时消息系统2携带有设备信息标识;

  其中,APP客户端1为用户移动设备APP;

  即时消息系统2为提供通信服务的后端服务器系统;

  消息推送平台3为APP客户端1甲方在即时消息系统2中生成好的消息体经过消息推送平台3推送到APP客户端1乙方的后台服务器系统。

  APP客户端1登录时把“策略标识信息”注册到即时消息系统2中并把策略中的“设备标识信息”注册到消息推送平台3,消息推送平台3响应唯一且有时效性身份鉴权标识,包含消息推送平台3中当前设备唯一标识,APP客户端1根据响应的身份鉴权唯一标识直接到消息推送平台3做合法身份验证。

  当用户APP客户端1消息互通时,即时消息系统2抓取消息接收方用户策略识别后将消息扔入消息推送平台3,消息推送平台3根据之前响应的设备唯一标识找到对应的设备信息,将消息推送到用户APP客户端1上。

  消息推送平台3上设置有微处理器31、存储模块32、判断单元33和执行单元34,即时消息系统2与微处理器31电连接,微处理器31的输出端与存储模块32的输入端电连接,存储模块32的输出端与判断单元33的输入端电连接,判断单元33与微处理器31电连接,微处理器31的输出端与执行单元34的输入端电连接。

  参阅图3-图8,为了更好的展现简单轻量的消息实时推送系统的实施流程,本实施例现提出一种简单轻量的消息实时推送系统的实施方法,包括如下步骤:

  S10:将即时消息系统2与APP客户端1建立连接,APP客户端1携带终端设备信息标识及用户信息标识登录即时消息系统2;

  S20:将消息推送平台3与即时消息系统2建立连接,即时消息系统2携带设备信息注册消息推送平台3;

  S30:消息推送平台3中以设备ID唯一标识分组存储设备信息、且生成无序的唯一序列标识后、经国密算法生成身份鉴权唯一标识;

  S40:将即时消息系统2与消息推送平台3建立连接,即时消息系统2得到消息推送平台3响应后记录设备唯一标识及身份鉴权唯一标识;

  S50:将APP客户端1与即时消息系统2建立连接,即时消息系统2返回身份鉴权唯一标识到APP客户端1。

  用户APP客户端1甲方向用户APP客户端1乙方发送即时消息,即时消息系统2会识别到用户APP客户端1乙方的当前状态,如用户APP客户端1乙方验证用户信息标识为后台状态时,即时消息系统2组装消息,消息推送平台3固定消息体后送达到消息推送平台3,消息推送平台3从消息体中提炼到设备唯一标识序列号验证设备信息,如健康存在则根据设备标识信息把消息推送到用户APP客户端1乙方,消息推送平台3推送信息给APP客户端1时,APP客户端1收到信息后,触发ACK确认事件,并向消息推送平台3发送ACK确认事件,消息推送平台3收到ACK确认事件后清理周期重发时效队列,避免移动端被回收后消息不可达或断网重连后消息丢失等问题,可提供消息推送平台3确保任何情况下消息都可必达,业务对接简易,服务轻量快捷,消息实时必达。

  参阅图9,S30包括如下步骤:

  S301:将微处理器31与即时消息系统2建立连接,微处理器31接收即时消息系统2携带的设备信息标识;

  S302:将判断单元33分别与存储模块32和微处理器31建立连接,通过判断单元33来判断微处理器31接收的即时消息系统2携带的设备信息标识在存储模块32中是否为身份鉴权唯一标识;

  S303:将微处理器31与判断单元33建立连接,判断单元33判断后将其判断结果反馈给微处理器31;

  S304:将执行单元34与微处理器31建立连接,微处理器31接收的即时消息系统2携带的设备信息标识为身份鉴权唯一标识,则执行单元34将执行存储模块32存储身份鉴权唯一标识的命令;

  S305:将执行单元34与微处理器31建立连接,微处理器31接收的即时消息系统2携带的设备信息标识不为身份鉴权唯一标识,则执行单元34将清理微处理器31接收的即时消息系统2携带的设备信息标识。

  微处理器31接收即时消息系统2携带的设备信息标识,通过判断单元33来判断微处理器31接收的即时消息系统2携带的设备信息标识在存储模块32中是否为身份鉴权唯一标识,若为身份鉴权唯一标识,则执行单元34将执行存储模块32存储身份鉴权唯一标识的命令,若不为身份鉴权唯一标识,则执行单元34将清理微处理器31接收的即时消息系统2携带的设备信息标识。

  实施例二

  一种简单轻量的消息实时推送系统,包括APP客户端1、即时消息系统2和消息推送平台3,APP客户端1通过无线网络按照全双工通信方式与即时消息系统2进行通信,即时消息系统2通过无线网络按照全双工通信方式与消息推送平台3进行通信,APP客户端1携带有终端设备信息标识及用户信息标识,即时消息系统2携带有设备信息标识;

  其中,APP客户端1为用户移动设备APP;

  即时消息系统2为提供通信服务的后端服务器系统;

  消息推送平台3为APP客户端1甲方在即时消息系统2中生成好的消息体经过消息推送平台3推送到APP客户端1乙方的后台服务器系统。

  消息推送平台3上设置有微处理器31、存储模块32、判断单元33和执行单元34,即时消息系统2与微处理器31电连接,微处理器31的输出端与存储模块32的输入端电连接,存储模块32的输出端与判断单元33的输入端电连接,判断单元33与微处理器31电连接,微处理器31的输出端与执行单元34的输入端电连接。

  消息推送平台3上设置有检测单元35和清理单元36,微处理器31与检测单元35电连接,检测单元35的输出端与存储模块32的输入端电连接,微处理器31的输出端还与清理单元36的输入端电连接,清理单元36的输出端与存储模块32的输入端电连接。

  为了更好的展现简单轻量的消息实时推送系统的实施流程,本实施例现提出一种简单轻量的消息实时推送系统的实施方法,包括如下步骤:

  S10:将即时消息系统2与APP客户端1建立连接,APP客户端1携带终端设备信息标识及用户信息标识登录即时消息系统2;

  S20:将消息推送平台3与即时消息系统2建立连接,即时消息系统2携带设备信息注册消息推送平台3;

  S30:消息推送平台3中以设备ID唯一标识分组存储设备信息、且生成无序的唯一序列标识后、经国密算法生成身份鉴权唯一标识;

  S40:将即时消息系统2与消息推送平台3建立连接,即时消息系统2得到消息推送平台3响应后记录设备唯一标识及身份鉴权唯一标识;

  S50:将APP客户端1与即时消息系统2建立连接,即时消息系统2返回身份鉴权唯一标识到APP客户端1。

  S30包括如下步骤:

  S301:将微处理器31与即时消息系统2建立连接,微处理器31接收即时消息系统2携带的设备信息标识;

  S302:将判断单元33分别与存储模块32和微处理器31建立连接,通过判断单元33来判断微处理器31接收的即时消息系统2携带的设备信息标识在存储模块32中是否为身份鉴权唯一标识;

  S303:将微处理器31与判断单元33建立连接,判断单元33判断后将其判断结果反馈给微处理器31;

  S304:将执行单元34与微处理器31建立连接,微处理器31接收的即时消息系统2携带的设备信息标识为身份鉴权唯一标识,则执行单元34将执行存储模块32存储身份鉴权唯一标识的命令;

  S305:将执行单元34与微处理器31建立连接,微处理器31接收的即时消息系统2携带的设备信息标识不为身份鉴权唯一标识,则执行单元34将清理微处理器31接收的即时消息系统2携带的设备信息标识。

  参阅图10,S304包括如下步骤:

  S3041:将检测单元35与微处理器31建立连接,微处理器31控制检测单元35检测存储模块32的存储空间;

  S3042:将存储模块32与检测单元35建立连接,通过检测单元35对存储模块32的存储空间进行检测,并将其检测的结果反馈给微处理器31。

  S3043:检测单元35检测后,若存储模块32的存储空间未满,则执行单元34将执行存储模块32存储身份鉴权唯一标识的命令。

  S3044:检测单元35检测后,若存储模块32的存储空间已满,则清理单元36按照优先级算法清理存储模块32的存储空间,并将新的身份鉴权唯一标识存储在存储模块32内。

  微处理器31控制检测单元35检测存储模块32的存储空间,通过检测单元35对存储模块32的存储空间进行检测,并将其检测的结果反馈给微处理器31,若存储模块32的存储空间未满,则执行单元34将执行存储模块32存储身份鉴权唯一标识的命令,若存储模块32的存储空间已满,则清理单元36按照优先级算法清理存储模块32的存储空间,并将新的身份鉴权唯一标识存储在存储模块32内。

  进一步地,消息推送平台3推送信息给APP客户端1时,APP客户端1收到信息后,触发ACK确认事件,并向消息推送平台3发送ACK确认事件,消息推送平台3收到ACK确认事件后清理周期重发时效队列。

  通过基于“工作宝”融合通信的消息实时必达的实现方法对本申请实施例进行详细描述:

  “工作宝”是一套面向移动互联网的,用于融合通信、商务办公、商务社交的沟通软件、解决方案和应用系统。

  该实例中对应发明中的构件说明:

  APP客户端1为工作宝客户端,下文使用gzbApp代称;

  APP服务端为工作宝服务端,下文使用gzbServer代称;

  消息推送平台3为工作宝推送服务端,下文使用gzbPush代称;

  该实例中使用的其他代名词有:

  pushDeviceId:设备推送唯一标识

  pushToken:推送身份鉴权唯一标识

  策略信息说明:

  支持云平台对接,具体的实例工作过程:

  现需要在gzbPush管理平台申请企业信息得到推送许可证及消息加密公钥;gzbApp和gzbServer集成gzbPush-sdk;gzbApp登录gzbServer后上报策略信息和用户信息、gzbServer携带设备信息注册gzbPush得到pushdeviceId和pushToken;将pushDeviceId绑定策略信息存储到gzbServer服务,将pushToken返回给gzbApp;Android客户端gzbApp拿到pushToken请求gzbPush做合法身份验证通过后建立推送链接通道;gzbApp消息互通时gzbServer会根据消息接收方用户信息检查判断gzbApp是否被切回到后台;gzbServer调用集成后SDK工具把公钥、pushDeviceId、消息结构体填写到工具方法中、得到gzbPush固有数据参数体发送;gzbApp收到消息后立马触发确认通知事件回调给gzbPush感知此消息已到达,如一定时间内未见确认事件回调gzbPush会触发自动重发机制已确保消息必达。

  支持私有化部署,具体的实例工作过程:

  从工作宝仓库下载gzbPush-rpm包;一键安装到本地服务、一键启动gzbPush服务、支持端口自定义;gzbApp和gzbServer集成gzbPush-sdk;gzbApp登录gzbServer后上报策略信息和用户信息、gzbServer携带设备信息注册gzbPush得到pushdeviceId和pushToken;Android客户端gzbApp拿到pushToken请求gzbPush做合法身份验证通过后建立推送链接通道;gzbServer无鉴权调用SDK、填充消息结构体填可通过gzbPush提供的RabbitMQ-RPC或直接HTTP方法发起消息推送;gzbApp收到消息后立马触发确认通知事件回调给gzbPush感知此消息已到达,如一定时间内未收到确认事件回调、gzbPush会触发自动重发机制已确保消息必达。

  综上所述,本发明的简单轻量的消息实时推送系统及其实施方法,用户APP客户端1甲方向用户APP客户端1乙方发送即时消息,即时消息系统2会识别到用户APP客户端1乙方的当前状态,如用户APP客户端1乙方验证用户信息标识为后台状态时,即时消息系统2组装消息,消息推送平台3固定消息体后送达到消息推送平台3,消息推送平台3从消息体中提炼到设备唯一标识序列号验证设备信息,如健康存在则根据设备标识信息把消息推送到用户APP客户端1乙方,消息推送平台3推送信息给APP客户端1时,APP客户端1收到信息后,触发ACK确认事件,并向消息推送平台3发送ACK确认事件,消息推送平台3收到ACK确认事件后清理周期重发时效队列,避免移动端被回收后消息不可达或断网重连后消息丢失等问题,可提供消息推送平台3确保任何情况下消息都可必达,业务对接简易,服务轻量快捷,消息实时必达。

  以上所述,仅为本发明较佳的具体实施方式,但本发明的保护范围并不局限于此,任何熟悉本技术领域的技术人员在本发明披露的技术范围内,根据本发明的技术方案及其发明构思加以等同替换或改变,都应涵盖在本发明的保护范围之内。

《一种简单轻量的消息实时推送系统及其实施方法.doc》
将本文的Word文档下载到电脑,方便收藏和打印
推荐度:
点击下载文档

文档为doc格式(或pdf格式)