作者在使用netty整合spring注入呼叫時普通的@Autowired一直bean注入為null,這裡我只是記錄針對netty注入spring無法注入bean的解決發放,具體底層實現,希望大神不吝賜教

首先上解決程式碼塊,copy過去就可以直接用

@Component
public class NettyWebSocketServerHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {


    public static NettyWebSocketServerHandler nettyWebSocketServerHandler;

    //1.正常注入[記得主類也需要使用@Component註解]
    @Autowired
    private IUserInfoService appUserService;
    @Autowired
    private IUserCoinRecordService userCoinRecordService;

    //2.初始化構造方法一定要有
    public NettyWebSocketServerHandler() {

    }

    //3.容器初始化的時候進行執行-這裡是重點
    @PostConstruct
    public void init() {
        nettyWebSocketServerHandler = this;
        nettyWebSocketServerHandler.appUserService = this.appUserService;
        nettyWebSocketServerHandler.userCoinRecordService = this.userCoinRecordService;
    }

    /**
     * 管道初始化
     *
     * @param ctx
     * @param msg
     * @throws Exception
     */
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception {
        System.out.println("收到訊息: " + msg.text());
        String info = DataParamsComm.analysisData(msg.text());
        System.out.println("解密資料:" + info);
        //4.這裡是呼叫方法需要通過另一個bean去呼叫,你真正使用的bean
System.out.println(nettyWebSocketServerHandler.appUserService.findByUserId(500001L));
        ctx.channel().writeAndFlush(new TextWebSocketFrame("接收到的內容: " + JSON.toJSONString(nettyWebSocketServerHandler.appUserService.findByUserId(500001L))));

    }
}
 

這樣就解決了spring整合netty無法注入bean的問題,現在bean在netty中正常的業務呼叫了