这个channelIdMap并不是并发安全的吧

[devhg]

MqttWk/mqtt-broker/src/main/java/cn/wizzer/iot/mqtt/server/broker/handler/BrokerHandler.java

Lines 25 to 50 in e12930f

	@IocBean
	@ChannelHandler.Sharable
	public class BrokerHandler extends SimpleChannelInboundHandler<MqttMessage> {
	@Inject
	private ProtocolProcess protocolProcess;
	@Inject
	private BrokerProperties brokerProperties;
	@Inject
	private ChannelGroup channelGroup;
	@Inject
	private Map<String, ChannelId> channelIdMap;
	@Override
	public void channelActive(ChannelHandlerContext ctx) throws Exception {
	super.channelActive(ctx);
	this.channelGroup.add(ctx.channel());
	this.channelIdMap.put(brokerProperties.getId() + "_" + ctx.channel().id().asLongText(), ctx.channel().id());
	}
	@Override
	public void channelInactive(ChannelHandlerContext ctx) throws Exception {
	super.channelInactive(ctx);
	this.channelGroup.remove(ctx.channel());
	this.channelIdMap.remove(brokerProperties.getId() + "_" + ctx.channel().id().asLongText());
	}