用Pomelo搭建一个简易的推送平台

前言

赣州网站制作公司哪家好，找成都创新互联！从网页设计、网站建设、微信开发、APP开发、响应式网站设计等网站项目制作，到程序开发，运营维护。成都创新互联2013年至今到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选成都创新互联。

实际上，个人感觉，pomelo 目前提供的两个默认sioconnector和hybridconnector 使用的协议并不适合用于做手机推送平台，在pomelo的一份公开ppt里面，有提到过，网易的消息推送平台是基于pomelo开发的 (一个frontend 支持30w 长连接，消耗了3g 内存，如果我没记错数据应该是这样)，不过，这里用的前端(frontend)实现的是基于MQTT协议，我估计这个基于MQTT协议实现的 frontend,基本不可能开源出来。这里只是说,默认提供的frontend不适合用于构建大型的推送平台(c10m规模的)，一般而言(c10k级别的),个人感觉还是够用的。

为了展示，更多pomelo 的相关特性，可能这里的逻辑业务，与实际有所不同.敬请注意。

推送平台的架构图

整个应用的架构图:

后端

  • pomelo@0.4.3

前端

  • android
  • web browser

开发约定

客户端请求对象

 
 
 
 
    
  
  
  
  
  1. { 
    2. 
  
  
  
  
  2.     "role": "client/server", 
    3. 
  
  
  
  
  3.     "apikey": "String", 
    4. 
  
  
  
  
  4.     "clientId": "String"
    5. 
  
  
  
  
  5. }
    6.

服务端返回对象

发给web management

 
 
 
 
    
  
  
  
  
  1. { 
    2. 
  
  
  
  
  2.     "code": "Int httpCode ex: 200", 
    3. 
  
  
  
  
  3.     "msg": "String", 
    4. 
  
  
  
  
  4.     "users": "Array 客户端的clientId 值 ex:["android1"] "
    5. 
  
  
  
  
  5. }
    6.

发给android客户端

 
 
 
 
    
  
  
  
  
  1. { 
    2. 
  
  
  
  
  2.     "code": "Int httpCode ex: 200", 
    3. 
  
  
  
  
  3.     "msg": "String"
    4. 
  
  
  
  
  4. }
    5.

客户端访问用的route

android:

connector route = sio-connector.entryHandler.enter, 用于把当前客户端加入到推送频道当中

WebManagement:

connector route = hybrid-connector.entryHandler.enter,用于连接服务器.
backend route = pushserver.pushHandler.pushAll, 把消息推送到所有已连接的客户端.

后台编码

Pomelo 有个特点,就是约定开发,很多地方是约定好的配置,优点是,架构清晰,可读性好,缺点是,需要大量的文档支持,目前而言,pomelo的官方文档做的不好的地方就是,虽然文档都有了,但是太零散了,分类不清楚,还有就是文档没跟上开发,有时候,你不阅读里面源码根本不知道这个api要传那些参数.

sioconnector / hybridconnector

由于pomelo 0.3 以后新增了一个新的connector:hybridconnector,支持socket和websocket，使用二进制通讯协议,但是除了,网页 js版本和c 客户端实现了这个connector,其他客户端均还没实现,所以,我们还需要一个兼容android 客户端的connector: siocnnector,关于两个connector 具体比较,以后有空重写这篇的时候,暂时,你只要知道,这个两个connector,一个基于socket.io,一个基于socket和websocket 即可.

app.js由于我们用到了两个不同的connector,所以要在app.js写上:

 
 
 
 
    
  
  
  
  
  1. // 支持 socket.io 
    2. 
  
  
  
  
  2. app.configure('production|development', 'sio-connector', function(){ 
    3. 
  
  
  
  
  3.     app.set('connectorConfig', 
    4. 
  
  
  
  
  4.         { 
    5. 
  
  
  
  
  5.             connector : pomelo.connectors.sioconnector 
    6. 
  
  
  
  
  6.         }); 
    7. 
  
  
  
  
  7. }); 
    8. 
  
  
  
  
  8. 
  
  
  
  
  9. //支持 websocket 和 socket 
    10. 
  
  
  
  
  10. app.configure('production|development', 'hybrid-connector', function(){ 
    11. 
  
  
  
  
  11.     app.set('connectorConfig', 
    12. 
  
  
  
  
  12.         { 
    13. 
  
  
  
  
  13.             connector : pomelo.connectors.hybridconnector, 
    14. 
  
  
  
  
  14.             heartbeat : 300, 
    15. 
  
  
  
  
  15.             useDict: true, 
    16. 
  
  
  
  
  16.             useProtobuf: true
    17. 
  
  
  
  
  17. 
  
  
  
  
  18.         }); 
    19. 
  
  
  
  
  19. });
    20.

经过这样的配置,我们就能够使用两个不同的connector了.

推送实现

用pomelo 进行消息的推送,非常便捷,由于,我们现在只关注推消息给全部客户端,那样就非常简单了.

推送流程:

  • 根据uuid 把 android 客户端添加到各自的推送频道当中.
  • web 端根据uuid 把消息推送的全部在线的客户端.

为了教学的方便,这里的uuid 硬编码为: xxx-xx--xx-xx

把客户端添加到相应的channel

 
 
 
 
    
  
  
  
  
  1. //把客户端添加到推送列表中 
    2. 
  
  
  
  
  2. PushRemote.prototype.add = function(uid, role, sid, channelName, cb){ 
    3. 
  
  
  
  
  3.     var channel = this.channelService.getChannel(channelName, true); 
    4. 
  
  
  
  
  4.     if(role === 'server'){ 
    5. 
  
  
  
  
  5.         //web 服务端直接返回用户列表 
    6. 
  
  
  
  
  6.         cb(null ,this.getUsers(channelName)); 
    7. 
  
  
  
  
  7.     }else { 
    8. 
  
  
  
  
  8.         if(!!channel){ 
    9. 
  
  
  
  
  9.             channel.add(uid ,sid); 
    10. 
  
  
  
  
  10.         } 
    11. 
  
  
  
  
  11.         //uuid 告诉给服务端onAdd 事件 
    12. 
  
  
  
  
  12.         // [{uid: userId, sid: frontendServerId}] 
    13. 
  
  
  
  
  13.         var server = [{uid: channelName, sid: sid}]; 
    14. 
  
  
  
  
  14.        this.channelService.pushMessageByUids('onAdd', {msg: "add ok", users:this.getUsers(channelName)},server, function(err){ 
    15. 
  
  
  
  
  15.            if(err){ 
    16. 
  
  
  
  
  16.                console.log(err); 
    17. 
  
  
  
  
  17.                return; 
    18. 
  
  
  
  
  18.            } 
    19. 
  
  
  
  
  19.        }); 
    20. 
  
  
  
  
  20.     } 
    21. 
  
  
  
  
  21. };
    22.

Frontend 利用rpc 调用pushserver 添加客户端到相应频道的方法.

 
 
 
 
    
  
  
  
  
  1. //sid 统一为web managment 所在的 frontend server. 
    2. 
  
  
  
  
  2.     this.app.rpc.pushserver.pushRemote.add(session, uid,role, 'connector-server-client', uuid, function(err, users){ 
    3. 
  
  
  
  
  3.         if(err){ 
    4. 
  
  
  
  
  4.             console.log(err); 
    5. 
  
  
  
  
  5.             return; 
    6. 
  
  
  
  
  6.         } 
    7. 
  
  
  
  
  7. 
  
  
  
  
  8.         if(users){ 
    9. 
  
  
  
  
  9.             next(null, {code: 200, msg: 'push server is ok.', users: users}); 
    10. 
  
  
  
  
  10.         }else{ 
    11. 
  
  
  
  
  11.             next(null,{code: 200, msg: "add ok", users: users}); 
    12. 
  
  
  
  
  12.         } 
    13. 
  
  
  
  
  13.     });
    14.

web 管理端调用消息推送

 
 
 
 
    
  
  
  
  
  1. Handler.prototype.pushAll = function(msg, session, next){ 
    2. 
  
  
  
  
  2.     var pushMsg = this.channelService.getChannel(msg.apikey, false); 
    3. 
  
  
  
  
  3.     pushMsg.pushMessage('onMsg',{msg: msg.msg}, function(err){ 
    4. 
  
  
  
  
  4.        if(err){ 
    5. 
  
  
  
  
  5.            console.log(err); 
    6. 
  
  
  
  
  6.        } else{ 
    7. 
  
  
  
  
  7.            console.log('push ok'); 
    8. 
  
  
  
  
  8.            next(null, {code: 200, msg: 'push is ok.'}); 
    9. 
  
  
  
  
  9.        } 
    10. 
  
  
  
  
  10.     }); 
    11. 
  
  
  
  
  11. 
  
  
  
  
  12. };
    13.

以上就是主要客户端如何加入到推送队列的代码,以及web 管理端进行消息推送的主要代码,是不是很简单! 完整代码可以参阅我的github https://github.com/youxiachai

有一点要注意的,如果pomelo 项目要部署到外网或者局域网,frontend 的host 要填写当前host 主机的ip 地址

例如:

 
 
 
 
    
  
  
  
  
  1. "connector": [ 
    2. 
  
  
  
  
  2.     {"id": "connector-server-1", "host": "127.0.0.1", "port": 3150, "clientPort": 3010, "frontend": true} 
    3. 
  
  
  
  
  3.         ]
    4.

部署到某台服务器,需要修改

 
 
 
 
    
  
  
  
  
  1. "connector": [ 
    2. 
  
  
  
  
  2.     {"id": "connector-server-1", "host": "192.168.1.107", "port": 3150, "clientPort": 3010, "frontend": true} 
    3. 
  
  
  
  
  3.         ]
    4.

客户端访问相应的host 的地址.

客户端和服务端的github 地址: https://github.com/youxiachai/pomelo-pushServer-Demo

标题名称：用Pomelo搭建一个简易的推送平台
分享链接：http://www.mswzjz.cn/qtweb/news43/243043.html

攀枝花网站建设、攀枝花网站运维推广公司-贝锐智能，是专注品牌与效果的网络营销公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 贝锐智能

贝锐智能技术为您推荐以下文章

网站内链知识

同城分类信息

成都h5建站开发　　 　成都微信二次开发公司　　 　四川雕琢时光　　 　解决方案　　 　研学实践　　 　西信中心　　 　温江服务器托管　　 　四川服务器托管　　 　成都广告招牌　　 　成都集团网站建设　　 　百度推广公司　　 　蓬安网站建设　　 　中建建业环保　　 　兴久牧业　　 　德阳柴油发电机组　　 　手机网站制作　　 　青羊区雕琢时光　　 　成都响应式网站建设　　 　西部信息服务器托管　　 　成都品牌官网设计公司