# 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);
});
```