55 lines
875 B
Markdown
55 lines
875 B
Markdown
|
# celery-mqtt
|
|||
|
|
|
|||
|
|
> 第一次发布插件，摸索学习中
|
|||
|
|
|
|||
|
|
- 进入项目根目录下安装mqtt，执行命令
|
|||
|
|
-
|
|||
|
|
```sh
|
|||
|
|
npm install mqtt --save
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
- 在页面引入mqtt
|
|||
|
|
```javascript
|
|||
|
|
import mqtt from '@/uni_modules/celery-mqtt/js_sdk/index.js';
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
- 连接订阅
|
|||
|
|
```javascript
|
|||
|
|
mqtt.connect('127.0.0.1', 8083,
|
|||
|
|
// 连接选项
|
|||
|
|
{
|
|||
|
|
// 用户名
|
|||
|
|
username: 'admin',
|
|||
|
|
// 密码
|
|||
|
|
password: '1234.abcd',
|
|||
|
|
// 自动重连间隔，设置为0表示禁用重连
|
|||
|
|
reconnectPeriod: 0
|
|||
|
|
},
|
|||
|
|
// 订阅主题，字符串或者数组均支持
|
|||
|
|
'Communication',
|
|||
|
|
// 订阅选项
|
|||
|
|
{
|
|||
|
|
qos: 0
|
|||
|
|
},
|
|||
|
|
// 订阅消息回调
|
|||
|
|
(topic, message) => {
|
|||
|
|
console.log('received:', topic, message);
|
|||
|
|
});
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
- 发布消息
|
|||
|
|
```javascript
|
|||
|
|
mqtt.publish(
|
|||
|
|
// 发布主题，字符串
|
|||
|
|
'Command',
|
|||
|
|
// 发布选项
|
|||
|
|
{
|
|||
|
|
qos: 0
|
|||
|
|
},
|
|||
|
|
// 消息
|
|||
|
|
'test',
|
|||
|
|
// 发布回调
|
|||
|
|
(topic) => {
|
|||
|
|
console.log('published:', topic);
|
|||
|
|
});
|
|||
|
|
```
|