這篇文章主要介紹“Storm中怎么定義Blots程序”，在日常操作中，相信很多人在Storm中怎么定義Blots程序問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”Storm中怎么定義Blots程序”的疑惑有所幫助！接下來，請跟著小編一起來學(xué)習(xí)吧！

創(chuàng)新互聯(lián)公司是一家專業(yè)的成都網(wǎng)站建設(shè)公司，我們專注網(wǎng)站制作、成都做網(wǎng)站、網(wǎng)絡(luò)營銷、企業(yè)網(wǎng)站建設(shè)，買鏈接，廣告投放為企業(yè)客戶提供一站式建站解決方案，能帶給客戶新的互聯(lián)網(wǎng)理念。從網(wǎng)站結(jié)構(gòu)的規(guī)劃UI設(shè)計到用戶體驗提高，創(chuàng)新互聯(lián)力求做到盡善盡美。

具體內(nèi)容

在Storm程序開發(fā)過程之中有兩個重要的核心概念：Spout、Blot。Spout會作為數(shù)據(jù)的發(fā)起點，這個數(shù)據(jù)可能來源于各種地方，例如：Kafka傳遞過來的消息內(nèi)容，而每一個Spout接收到數(shù)據(jù)之后如果有需要則將數(shù)據(jù)傳遞給Blot，由多個Blot進(jìn)行數(shù)據(jù)的操作處理。把每一個Blot想象為一個數(shù)據(jù)的過濾器，而最后一個Blot將作為數(shù)據(jù)的存儲使用，而一般的存儲設(shè)備往往是文件、redis數(shù)據(jù)庫。

在本次程序的處理里面，Spouts將使用隨機數(shù)產(chǎn)生相應(yīng)的年齡數(shù)據(jù)，而有會有三個Blot進(jìn)行數(shù)據(jù)的處理，這些數(shù)據(jù)處理是有自己嚴(yán)格的語法要求的。如果要想實現(xiàn)Storm開發(fā)，則需要將Storm所有的相關(guān)庫文件配置到ClassPath之中。如果要想開發(fā)Spout往往需要實現(xiàn)一個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";//假設(shè)為用戶名private Random rand=new Random();
@SuppressWarnings("rawtypes")@Overridepublic void open(Mapconf,TopologyContextcontext,SpoutOutputCollectorcollector){//為Spout初始化方法，這個初始化方法只執(zhí)行一次；this.collector=collector;//接收初始化方法中的SpoutOutputCollector對象 }@OverridepublicvoidnextTuple(){ //執(zhí)行Spout程序時會自動找到此方法，此方法為發(fā)送消息//從正常的開發(fā)角度而言，此處的數(shù)據(jù)應(yīng)該由消息系統(tǒng)傳遞過來 String nameInfo=String.valueOf(this.nameStr.charAt(rand.nextInt(nameStr.length())));intageInfo=this.rand.nextInt(150);//隨機生成一個年齡 //最終如果要進(jìn)行數(shù)據(jù)的發(fā)送，結(jié)構(gòu)：name、age，所有的Spouts的數(shù)據(jù)要交給Blot完成。this.collector.emit(newValues(nameInfo,ageInfo));}@OverridepublicvoiddeclareOutputFields(OutputFieldsDeclarerdeclare){//需要定義每一個傳輸中的數(shù)據(jù)保存的名稱declare.declare(newFields("name","age"));//向后發(fā)送Tuple的時候此為信息的文字標(biāo)注}}

在整個的代碼里面，nextTuple()為系統(tǒng)自動調(diào)用，Spout產(chǎn)生Blot所需要的數(shù)據(jù)。

定義Blots程序

在本處理流程之中需要有三個Blot，作用分別如下：

·AgeJudementBlot：判斷傳入數(shù)據(jù)的年齡是成年人（ADULT）還是年輕人（YOUNG）；·NameUpperBlot：因為姓名有大寫和小寫，為了統(tǒng)一管理，信息都變?yōu)榇髮懀弧inalBlot：進(jìn)行數(shù)據(jù)的保存處理。但是需要注意的是，此時定義的只是一個個獨立的Blot，彼此之間的聯(lián)系需要通過程序來完成。范例：進(jìn)行年齡判斷的Blot實現(xiàn).

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){

范例：處理姓名大小寫的操作

范例：增加一個輸出到文件的Blot

這些定義的Blot一定要接收Spout傳來的數(shù)據(jù)，但是這些Blot之間沒有直接的聯(lián)系，所有的關(guān)系都必須通過程序動態(tài)配置。

編寫測試程序

Storm最大的好處是直接提供了本地的windows模擬測試，但是在配置過程里面需要配置這些bolts關(guān)系。范例：編寫測試程序

到此，關(guān)于“Storm中怎么定義Blots程序”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
當(dāng)前文章：Storm中怎么定義Blots程序
網(wǎng)站地址：http://weahome.cn/article/pjpdes.html