mqtt实现自动监听服务器消息

  本示例借助meteor的一个环境跑,和我们平时用的node自己搭的环境或java,php的环境本质一样,在此不多讨论。

   首先需求是:多系统对接进行消息实时传递。

   安装好mqtt:    npm install mqtt --save

   本地服务(可以直接配在java中):这里采用mosca

  安装好mosca:  npm install mosca --save

var mosca=reqire('mosca');
var mqttServer=new mosca.Server({port:8000});  //设置监听端口
//published监听所发布的消息
mqttServer.on('published',function(packet,client){
  console.log('published----',packet);
  switch(packet.topic){    //topic字段是消息主题,可以理解为接口中的方法名
    case 'test':        //不同的订阅主题,发布消息不同
    console.log(packet.payload.toString());
    mqttServer.publish({topic:'other',payload:'测试不同主题!'});  
    break;
    case 'other':
    console.log(packet.paload.toString());
    break;
}
});
//服务开启时给个提示:
mqttServer.on('ready',function(){
  console.log('Mosca server is running ... ');
});

   订阅消息(接收):    

var mqtt=require('mqtt');
var client=mqtt.connect('tcp://172.19.5.217:8000');  //本地建立连接
//模拟一个消息发送
var msg={talk:'this is test!!',name:'测试'};
//轮洵发送,仅做测试用,实际场景不需要轮洵
setInterval(function(){
  client.publish('test',JSON.stringify(msg),{qos:1,retain:true});  //发布一条主题为test的消息,
},60000);
client.subscribe('test');  //订阅主题为test的消息
client.on('message',function(topic,message){
  var result=JSON.parse(message.toString());  //接收到新消息,并对其进行处理
  try{
    console.log('result---->',result);

    //****do something **** 
  }catch(e){
    console.log('error---->',result);
  }
})

  publish()方法接收四个参数publish(topic,message,[options],[callback]);

    topic: 消息主题;

    message:传递的消息;

    options:指定参数值:qos :服务质量级别,默认为0 (消息最多发送一次,不管是否接收到)

               retain:默认为false,推送至当前订阅就释放这条消息。设为true,表示服务器要保留这次推送的信息,如果新的订阅者出现,就把这条消息推送给它。

               dup:保证消息可靠传输,默认为false,只占用一个字节,表示第一次发送。不能用于检测消息重复发送等。注意需要满足以下条件:

              1.当QoS > 0,即消息至少传递一次)

              2.消息需要回复确认。

               此时,在可变头部需要包含消息ID(即client.id)。当值为1时,表示当前消息先前已经被传送过。

     这样一个简单的消息监听功能就做好了,我这边是做一个接收消息自动发送功能,效果如下:

   由于我做即时聊天有用到websocket,与mqtt都是与服务器保持长连接,进行消息传递。那么,来对比一下MQTT和WebSocket有什么区别?

    MQTT具备以下特点:

    1.采用发布/订阅消息传输协议,设计思想开放,简单,轻量。

    2.网络代码高,比较依赖网络。

    3.有三种服务质量:至多一次,只有一次,至少一次。前两者会有风险,后者会负载过重。

    WebSocket的不同在于:

    1.提供使用一个TCP连接进行双向通讯机制,包括网络协议和API,以取代网页和服务器采用HTTP轮询进行双向通讯。

    2.借用HTTP和HTTPS端口,与TCP建立连接和关闭连接时握手。传输消息采用TCP协议。

  具体应用时,我们只需要根据实现场景及两者的特点,选择更合适的通讯方式即可。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏前端吧啦吧啦

mqtt实现自动监听服务器消息

3597
来自专栏九彩拼盘的叨叨叨

最近写的《后台管理系统的前端代码生成工具》介绍

《后台管理系统的前端代码生成工具》做的是生成项目 admin-template 的列表,新增,编辑,详情页的代码,如上图所示。通过点击“生成下载内容”,点相应的...

541
来自专栏容器化

一个典型的kubernetes工作流程 - kubernetes

2242
来自专栏杨建荣的学习笔记

Linux命令ping,nc的学习(r10笔记第20天)

今天看了下《Linux大棚命令百篇》网络和系统篇,发现了几个很不错的命令,我是看着目录然后根据自己的需要选了3个命令,没想到3个命令都让人眼前一亮,刷新了我原本...

3606
来自专栏北京马哥教育

Linux之任务计划

用过windows的同学应该都知道在控制面板中有一个“任务计划”选项,我们可以通过向导设置让计算机在某个时间点或者开机时运行某个脚本或者批处理等等,方便我们的...

2544
来自专栏零基础使用Django2.0.1打造在线教育网站

利用Flask搭建微电影视频网站(四):后台页面搭建

努力与运动兼备~~~有任何问题可以加我好友或者关注微信公众号,欢迎交流,我们一起进步!

1871
来自专栏北京马哥教育

最全 Linux 磁盘管理基础知识全汇总

运维行业正在变革,推荐阅读:30万年薪Linux运维工程师成长魔法 一、存储设备的挂载和卸载 存储设备的挂载和卸载常用操作命令:fdisk -l、df、du、...

4078
来自专栏梦里茶室

【Chromium中文文档】OS X 沙箱设计

背景 沙箱将进程视为一种恶劣的环境,因为进程任何时候都可能被一个恶意攻击者借由缓冲区溢出或者其他这样的攻击方式所影响。一旦进程被影响,我们的目标就变成了,让这个...

2060
来自专栏Laoqi's Linux运维专列

git 分支+标签+别名配置管理

1616
来自专栏mini188

MongoDB安装与使用体验

1、获取并安装 具体的安装包可以到官方网站下载:http://www.mongodb.org/downloads 我看着教程就下载了linux版本吧,也不是很...

2176

扫码关注云+社区