Storm開發(fā)中易犯的 小錯(cuò)誤

Storm是一個(gè)分布式的、容錯(cuò)的實(shí)時(shí)計(jì)算系統(tǒng)，遵循Eclipse Public License 1.0,Storm可以方便地在一個(gè)計(jì)算機(jī)集群中編寫與擴(kuò)展復(fù)雜的實(shí)時(shí)計(jì)算，Storm之于實(shí)時(shí)處理，就好比Hadoop之于批處理。Storm保證每個(gè)消息都會得到處理，而且它很快——在一個(gè)小集群中，每秒可以處理數(shù)以百萬計(jì)的消息?？梢允褂萌我饩幊陶Z言來做開發(fā)。

創(chuàng)新互聯(lián)一直秉承“誠信做人，踏實(shí)做事”的原則，不欺瞞客戶，是我們最起碼的底線！ 以服務(wù)為基礎(chǔ)，以質(zhì)量求生存，以技術(shù)求發(fā)展，成交一個(gè)客戶多一個(gè)朋友！為您提供做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)頁設(shè)計(jì)、小程序定制開發(fā)、成都網(wǎng)站開發(fā)、成都網(wǎng)站制作、成都軟件開發(fā)、重慶App定制開發(fā)是成都本地專業(yè)的網(wǎng)站建設(shè)和網(wǎng)站設(shè)計(jì)公司，等你一起來見證！

Storm的優(yōu)點(diǎn)
1. 簡單的編程模型。類似于MapReduce降低了并行批處理復(fù)雜性，Storm降低了進(jìn)行實(shí)時(shí)處理的復(fù)雜性。
2. 服務(wù)化,一個(gè)服務(wù)框架,支持熱部署,即時(shí)上線或下線App.
3. 可以使用各種編程語言。你可以在Storm之上使用各種編程語言。默認(rèn)支持Clojure、Java、Ruby和Python。要增加對其他語言的支持，只需實(shí)現(xiàn)一個(gè)簡單的Storm通信協(xié)議即可。
4. 容錯(cuò)性。Storm會管理工作進(jìn)程和節(jié)點(diǎn)的故障。
5. 水平擴(kuò)展。計(jì)算是在多個(gè)線程、進(jìn)程和服務(wù)器之間并行進(jìn)行的。
6. 可靠的消息處理。Storm保證每個(gè)消息至少能得到一次完整處理。任務(wù)失敗時(shí)，它會負(fù)責(zé)從消息源重試消息。
7. 快速。系統(tǒng)的設(shè)計(jì)保證了消息能得到快速的處理，使用ZeroMQ作為其底層消息隊(duì)列。
8. 本地模式。Storm有一個(gè)“本地模式”，可以在處理過程中完全模擬Storm集群。這讓你可以快速進(jìn)行開發(fā)和單元測試。

然而，在開發(fā)的過程中，由于Storm的kill Topology，常常會導(dǎo)致一些莫名的錯(cuò)誤，比如下面的一個(gè)錯(cuò)誤：

造成異常的原因就是，

沒有kill 正在運(yùn)行的topology，卻先kill nimbus和supervisor的storm進(jìn)程

解決方案：

刪除了配置中"storm.local.dir"的文件夾內(nèi)的內(nèi)容（這個(gè)是導(dǎo)致ＥＲＲＯＲ的主要原因）

在Zookeeper客戶端下   delete   /storm/assignments

在Zookeeper客戶端下   delete   /storm/workerbeats

刪除 storm目錄下的workdir（即配置文件中配置的將TOPOLOGY序列化所放置的文件夾）