环境信息
- EMQX 版本:EMQ X Broker:4.3.5
- 操作系统及版本:CentOS 8
- 其他
问题描述
在 etc/plugins/emqx_auth_http.conf 文件中做了相应的设置
在java 中也设置了相应的接口文件,接口文件通过postman访问都没有问题;
其中 /mqtt/auth 好用;/mqtt/acl 不好用;
@Path("/mqtt")
#POST
#Path("/auth")
#Produces({ MediaType.APPLICATION_JSON })
#Consumes({ MediaType.APPLICATION_JSON })
Object mqttLoginAuth(JSONObject request) throws BusinessException;
#POST
#Path("/acl")
#Produces({ MediaType.APPLICATION_JSON })
#Consumes({ "application/x-www-form-urlencoded" })
Object mqttACL(#FormParam("access") String access, #FormParam("username") String username,
#FormParam("clientid") String clientid, #FormParam("topic") String topic) throws Exception;
public Object mqttACL(String access, String username, String clientid, String topic) throws BusinessException {
logger.info(String.format("mqttACL_Result: 进入:" + clientid + ":" + access + ":" + username + ":" + topic));
// logger.info("mqttACLmqttACLmqttACL:"+request.toString());
throw new BusinessException("mqttACL err");