在Node.js下运用MQTT协议实现即时通讯及离线推送的方法
作者:青荼 发布时间:2024-05-03 15:54:50
前言
前些日子了解到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 (topic, 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(topic,opts)
client.subscribe('test',{qos:1})
opts中的qos为通信机制,控制发送端与接收端的互锁程度
上文中的其中一个collection: subscriptions即记录各用户话题订阅情况
用户cli_sub及cli2_sub订阅了话题test:
(新增一个cli2_pub,下文有用)
注:
重复执行脚本sub.js实际上对topic进行了重复订阅
实际编码时,应避免topic的重复订阅,即使重复订阅并不影响实现效果
client.publish():
向指定topic发送数据
message为Buffer或String格式,可以通过序列化或转json实现对复杂数据对象的传送
//client.publish(topic, message, opts, callback)
let num = 0;
setInterval(function (){
client.publish('test',
'Hello mqtt ' + (++num),
{qos:1},
() => console.log(num));
}, 1000)
参数不再赘述
此处用一个定时器定时在 topic: 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 (topic, message) {
console.log('received message: ', message.toString())
})
处理为简单地打印到控制台
来源:https://segmentfault.com/a/1190000018002561
猜你喜欢
- 下面介绍下Python import与from import使用,具体内容如下所示:Python程序可以调用一组基本的函数(即内建函数),比
- 导言很多Web程序都支持用户帐号,根据不同的登录用户提供不同的选项,报表等功能。例如,就我们的教程中,我们要允许供应商公司的一些账户能登录网
- 前言在pytorch中经常会遇到图像格式的转化,例如将PIL库读取出来的图片转化为Tensor,亦或者将Tensor转化为numpy格式的图
- 用命令创建Django项目1.将磁盘切换为D盘2.在D盘的路径下创建Django项目创建项目应用3.最后显示新建index文件夹启动项目1.
- 本文实例讲述了Python3基于sax解析xml操作。分享给大家供大家参考,具体如下:python使用SAX解析xmlSAX是一种基于事件驱
- 前言办公中,偶尔会碰到一种情况,需要提取word文档中的图片,决定写这样一款工具自动提取图片。关于脚本的使用:情景1:如果你拿到的是一个文件
- python函数式编程之装饰器1.开放封闭原则简单来说,就是对扩展开放,对修改封闭。在面向对象的编程方式中,经常会定义各种函数。一个函数的使
- sympy有个vector 模块,里面提供了求解标量场、向量场的梯度、散度、旋度等计算,官方参考连接:http://docs.sympy.o
- 6月初,Python之父Guido van Rossum在今天的PyCon US大会上作了名为“Python Language”的演讲。近日
- 目录前言全局锁表级锁表锁元数据锁(Metadata Locking,简称:MDL锁)总结参考资料前言在真实的企业开发环境中使用MySQL,M
- 1、MySQL8.0.16解压其中dada文件夹和my.ini配置文件是解压后手动加入的,如下图所示2、新建配置文件my.ini放在D:\F
- 前言数据处理过程中,经常会遇到数据有缺失值的情况,本文介绍如何用Pandas处理数据中的缺失值。一、什么是缺失值对数据而言,缺失值分为两种,
- asp编程中我们经常要处理字符串,比如一个新闻列表,在我们编写asp程序的时候就要考虑到新闻标题的长度不确定性,因为有的文章标题可能很长,可
- Python 提供了两个级别访问的网络服务。低级别的网络服务支持基本的 Socket,它提供了标准的 BSD Sockets API,可以访
- 众所周知当前(甚至接下来的几年)最酷的东西是iPhone。不仅仅是因为iPhone看起来不错,它们在网站方面也很不错。而且,更重要的是,很多
- MySQL中的锁锁是为了解决并发环境下资源竞争的手段,其中乐观并发控制,悲观并发控制和多版本并发控制是数据库并发控制主要采用的技术手段(具体
- spring boot 不连接数据库启动用spring boot 搭建的项目,在配置文件不连接数据库启动项目会报错。原因在于spring b
- 本文实例讲述了Python字符串拼接、截取及替换方法。分享给大家供大家参考,具体如下:python字符串连接python字符串连接有几种方法
- 众所周知tensorflow造势虽大却很难用,因此推荐使用Keras,它缺省是基于tensorflow的,但通过修改keras.json也可
- # _*_ coding:utf-8 _*_# name start_qq.pyimport osos.startfile("C: