szwlServer/src/main/java/com/szwl/service/MqttService.java

package com.szwl.service;

import com.baomidou.mybatisplus.extension.service.IService;

public interface MqttService {

    void sendMessage(String topic, String message, int qos);

    void subscribe(String topic, int qos);

    void unsubscribe(String topic);
}