• 使用CometD技术实现web系统中的主动推送


           CometD技术通过Http长轮询(或websocket长链接)方式在服务器与客户端之间构建了一条交互的链路。它们都遵守Bayeux协议,交换的消息是Bayeux message,消息格式是JSON。

    1、需求说明

    当用户登录后,后台根据用户订阅把最新的信息反推给web客户端,展示在页面上。CometD服务器实现的具体思路如下:当网页客户端登陆后,服务器创建自定义通道(group/user), 然后接收网页客户端的订阅,当后台有数据更新时,后台服务器对数据进行分析,发送给指定的用户。相关示意图如下:

    2、CometD实现

    2.1、服务端service创建

            CometD服务器继承服务实现自org.Cometd.server.AbstractService。对应的JAVA服务器代码如下:

    1. public class BayeuxService extends AbstractService {  
    2.      
    3.     //创建固定的channel
    4.     public BayeuxService(BayeuxServer bayeux) {
    5.         super(bayeux, "cometdServer");
    6.         BayeuxService.bayeux=bayeux;
    7.         addService(LOGIN_CHANNEL, "clientLoginCB");
    8.         addService(TRANSDATA_CHANNEL, "JavaClientTransCB");
    9.     }
    10. public void clientLoginCB(ServerSession _session, Message message){//定义回调函数
    11.     
    12. }
    13. }

    以上代码创建2个通道,一个网页客户端的登录通道(LOGIN_CHANNEL),一个是接收后台数据的通道(TRANSDATA_CHANNEL)。  "clientLoginCB"是网页客户端登陆的处理函数, "JavaClientTransCB" 是后台发布数据的处理函数。

    2.2、网页客户端登录过程

           当用户登录时,将自己的组id和用户id拼接成格式为“/groupxxx/userxxx”的字符串,然后发布到LOGIN_CHANNEL上去,对应的网页JS代码如下:

    1. $.cometd.publish(LOGIN_CHANNEL,{
    2.    
    3. },function(publishReply){
    4.    
    5. })
    6. Bayeux服务器收到“/groupxxx/userxxx”字符串后,会为该网页客户端创建名为“/groupxxx/userxxx”的通道,并且服务器和客户端都会订阅这个通道以便接收对方发出的信息。 
    7. 网页JS代码:
    8. $.cometd.subscribe(“/groupxxx/userxxx”,function(){
    9.    
    10. })

    2.3、网页客户端订阅

           网页客户端登录之后,需要向服务器发送需要订阅的数据,对应的网页JS代码如下:

    1. $.cometd.publish(“/groupxxx/userxxx”,{
    2.    
    3. },function(publishReply){
    4.    
    5. })

    2.4、服务器接受订阅

           服务器在通道“/groupxxx/userxxx”上收到订阅内容后,会用map存放订阅通道名称与订阅内容。由于同一个内容可能被多个用户(通道)订阅,所以map的Key值是订阅内容(即API),value是个订阅该内容(API)的一个或多个通道名称。

    2.5、服务器推送数据

            后台有数据更新会通过TRANSDATA_CHANNEL通道发给后台服务器,后台服务器通过与map中的key值(API)比较,找出订阅该内容的所有通道并且推送。

  • 相关阅读:
    5分钟学会 Lambda 表达式,一篇就够了!
    代码随想录训练营二刷第二十三天 | 669. 修剪二叉搜索树 108.将有序数组转换为二叉搜索树 538.把二叉搜索树转换为累加树
    JAVA 日期时间类(Date)
    腾讯 13 年,我所总结的Code Review终极大法
    黑马点评-短信登录业务
    VS Code 配置C语言
    详解GaussDB(DWS) 资源监控
    Jenkins对应java版本
    【Nginx】Nginx $remote_addr和$proxy_add_x_forwarded_for变量详解
    目前主流的负载均衡器
  • 原文地址:https://blog.csdn.net/chenlycly/article/details/126333470