干燥机配套车间生产管理系统/云平台服务端
zhuguifei
2024-11-20 426f50baf57ae5901a6b5a26d1567e3b270d2499
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";
@@ -27,6 +34,11 @@
  /**************************移动端向服务端请求指令end*******************************/
  /**************************服务端向移动端响应指令start*******************************/
  //返回数据仅返回给请求的客户端 %s发起请求客户端id
  //服务端下行指令前缀(返回给移动端)
@@ -37,9 +49,42 @@
  String SERVICE_RES_EQU_CMD = SERVICE_DOWN_PREFIX + "/%s/cmd";
  /**************************服务端向移动端响应指令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缓存
  //client
  String MQTT_REAL_FAULT = "mqtt:real:fault";
  //service(cloud)
  //在线客户端
  String MQTT_ONLINE_CLIENT = "mqtt:online:client::";
  //所有租户的实时报警(%s:租户id)
  String MQTT_CLOUD_REAL_FAULT = "mqtt:real:fault:%s:";
}