Bermula dengan RabbitMq menggunakan NodeJs

Pengenalan kepada RabbitMq

RabbitMq ialah broker mesej yang membenarkan penghantaran dan penerimaan mesej antara perkhidmatan yang berbeza. Ia adalah broker mesej yang melaksanakan Protokol Gilir Mesej Lanjutan (AMQP). Ditulis dengan Bahasa Pengaturcaraan Erlang.

Memasang RabbitMq

RabbitMq boleh dipasang pada sistem pengendalian yang berbeza Menggunakan pengurus pakej masing-masing. RabbitMQ memerlukan Erlang/OTP dipasang terlebih dahulu, sila rujuk dokumentasi rasmi untuk maklumat lanjut.

• Linux

sudo apt-get install rabbitmq-server

• Mac

brew install rabbitmq

Setelah dipasang, kita boleh memulakan pelayan RabbitMq menggunakan arahan berikut:

sudo rabbitmq-server

Setelah pelayan dimulakan, kami boleh mengakses rabbitmq daripada aplikasi kami menggunakan port lalai 5672.

Untuk mendayakan konsol pengurusan RabbitMq, kami boleh menjalankan arahan berikut:

sudo rabbitmq-plugins enable rabbitmq_management

kami boleh mengakses konsol pengurusan RabbitMq dengan melawati http://localhost:15672/ dalam penyemak imbas anda. Nama pengguna dan kata laluan lalai adalah tetamu.

Menyediakan RabbitMq dengan NodeJs

Untuk berinteraksi dengan RabbitMq daripada NodeJs, kita boleh menggunakan perpustakaan amqplib. Kita boleh memasang perpustakaan menggunakan arahan berikut:

npm install amqplib

Untuk menyambung ke RabbitMq daripada NodeJs dan mencipta saluran untuk berinteraksi dengan RabbitMq, kami boleh menggunakan kod berikut:

const amqp = require("amqplib");

const connect = async (url) => {
  const connection = await amqp.connect(url);
  const channel = await connection.createChannel();

  return channel;
};

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.close();
  process.exit(0);
});

Kini, kami mempunyai saluran untuk berinteraksi dengan RabbitMq. Kami boleh menggunakan saluran ini untuk menghantar dan menerima mesej daripada RabbitMq. namakan baris gilir kami mq-test-queue dan hantar mesej ke baris gilir.

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.assertQueue("mq-test-queue");
  console.log("Queue created");
  channel.sendToQueue("mq-test-queue", Buffer.from("Hello World!"));
  console.log("Message sent");
});

Kami telah mencipta baris gilir mq-test-queue dan menghantar mesej Hello World! ke barisan. Untuk membuat Baris Gilir, kami telah menggunakan kaedah assertQueue dan untuk menghantar mesej ke baris gilir, kami telah menggunakan kaedah sendToQueue.

Untuk menerima mesej daripada baris gilir, kami boleh menggunakan kaedah penggunaan.

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.assertQueue("mq-test-queue");
  console.log("Queue created");
  channel.sendToQueue("mq-test-queue", Buffer.from("Hello World!"));
  console.log("Message sent");
  channel.consume("mq-test-queue", (msg) => {
    console.log("Message received", msg.content.toString());
  });
});

Kaedah penggunaan mengambil fungsi panggil balik dan menghantar objek mesej ke fungsi panggil balik untuk mengakses kandungan mesej menggunakan msg.content.toString().

Selepas menggunakan mesej, kita perlu mengambil atau menack mesej untuk mengalih keluar mesej daripada baris gilir. Kita boleh menggunakan kaedah ack untuk mengakui mesej dan kaedah nack untuk menolak mesej.

Untuk contoh ini, kami akan menerima mesej selepas menggunakan mesej.

const amqp = require("amqplib");

const connect = async (url) => {
  const connection = await amqp.connect(url);
  const channel = await connection.createChannel();

  return channel;
};

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.assertQueue("mq-test-queue");
  console.log("Queue created");
  channel.sendToQueue("mq-test-queue", Buffer.from("Hello World!"));
  console.log("Message sent");
  channel.consume("mq-test-queue", (msg) => {
    console.log("Message received", msg.content.toString());
    channel.ack(msg);
  });
});

Kita dapat melihat mesej yang dihantar dan diterima dengan jayanya daripada baris gilir. menggunakan konsol pengurusan rabbitmq.

Kesimpulan

Dalam artikel ini, kami telah mempelajari cara menyediakan RabbitMq dan berinteraksi dengan RabbitMq daripada NodeJs menggunakan perpustakaan amqplib. Kami telah membuat baris gilir, menghantar mesej ke baris gilir dan menerima mesej daripada baris gilir.

Atas ialah kandungan terperinci Bermula dengan RabbitMq menggunakan NodeJs. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!