本文主要是介绍智慧停车(十八) 微消息队列 MQTT使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
微消息队列 MQTT 版是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。简单的来说，可以使用它来实现设备端和云端的通讯。快速实现效果。
一 阿里云微消息队列 MQTT
分享个阿里云2000元代金劵，免费领取可以给你购买服务器节省一些资金
购买后会创建一个实例，实例信息如下：
接下来要创建topic和group。
1.创建topic
MQTT 协议支持多级 Topic，父级 Topic 需在控制台创建，子级 Topic 无需创建。选择 Topic 管理 > 创建 Topic ，在创建 Topic 对话框，输入 Topic 以及描述，单击确认，可以在 Topic 管理页面查看刚创建的 Topic。
2.创建group
订阅消息的时候要用到group，选择 Group 管理 > 创建 Group ID，在创建 Group ID 对话框，输入 Group ID，然后单击确认，就可以可以在 Group ID 列表中查看到刚创建的 Group ID。
3.通过Java收发消息
(1).pom.xml
<dependencies><dependency><groupId>commons-codec</groupId><artifactId>commons-codec</artifactId><version>1.10</version></dependency><dependency><groupId>org.eclipse.paho</groupId><artifactId>org.eclipse.paho.client.mqttv3</artifactId><version>1.2.2</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.2</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.48</version></dependency><dependency><groupId>com.aliyun</groupId><artifactId>aliyun-java-sdk-onsmqtt</artifactId><version>1.0.3</version></dependency><dependency><groupId>com.aliyun</groupId><artifactId>aliyun-java-sdk-core</artifactId><version>4.5.0</version></dependency>
</dependencies>(2).java代码
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallbackExtended;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;public class MQ4IoTSendMessageToMQ4IoTUseSignatureMode {public static void main(String[] args) throws Exception {/*** MQ4IOT 实例 ID，购买后控制台获取*/String instanceId = "post-cn-n6w*********";/*** 接入点地址，购买 MQ4IOT 实例，且配置完成后即可获取，接入点地址必须填写分配的域名，不得使用 IP 地址直接连接，否则可能会导致客户端异常。*/String endPoint = 这篇关于智慧停车(十八) 微消息队列 MQTT使用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
