這篇文章主要為大家展示了“RocketMq的用法示例”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“RocketMq的用法示例”這篇文章吧。

成都創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作與策劃設(shè)計(jì),長樂網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)十載,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:長樂等地區(qū)。長樂做網(wǎng)站價格咨詢:18980820575

1.搭建rocketmq服務(wù)

下載: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip

# 解壓至: /usr/local/rocketmq-all-4.5.1-bin-release
# 啟動/關(guān)閉服務(wù): 
    rocketmq
        # 啟動:
            /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqnamesrv -c /usr/local/rocketmq-all-4.5.1-bin-release/conf/namesrv.properties -n "192.168.1.180:6500" &
            # 設(shè)置自定義端口: 6500
            -n /usr/local/rocketmq-all-4.5.1-bin-release/conf/namesrv.properties
            # 文件內(nèi)容是: 
                listenPort=6600
        # 關(guān)閉: 
            /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqshutdown namesrv

    mqbroker:
        # 啟動:  autoCreateTopicEnable=true(允許微服務(wù)創(chuàng)建topic)
            /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqbroker -n "192.168.1.180:6500" autoCreateTopicEnable=true &
        # 關(guān)閉: 
        /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqshutdown broker

2.生產(chǎn)者-微服務(wù)(發(fā)送-隊(duì)列消息)

# 消息體-對象:
@Data
@Builder
@ToString
public class MemberMoneyMessage {
    int memberId;
    String event;
    double money;
}

# 發(fā)送消息:
@Autowired
RocketMQTemplate rocketMQTemplate;
....
rocketMQTemplate.convertAndSend(
            "member-money-act",
            MemberMoneyMessage.builder()
                    .event("pay-order")
                    .memberId(50)
                    .money(100)
                    .build()
    );
....

配置rocket服務(wù)端:
rocketmq:
name-server: tsca.cc:6600
producer:
    group: tsca-group

3.消費(fèi)者-微服務(wù)(處理-隊(duì)列消息)

# 監(jiān)聽處理(發(fā)送方的member-money-act和接收方的member-money-act一樣便能接收):
@Service
@RocketMQMessageListener(consumerGroup = "tsca-group",topic = "member-money-act")
@Slf4j
public class MemberMoneyMqListener implements RocketMQListener {
    @Override
    public void onMessage(MemberMoneyMessage memberMoneyMessage) {
        log.info("收到-用戶余額變動");
        log.info(JSON.toJSONString(memberMoneyMessage));
    }
}

# 配置:
rocketmq:
    name-server: tsca.cc:6600
    producer:
        group: tsca-group

4.搭建: rocketmq-控制臺

# 1.下載源碼
git clone https://github.com/apache/rocketmq-externals.git

# 2.用IDEA打開【rocketmq-console】項(xiàng)目，修改pom文件 rocketmq版本
 (2-1).更改pom文件的rocketmq版本:
4.4.0
# 改為:
4.5.1
 (2-2).更改代碼:
org/apache/rocketmq/console/service/impl/MessageServiceImpl.java
# 92,93 rows
DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, null);
改為:
RPCHook rpcHook = null;
DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, rpcHook);

# 3.更改配置
# 當(dāng)前網(wǎng)頁控制臺端口
server.port=6650
# rocketmq服務(wù)端口
rocketmq.config.namesrvAddr=192.168.1.180:6600

# 4.編譯打包
mvn clean package -DskipTests

# 5.運(yùn)行
java -jar -Dserver.port=6650 -Drocketmq.config.namesrvAddr=192.168.1.180:6600 rocketmq-console-ng-1.0.1.jar

以上是“RocketMq的用法示例”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)網(wǎng)站制作公司行業(yè)資訊頻道！

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務(wù)器，動態(tài)BGP最優(yōu)骨干路由自動選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機(jī)房獨(dú)有T級流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動現(xiàn)已開啟，新人活動云服務(wù)器買多久送多久。

分享標(biāo)題：RocketMq的用法示例-創(chuàng)新互聯(lián)
網(wǎng)站地址：http://weahome.cn/article/jjehg.html