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!
Alat AI Hot
Undress AI Tool
Gambar buka pakaian secara percuma
Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik
AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.
Clothoff.io
Penyingkiran pakaian AI
Video Face Swap
Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!
Artikel Panas
Alat panas
Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma
SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan
Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa
Dreamweaver CS6
Alat pembangunan web visual
SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)
Topik panas
Kenapa anda harus meletakkan tag di bahagian bawah ?
Jul 02, 2025 am 01:22 AM
PlacingtagsatthebottomofablogpostorwebpageservespracticalpurposesforSEO,userexperience,anddesign.1.IthelpswithSEObyallowingsearchenginestoaccesskeyword-relevanttagswithoutclutteringthemaincontent.2.Itimprovesuserexperiencebykeepingthefocusonthearticl
Bagaimana untuk bekerja dengan tarikh dan masa di JS?
Jul 01, 2025 am 01:27 AM
Titik berikut harus diperhatikan apabila tarikh pemprosesan dan masa di JavaScript: 1. Terdapat banyak cara untuk membuat objek tarikh. Adalah disyorkan untuk menggunakan rentetan format ISO untuk memastikan keserasian; 2. Dapatkan dan tetapkan maklumat masa boleh diperoleh dan tetapkan kaedah, dan ambil perhatian bahawa bulan bermula dari 0; 3. Tarikh pemformatan secara manual memerlukan rentetan, dan perpustakaan pihak ketiga juga boleh digunakan; 4. Adalah disyorkan untuk menggunakan perpustakaan yang menyokong zon masa, seperti Luxon. Menguasai perkara -perkara utama ini secara berkesan dapat mengelakkan kesilapan yang sama.
Apakah peristiwa yang menggelegak dan menangkap di Dom?
Jul 02, 2025 am 01:19 AM
Penangkapan dan gelembung acara adalah dua peringkat penyebaran acara di Dom. Tangkap adalah dari lapisan atas ke elemen sasaran, dan gelembung adalah dari elemen sasaran ke lapisan atas. 1. Penangkapan acara dilaksanakan dengan menetapkan parameter useCapture addeventlistener kepada benar; 2. Bubble acara adalah tingkah laku lalai, useCapture ditetapkan kepada palsu atau ditinggalkan; 3. Penyebaran acara boleh digunakan untuk mencegah penyebaran acara; 4. Acara menggelegak menyokong delegasi acara untuk meningkatkan kecekapan pemprosesan kandungan dinamik; 5. Penangkapan boleh digunakan untuk memintas peristiwa terlebih dahulu, seperti pemprosesan pembalakan atau ralat. Memahami kedua -dua fasa ini membantu mengawal masa dan bagaimana JavaScript bertindak balas terhadap operasi pengguna.
Roundup JS yang pasti pada modul JavaScript: Modul ES vs Commonjs
Jul 02, 2025 am 01:28 AM
Perbezaan utama antara modul ES dan Commonjs adalah kaedah pemuatan dan senario penggunaan. 1.Commonjs dimuatkan secara serentak, sesuai untuk persekitaran sisi pelayan Node.js; 2. Modul tidak disengajakan, sesuai untuk persekitaran rangkaian seperti penyemak imbas; 3. Sintaks, modul ES menggunakan import/eksport dan mesti terletak di skop peringkat atas, manakala penggunaan CommonJS memerlukan/modul.exports, yang boleh dipanggil secara dinamik pada runtime; 4.Commonjs digunakan secara meluas dalam versi lama node.js dan perpustakaan yang bergantung kepadanya seperti Express, manakala modul ES sesuai untuk kerangka depan moden dan nod.jsv14; 5. Walaupun ia boleh dicampur, ia boleh menyebabkan masalah dengan mudah.
Bagaimanakah pengumpulan sampah berfungsi di JavaScript?
Jul 04, 2025 am 12:42 AM
Mekanisme pengumpulan sampah JavaScript secara automatik menguruskan memori melalui algoritma pembersihan tag untuk mengurangkan risiko kebocoran ingatan. Enjin melintasi dan menandakan objek aktif dari objek akar, dan tidak bertanda dianggap sebagai sampah dan dibersihkan. Sebagai contoh, apabila objek tidak lagi dirujuk (seperti menetapkan pembolehubah kepada null), ia akan dikeluarkan dalam pusingan seterusnya kitar semula. Punca kebocoran memori yang biasa termasuk: ① Pemasa atau pendengar peristiwa yang tidak jelas; ② Rujukan kepada pembolehubah luaran dalam penutupan; ③ Pembolehubah global terus memegang sejumlah besar data. Enjin V8 mengoptimumkan kecekapan kitar semula melalui strategi seperti kitar semula generasi, penandaan tambahan, kitar semula selari/serentak, dan mengurangkan masa menyekat benang utama. Semasa pembangunan, rujukan global yang tidak perlu harus dielakkan dan persatuan objek harus dihiasi dengan segera untuk meningkatkan prestasi dan kestabilan.
Bagaimana membuat permintaan HTTP di node.js?
Jul 13, 2025 am 02:18 AM
Terdapat tiga cara biasa untuk memulakan permintaan HTTP dalam node.js: Gunakan modul terbina dalam, axios, dan nod-fetch. 1. Gunakan modul HTTP/HTTPS terbina dalam tanpa kebergantungan, yang sesuai untuk senario asas, tetapi memerlukan pemprosesan manual jahitan data dan pemantauan ralat, seperti menggunakan https.get () untuk mendapatkan data atau menghantar permintaan pos melalui .write (); 2.AXIOS adalah perpustakaan pihak ketiga berdasarkan janji. Ia mempunyai sintaks ringkas dan fungsi yang kuat, menyokong async/menunggu, penukaran JSON automatik, pemintas, dan lain -lain. Adalah disyorkan untuk memudahkan operasi permintaan tak segerak; 3.Node-Fetch menyediakan gaya yang serupa dengan pengambilan penyemak imbas, berdasarkan janji dan sintaks mudah
var vs let vs const: penjelasan js roundup cepat
Jul 02, 2025 am 01:18 AM
Perbezaan antara VAR, LET dan Const adalah skop, promosi dan pengisytiharan berulang. 1.VAR adalah skop fungsi, dengan promosi yang berubah -ubah, yang membolehkan pengisytiharan berulang; 2.Let adalah skop peringkat blok, dengan zon mati sementara, dan pengisytiharan berulang tidak dibenarkan; 3.const juga skop peringkat blok, dan mesti diberikan dengan segera, dan tidak boleh ditugaskan semula, tetapi nilai dalaman jenis rujukan boleh diubah suai. Gunakan const terlebih dahulu, gunakan biarkan apabila menukar pembolehubah, dan elakkan menggunakan var.
Mengapa manipulasi Dom perlahan dan bagaimanakah ia dapat dioptimumkan?
Jul 01, 2025 am 01:28 AM
Sebab -sebab utama untuk operasi perlahan DOM adalah kos penyusunan semula dan penyusunan semula dan kecekapan akses yang rendah. Kaedah pengoptimuman termasuk: 1. Mengurangkan bilangan akses dan nilai baca cache; 2. Batch membaca dan menulis operasi; 3. Menggabungkan dan mengubah suai, menggunakan serpihan dokumen atau elemen tersembunyi; 4. Elakkan susun atur susun atur dan mengendalikan membaca dan menulis; 5. Rangka Kerja Gunakan atau Kemas Kini Asynchronous Rangka Kerja.
