使用org.eclipse.paho.client.mqttv3实现mqtt 消息队列

使用org.eclipse.paho.client.mqttv3集成mqtt消息通讯 pom文件加入: <dependency> <groupId>org.eclipse.paho</groupId> <artifactId>org.eclipse.paho.client.mqttv3</artifactId> <version>1.1.1</version> </dependency> 将文件: MqttConsumer.java MqttServer.java SubscribeCallback.java 其中 MqttConsumer.java 为消费者（订阅端） MqttServer.java 为生产者（发布端） SubscribeCallback.java 为消费者的回调类 生产者的回调类 是 内部类，所以没有单独的文件。 集成时注意 包路径，文件内关键注释都有写。有问题可给我留言