Spout的相關(guān)知識(shí)點(diǎn)有哪些

本篇內(nèi)容主要講解“Spout的相關(guān)知識(shí)點(diǎn)有哪些”，感興趣的朋友不妨來看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Spout的相關(guān)知識(shí)點(diǎn)有哪些”吧!

Component

在Storm 之中，Spout 和Bolt 都是其Compnent， 所以在Storm之中定義了一個(gè)名叫 IComponent

的總接口

Spout

在前面的基本例子中，我們實(shí)現(xiàn)了一個(gè)RandomSout，來看看其類圖

Spout的最頂級(jí)的抽象是ISpout接口

有關(guān)如下的API  

1：oepn 方法是初始化動(dòng)作： 允許你在該spout 初始化時(shí)做一些動(dòng)作，傳入了上寫文，也方便娶上下文的一些數(shù)據(jù)

2 ：close 方法在該Spout 關(guān)閉前執(zhí)行，但是并不能得到保證其一定會(huì)執(zhí)行，spout是作為task 運(yùn)行，在worker內(nèi)的，在

clouster 集群之下，我們的 supervisor 會(huì)直接kill掉 ，這樣它就有可能不會(huì)允許， 而在本地的模式之下，只要不是kill -9，如果是發(fā)送停止命令，是可以保證close的執(zhí)行的。

3 : Activate

4 :deactivate

5: nextTuple                       : nextTuple 用來發(fā)送數(shù)據(jù)

6 ack ( Object )                   : Ack 傳入的Object其實(shí)是一個(gè)id. 表示唯一一個(gè)tuple 

7 fail ( Object )

由于繼承了BaseRichSpout， 所以不用實(shí)現(xiàn) close，activate，deactivate，ack，fail

等方法。

結(jié)論：

        在通常的情況之下，(Shel 和事物型的除外)，實(shí)現(xiàn)一個(gè)Spout，可以直接的去實(shí)現(xiàn)IRichSpout

如果不想寫IRIchSpout代碼，可以繼承自BaseRichSpout

Bolt

ExclaimBasicBolt的類圖

Ibolt 繼承了java.io.Serializable 我們?cè)趎imbus上提交了topology

execute 接受一個(gè)tuple進(jìn)行處理，并在prepare 方法傳入的 ACK方法，或者fail方法表示來反饋處理的結(jié)果

通常情況之下，他實(shí)際上相當(dāng)于自動(dòng)做掉prepare方法和collector.emit.ack(inputTupe)

到此，相信大家對(duì)“Spout的相關(guān)知識(shí)點(diǎn)有哪些”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！