Apache Storm - İş Akışı
Çalışan bir Storm kümesinde bir nimbus ve bir veya daha fazla denetçi bulunmalıdır. Bir diğer önemli düğüm, nimbus ve denetleyiciler arasındaki koordinasyon için kullanılacak olan Apache ZooKeeper'dır.
Şimdi Apache Storm'un iş akışına yakından bakalım -
Başlangıçta nimbus, "Fırtına Topolojisi" nin kendisine sunulmasını bekleyecektir.
Bir topoloji gönderildikten sonra, topolojiyi işleyecek ve gerçekleştirilecek tüm görevleri ve görevin yürütüleceği sırayı toplayacaktır.
Daha sonra, nimbus görevleri mevcut tüm süpervizörlere eşit olarak dağıtacaktır.
Belirli bir zaman aralığında, tüm denetleyiciler hala hayatta olduklarını bildirmek için nimbus'a kalp atışları gönderecekler.
Bir süpervizör öldüğünde ve nimbus'a bir kalp atışı göndermediğinde, nimbus görevleri başka bir süpervizöre atar.
Nimbus öldüğünde, süpervizörler herhangi bir sorun olmadan önceden atanmış görev üzerinde çalışacaktır.
Tüm görevler tamamlandığında, süpervizör yeni bir görevin gelmesini bekleyecektir.
Bu arada, ölü nimbus servis izleme araçları tarafından otomatik olarak yeniden başlatılacaktır.
Yeniden başlatılan nimbus durduğu yerden devam edecektir. Benzer şekilde, ölü gözetmen de otomatik olarak yeniden başlatılabilir. Hem nimbus hem de süpervizör otomatik olarak yeniden başlatılabildiğinden ve her ikisi de eskisi gibi devam edeceğinden, Storm'un tüm görevi en az bir kez işlemesi garanti edilir.
Tüm topolojiler işlendikten sonra, nimbus yeni bir topolojinin gelmesini bekler ve benzer şekilde süpervizör yeni görevleri bekler.
Varsayılan olarak, bir Fırtına kümesinde iki mod vardır -
Local mode- Bu mod geliştirme, test etme ve hata ayıklama için kullanılır çünkü birlikte çalışan tüm topoloji bileşenlerini görmenin en kolay yolu budur. Bu modda, topolojimizin farklı Storm yapılandırma ortamlarında nasıl çalıştığını görmemizi sağlayan parametreleri ayarlayabiliriz. Yerel modda, fırtına topolojileri yerel makinede tek bir JVM'de çalışır.
Production mode- Bu modda topolojimizi, genellikle farklı makinelerde çalışan birçok işlemden oluşan çalışma fırtınası kümesine sunuyoruz. Fırtınanın iş akışında tartışıldığı gibi, çalışan bir küme kapatılana kadar süresiz olarak çalışacaktır.