netty mqtt 服务器主动向客户端发送消息

在Netty Mqtt服务器中，要主动向客户端发送消息，需要先获取客户端的ChannelHandlerContext对象，然后通过该对象构造一个MqttPublishMessage对象，最后将该对象写入通道即可。

以下是一个示例代码：

// 获取客户端的ChannelHandlerContext对象
ChannelHandlerContext ctx = clientChannelMap.get(clientId);

// 构造MqttPublishMessage对象
MqttFixedHeader fixedHeader = new MqttFixedHeader(MqttMessageType.PUBLISH, false, MqttQoS.AT_LEAST_ONCE, false, 0);
MqttPublishVariableHeader variableHeader = new MqttPublishVariableHeader(topicName, messageId);
MqttPublishMessage publishMessage = new MqttPublishMessage(fixedHeader, variableHeader, Unpooled.buffer().writeBytes(message.getBytes()));

// 将消息写入通道
ctx.writeAndFlush(publishMessage);

其中，clientChannelMap是一个Map对象，用于保存客户端的ChannelHandlerContext对象，clientId是客户端的唯一标识，topicName是消息的主题，messageId是消息的ID，message是消息的内容。