Storm中怎么定义Blots程序

这篇文章主要介绍“Storm中怎么定义Blots程序”，在日常操作中，相信很多人在Storm中怎么定义Blots程序问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Storm中怎么定义Blots程序”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

创新互联公司是一家专业的成都网站建设公司，我们专注网站制作、成都做网站、网络营销、企业网站建设，买链接，广告投放为企业客户提供一站式建站解决方案，能带给客户新的互联网理念。从网站结构的规划UI设计到用户体验提高，创新互联力求做到尽善尽美。

具体内容

在Storm程序开发过程之中有两个重要的核心概念：Spout、Blot。Spout会作为数据的发起点，这个数据可能来源于各种地方，例如：Kafka传递过来的消息内容，而每一个Spout接收到数据之后如果有需要则将数据传递给Blot，由多个Blot进行数据的操作处理。把每一个Blot想象为一个数据的过滤器，而最后一个Blot将作为数据的存储使用，而一般的存储设备往往是文件、redis数据库。

Storm中怎么定义Blots程序

在本次程序的处理里面，Spouts将使用随机数产生相应的年龄数据，而有会有三个Blot进行数据的处理，这些数据处理是有自己严格的语法要求的。如果要想实现Storm开发，则需要将Storm所有的相关库文件配置到ClassPath之中。如果要想开发Spout往往需要实现一个IRickSpout接口，但是这个接口里面的方法比较多，所以建议继承这个接口的子类：BaseRichSpout。范例：定义InfoCreateSpouts

package cn.mldn.info.spouts;import java.util.Map;import java.util.Random;import org.apache.storm.spout.SpoutOutputCollector;import org.apache.storm.task.TopologyContext;import org.apache.storm.topology.OutputFieldsDeclarer;importorg.apache.storm.topology.base.BaseRichSpout;import org.apache.storm.tuple.Fields;import org.apache.storm.tuple.Values;@SuppressWarnings("serial")publi cclass InfoCreateSpoutextendsBaseRichSpout{private SpoutOutputCollector collector=null;private String nameStr="aBcDefghIjklmnopQrStuvwxyz";//假设为用户名private Random rand=new Random();
@SuppressWarnings("rawtypes")@Overridepublic void open(Mapconf,TopologyContextcontext,SpoutOutputCollectorcollector){//为Spout初始化方法，这个初始化方法只执行一次；this.collector=collector;//接收初始化方法中的SpoutOutputCollector对象 }@OverridepublicvoidnextTuple(){ //执行Spout程序时会自动找到此方法，此方法为发送消息//从正常的开发角度而言，此处的数据应该由消息系统传递过来 String nameInfo=String.valueOf(this.nameStr.charAt(rand.nextInt(nameStr.length())));intageInfo=this.rand.nextInt(150);//随机生成一个年龄 //最终如果要进行数据的发送，结构：name、age，所有的Spouts的数据要交给Blot完成。this.collector.emit(newValues(nameInfo,ageInfo));}@OverridepublicvoiddeclareOutputFields(OutputFieldsDeclarerdeclare){//需要定义每一个传输中的数据保存的名称declare.declare(newFields("name","age"));//向后发送Tuple的时候此为信息的文字标注}}

在整个的代码里面，nextTuple()为系统自动调用，Spout产生Blot所需要的数据。

定义Blots程序

在本处理流程之中需要有三个Blot，作用分别如下：

·AgeJudementBlot：判断传入数据的年龄是成年人（ADULT）还是年轻人（YOUNG）；·NameUpperBlot：因为姓名有大写和小写，为了统一管理，信息都变为大写；·FinalBlot：进行数据的保存处理。但是需要注意的是，此时定义的只是一个个独立的Blot，彼此之间的联系需要通过程序来完成。范例：进行年龄判断的Blot实现.

package cn.mldn.info.blots;import org.apache.storm.topology.BasicOutputCollector;importorg.apache.storm.topology.OutputFieldsDeclarer;importorg.apache.storm.topology.base.BaseBasicBolt;import org.apache.storm.tuple.Fields;import org.apache.storm.tuple.Tuple;import org.apache.storm.tuple.Values;@SuppressWarnings("serial")public class AgeJudementBlotextendsBaseBasicBolt{  @Override public void execute(Tupletuple,BasicOutputCollectorcollector){

Storm中怎么定义Blots程序

范例：处理姓名大小写的操作

Storm中怎么定义Blots程序

范例：增加一个输出到文件的Blot

Storm中怎么定义Blots程序

这些定义的Blot一定要接收Spout传来的数据，但是这些Blot之间没有直接的联系，所有的关系都必须通过程序动态配置。

编写测试程序

Storm最大的好处是直接提供了本地的windows模拟测试，但是在配置过程里面需要配置这些bolts关系。范例：编写测试程序

Storm中怎么定义Blots程序

到此，关于“Storm中怎么定义Blots程序”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！

本文标题：Storm中怎么定义Blots程序
网站路径：http://myzitong.com/article/pjpdes.html

Storm中怎么定义Blots程序

其他资讯