質問編集履歴
1
誤字の訂正
title
CHANGED
|
File without changes
|
body
CHANGED
|
@@ -8,7 +8,7 @@
|
|
|
8
8
|
* rabbitMQ
|
|
9
9
|
* redis-server
|
|
10
10
|
## 実現したいこと
|
|
11
|
-
1. rabbitMQにmodelの全データを送る.コードはjobで作成し、taskで実行する
|
|
11
|
+
1. rabbitMQにmodelの全データを送る.コードはjobで作成し、taskで実行する.（詳細は以下のコード参照）
|
|
12
12
|
|
|
13
13
|
2. rabbitMQからデータを受け取るworkerを非同期で複数待機させておき、rabbitMQ内のデータを逐次処理して行く（今回は内部データを表示させるのみだが、時間がかかる処理であることを想定して一つの処理あたり１秒sleepさせる）
|
|
14
14
|
コードはjobで作成し、taskで実行する.
|
|
@@ -122,18 +122,18 @@
|
|
|
122
122
|
|
|
123
123
|
ここからはどの順でプログラムを動かすかによって挙動が違ったので、それぞれのパターンについて述べようと思います。
|
|
124
124
|
|
|
125
|
-
|
|
125
|
+
### send task実行後にreceive taskを実行した場合
|
|
126
126
|
|
|
127
127
|
* send taskは正常に実行され、rabbitMQにもデータが行っている（sidekiqおよびrabbitMQのダッシュボードで確認）
|
|
128
128
|
* worker1,worker2ともに正常に実行されている模様（sidekiqのコンソール上に”[worker 1]waiting for items…”、”[worker 2]waiting for items…”が出ることから確認）
|
|
129
129
|
|
|
130
130
|
* worker2では正常に処理が行われるが、worker1では全く行われていない（worker1に関するコメントが全く出ない）
|
|
131
131
|
|
|
132
|
-
|
|
132
|
+
### receive task実行後にsend taskを実行した場合
|
|
133
133
|
|
|
134
134
|
* worker1,worker2ともに正常に実行されている模様（sidekiqのコンソール上に”[worker 1]waiting for items…”、”[worker 2]waiting for items…”が出ることから確認）
|
|
135
135
|
|
|
136
|
-
*send taskは正常に実行されない
|
|
136
|
+
* send taskは正常に実行されない
|
|
137
137
|
（sidekiqのダッシュボード上では実行中になっているが、rabbitMQにはメッセージが送られていない）
|
|
138
138
|
|
|
139
139
|
******************
|