添加mqtt数据接口

zhuguifei

2024-11-27 320c0c10a90140627b10a6fcf498e79d09785da6

 jeecg-boot-base-core/src/main/java/org/jeecg/common/constant/MqttConstant.java

@@ -5,6 +5,13 @@
 */
public interface MqttConstant {

  /**************************** MQTT角色 start *************************************/
  String ROLE_ADMIN = "admin";
  String ROLE_USER = "user";


  /**************************** MQTT角色 end *************************************/

  /**************************系统订阅strat*******************************/
  //上线订阅
  String MQTT_TOPIC_ONLINE = "$SYS/brokers/+/clients/+/connected";
@@ -24,7 +31,11 @@
  String MOBILE_QUERY_EQU_STATU = MOBILE_UP_PREFIX + "/query/equ/statu";
  //移动端远程请求指令
  String MOBILE_REQ_EQU_CMD = MOBILE_UP_PREFIX + "/req/equ/cmd";


  /**************************移动端向服务端请求指令end*******************************/




  /**************************服务端向移动端响应指令start*******************************/
@@ -35,11 +46,63 @@
  String SERVICE_RES_EQU_STATU = SERVICE_DOWN_PREFIX + "/%s/statu";
  //返回移动端远程请求指令
  String SERVICE_RES_EQU_CMD = SERVICE_DOWN_PREFIX + "/%s/cmd";



  /**************************服务端向移动端响应指令end*******************************/


  /**************************服务端向移动端发送广播start*******************************/
  //广播类型推送无关移动端设备id，向所有在线移动端发送
  String SERVICE_BROADCAST_PREFIX = "service/broadcast";

  //服务端向各租户客户端发送实时故障广播
  String  SERVICE_BROADCAST_TENANT_REAL_FAULT = SERVICE_BROADCAST_PREFIX + "/real/fault/%s"  ;



  /**************************服务端向移动端发送广播end*******************************/





  /**************************租户端向服务端发送数据start*******************************/


  String TENANT_UP_PREFIX = "tenant/up";
  String TENANT_UP_PREFIX_REALTIME_DATA = TENANT_UP_PREFIX + "/realTime/data";
  String TENANT_UP_PREFIX_FAULT_DATA = TENANT_UP_PREFIX + "/fault/data";
  String TENANT_UP_PREFIX_REAL_FAULT_DATA = TENANT_UP_PREFIX + "/real/fault/data";

  String TENANT_UP_PREFIX_EQU = TENANT_UP_PREFIX + "/equipment";


  /**************************租户端向服务端发送数据end*******************************/

  /**************************服务端向租户端请求数据start*******************************/


  String SERVICE_REQ_PREFIX = "service/req";


  /**************************服务端向租户端请求数据end*******************************/

  /**************************start*******************************/
  /**************************end*******************************/
  //redis缓存
  String MQTT_ONLINE_CLIENT = "mqtt:online:client::";
  //client
  String MQTT_REAL_FAULT = "mqtt:real:fault";



  //service(cloud)
  //在线客户端
  String MQTT_ONLINE_CLIENT = "mqtt:online:client:%s";
  //所有租户的实时报警（%s：租户id）
  String MQTT_CLOUD_REAL_FAULT = "mqtt:real:fault:%s";




}