Skip to content

Commit 64280ad

Browse files
author
YunaiV
committed
增加 rabbitmq 并发消费
1 parent bd25402 commit 64280ad

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

lab-04/lab-04-rabbitmq-demo-concurrency/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/consumer/Demo09Consumer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
@Component
1111
@RabbitListener(queues = Demo09Message.QUEUE)
12+
//@RabbitListener(queues = {"QUEUE_DEMO_01", "QUEUE_DEMO_02"})
1213
public class Demo09Consumer {
1314

1415
private Logger logger = LoggerFactory.getLogger(getClass());

lab-04/lab-04-rabbitmq-demo-concurrency/src/main/resources/application.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,4 +11,4 @@ spring:
1111
concurrency: 2
1212
max-concurrency: 10
1313
# direct:
14-
# consumers-per-queue: 1
14+
# consumers-per-queue: 2 # 对于每一个 @RabbitListener ,一个 Queue ,对应创建几个 Consumer 。

lab-04/lab-04-rabbitmq-demo-concurrency/target/classes/application.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,5 +10,5 @@ spring:
1010
simple:
1111
concurrency: 2
1212
max-concurrency: 10
13-
# direct:
14-
# consumers-per-queue: 1
13+
direct:
14+
consumers-per-queue: 2

0 commit comments

Comments
 (0)