注：客戶端代碼實現請看我的上一篇

1mqtt發送消息

發送時不用多講，每次發送肯定需要運行一次發送消息方法

MyMqttClient mqttClient = new MyMqttClient();

@org.junit.Test

public void testMqtt1() throws InterruptedException, MqttException {

final long timeInterval = 5000;

while(true) {

Thread.sleep(timeInterval);

mqttClient.publishMessage("world/1234", "hello", 1);

System.out.println("qqq");

}

}

2mqtt接收消息

接收消息只需要運行一次receive()方法即可，但需要保證的是方法進程不可以停止，具體可以用tomcat啟動線程或者自己寫一個循環阻塞等，只要本方法不停就可以一直接收訂閱的消息，比如：

@org.junit.Test

public void testMqtt1() throws InterruptedException, MqttException {

final long timeInterval = 5000;

myMqttRecieveMessage.receive(myMqttRecieveMessage.client, "world");

while(true) {

Thread.sleep(timeInterval);

}

}

總結

以上是生活随笔為你收集整理的java mqtt客户端_java 实现mqtt发送和接收消息客户端具体用法及测试代码的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。