MQTT （mosqu itto）环境搭建 一、下载 mosqu itto 安装 二、启动 mosqu itto C:\Program Files (x 86)\mosqu itto>mosqu itto.ex e -c mosqu itto.conf 三、模拟订阅客户端
org.fu sesou rce.mqtt-client mqtt-client 1.0 package com.su ning.ebu y .passbook; import jav a.net.URISy ntax Ex ception; import org.fu sesou rce.mqtt.client.BlockingConnection; import org.fu sesou rce.mqtt.client.MQTT; import org.fu sesou rce.mqtt.client.Message; import org.fu sesou rce.mqtt.client.QoS; import org.fu sesou rce.mqtt.client.Topic; import org.slf4j.Logger; import org.slf4j.LoggerFactory ; /** * * 使用 Java 为 MQ Telemetry Transport 创建订户 在此任务中，您将遵循教程来创建订户应用程序。订户将针对主题创建预订并接 收该 预订的 发布 。 提供 了一 个示 例订户应用程序 Subscribe。Subscribe * 将创建预订主题 MQTT Examples，并等待获 得该预订的发布，等待时间为 30 秒。订户可以创建预订并等待获得发布。它还可以接收发送至先前 为同一客户机标识创建的预订的发布。 * * @author longgangbai */ public class WSMQTTClientSubscribe { private static final Logger LOG = LoggerFactory.getLogger(WSMQTTClientSubscribe.class); private final static String CONNECTION_STRING = "tcp://localhost:1883"; private final static boolean CLEAN_START = true; private final static short KEEP_ALIVE = 30;// 低耗网络，但是又需要及时获取数据，心跳 30s private final static String CLIENT_ID = "publishService"; public static Topic[] topics1 = { new Topic("china/beijing", QoS.EXACTLY_ONCE), new Topic("china/tianjin", QoS.AT_LEAST_ONCE), new Topic("china/henan", QoS.AT_MOST_ONCE) }; public final static long RECONNECTION_ATTEMPT_MAX = 6; public final static long RECONNECTION_DELAY = 2000; public final static int SEND_BUFFER_SIZE = 2 * 1024 * 1024;// 发送最大缓冲为 2M publi...
