今回はチュートリアル 6 RPC についてやっていきます。まずは RPCのサーバ側です。引数で受けた文字列に日時をつけて返します。rpc_server.js #!/usr/bin/env node const amqp = require('amqplib'); const my = require('./my.js'); async function main() …

今回はチュートリアル 5 Topics をやっていきます。Topic と言ったって単にワイルドカードを使った部分一致で待ち受けできますよ、と言うだけです。では早速 Receiver から。sub_t.js #!/usr/bin/env node const amqp = require('amqplib'); const my = requ…

さて今回は本家チュートリアル 4 Routing をやってまいります。 Routing と言ったって Receiver 側で名前を OR で待ち受けれるだけと言う簡単な機能です。pub_r.js #!/usr/bin/env node const amqp = require('amqplib'); const my = require('./my.js'); as…

今回は本家チュートリアル 3 Publish/Subscribe です。これは何か？を簡単に言うと、ブロードキャストです。 今までの例では Receiver 側は Sender から送られた Message をどれか一つの Receiver だけで受けていましたが、これを複数の Receiver で受ける事…

前回、単純なメッセージ送信を行いました。今回は本家チュートリアル 2 Work queues にあたる、タスク処理を行ってみます。タスク処理で大事なのはきちんとタスクが完遂されることです。なので、もし処理途中でプロセスが死んだ場合、他のプロセスがタスク処…

RabbitMQ を仕事で使う必要があり使い始めたんですがこれがまた分かり辛い。むちゃくちゃ単純な代物なのにやたらと難しくする病気を患っているシリーズです。 自分は Node.js から使うんですが、本家チュートリアルのコードがコールバック地獄コードだったり…