EMQ推送服务集成
# blzo-ex-mqtt EMQ推送服务集成
引入此包可在blzo中直接集成基于EMQ服务器的MQTT推送功能。
目前只实现了服务端推送消息到EMQ服务器的功能,更多使用方法有待扩展。
# 引入
gradle
// https://mvnrepository.com/artifact/com.jdkhome.blzo/blzo-ex-mqtt
compile group: 'com.jdkhome.blzo', name: 'blzo-ex-mqtt', version: 0.3.0.1.RELEASE
1
2
2
maven
<!-- https://mvnrepository.com/artifact/com.jdkhome.blzo/blzo-ex-mqtt -->
<dependency>
<groupId>com.jdkhome.blzo</groupId>
<artifactId>blzo-ex-mqtt</artifactId>
<version>0.3.0.1.RELEASE</version>
</dependency>
1
2
3
4
5
6
2
3
4
5
6
# 使用
# 配置文件
mqtt:
# emq 服务地址
host: tcp://192.168.1.244:1883
# emq 用户名
username: admin
# emq 密码
password: public
# 客户端标识
clientId: ${spring.cloud.consul.discovery.instanceId}
# post url
publish_url: http://192.168.1.244:8080/api/v3/mqtt/publish
app_id: 536c0891820c
app_key: Mjg4Mjc0NTc5MDM5ODMzMDM5NDk0NjY1NzI3MjY2NjUyMTG
1
2
3
4
5
6
7
8
9
10
11
12
13
2
3
4
5
6
7
8
9
10
11
12
13
# 使用
@Autowired
MqttService mqttService;
// 基于tcp的推送
mqttService.send("topic","message");
// 基于http的推送
mqttService.httpSend("topic","message");
1
2
3
4
5
6
7
8
9
10
2
3
4
5
6
7
8
9
10
上次更新: 2020/06/11, 18:06:00