搭建流程
下載
rocketmq包
修改配置
解壓上一步的包，在conf文件夾下你就會發現2m-2s-async文件夾
boker配置
boker-a master boker-a-sslave
修改boker-a.properties
#所屬集群名字
brokerClusterName=rocketmq-cluster
#broker名字，名字可重復,為了管理,每個master起一個名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分號分割
namesrvAddr=127.0.0.1:9876;127.0.0.1:9875
#在發送消息時，自動創建服務器不存在的topic，默認創建的隊列數
defaultTopicQueueNums=4
#是否允許 Broker 自動創建Topic，建議線下開啟，線上關閉
autoCreateTopicEnable=true
#是否允許 Broker 自動創建訂閱組，建議線下開啟，線上關閉
autoCreateSubscriptionGroup=true
#Broker 對外服務的監聽端口,
listenPort=10911
#刪除文件時間點，默認凌晨 4點
deleteWhen=04
#文件保留時間，默認 48 小時
fileReservedTime=120
#commitLog每個文件的大小默認1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每個文件默認存30W條，根據業務情況調整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
#存儲路徑
storePathRootDir=E:\cloud\RocketMQ\store\broker-a
#commitLog 存儲路徑
storePathCommitLog=E:\cloud\RocketMQ\store\broker-a\commitlog
#消費隊列存儲路徑存儲路徑
storePathConsumeQueue=E:\cloud\RocketMQ\store\broker-a\consumequeue
#消息索引存儲路徑
storePathIndex=E:\cloud\RocketMQ\store\broker-a\index
#checkpoint 文件存儲路徑
storeCheckpoint=E:\cloud\RocketMQ\store\checkpoint
#abort 文件存儲路徑
abortFile=E:\cloud\RocketMQ\store\abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 異步復制Master
#- SYNC_MASTER 同步雙寫Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盤方式
#- ASYNC_FLUSH 異步刷盤
#- SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#發消息線程池數量
#sendMessageThreadPoolNums=128
#拉消息線程池數量
#pullMessageThreadPoolNums=128
====== 修改boker-a-s.properties
#所屬集群名字
brokerClusterName=rocketmq-cluster
#broker名字，名字可重復,為了管理,每個master起一個名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
brokerName=broker-a-s
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分號分割
namesrvAddr=127.0.0.1:9876;127.0.0.1:9875
#在發送消息時，自動創建服務器不存在的topic，默認創建的隊列數
defaultTopicQueueNums=4
#是否允許 Broker 自動創建Topic，建議線下開啟，線上關閉
autoCreateTopicEnable=true
#是否允許 Broker 自動創建訂閱組，建議線下開啟，線上關閉
autoCreateSubscriptionGroup=true
#Broker 對外服務的監聽端口,
listenPort=10931
#刪除文件時間點，默認凌晨 4點
deleteWhen=04
#文件保留時間，默認 48 小時
fileReservedTime=120
#commitLog每個文件的大小默認1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每個文件默認存30W條，根據業務情況調整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
#存儲路徑
storePathRootDir=E:\cloud\RocketMQ\store\broker-a-s
#commitLog 存儲路徑
storePathCommitLog=E:\cloud\RocketMQ\store\broker-a-s\commitlog
#消費隊列存儲路徑存儲路徑
storePathConsumeQueue=E:\cloud\RocketMQ\store\broker-a-s\consumequeue
#消息索引存儲路徑
storePathIndex=E:\cloud\RocketMQ\store\broker-a-s\index
#checkpoint 文件存儲路徑
storeCheckpoint=E:\cloud\RocketMQ\store\checkpoint
#abort 文件存儲路徑
abortFile=E:\cloud\RocketMQ\store\abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 異步復制Master
#- SYNC_MASTER 同步雙寫Master
#- SLAVE
brokerRole=SLAVE
#刷盤方式
#- ASYNC_FLUSH 異步刷盤
#- SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#發消息線程池數量
#sendMessageThreadPoolNums=128
#拉消息線程池數量
#pullMessageThreadPoolNums=128
boker-b和boker-b-s參照上面配置 注意端口
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
新建namesrv配置
新建namesrv-a.properties/namesrv-a.properties
a listenPort=9876 b listenPort=9875
1
2
修改啟動命令
修改cmd 的內存配置(線上不用修改)
runserver.cmd
-server -Xms512m -Xmx512m -Xmn126m -XX:PermSize=128m -XX:MaxPermSize=320m
runboker.cmd
-server -Xms512m -Xmx512m -Xmn256m
1
2
3
4
5
配置環境變量
key = ROCKETMQ_HOME
示例:
E:\cloud\RocketMQ\rocketmq-all-4.3.2-bin-release
1
2
3
啟動
啟動程序都在bin目錄
namesrv
mqnamesrv.cmd -c 你的配置文件所在位置/nameserver-a.properties
mqnamesrv.cmd -c 你的配置文件所在位置/nameserver-b.properties
boker 啟動后信息很容器判斷是否成功
mqbroker.cmd -c 你的配置文件所在位置/broker-a.properties
mqbroker.cmd -c 你的配置文件所在位置/broker-b.properties
mqbroker.cmd -c 你的配置文件所在位置/broker-a-s.properties
mqbroker.cmd -c 你的配置文件所在位置/broker-b-s.properties
1
2
3
4
5
6
7
8
9
10
啟動控制台
把rokcetmq-console項目
拉下來后
修改配置文件 rocketmq.config.namesrvAddr=127.0.0.1:9876;127.0.0.1:9875
執行
mvn clean
mvn install -Dmaven.test.skip=true
運行jar包 在頁面范文 localhost:8080
---------------------