一、emqx添加http登录鉴权认证

进入emqx映射出来的配置文件目录，编辑鉴权的配置文件

cd /home/egn/emqx/etc/plugins vim emqx_auth_http.conf

auth.http.auth_req.url = http://127.0.0.1:8002/emqapi/auth【修改接口地址】 auth.http.super_req.url = http://127.0.0.1:8003/emqapi/superuser【放开注释并修改接口地址】 auth.http.super_req.method = post【放开注释】 auth.http.super_req.headers.content-type = application/x-www-form-urlencoded【放开注释】 auth.http.super_req.params = clientid=%c,username=%u【放开注释】【修改接口地址】 auth.http.acl_req.url = http://127.0.0.1:8003/emqapi/acl【修改接口地址】

重启容器，使配置文件生效

docker restart emqx

开启插件

二、Springboot 鉴权接口

@RestController @RequestMapping("/emqapi") @Api(value="EMQAPI接口",tags={"EMQAPI接口"}) public class EmqApiController{   private static Logger logger = LoggerFactory.getLogger(EmqApiController.class);  @Autowired  AuthService authService;   @ApiOperation(value = "客户端连接授权" ,notes = "客户端连接授权" )  @ApiImplicitParams({  @ApiImplicitParam(name = "clientid" ,value = "客户端clientId" , required = false, dataType = "String"),  @ApiImplicitParam(name = "username" ,value = "客户端username" , required = false, dataType = "String"),  @ApiImplicitParam(name = "password" ,value = "客户端password" , required = false, dataType = "String")  })  @PostMapping(value = "/auth")  public void checkUser(String clientid, String username, String password, HttpServletResponse response) throws Exception {  //这里添加业务逻辑 200 允许登录，其他Stuatus不允许登录  System.out.println("普通用户；clientid:" + clientid + ";username:" + username);  response.setStatus(200);  }    @PostMapping("/superuser")  public void mqttSuperuser(String clientid, String username, HttpServletResponse response) {  logger.info("超级用户；clientid:" + clientid + ";username:" + username);  System.out.println("超级用户；clientid:" + clientid + ";username:" + username);  response.setStatus(200);  }   @PostMapping("/acl")  public void mqttAcl(String access, String username, String clientid, String ipaddr, String topic, HttpServletResponse response) {  //auth.http.acl_req.params = access=%A,username=%u,clientid=%c,ipaddr=%a,topic=%t  logger.info("access: " + access + ";username: " + username + ";clientid: " + clientid + "; ipaddr: " + ipaddr + ";topic: " + topic);  System.out.println("access: " + access + ";username: " + username + ";clientid: " + clientid + "; ipaddr: " + ipaddr + ";topic: " + topic);  response.setStatus(200);  }  }