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_EQU = TENANT_UP_PREFIX + "/equipment";
|
|
|
/**************************租户端向服务端发送数据end*******************************/
|
|
/**************************服务端向租户端请求数据start*******************************/
|
|
|
String SERVICE_REQ_PREFIX = "service/req";
|
|
|
/**************************服务端向租户端请求数据end*******************************/
|
//redis缓存
|
String MQTT_ONLINE_CLIENT = "mqtt:online:client::";
|
|
|
}
|
