Setelah kita melakukan praktek simple publish subscribe menggunakan NATS. NATS juga menyediakan fitur Queue Groups yang digunakan biasanya untuk kebutuhan replika clustering. Jika suatu service mempunyai replika lebih dari satu, maka pesan tidak akan di kirimkan kesemua service yang sama karna akan mengakitbatkan duplikat. Maka dari itu Queue Groups di sini berfungsi untuk menyeimbangkan (Seperti load balancer) semua data yang dikirim ke suatu kelompok service yang sama.

diambil dari https://nats-io.github.io/docs/developer/concepts/queue.html

Untuk pengimplementasian di NATS.js nya pun cukup mudah, kita hanya butuh menambahkan { queue: '<namaGroup>' }. di parameter kedua di fungsi nats.subscribe(). contoh:

nats.subscribe('foo', {'queue':'job.workers'}, function() {
  received += 1;
});

Untuk langsung mencoba mari kita ubah subscriber yang postingan sebelumnya kita buat lalu tambahkan queue groupsnya.

nats.subscribe(TOPIC, {'queue': 'job.workers'}, handleBandungSuhuTopic)

Lalu kita coba test jalankan 2 subcriber dengan queue groups yang sama, dan satu publisher. Jika berhasil, makan pesan tidak akan di terima oleh semua subscriber. Tetapi akan di bagi2 ke semua subscriber. seperti berikut:

Repo catatan hasil belajar ini bisa diliat di github: https://github.com/aldinp16/learn-nats/

Setelah pengenalan tentang NATS, disini saya akan memulai praktek belajar simple Publish Subscribe menggunakan NATS.js sebagai client dan instalasi nats server menggunakan Docker.

Pertama pull docker image NATS di dockerhub

$ docker pull nats:latest

Lalu jalankan nats-server menggunakan perintah docker run. disini kita melakukan expose port 4222 dan 8222 dari container agar dapat di akses di mesin lokal kita. nats berjalan di port 4222 sementara port 8222 di gunakan untuk monitoring server nats via http.

$ docker run -d --name nats-server -p 4222:4222 -p 8222:8222 nats

Lalu cek apakah server nats telah siap digunakan atau tidak menggunakan docker logs

$ docker ps
$ docker logs -f <container-id>

Jika nats server siap di gunakan akan mengeluarkan log kurang lebih sebagai berikut

Lalu menyiapkan client nodejsnya. install dulu nats.js melalui npm di folder root projectnya.

npm install nats

Lalu kita mulai membuat client untuk publishernya. publisher akan melakukan publish angka random antara 0 - 99 ke topic jawabarat.bandung.suhu setiap 5000 milisecond (5 detik). Disini parameter NATS.connect() tidak di isi, maka akan automatis mengset host menjadi localhost dan port default yaitu 4222. Kita berinama publisher.js

#!/usr/bin/env node

'use strict'

const NATS = require('nats')
const nats = NATS.connect()

const interval = 5000

function sendRandomSuhu () {
  // generate random number beetwen 0 and 99
  const randomNumber = Math.floor(Math.random() * 100)
  const topic = 'jawabarat.bandung.suhu'
  nats.publish(topic, randomNumber.toString())
  console.log(`[PUBLISHER] Publish ${randomNumber} to ${topic}`)
}

function onConnectHandler () {
  console.log(`[PUBLISHER] Connected, ready for publish random suhu every ${interval/1000} Second`)
}

nats.on('connect', onConnectHandler)

// publish random number every 5 second
setInterval(sendRandomSuhu, interval)

Lalu membuat subscribernya, disini saya buat subscriber agar memiliki ID diambil dari parameter pertama saat script dijalankan. Kegunaanya agar dapat dapat mengidentifikasi subscriber karna kita akan menjalankan lebih dari satu subscriber. Lalu berinama subscriber.js

#!/usr/bin/env node

'use strict'

const NATS = require('nats')

const nats = NATS.connect()
const ID = process.argv[2]
const TOPIC = 'jawabarat.bandung.suhu'

// check if id filled
if (typeof ID === 'undefined') {
  console.error(`ID can't empty.`)
  process.exit(1)
}

function onConnectHandler () {
  console.log(`[SUBSCRIBER-${ID}] (${TOPIC}) Connected, ready receive message.`)
}

function handleBandungSuhuTopic (msg) {
  console.log(`[SUBSCRIBER-${ID}] (${TOPIC}) Received data: ${msg}`)
}

nats.on('connect', onConnectHandler)
nats.subscribe(TOPIC, handleBandungSuhuTopic)

Setelah semuanya siap. pertama kita jalankan subscribernya. disini kita menjalankan dua subcriber untuk melihat apakah pesan diterima oleh semua subscriber atau tidak.

$ node subscriber.js 1
$ node subscriber.js 2

Lalu jalankan publishernya

$ node publisher.js

Bila tidak mengalami error, seharusnya message dapat di publish oleh publisher dan di terima oleh semua subscriber.

Bisa juga monitoring client yang sedang connect menggunakan http api, dengan mengakses http://localhost:8222/connz

Repo catatan hasil belajar ini bisa diliat di github: https://github.com/aldinp16/learn-nats/

NATS adalah salah satu sistem aplikasi untuk melakukan pertukaran pesan asyncronus yang biasa digunakan untuk komunikasi antara aplikas atau suatu services komputer.

Konsep pertukaran pesan menggunakan Publish dan Subscribe mirip dengan MQTT. Dimana service yang menerima data biasa di sebut Consumer/Subscriber, dan service yang bertugas mengirim data biasa di sebut Producer/Publisher

NATS Bisa dipakai untuk kebutuhan komunikasi antar service di arsitektur microservices, untuk kebutuhan collecting data device IOT, kebutuhan data streaming, dan lain-lain.

Di dalam NATS membutuhkan Topic agar antar service dapat berkomunikasi. topic adalah sebuah string biasa yang harus diketahui oleh subscriber ataupun publisher agar masing2 tau dimana harus mempublish/melisten topic agar mendapatkan data yang sesuai.

Selain topic biasa, Di NATS bisa juga menggunakan Wilcards topic untuk mendapatkan/mengirim data lebih dari satu nested topic tertentu. Nested topic dalam nats dipisahkan menggunakan (.) dot/titik. misal:

• jawabarat.bandung.suhu
• jawabarat.bogor.suhu
• jawabarat.bandung.suhu.celcius
• jawabarat.bandung.suhu.farenheit

Wilcard yang pertama menggunakan simbol asterik (*) untuk mencocokan satu topic di dalam nested topic. misal: jawabarat.*.suhu untuk mendapatkan data suhu dari semua kota di jawabarat.

Wilcard yang kedua menggunakan simbol greather-than (>) untuk mencocokan dua topic atau lebih dalam nested topic. misal: jawabarat.bandung.> untuk mendapatkan data suhu di kota bandung, jawabarat. dengan skala farenheit dan celcius

Selain dengan konsep Publish-Subscribe, NATS pun mendukung komunikasi dengan cara Request-Reply dimana salah satu client akan melakukan Permintaan (Request) dan menunggu balasan dengan batas waktu tertantu (timeout)

• https://nats-io.github.io/docs/developer/concepts/subjects.html
• https://nats-io.github.io/docs/developer/concepts/pubsub.html
• https://nats-io.github.io/docs/developer/concepts/reqreply.html

AdonisJS adalah web framework NodeJs dengan konsep MVC. Sebelum kita mengenal jauh tentang Adonis ini ada baiknya kita mengenal terlebih dahulu apa itu NodeJs dan konsep MVC itu sendiri.

NodeJs adalah Javascript runtime yang bergguna untuk menjalankan kode Javascript disisi server (Server Side). Atau lebih mudahnya kita anggap Javscript untuk keperluan Server Side. Seperti yang kita semua tau sebelumnya bahwa Javascript adalah pemograman yang berjalan di sisi client bersamaan dengan CSS dan HTML untuk membuat antarmuka Web menjadi lebih interaktif.

MVC Atau Model View Controller adalah sebuah konsep untuk membuat aplikasi dengan memisahkan Data (Model), Tampilan (View), dan proses (Controller). Konsep MVC ini akan memudahkan dalam membuat atau me-maintance suatu aplikasi karna struktur aplikasi yang jelas.

Saya sangat suka dengan AdonisJS ini karna dilengkapi banyak fitur sepeti adonis-ally, adonis-lucid dan lain2 sehingga bisa mempercepat proses pembuatan aplikasi tanpa harus bangun dari awal. Selain itu AdonisJS sudah mengadopsi async / await sehingga kode terlihat lebih indah dibanding kita memakai callback ataupun promise. Dokumentasinya yang cukup lumayan lengkap, dapat mudah dipahami dan adanya komunitas yang aktif di forum adalah salah satu kenapa saya cukup yakin framework ini akan berkembang menjadi besar.

const User = use('App/Models/User')

class UserController {
  async index ({ request, response }) {
    const users = await User.all()
    return response.ok({
      status: 200,
      error: false,
      data: users,
      message: null
    })
  }

  async show ({ request, response, params: { userId } }) {
    const user = await User.findOrFail(userId)
    return response.ok({
      status: 200,
      error: false,
      data: user,
      message: null
    })
  }
}

Walaupun AdonisJS ini memakai konsep MVC tetapi kitapun bisa membuat REST API karna AdonisJS ini menyediakan 3 blueprint yang bisa kita pakai yaitu Fullstack, Api only, dan slim. Jadi jika ingin membuat suatu REST API kita tidak membutuhkan fitur view karna yang di return hanyalah sebuah JSON ataupun XML, jadi kita bisa memakai blueprint “Api only” untuk mengurangi dependensi yang tidak di pakai.

Seperti yang sebelumnya saya bilang, AdonisJS dilengkapi banyak fitur sehingga mempercepat proses development dan pembuatan suatu aplikasi web.

• Router
• View (EdgeJS)
• SQL ORM (Lucid)
• Migrasi
• Exception Handler
• Data Validation / Data Sanitization
• Unit / Functional Test
• Dan masih banyak yang lainya.

Untuk memulai dengan AdonisJS cukup mudah, pertama kita harus install Nodejs versi 8 atau terbaru terlebih dahulu. Saya memakai Ubuntu dan kebutulan instalasi di ubuntu tidak terlalu ribet, untuk sistem operasi yang berbeda bisa di sesuaikan, Download NodeJS. Silakan buka terminal dan paste baris kode di bawah ini dan ikuti langkah2 selanjutnya yang diperintahkan.

curl -sL https://rpm.nodesource.com/setup_10.x | bash -

Bila Nodejs sudah terpasang, selanjutnya kita install adonis-cli untuk memudahkan kita membuat web menggunakan AdonisJS.

npm i -g @adonisjs/cli

Bila anda mengalami error EACCES saat menginstall adonis-cli secara global, coba ikuti tutor berikut Resolving EACCES permissions errors when installing packages globally

Lalu kita cek apakah adonis-cli sudah terpasang dengan benar di mesin kita atau belum dengan perintah dibawah. bila telah terpasang akan keluar perintah2 apa saja yang kita bisa panggil.

adonis --help

Lanjut dengan membuat webnya dengan perintah di bawah. Perintah dibawah akan membuat directory bernama adonisjs-web-app dan melakukan clone blueprint AdonisJS versi fullstack serta melakukan instalasi semua depedensi yang di butuhkan (npm install). adonisjs-web-app adalah nama aplikasinya.

adonis new adonisjs-web-app

Jika telah seslai melakukan perintah di atas, selanjutnya kita masuk ke hasil directory yang telah dilakukan perintah di atas dan menjalankan webnya dengan environment development

cd adonisjs-web-app
adonis serve --dev

Lalu akses http://localhost:3333 di browser dan akan terlihat bacaan It Works! yang menandakan bawah kita siap untuk membangun web dengan AdonisJS yang kita bahas di lain hari! Terimakasih.