在Node.js下运用MQTT协议实现即时通讯及离线推送的
前言
前些日子了解到mqtt这样一个协议,可以在web上达到即时通讯的效果,但网上并不能很方便地找到一篇目前版本的在node下正确实现这个协议的博客。
自己捣鼓了一段时间,理解不深刻,但也算是基本能够达到使用目的。
本文尚未对离线消息的接收顺序进行处理。
代码
服务端: server.js
//服务端引入中间件mosca let mosca = require('mosca') let settings = { port: 5112 } let server = new mosca.Server(settings) server.on('ready', function(){ console.log('Mosca server is up and running at port 5112'); }) server.on('published', function(packet, client) { console.log('Published', packet.payload) }) server.on('clientDisconnected', function(client){ console.log('disconnected: ', client.id) })
推送端: pub.js
//客户端引入mqtt let mqtt = require('mqtt'); let client = mqtt.connect('mqtt://localhost', { port: 5112, clientId: 'cli_pub', }) let num = 0; setInterval(function (){ client.publish('test', 'Hello mqtt ' + (++num), {qos:1}, () => console.log(num)); }, 1000)
订阅端: sub.js
let mqtt = require('mqtt') let client = mqtt.connect('mqtt://localhost', { port: 5112, clientId: 'cli_sub', }) client.subscribe('test',{qos:1}) client.on('message', function (ic, message) { console.log('received message: ', message.toString()) })
server运行后,先启动pub,再启动sub,即可在sub中接收到推送过来的消息序列
至此实现了简单的即时推送
离线推送相关配置及简要介绍
离线配置-服务端
要实现消息的离线推送,必然需要一个存储临时数据的部件
此处用到的是mongo,可以根据需要选择其他的存储工具
server.js中的settings需更改为:
let settings = { port: 5112, persistence:{ //增加了此项 factory: mosca.persistence.Mongo, url: "mongodb://localhost:27017/mosca" } }
factory: 引入mosca对特定存储工具的一些处理方法
url: 其中的 27017 为mongo所监听的端口号,mosca为存储相关数据的数据库
值得一提的是配置好mongo的环境后,不需要提前在mongo中手动创建,若数据库不存在会自动生成,而且mosca会为你作好其他一切基本事项 (即若只想临时体验下效果,甚至可以暂时把mongo放一边 )
在mongo中,可以看到自动新添了db: mosca及其下的collection(相当于关系型数据库中的表/关系)
离线配置-客户端
pub.js和sub.js中的client中都可以改为
let client = mqtt.connect('mqtt://localhost', { port: 5112, clientId: 'cli_', clean: false//增加了此项 })
- clientId: 区分客户端的识别码
- clean: 此处决定了客户端在服务端的session是否会被清除,默认为true,为实现离线推送,我们需要将其保留
- clean及上文中的persistence为实现离线推送的关键配置
mqtt.connect()会返回一个mqttClient对象,包含了reconnect(), subscribe(), publish()等一系列方法。
本文中发送端接收端被分为了pub.js和sub.js两个独立文件,仅仅为了方便在不同控制台中观察效果
一个client可以既为推送端,又为订阅端
至此,所有代码已完成
其他介绍
client.subscribe():
为本客户端订阅一个话题,所有订阅此话题的用户都会收到在此话题下推送的信息
//client.subscribe(ic,opts) client.subscribe('test',{qos:1})
opts中的qos为通信机制,控制发送端与接收端的互锁程度
上文中的其中一个collection: subscriptions即记录各用户话题订阅情况
用户cli_sub及cli2_sub订阅了话题test:
(新增一个cli2_pub,下文有用)
注
重复执行脚本sub.js实际上对ic进行了重复订阅
实际编码时,应避免ic的重复订阅,即使重复订阅并不影响实现效果
client.publish():
向指定ic发送数据
message为Buffer或String格式,可以通过序列化或转json实现对复杂数据对象的传送
//client.publish(ic, message, opts, callback) let num = 0; setInterval(function (){ client.publish('test', 'Hello mqtt ' + (++num), {qos:1}, () => console.log(num)); }, 1000)
参数不再赘述
此处用一个定时器定时在 ic: test 下发送'Hello mqtt 1,2,3..'
用回调函数实时打印一下发送的num
当订阅者处于离线状态时,可以在collection: packets中查看到临时数据的存储情况
mosca把每一条推送消息为所有订阅用户都生成了独立的记录,用同一个messageId进行关联
当其中一个用户(cli2_sub)上线时,获取到其对应的数据,
而后数据库中相应记录便会被删除
此时仅有cli_sub用户的数据
当cli2_sub上线接收消息后,packets中记录将被清空
client.on():
即在client上触发的事件,此处只列举消息接收事件
//client.on(event, callback) client.on('message', function (ic, message) { console.log('received message: ', message.toString()) })
处理为简单地打印到控制台
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持狼蚁SEO。
编程语言
- 甘肃哪有关键词排名优化购买方式有哪些
- 甘肃SEO如何做网站优化
- 河南seo关键词优化怎么做电话营销
- 北京SEO优化如何做QQ群营销
- 来宾百度关键词排名:提升您网站曝光率的关键
- 卢龙关键词优化:提升您网站排名的策略与技巧
- 山东网站优化的注意事项有哪些
- 四川整站优化怎样提升在搜索引擎中的排名
- 疏附整站优化:提升网站性能与用户体验的全新
- 海南seo主要做什么工作售后服务要做到哪些
- 荣昌百度网站优化:提升您网站的搜索引擎排名
- 河北seo网站排名关键词优化如何做SEO
- 江西优化关键词排名推广售后保障一般有哪些
- 古浪SEO优化:提升你的网站可见性
- 西藏网站排名优化怎么把网站排名在百度首页
- 如何提升阳东百度快照排名:详尽指南