JAvaはmqtt送信と受信メッセージクライアントの具体的な使い方とテストコードを実現する

注意:クライアントコードの実装は私の前の編を見てください
1 mqttメッセージ送信
送信時は言うまでもなく、送信するたびに必ずメッセージの送信方法を実行する必要があります.

 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");
		}
		
	}

2 mqtt受信メッセージ
メッセージを受信するにはreceive()メソッドを1回実行するだけでよいが、メソッドプロセスが停止できないことを保証する必要がある.具体的にはtomcatでスレッドを起動したり、自分でループブロックを書いたりすることができる.本メソッドが停止しない限り、サブスクリプションのメッセージをずっと受信することができる.例えば、

	@org.junit.Test
	public   void testMqtt1() throws InterruptedException, MqttException {		
		final long timeInterval = 5000;
		
		myMqttRecieveMessage.receive(myMqttRecieveMessage.client, "world");
		while(true) {
			Thread.sleep(timeInterval);
		
		}
		
	}