package org.jeecg.common.constant; /** * Mqtt指令常量 */ public interface MqttConstant { /**************************** MQTT角色 start *************************************/ String ROLE_ADMIN = "admin"; String ROLE_USER = "user"; /**************************** MQTT角色 end *************************************/ /**************************系统订阅strat*******************************/ //上线订阅 String MQTT_TOPIC_ONLINE = "$SYS/brokers/+/clients/+/connected"; //下线订阅 String MQTT_TOPIC_OFFLINE = "$SYS/brokers/+/clients/+/disconnected"; /**************************系统订阅end*******************************/ /**************************移动端向服务端请求指令start*******************************/ //移动端相关 String MOBILE_UP = "mobile/up/#"; //查询设备状态 //移动端上行指令前缀(移动端请求) String MOBILE_UP_PREFIX = "mobile/up"; //请求查询设备状态 String MOBILE_QUERY_EQU_STATU = MOBILE_UP_PREFIX + "/query/equ/statu"; //移动端远程请求指令 String MOBILE_REQ_EQU_CMD = MOBILE_UP_PREFIX + "/req/equ/cmd"; /**************************移动端向服务端请求指令end*******************************/ /**************************服务端向移动端响应指令start*******************************/ //返回数据仅返回给请求的客户端 %s发起请求客户端id //服务端下行指令前缀(返回给移动端) String SERVICE_DOWN_PREFIX = "service/down/res"; //返回移动端查询设备状态 String SERVICE_RES_EQU_STATU = SERVICE_DOWN_PREFIX + "/%s/statu"; //返回移动端远程请求指令 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:"; }