NPM-mqtt订阅发布包

安装

1
npm install mqtt --save

创建一个客户端进行测试

在刚刚安装mqtt.js文件夹下创建一个mqtt-test.js文件,然后键入以下代码

这样就说明你的mqtt模块就建立好了,但这仅限于客户端的使用为了使我们更方便的使用我们将在本地搭建一个服务器 下面来说说如何建立服务端安装mosca(和上面安装mqtt.js一样)打开cmd然后输入npm install mosca –save 创建mqtt-server.js文件代码如下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
var mosca = require('mosca');

var ascoltatore = {
//using ascoltatore
//type: 'mongo',
//url: 'mongodb://localhost:27017/mqtt',
//pubsubCollection: 'ascoltatori',
//mongo: {}
};

var settings = {
port: 1883,
backend: ascoltatore
};

var server = new mosca.Server(settings);

server.on('clientConnected', function(client) {
console.log('client connected', client.id);
});

// fired when a message is received
server.on('published', function(packet, client) {
console.log('Published', packet.payload);
});

server.on('ready', setup);

// fired when the mqtt server is ready
function setup() {
console.log('Mosca server is up and running');
}

然后在此文件夹下打开cmd 输入node mqtt-server.js

链接自己的mqtt服务端

将mqtt-test.js中的mqtt://test.mosquitto.org改为mqtt://127.0.0.1即可 然后打开两个终端 一个是运行服务端的 另一个运行客户端 首先运行服务端,然后在运行客户端

  • 版权声明: 本博客所有文章,未经许可,任何单位及个人不得做营利性使用!转载请标明出处!如有侵权请联系作者。
  • Copyrights © 2015-2023 翟天野

请我喝杯咖啡吧~