海滨擎蟹

@Autowired 对象注入失败的问题

遇到的场景:netty 中初始化 mqtt 服务,添加处理器时,默认使用的是 new MstMqttSocketHandler() 返回处理器。

if (isMqttRequest(msgBody)) {
    pipeline.addLast("mqttDecoder", new MqttDecoder())
            .addLast(MqttEncoder.INSTANCE)
            .addLast("mqttHandler", new MstMqttSocketHandler());
    ctx.fireChannelRead(byteBuf);
    pipeline.remove(this.getClass());
}

在使用 MQTTX 客户端发起 CONNECT 连接请求时报错了:An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception.

提示在 pipeline 尾部触发了异常,结合 Wizzer / MqttWk 中 mqtt 协议处理代码,末尾的两句似乎有问题:

ctx.fireChannelRead(byteBuf);
pipeline.remove(this.getClass());

尝试注释掉两行再发送连接,没有报错,但此时连接没有连接成功。通过增加日志发现请求消息并没有经过 MstMqttSocketHandler 处理器。网上查到 fireChannelRead 用法,后面还有一个心跳的处理器,这个操作似乎是必要的。其他协议(tcp)之类的接入似乎没有发生这种情况,所以这两句不能去掉。

观察原有代码 tcp 协议的处理发现了几行比较有意思的内容:

if (protocolProcess == null) {
   protocolProcess = MyContext.getContext().getBean(ProtocolProcess.class);
}

本来 protocolProcess 就是通过 @Autowired 注解注入的对象,怎么会有有一个为空从容器中获取的操作呢?尝试按照相同的方式添加类似的代码,果然再次连接没有报错了。这意味着 @Autowired 注入失败了。

查找 @Autowired 注入失败的情况,找到以下符合现状的描述:

A 类包含以 @Autowired 方式注入的属性 B,如果 A 类通过 new 实例对象则属性 B 会注入失败

所以 A 类的使用需要通过从容器中获取,即 new MstMqttSocketHandler() 应该改成 MyContext.getContext().getBean(MstMqttSocketHandler.class),这样就好了。

后续遇到说 MstMqttSocketHandler 不能 share,添加 @ChannelHandler.Sharable 注解即可。

当前页面是本站的「Google AMP」版。查看和发表评论请点击:完整版 »