集成mqtt

jiangping

2023-10-09 a89b82b53214b1e9f2d61f1978e7694a55543f21

集成mqtt

 server/services/src/main/java/com/doumee/service/business/DeviceService.java

@@ -14,7 +14,7 @@
     * 下发开车开锁指令
     * @return String
     */
    String openLock(Locks locks);
    boolean openLock(Locks locks);
    void startSubcribe();

}

 server/services/src/main/java/com/doumee/service/business/impl/DeviceServiceImpl.java

@@ -27,9 +27,9 @@
        mqttToolService.subscribe(new String[]{ Constants.MqttTopic.openLock, Constants.MqttTopic.closeLock});
    }
    @Override
    public String openLock(Locks locks) {
    public boolean openLock(Locks locks) {
        mqttToolService.pubMessage(locks.getName(), Constants.MqttTopic.openLock);
        return null;
        return true;
    }

}