Aliran kerja Apache Storm


Kluster Storm yang berfungsi harus mempunyai Nimbus dan satu atau lebih penyelia. Satu lagi nod penting ialah Apache ZooKeeper, yang akan digunakan untuk penyelarasan antara nimbus dan penyelia.

Sekarang mari kita lihat dengan lebih dekat aliran kerja Apache Storm −

  • Pada mulanya, nimbus akan menunggu untuk "topologi Ribut" diserahkan kepadanya.

  • Setelah topologi diserahkan, ia akan memproses topologi dan mengumpul semua tugasan untuk dilaksanakan dan susunan tugasan akan dilaksanakan.

  • Kemudian, nimbus mengagihkan tugas secara merata kepada semua penyelia yang ada.

  • Pada selang masa tertentu, semua penyelia akan menghantar degupan jantung untuk memberitahu mereka bahawa mereka masih berjalan.

  • Apabila penyelia tamat dan tidak menghantar degupan jantung ke degupan jantung, maka nimbus memberikan tugas kepada penyelia lain.

  • Apabila nimbus itu sendiri tamat, penyelia akan mengerjakan tugasan yang telah diberikan tanpa sebarang masalah.

  • Setelah semua tugasan selesai, penyelia akan menunggu tugasan baru masuk.

  • Pada masa yang sama, penamatan nimbus akan dimulakan semula secara automatik oleh alat pemantauan perkhidmatan.

  • Rangkaian yang dimulakan semula akan diteruskan di mana ia berhenti. Begitu juga, menamatkan penyelia juga boleh memulakannya semula secara automatik. Memandangkan kedua-dua pengurus rangkaian dan penyelia boleh dimulakan semula secara automatik dan kedua-duanya akan diteruskan seperti sebelumnya, Storm menjamin bahawa semua tugas akan diproses sekurang-kurangnya sekali.

  • Setelah semua topologi diproses maka pengurus rangkaian menunggu topologi baharu tiba dan begitu juga pengurus menunggu tugasan baharu.

Secara lalai, terdapat dua mod dalam gugusan Ribut:

  • Mod Setempat - Mod ini digunakan untuk pembangunan, ujian dan penyahpepijatan kerana ia adalah cara paling mudah untuk melihat semua komponen topologi berfungsi bersama. Dalam mod ini, kami boleh melaraskan parameter, membolehkan kami melihat prestasi topologi kami dalam persekitaran konfigurasi Storm yang berbeza. Dalam mod tempatan, topologi Storm berjalan dalam satu JVM pada mesin tempatan.

  • Mod Pengeluaran - Dalam mod ini kami menyerahkan topologi kepada kluster Storm yang berfungsi, yang terdiri daripada banyak proses, biasanya berjalan pada mesin yang berbeza. Seperti yang dibincangkan dalam aliran kerja Storm, kluster pekerja akan berjalan selama-lamanya sehingga ia ditutup.