3、SpringBoot集成Storm WorldCount

RandomSentenceSpout

//数据源，在已知的英文句子中，随机发送一条句子出去。
public class RandomSentenceSpout extends BaseRichSpout {//用来收集Spout输出的tupleprivate SpoutOutputCollector collector;private Random random;//该方法调用一次，主要由storm框架传入SpoutOutputCollector@Overridepublic void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector) {this.collector = collector;random = new Random();//连接kafka mysql ,打开本地文件}/*** 上帝之手* while(true)*      spout.nextTuple()*/@Overridepublic void nextTuple() {String[] sentences = new String[]{"the cow jumped over the moon","the dog jumped over the moon","the pig jumped over the gun","the fish jumped over the moon","the duck jumped over the moon","the man jumped over the sun","the girl jumped over the sun","the boy jumped over the sun"};String sentence = sentences[random.nextInt(sentences.length)];collector.emit(new Values(sentence));System.out.println("RandomSentenceSpout 发送数据："+sentence);}//消息源可以发射多条消息流stream@Overridepublic void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {outputFieldsDeclarer.declare(new Fields("sentence"));}
}

转载于:https://www.cnblogs.com/xidianzxm/p/10751382.html

3、SpringBoot集成Storm WorldCount相关推荐

SpringBoot集成swagger3（powernode CD2207）（内含教学视频+源代码）
SpringBoot集成swagger3(powernode CD2207)(内含教学视频+源代码) 教学视频+源代码下载链接地址:https://download.csdn.net/download ...
kafka(组件分析整合springboot集成实战)
kafka 组件搭建 springboot集成实战 kafka 组件搭建 springboot集成实战 1.应用场景 1.1 kafka场景 1.2 kafka特性 1.3 消息对比 1.4 ...
Windows下安装Mongodb SpringBoot集成MongoDB和Redis多数据源
全文内容: Mongodb安装说明:Mongodb和redis是开发中常用的中间件,Redis的安装使用比较简单就不写了,只说本地也就是Windows安装Mongodb. SpringBoot集成M ...
SpringBoot集成FreeMarker
给大家简单介绍一下springboot 集成FreeMarker 过程很简单,5分钟即可. 首先在项目中增添依赖spring-boot-starter-freemarker pom文件代码如下: &l ...
springboot集成swagger2测试接口
springboot集成swagger2测试接口 1.需要的依赖 2.开始编写一个swagger2 3.演示效果图片 1.需要的依赖 <dependency><groupId> ...
springboot 集成logback
springboot 集成logback 1.application.properties配置文件指定logback.xml logging.config=classpath:logback.xml ...
springboot集成swagger2多模块中文配置详细步骤，解决集成mybatis或mybatis-plus无法正常使用问题
springboot集成swagger2多模块中文配置详细步骤,解决集成mybatis或mybatis-plus无法正常使用问题参考文章: (1)springboot集成swagger2多模块中文配 ...
SpringBoot集成Quartz(解决@Autowired空指针Null问题即依赖注入的属性为null)
SpringBoot集成Quartz(解决@Autowired空指针Null问题即依赖注入的属性为null) 参考文章: (1)SpringBoot集成Quartz(解决@Autowired空指针Nu ...
SpringBoot集成全局异常处理
2019独角兽企业重金招聘Python工程师标准>>> SpringBoot集成全局异常处理前言对于通常的MVC项目,大量的异常需要我们去处理,如此一来,我们的 Controll ...
dubbo web工程示例_dubbo实战之二：与SpringBoot集成
欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容:所有原创文章分类和汇总,及配套源码,涉及Java.Docker.Kubernetes.DevO ...

3、SpringBoot集成Storm WorldCount

RandomSentenceSpout

3、SpringBoot集成Storm WorldCount相关推荐

最新文章

热门文章