修改

ruoyi-system/src/main/java/com/ruoyi/data/service/impl/MqttServiceImpl.java

@@ -112,7 +112,7 @@ public class MqttServiceImpl implements MqttService {
 //        tblSensorRecord.setUpdateBy("admin");
 //        updateNowRecord(tblSensorRecord);
         CacheUtils.put("sensorData",sensorId,mqttMsg.toString());
-        //websocketService.sendMessageAll(mqttStr);
+        websocketService.sendMessageAll(mqttStr);
 //      tblSensorRecordMapper.insert(tblSensorRecord);
         String protocolType = "";
         List<SysDictData> sysDictTypeList = sysDictTypeService.selectDictDataByType("protocal_type");