Melakukan Konfigurasi Subcriber pada arsitekture Pub-sub menggunakan MQTT broker
Melakukan Konfigurasi Subcriber pada arsitekture Pub-sub menggunakan MQTT broker
Protokol
ini menggunakan mempublikasikan / berlangganan arsitektur berbeda
dengan HTTP dengan paradigma permintaan / tanggapan nya. Publish /
Subscribe adalah event-driven dan memungkinkan pesan yang akan
didorong untuk klien. Titik komunikasi pusat adalah broker MQTT, itu
bertanggung jawab atas pengiriman semua pesan antara pengirim dan
penerima yang sah. Setiap klien yang menerbitkan pesan ke broker,
termasuk topik ke dalam pesan.Topik adalah informasi routing untuk
broker. Setiap klien yang ingin menerima pesan berlangganan topik
tertentu dan broker memberikan semua pesan dengan topik yang cocok
untuk klien. Oleh karena itu klien tidak harus saling mengenal,
mereka hanya berkomunikasi melalui topik. Arsitektur ini memungkinkan
solusi yang sangat scalable tanpa ketergantungan antara produsen data
dan konsumen data.
Subscriber
Install &
Download node js
download &
install node-red di cmd
npm install -g
--unsafe-perm node-red
run node-red di
cmd
node-red
jalankan server
node-red di browser yaitu localhost:1880
Buat flow seperti
dibawah ini
[{"id":"3812db40.671804","type":"mqtt
in","z":"58e11e48.d8218","name":"/sensor/cuaca/#",
"topic":"/sensor/cuaca/#","qos":"2","broker":"4855bc10.7e6f34","x":120,"y":120,
"wires":[["d53bd9bf.534c78","eea5815b.5f0ac"]]},
{"id":"4855bc10.7e6f34","type":"mqtt-broker","z":"","name":"",
"broker":"broker.hivemq.com","port":"1883","clientid":"",
"usetls":false,"compatmode":true,"keepalive":"60",
"cleansession":true,"birthTopic":"","birthQos":"0","birthRetain":"false",
"birthPayload":"","closeTopic":"","closePayload":"","willTopic":"","willQos":"0",
"willRetain":"false","willPayload":""}]
|
Atau bisa juga dengan mengimport flow dibawah ini
Penjelasan :
Node
/sensor/cuaca/# : node mqqt input yang berfungsi sebagai subscriber
untuk mensubscribe semua topik yang telah publisher publish
Node Switch :
untuk mengarahkan pesan bedasarkan topik spesifik publisher
Node Json : untuk
mengambil data json yang dikirim yang telah diambil subscriber dari
publisher lewat broker
Node timestamp
and format data : sebuah fungsi untuk memformat data json sebelum
dimasukan ke database yaitu mongo db
Node warna hijau
: berfungsi untuk menampilkan payload massage di debug pada node-red
sesaai dengan topiknya masing”
Node mongodb save
: berfungsi untuk melakukan insert file json ke mongodb dengan
menggunakan host,port,username,password serta collection dari
distributed database
Related Project : project sistem komputasi terdistribusi
Related Project : project sistem komputasi terdistribusi
Komentar
Posting Komentar