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";
|
|
//移动端请求查询一次设备实时故障告警
|
String MOBILE_REQ_EQU_REAL_FAULT = MOBILE_UP_PREFIX + "/req/real/fault";
|
|
|
/**************************移动端向服务端请求指令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*******************************/
|
//广播类型推送无关移动端设备id，向所有在线移动端发送
|
String SERVICE_BROADCAST_PREFIX = "service/broadcast";
|
|
//服务端向各租户客户端发送实时故障广播
|
String SERVICE_BROADCAST_TENANT_REAL_FAULT = SERVICE_BROADCAST_PREFIX + "/real/fault/%s";
|
//服务端向移动端回复一次设备实时故障告警
|
String SERVICE_ONECE_TENANT_REAL_FAULT = "service/onece" + "/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_REALTIME_DATA_EQP = TENANT_UP_PREFIX + "/realTime/data/eqp";
|
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缓存
|
//所有租户的实时报警（%s：租户id）
|
String MQTT_REAL_FAULT = "mqtt:real:fault:%s";
|
|
|
|
//service(cloud)
|
//在线客户端
|
String MQTT_ONLINE_CLIENT = "mqtt:online:client:%s";
|
// String MQTT_CLOUD_REAL_FAULT = "mqtt:real:fault:%s";
|
|
|
|
|
}
|
