流程今天看公司框架的订阅发布流程时,发现大佬提供了一个接口用于测试订阅发布功能是否正常.于是启动项目调用,一直失败报错.
分析
- 向指定channel发布消息
- 监听者完成对该channel的订阅,channel有消息时触发监听者后续操作.
报的错大致是说可能没有监听者,看了下源码,系统框架会判断当前channel是否有注册监听,如果没有就会报上述错误.这个接口的发布订阅的写法和其他正常运行的写法一致.
订阅发布的流程肯定是先注册订阅,然后才能监听到发布的信息.注册监听是通过让service实现ApplicationContextAware 接口来做的,在setAppliationContext()方法中进行注册器的添加.使用这个方法也是希望在bean实例化完成后,注册监听器的操作也随之完成,从而保证正常的监听.报错信息说明注册可能没有执行,spring中bean默认都是非懒加载,setAppliationContext这个方法应该正常执行,打断点发现这个方法没进入.看了下配置,全局设置懒加载,再看下提供接口的controller,根本没有注入service,也就是说service没有实例化,这也说的通setAppliationContext为什么没执行了.
将service注入controller,或者在service上添加@Lazy(false)取消懒加载,问题得以解决
