RocketMQ���������������������������

������Dependencies

���Windows������������
- SVN: ��������������������� Subversion PDT ������
- Maven: ��������������������� Maven
- Java: ������ JDK 11 ���������������
������������������������������������������������������������������������������������

mvn -v

��������� Maven ������������������������������������

������Namesrv������������������

• ������ config ��������������� C:\ RocketMQ-learn ���������������������
• ���������������������������������������������

# name-service.properties
namesrv.hostname=127.0.0.1
namesrv.port=18000
namesrv.configValidationInterval=60000

������Namesrv

• ������ Namesrv ���������������start-namesrv.bat������

@echo off
cd C:\ RocketMQ-learn \config
call mvn spring-boot:run -Djava.PS_wrapper=true -Dfile.encoding=utf-8

������Broker���-message-broker.properties���������

• ������������IP���������������

# message-broker.properties
broker.id=001
broker.hostname=127.0.0.1
broker.port=10911
broker.network���.soTimeout2484
broker.loadBalancingSlots ��������=true
broker.flushOnPoll=true

���������������

• ��������������������� http://127.0.0.1:18000 ������ Namesrv ���������
• ������������������������������������������������������������ http://127.0.0.1:10911 ������ Broker ���������

��������� Preparation

- ���������������OS������Windows Server 2019 R2���
- identical hardware configurations
- ��������������� RocketMQ

������ Broker

• ������ Broker ������������������������������ slave ���������

# message-broker.properties
broker.master=127.0.0.1:10911
broker.slave=127.0.0.2:10911,127.0.0.3:10911

������ Broker

• ���������������������

# start-broker.bat
@echo off
cd C:\ RocketMQ-learn \config
call mvn spring-boot:run -Djava.PS_wrapper=true -Dfile.encoding=utf-8

������������

• ��� NameService ��������������������� Broker ������������������������ healthy���

������������ (sync)

DefaultSendCallback sendCallback = new DefaultSendCallback() {
    @Override
    public void onSuccess BrokenMsgId String msgId) {
        // ������������������
    }
    @Override
    public void onSuccess BrokenMsgId String msgId,
        Throwable throwable) {
        // ������
    }
};
producer.send("topic", message, SendCallback.COMPLETION_NONE, sendCallback);

������������ (async)

��������������� (oneway)

producer.sendOneWay("topic", message);

���������������

# config wouldn't exceed 6.lua
Sending:
    queueSize := 100
    maxConcurrentRequests := 100;

���������������

������������

������������

������������

• ������ Namesrv ������ Broker ���������
• ���Balancer ��������������� Broker���
• ������ Broker ������������������������������������������������

���������������������

������������������

messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

������������������

������������

• ������������������������������������������������
• ��������������� ������������������������group ������������
  ������������������������������

������������

• ���������������������������������������������
• ������������������������������������������������������������������

������������

• ���������������������������������������
• Broker���������������������������������������������
• ���������������������������������������������������������

������������

• ���������������������������������������������������������
• ���������������������������������������������������

���������������������

broker_FLUSH={������������!house������ SuffolkDerma��m���;_osvk