基于netty搭建MQTT服务器如何设置用户名密码

在基于Netty搭建MQTT服务器时，可以通过以下步骤设置用户名密码：

1. 创建一个自定义的MqttAuthenticator类，并实现MqttAuthenticator接口。

2. 在MqttAuthenticator类中实现authenticate方法，该方法接收一个MqttConnectMessage对象和一个ChannelHandlerContext对象作为参数。

3. 在authenticate方法中，可以获取MqttConnectMessage对象中的用户名和密码，并进行验证。

4. 如果用户名和密码正确，则在ChannelHandlerContext对象中设置属性，以便后续的消息处理器可以获取这些属性。

5. 如果用户名和密码不正确，则可以通过ChannelHandlerContext对象关闭连接。

以下是一个例子：

public class MyMqttAuthenticator implements MqttAuthenticator {

    @Override
    public void authenticate(MqttConnectMessage connectMessage, ChannelHandlerContext ctx, Promise<Void> promise) throws Exception {
        String username = connectMessage.payload().userName();
        String password = connectMessage.payload().password();

        if (isValidUsernameAndPassword(username, password)) {
            // 设置属性，以便后续的消息处理器可以获取这些属性
            ctx.channel().attr(AttributeKey.valueOf("username")).set(username);
            ctx.channel().attr(AttributeKey.valueOf("password")).set(password);
            promise.setSuccess(null);
        } else {
            // 关闭连接
            ctx.close();
            promise.setFailure(new MqttConnectException(MqttConnectReturnCode.CONNECTION_REFUSED_BAD_USER_NAME_OR_PASSWORD));
        }
    }

    private boolean isValidUsernameAndPassword(String username, String password) {
        // TODO: 验证用户名和密码是否正确
        return true;
    }

}

在MqttServerInitializer类中，可以将自定义的MqttAuthenticator类添加到MqttServerHandler类中：

public class MqttServerInitializer extends ChannelInitializer<SocketChannel> {

    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        MqttServer mqttServer = new MqttServer();
        MqttServerHandler mqttHandler = new MqttServerHandler(mqttServer);
        mqttHandler.setAuthenticator(new MyMqttAuthenticator()); // 添加自定义的MqttAuthenticator类
        ch.pipeline().addLast(new MqttDecoder(), new MqttEncoder(), mqttHandler);
    }

}