调整优化正来电子粮情协议

jiazx0107@163.com

2024-01-04 013c5f28422defd9b47abbe17a827be693872a26

 src/main/java/com/fzzy/mqtt/MqttGatewayService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,31 @@
package com.fzzy.mqtt;

import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;


@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel")
public interface MqttGatewayService {

    /**
     * å‘送信息到MQTT服务器
     *
     * @param topic   ä¸»é¢˜
     * @param message æ¶ˆæ¯ä¸»ä½“
     */
    void publishMqttWithTopic(String message, @Header(MqttHeaders.TOPIC) String topic);

    /**
     * å‘送信息到MQTT服务器
     *
     * @param topic   ä¸»é¢˜
     * @param qos     å¯¹æ¶ˆæ¯å¤„理的几种机制。<br> 0 è¡¨ç¤ºçš„是订阅者没收到消息不会再次发送，消息会丢失。<br>
     *                1 è¡¨ç¤ºçš„是会尝试重试，一直到接收到消息，但这种情况可能导致订阅者收到多次重复消息。<br>
     *                2 å¤šäº†ä¸€æ¬¡åŽ»é‡çš„动作，确保订阅者收到的消息有一次。
     * @param message æ¶ˆæ¯ä¸»ä½“
     */
    void publishMqttWithTopic(String message, @Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) int qos);


}