{"id":271,"date":"2022-04-16T06:48:52","date_gmt":"2022-04-16T06:48:52","guid":{"rendered":"https:\/\/sentraldigitalindonesia.co.id\/blog\/2022\/04\/16\/rabbitmq-si-message-broker-alias-kantor-pos\/"},"modified":"2022-04-16T06:48:52","modified_gmt":"2022-04-16T06:48:52","slug":"rabbitmq-si-message-broker-alias-kantor-pos","status":"publish","type":"post","link":"https:\/\/sentraldigitalindonesia.co.id\/blog\/2022\/04\/16\/rabbitmq-si-message-broker-alias-kantor-pos\/","title":{"rendered":"RabbitMQ, si message broker alias kantor pos"},"content":{"rendered":"
\n

Dalam dunia pemrograman, terdapat jenis perangkat lunak bernama message broker. Fungsinya, untuk mengatur pesan yang dikirimkan oleh pengirim agar dapat sampai ke penerima. Seperti dilansir 3pillarglobal.com, message broker biasanya digunakan pada layanan telekomunikasi, perbankan, e-commerce, serta pesan singkat. Ada banyak contoh perangkat lunak jenis ini, antara lain ActiveMQ, Kafka, dan RabbitMQ. Namun, dalam artikel ini, kami akan menggunakan RabbitMQ sebagai contoh.<\/p>\n

Seperti kantor pos<\/strong><\/h2>\n

Agar lebih mudah, Anda dapat menganalogikan RabbitMQ sebagai kantor pos. Ketika Anda mengirim surat, Anda harus memasukkan surat tersebut ke kotak pos untuk diproses di kantor pos, disortir, dan diantarkan oleh tukang pos.<\/p>\n

Dalam analogi tersebut, RabbitMQ bertindak sebagai kotak pos, kantor pos, dan tukang pos sekaligus. Misalnya, RabbitMQ menyimpan antrean pesan yang berisi alamat surel dan isi surel. Ketika RabbitMQ mengirim pesan tersebut ke receiver, maka receiver akan mengirim surel dengan tujuan dan isi surel sesuai pesan yang diterima RabbitMQ.<\/p>\n

Proses penggunaan<\/strong><\/h2>\n

Untuk mengetahui proses penggunaan RabbitMQ, mari ikuti langkah-langkah berikut.<\/p>\n

Instalasi<\/strong><\/h3>\n

Untuk instalasi RabbitMQ, Anda bisa mengecek https:\/\/www.rabbitmq.com\/download.html. Lalu pilih instruksi sesuai dengan platform yang Anda gunakan.<\/p>\n

Kenali berbagai istilahnya<\/strong><\/h3>\n

Sebelum memulai, ada beberapa istilah yang harus kita ketahui pada RabbitMQ.<\/p>\n

Producing<\/strong><\/h3>\n

Producing tidak beda dari mengirim. Program yang mengirimkan pesan disebut dengan producer.<\/p>\n

Queue<\/strong><\/h3>\n

Queue bisa disebut dengan antrean yaitu nama untuk kotak pos yang ada didalam RabbitMQ. Banyak producer bisa mengirim banyak pesan ke satu antrean dan banyak consumer dapat menerima data dari satu antrean.<\/p>\n

Consuming<\/strong><\/h3>\n

Consuming sama saja dengan menerima. Consumer adalah program penunggu penerimaan pesan.<\/p>\n

Sebagai catatan producer, consumer, dan broker tidak harus berada pada satu host yang sama.<\/p>\n

Permulaan<\/strong><\/h2>\n

Sebagai permulaan, Anda bisa membuat program sederhana yang akan mengirimkan pesan kepada penerima. Sebelum memulai, pastikan RabbitMQ sudah terpasang dan berjalan. Lalu buat direktori baru dan npm init di dalamnya.<\/p>\n

Kode<\/strong><\/h2>\n

Install amqp.node dengan npm install amqplib lalu buat file baru producer.js yang nantinya akan berperan sebagai producer.
<\/br>
\nImport package amqp.node tadi
<\/br>
\nconst amqp = require(‘amqplib’)<\/p>\n

Hubungkan ke RabbitMQ server dan buat channel baru
<\/br>
\n…
<\/br>
\namqp.connect(‘amqp:\/\/localhost’).then(conn => conn.createChannel())<\/p>\n

Kemudian declare queue, agar Anda bisa mengirimkan pesan.
<\/br>
\n…
<\/br>
\nconn.createChannel().then(ch => {
<\/br>
\n\u00a0 const q = ‘hello’
<\/br>
\n\u00a0 const msg = ‘Hello world!’
<\/br>
\n\u00a0 const ok = ch.assertQueue(q, { durable: false })
<\/br>
\n\u00a0 ok.then(() => {
<\/br>
\n\u00a0 \u00a0 ch.sendToQueue(q, Buffer.from(msg))
<\/br>
\n\u00a0 \u00a0 console.log(‘- Sent’, msg)
<\/br>
\n\u00a0 \u00a0 return ch.close()
<\/br>
\n\u00a0 })
<\/br>
\n})
<\/br>
\n…<\/p>\n

Kode lengkap producer.js<\/p>\n

const amqp = require(‘amqplib’) \u00a0 \u00a0 \/\/ Import library amqp<\/p>\n

amqp.connect(‘amqp:\/\/localhost’)
<\/br>
\n\u00a0 .then(conn => {
<\/br>
\n\u00a0 \u00a0 return conn.createChannel().then(ch => {
<\/br>
\n\u00a0 \u00a0 \u00a0 const q = ‘hello’ \u00a0 \u00a0 \/\/ Nama antrian adalah ‘hello’
<\/br>
\n\u00a0 \u00a0 \u00a0 const msg = ‘Hello world!’ \u00a0 \u00a0\/\/ Isi pesan yang dikirim ke RabbitMQ<\/p>\n

\u00a0 \u00a0 \u00a0 const ok = ch.assertQueue(q, { durable: false }) \u00a0 \u00a0\/\/ Membuat antrian ‘hello’
<\/br>
\n\u00a0 \u00a0 \u00a0 return ok.then(() => {
<\/br>
\n\u00a0 \u00a0 \u00a0 \u00a0 ch.sendToQueue(q, Buffer.from(msg)) \u00a0 \u00a0 \/\/ Mengirim pesan ke RabbitMQ
<\/br>
\n\u00a0 \u00a0 \u00a0 \u00a0 console.log(‘- Sent’, msg)
<\/br>
\n\u00a0 \u00a0 \u00a0 \u00a0 return ch.close()
<\/br>
\n\u00a0 \u00a0 \u00a0 })
<\/br>
\n\u00a0 \u00a0 }).finally(() => conn.close())
<\/br>
\n\u00a0 }).catch(console.warn)<\/p>\n

Selanjutnya, buat file baru consumer.js yang akan berperan sebagai consumer. Import amqp.node lalu hubungkan ke RabbitMQ server dan buat channel baru.<\/p>\n

const amqp = require(‘amqplib’)
<\/br>
\namqp.connect(‘amqp:\/\/localhost’).then(conn=> {
<\/br>
\n\u00a0 return conn.createChannel().then(ch => {})
<\/br>
\n})<\/p>\n

Declare nama queue dan buat callback yang akan dieksekusi ketika RabbitMQ mengirim pesan ke consumer. Sebagai catatan, jika nama queue yang dideklarasikan sudah ada, maka broker tidak akan membuat queue baru, melainkan menggunakan queue yang sudah ada.<\/p>\n

conn.createChannel().then(ch => {
<\/br>
\n\u00a0 const ok = ch.assertQueue(‘hello’, { durable: false })
<\/br>
\n\u00a0 ok.then(() => {
<\/br>
\n\u00a0 \u00a0 return ch.consume(‘hello’, msg => console.log(‘- Received’, msg.content.toString()), { noAck: true })
<\/br>
\n})<\/p>\n

Kode lengkap consumer.js<\/p>\n

const amqp = require(‘amqplib’) \u00a0 \u00a0 \/\/ Import library amqp<\/p>\n

amqp.connect(‘amqp:\/\/localhost’)
<\/br>
\n\u00a0 .then(conn=> {
<\/br>
\n\u00a0 \u00a0 return conn.createChannel().then(ch => {
<\/br>
\n\u00a0 \u00a0 \u00a0 const ok = ch.assertQueue(‘hello’, { durable: false }) \u00a0 \u00a0 \u00a0\/\/ Deklarasi antrian
<\/br>
\n\u00a0 \u00a0 \u00a0 ok.then(() => {
<\/br>
\n\u00a0 \u00a0 \u00a0 \u00a0 \/* Menangkap pesan yang dikirimkan oleh RabbitMQ *\/
<\/br>
\n\u00a0 \u00a0 \u00a0 \u00a0 return ch.consume(‘hello’, msg => console.log(‘- Received’, msg.content.toString()), { noAck: true })
<\/br>
\n\u00a0 \u00a0 \u00a0 })
<\/br>
\n\u00a0 \u00a0 \u00a0 .then(() => {
<\/br>
\n\u00a0 \u00a0 \u00a0 \u00a0 console.log(‘* Waiting for messages. Ctrl+C to exit’)
<\/br>
\n\u00a0 \u00a0 \u00a0 })
<\/br>
\n\u00a0 \u00a0 })
<\/br>
\n\u00a0 }).catch(console.warn)<\/p>\n

Uji coba<\/strong><\/h2>\n

Untuk uji coba dari kode yang Anda buat di atas menggunakan terminal, jalankan node producer.js terlebih dahulu. Lalu jalankan consumer untuk menerima pesan Hello world! yang dikirimkan oleh producer node consumer.js<\/p>\n

Dapat dilihat, sesaat setelah Anda menjalankan consumer, akan tercetak tulisan, \u201cReceived Hello World!\u201d Artinya,\u00a0<\/p>\n

Dapat kita lihat sesaat setelah kita menjalankan consumer akan tercetak tulisan \u2014 Received Hello world! Itu artinya, percobaan Anda menggunakan RabbitMQ pertama kali telah berhasil!<\/p>\n

Sumber:<\/strong>
<\/br>
\nmedium.com
<\/br>
\nmedium.com
<\/br>
\n3pillarglobal.com
<\/br>
\n\u00a0<\/p>\n<\/div>\n","protected":false},"excerpt":{"rendered":"

Dalam dunia pemrograman, terdapat jenis perangkat lunak bernama message broker. Fungsinya, untuk mengatur pesan yang dikirimkan oleh pengirim agar dapat sampai ke penerima. Seperti dilansir 3pillarglobal.com, message broker biasanya digunakan … <\/p>\n","protected":false},"author":1,"featured_media":272,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[5],"tags":[],"class_list":["post-271","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-teknologi"],"_links":{"self":[{"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/posts\/271","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/comments?post=271"}],"version-history":[{"count":0,"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/posts\/271\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/media\/272"}],"wp:attachment":[{"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/media?parent=271"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/categories?post=271"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/sentraldigitalindonesia.co.id\/blog\/wp-json\/wp\/v2\/tags?post=271"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}