文件名称:storm-spring-autowire:使storm支持spring的注入功能
文件大小:36KB
文件格式:ZIP
更新时间:2024-05-24 17:37:57
Java
storm-spring-autowire 使storm支持spring的注入功能 由于storm的生命周期如下 1.在提交了一个topology之后(是在nimbus所在的机器么?), 创建spout/bolt实例(spout/bolt在storm中统称为component)并进行序列化. 2.将序列化的component发送给所有的任务所在的机器 3.在每一个任务上反序列化component. 4.在开始执行任务之前, 先执行component的初始化方法(bolt是prepare, spout是open). 这个项目采取了了在prepare方法中执行注入的方式使bolt在序列化完成后执行注入,绕开了storm的序列化机制 使用这个项目里 你可以通过以下代码做到最基本的注入 @Resource private SentenceCounter counter; public void
【文件预览】:
storm-spring-autowire-master
----README.md(3KB)
----pom.xml(1KB)
----java()
--------test()
--------main()