阅读量:0
要使用Java MQTT客户端连接到服务器，您需要首先添加MQTT客户端库依赖。如果您使用的是Maven项目，可以在pom.xml文件中添加以下依赖：
<dependency> <groupId>org.eclipse.paho</groupId> <artifactId>org.eclipse.paho.client.mqttv3</artifactId> <version>1.2.5</version> </dependency> 接下来，您可以使用以下代码示例来创建一个简单的Java MQTT客户端，连接到服务器并订阅主题：
import org.eclipse.paho.client.mqttv3.*; import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; public class MqttClientExample { public static void main(String[] args) { String brokerUrl = "tcp://your_mqtt_server_address:port"; // 例如: "tcp://broker.hivemq.com:1883" String clientId = "your_client_id"; // 例如: "JavaSampleClient" String topic = "your_topic"; // 例如: "test/topic" // 创建一个内存中的持久化对象 MemoryPersistence persistence = new MemoryPersistence(); try { // 创建一个MQTT客户端实例 MqttClient client = new MqttClient(brokerUrl, clientId, persistence); // 连接到MQTT服务器 MqttConnectOptions connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true); client.connect(connOpts); // 订阅指定主题 client.subscribe(topic); // 设置消息回调和处理逻辑 client.setCallback(new MqttCallback() { @Override public void messageArrived(String topic, MqttMessage message) { System.out.println("Message arrived: " + new String(message.getPayload())); } @Override public void connectionLost(Throwable cause) { System.out.println("Connection lost: " + cause.getMessage()); } @Override public void deliveryComplete(IMqttDeliveryToken token) { System.out.println("Delivery complete"); } }); // 保持客户端运行，以便持续接收消息 Thread.sleep(60000); } catch (Exception e) { System.out.println("Error: " + e.getMessage()); e.printStackTrace(); } } } 请确保将your_mqtt_server_address、port、your_client_id和your_topic替换为您的实际MQTT服务器地址、端口、客户端ID和订阅的主题。
这个示例代码会连接到MQTT服务器，订阅指定主题，并在接收到消息时打印消息内容。您可以根据需要修改回调方法来实现自定义的消息处理逻辑。
