自定义MQTT

BladeX大约 2 分钟mqttfeature

概念说明

MQTT（Message Queuing Telemetry Transport）是一种轻量级的、基于发布/订阅模式的消息传输协议，广泛应用于物联网(IoT)、移动应用等领域。自定义MQTT服务端监听功能，旨在实现更加灵活、高效的消息处理机制，以满足特定业务需求。

特点和优势：

灵活性：自定义监听逻辑可以根据业务需求进行灵活调整，满足不同的消息处理场景。
高效性：通过优化消息处理流程，提高消息传输和处理的效率，降低系统资源消耗。
可扩展性：监听逻辑可以与其他系统或服务进行集成，实现更复杂的业务功能。
安全性：通过身份验证和权限控制，确保只有合法的客户端才能连接和发布消息，保障系统安全。

一、自定义MQTT监听类

进入blade-broker工程，前往org.springblade.mqtt.broker.data.listener包下，找到MqttMessageListener类。
此类为提前预留，方便用户进行自定义消息监听逻辑的实现。在现有broker服务器消息处理的逻辑之外，可自由定义各种复杂业务的处理实现。

二、增加自定义逻辑

本处仅为示例，用户可根据实际业务需求进行自定义逻辑的实现。
在onMessage方法中，增加对自定义topic的处理逻辑，如数据入库、推送等。

@Override  
public void onMessage(ChannelContext context, String clientId, String topic, MqttQoS qos, MqttPublishMessage message) {  
    // 自定义消息处理  
    String pattern = BladeTopics.getTopicPattern("/blade/custom/${productKey}/${deviceName}/battery/post");  
    boolean match = BladeTopics.isMatch(pattern, topic);  
    if (match) {  
        log.info("========================================================================");  
        log.info("自定义Topic：{}", topic);  
        log.info("自定义Topic消息处理：{}", message);  
        log.info("=======================================================================");  
    }  
}

三、运行模拟器查看控制台效果

可以看到自定义Topic的消息处理逻辑已经生效，控制台打印出了自定义Topic的消息内容。