Jstorm+Spring+mybatis整合

  在现有的jstorm框架下,有一个需求:jstorm要对接mysql数据库的实时读取数据, 通过bolt处理,可能要调用service层的框架,最后保存到数据库。

在网上寻找了一下,发现storm集成spring的资料非常少,有的也只是简单描述,现把搭建过程的一些问题和注意事项详细列出。

1、pom文件、jstorm+spring+mybatis  网上大把的资料,不在这里详细累述。需要注意就是版本兼容问题,可以到www.mvnreposity.com去查看一下

2、jstorm容器集成spring容器,不能采用@autowire 注入的方式,只能在component(spout/bolt)中获取bean,可以写一个公共类,方便以后相同操作。

public class SpringContext implements ApplicationContextAware{private static ClassPathXmlApplicationContext applicationContext ;public static synchronized  void SpringContextInit(){if (applicationContext==null){applicationContext =new ClassPathXmlApplicationContext(new String[]{"application.xml"});
//                applicationContext.start();
                 }}public static <T> T getBean(String name,Class<T> clazz){if (applicationContext==null){SpringContext.SpringContextInit();}return applicationContext.getBean(name,clazz);}@Overridepublic void setApplicationContext(ApplicationContext arg0) throws BeansException {applicationContext=(ClassPathXmlApplicationContext) arg0;}
}
View Code

3、序列化问题:通过本地测试  加不加序列化都无所谓   都能跑通, 建议加上,因为现在还没有上线集群测试

4、将获取bean的操作 放在open和prepare里、在spout中获取数据源的方法放在open中,nextTuple只负责提交数据到stream中、在bolt中处理数据的方法放在excute中。

 

转载于:https://www.cnblogs.com/syd-fish-cat/p/9602823.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/451384.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

上海云栖:金融政企行业的CDN最佳实践

2019独角兽企业重金招聘Python工程师标准>>> 摘要&#xff1a; 在刚刚结束的上海云栖大会飞天技术汇分论坛上&#xff0c;阿里云视频云产品架构师罗小飞进行了《阿里云CDN——面向金融政企的CDN最佳实践》主题分享&#xff0c;为上海的嘉宾介绍CDN的解决方案与技术服…

lunix基本命令

安装lunix 批量创建文件 whoami查看当前用户 sudo adduser lilei创建用户 groups lilei 查看用户所属用户组 sudo usermod -G root lilei 赋予root权限 sudo deluser lilei --remove-home ls -l 显示目录的文件 ls -a 显示隐藏文件 PWD 获取当前目录 cd .. 返回上层目录 cd 进入…

开启Swarm集群以及可视化管理

为什么80%的码农都做不了架构师&#xff1f;>>> 在搭建的两台coreos服务器上开启swarm集群 前置条件&#xff1a; docker均开启2375端口同一个局域网内主服务器上安装Portainer容器安装Portainer容器执行&#xff1a; docker run -d -p 9000:9000 --restartalways …

python基本语法:序列

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 1. 序列的基本操作&#xff1a; 2.用例&#xff1a; 3.序列包含字符串、元组、列表。

IMDb、烂番茄、MTC、各种电影行业评分名字整理

这篇不是技术文章&#xff0c;就是对总是看到但是不知道具体是什么的一些电影名词、评分、来源&#xff0c;学习一下。 IMDb 互联网电影资料库&#xff08;Internet Movie Database&#xff0c;简称IMDb&#xff09;是一个关于电影演员、电影、电视节目、电视明星和电影制作的在…

iOS应用:成功就像中彩票,大半开发者亏本

移动是座大金矿&#xff0c;从来都不乏一飞冲天的成功故事&#xff08;Draw Something、愤怒的小鸟等&#xff09;。但是大家往往只看到光鲜的一面&#xff0c;对于移动开发者来说&#xff0c;现实是残酷的&#xff0c;根据市场营销机构App Promo的一项调查&#xff0c;绝大多数…

python基本语法:元组

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 1. 元组说明&#xff1a; 元组和列表类似&#xff0c;只不过元组和字符串一样是不可变的&#xff0c;即你不能修改元组。 元组通过圆括…

python基本语法:列表(列表和元组的区别)

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 1.基本说明 2.用例&#xff1a; 3.列表类似于java中的list. 与元组不同&#xff0c;定义单个元素对象时不用加逗号&#xff0c;且元素值…

用JSONObject解析和处理json数据

本文中主要介绍JSONObject处理json数据时候的一些常用场景和方法。 &#xff08;一&#xff09;jar包下载 所需jar包打包下载百度网盘地址&#xff1a;https://pan.baidu.com/s/1c27Uyre&#xff08;二&#xff09;常见场景及处理方法 1、解析简单的json字符串&#xff1a;1  …

手机、平板、PC与智能电视实现数据大统一

进来&#xff0c;由 Ubuntu 手机原型设计引发的风波&#xff08;数据大贯通&#xff09;&#xff0c;越演越烈&#xff0c;给人的感觉是“大雨欲来&#xff0c;风满楼”。这是什么事情呢&#xff1f; 根据4月12日透露出的一份Ubuntu手机的功能设计示意图&#xff0c;人们纷纷猜…

PL SQL导入导出sql/dmp文件

导出步骤&#xff1a;1、tools ->export user object (导出的是建表语句&#xff08;包括存储结构&#xff09;&#xff0c;选择选项&#xff0c;导出.sql文件2、tools ->export tables-> SQL Inserts 选择选项导出指定某些表.sql文件按照如图所示的勾选&#xff0c;成…

Python 中使用help()命令后如何退出

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 1. 如图在 help 界面时&#xff0c;想要回到原本书写界面&#xff0c;按 q 就可以了&#xff0c;网上也有的说可以 Ctrl d ---------…

轻松理解—继承成员访问控制机制

在我们学习面向对象程序设计的时候&#xff0c;那么这个继承成员访问控制机制您必须对其有深入的了解&#xff0c;达到熟练掌握的目的&#xff1b;要不也许这点知识你不过关&#xff0c;你对这点知识还抱着半信半疑的感觉&#xff0c;那么你一旦碰到这个问题&#xff0c;你的第…

iPhone iPad 各种控件默认高度

iPhone和iPad下各种常见控件的宽度和标准是一样的&#xff0c;所以这里就用iPhone说明。 以下是常见的几种控件的高度。Statusbar,Navigationbar和Tabbar的宽度极其图标大小。 下表是更为详细的参数&#xff0c;包括了Statusbar,Navigationbar、Tabbar、toolbar和Keyboard等等 …

Map.putAll方法——追加另一个Map对象到当前Map集合

该方法用来追加另一个Map对象到当前Map集合对象&#xff0c;它会把另一个Map集合对象中的所有内容添加到当前Map集合对象。 语法 putAll(Map<? extends K,? extends V> m) m&#xff1a;一个Map集合对象。 典型应用 本示例创建一个Map集合对象&#xff0c;为它添加一…

PLSQL的表窗口开启(不小心把PLSQL的表窗口关了,在哪里打开)

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 菜单条---工具---浏览器。

Django的视图层

一、视图函数 一个视图函数&#xff0c;简称视图&#xff0c;是一个简单的python函数&#xff0c;它接受Web请求并且返回Web响应。响应可以是一张网页的HTML内容&#xff0c;一个重定向&#xff0c;一个404错误&#xff0c;一个XML文档&#xff0c;或者一张图片...是任何东西都…

技术债务真正的代价

无论你是否喜欢把它想成技术债务或是对冲期权&#xff0c;在我们的周围都充斥着糟糕的代码&#xff0c;糟糕的决定&#xff0c;以及这些东西给我们每天的生活带来的影响。但是这些决定所带来的长期影响会是什么&#xff1f;我们真的做了明智的选择吗&#xff1f;Martin Fowler谈…

Java 8 Stream的性能到底如何?

Java 8提供的流的基于Lambda表达式的函数式的操作写法让人感觉很爽&#xff0c;笔者也一直用的很开心&#xff0c;直到看到了Java8 Lambda表达式和流操作如何让你的代码变慢5倍&#xff0c;笔者当时是震惊的&#xff0c;我读书少&#xff0c;你不要骗我。瞬间我似乎为我的Serve…