-
Notifications
You must be signed in to change notification settings - Fork 86
/
application.yml
84 lines (75 loc) · 2.87 KB
/
application.yml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
# 配置tomcat端口号
server:
port: 9003
# 配置rabbitmq
spring:
rabbitmq:
host: 127.0.0.1 # rabbitMQ的ip地址
#addresses: 192.168.150.101:8071, 192.168.150.101:8072, 192.168.150.101:8073 #集群地址
port: 5672 # 端口
username: guest # 账号
password: guest #密码
virtual-host: / #虚拟机
#publisher-confirms: true # 开启消息发送确认机制,低版本(一般在生产端，消费端加上也没关系)
publisher-confirm-type: correlated # 开启消息发送确认机制(一般在生产端，消费端加上也没关系)
listener:
simple:
# 并发消费：每个侦听器线程的最小数量，具体数值根据系统性能配置（一般为系统cpu核数）
concurrency: 2
# 并发消费：每个侦听器线程的最大数量，具体数值根据系统性能配置（一般为系统cpu核数*2）
max-concurrency: 4
# 每次只能获取一条消息，处理完成才能获取下一个消息,避免照成消息堆积在一个消费线程上
prefetch: 1
#acknowledge-mode: manual # 消费者开启手动ack消息确认，需要测试请看示例请AckConsumer,所有队列都会生效
#default-requeue-rejected: false # 设置为false，会重发消息到死信队列（防止手动ack确认失败的消息堆积），需要测试请示例AckConsumer,所有队列都会生效
retry:
enabled: true # 解决消息死循环问题-启用重试
max-attempts: 3 # 最大重试3次(默认)，超过就丢失（或放到死信队列中，防止消息堆积）
multiplier: 2 # 乘子
initial-interval: 3000 # 第一次和第二次之间的重试间隔，后面的用乘子计算 3s 6s 12s
max-interval: 16000 # 最大重试时间间隔16s
# ==================================其实下面用常量配置更好，统一管理，这里只是作为配置文件的演示==================================
# 发布与订阅模式
fanout:
# 交换机
exchange: fanout-exchange
# 队列名称
sms:
queue: fanout-sms-queue
weixin:
queue: fanout-weixin-queue
# 路由模式
direct:
# 交换机
exchange: direct-exchange
# 队列名称
info:
queue: direct-info-queue
error:
queue: direct-error-queue
all:
queue: direct-all-queue
# 主题模式
topic:
# 交换机
exchange: topic-exchange
# 配置队列名称
info:
queue: topic-info-queue
error:
queue: topic-error-queue
full:
queue: topic-full-queue
# 主题模式下的ack确认+死信队列
topicAck:
# 交换机
exchange: topicAck-exchange
# 配置队列名称
ack:
queue: topicAck-ack-queue
# 死信队列
dead:
# 交换机
exchange: dead-exchange
# 配置队列名称
queue: dead-queue