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

Komentar

Postingan populer dari blog ini

CHMOD untuk modifikasi seluruh folder, sub folder dan file

Melakukan Clone Virtual Machine Pada VirtualBox

Konfigurasi DNS pada Ubuntu Server 18.04