SpringCloud Alibaba(五) - RocketMQ

来源:https://www.cnblogs.com/xiaoqigui/archive/2022/12/02/16944937.html
-Advertisement-
Play Games

1、 RocketMQ安裝測試 1.1 下載解壓 下載地址：https://rocketmq.apache.org/release-notes/ rocketmq-all-5.0.0-bin-release.zip 下載後上傳到伺服器； 解壓命令# unzip rocketmq-all-5.0.0- ...


1、 RocketMQ安裝測試

1.1 下載解壓

下載地址：https://rocketmq.apache.org/release-notes/

rocketmq-all-5.0.0-bin-release.zip

下載後上傳到伺服器；

解壓命令# unzip rocketmq-all-5.0.0-bin-release.zip

1.2 啟動 測試

RocketMQ預設配置是比較好的，這樣可以直接應用於生產環境，所以如果機器記憶體較小，啟動會因為記憶體不足失敗，為了避免後面啟動失敗，選擇先修改其記憶體大小，一般阿裡雲伺服器是滿足不了預設記憶體。

手動調整JVM的配置，單位從g改為m

1.2.1 啟動nameserver

1.2.1.1 修改runbroker.sh和runserver.sh

1.2.1.2 runbroker.sh
 -server -Xms256m -Xmx256m -Xmn128m

1.2.1.3 runserver.sh
-server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m

1.2.1.4 啟動nameserver
解壓目錄執行# nohup ./bin/mqnamesrv -n 1.117.75.57(自己的ip):9876 &

1.2.2 啟動broker

1.2.2.1 修改broker.conf

添加namesrvAddr 和 brokerIP1:

1.2.2.3 啟動 borker
解壓目錄執行# nohup ./bin/mqbroker -n 1.117.75.57:9876 -c ./conf/broker.conf &
1.2.2.4 查看啟動情況
jps

1.2.3 測試

由於伺服器記憶體可能比較小，建議先關閉其他應用，比如rabbitmq,docker的容器等；

還需要開啟幾個埠：9876，10909，10910，10911；

1.2.3.1 生產者
導出環境變數# export NAMESRV_ADDR=1.117.75.57:9876
發送消息# bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

1.2.3.2 消費者
導出環境變數# export NAMESRV_ADDR=1.117.75.57:9876
消費消息# bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

1.2.4 關閉命令

關閉nameserver# bin/mqshutdown namesrv

關閉broker# bin/mqshutdown broker

1.2.5 RocketMQ控制台

1.2.5.1 下載，解壓，修改配置信息

1.2.5.2 訪問控制台

localhost:9696

2、RocketMQ框架原理

2.1 框架

2.2 概念

整體可以分成4個角色，分別是：NameServer，Broker，Producer，Consumer：

  • Broker(郵遞員):Broker是RocketMQ的核心，負責消息的接收，存儲，投遞等功能；
  • NameServer(郵局):消息隊列的協調者，Broker向它註冊路由信息，同時Producer和Consumer向其獲取路由信息Producer(寄件人)消息的生產者，需要從NameServer獲取Broker信息，然後與Broker建立連接，向Broker發送消息；
  • Consumer(收件人) :消息的消費者，需要從NameServer獲取Broker信息，然後與Broker建立連接，從Broker獲取消息；
  • Topic(地區):用來區分不同類型的消息，發送和接收消息前都需要先創建Topic，針對Topic來發送和接收消息Message Queue(郵件)為了提高性能和吞吐量，引入了Message Queue，一個Topic可以設置一個或多個Message Queue，這樣消息就可以並行往各個Message Queue發送消息，消費者也可以並行的從多個Message Queue讀取消息；
  • Message:Message 是消息的載體；
  • Producer Group:生產者組，簡單來說就是多個發送同一類消息的生產者稱之為一個生產者組。
  • Consumer Group:消費者組，消費同一類消息的多個 consumer 實例組成一個消費者組。

3、RocketMQ整合

3.1 rocketmq模塊 發送消息

3.2.1.1 依賴
<!-- rocket -->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.0.2</version>
</dependency>
3.2.1.2 配置
# rocketmq配置
rocketmq:
  #rocketMQ服務的地址
  name-server: 1.117.75.57:9876
  # 生產者組
  producer:
    group: kh96-sendsms-group
3.2.1.3 請求
@Autowired(required = false)
private RocketMQTemplate rocketMQTemplate;

/**
* @param : [phoneNo]
* @return : java.lang.String
* @author : huayu
* @date : 30/11/2022
* @description : 測試發送消息到用戶中心，用戶中心給手機號發信息
*/
@RequestMapping("/testRocketMQSendMsg")
public String testRocketMQSendMsg(@RequestParam String phoneNo) {
    log.info("------ 使用RocketMQ,測試給手機:{}，發送消息 -------", phoneNo);

    //使用RocketMQ發送消息
    rocketMQTemplate.convertAndSend("rocketmq-send-sms-kh96", phoneNo);

    return "send msg success";

}

3.2 user模塊 消費消息

1.添加加rocketmq的依賴；

2.用戶服務，監聽發送簡訊的請求發送消息:

/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 用戶服務，監聽發送簡訊的請求發送消息
 */
@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "rocketmq-user-sms-group", //組 隨便寫
        topic = "rocketmq-send-sms-kh96" //消息隊列，發送的時候指定的
)
public class SendSmsListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("*****  接收發送信息的請求，給手機:{}，發送消息 ******", message);
    }

}

3.3 測試

3.3.1 發送請求

3.3.2 發送消息模塊日誌

3.3.3 接收消息模塊日誌

3.3.4 控制台查看消息詳情

4、發送不同類型的消息

4.1 發送可靠同步消息

4.1.1 請求

/**
* @param : [phoneNo]
* @return : java.lang.String
* @author : huayu
* @date : 30/11/2022
* @description : 測試roketmq-發送可靠同步消息
*/
@RequestMapping("/testRocketMQSendMsgSync")
public String testRocketMQSendMsgSync(@RequestParam String syncMsg) {
    log.info("------ 使用RocketMQ,發送可靠同步消息{} -------", syncMsg);

    //使用RocketMQ發送消息,拿到同步結果
    SendResult sendResult = rocketMQTemplate.syncSend("rocketmq-sync-msg-kh96", syncMsg);

    log.info("------ 使用RocketMQ,發送可靠同步消息結果:{} -------", sendResult);

    return "send sync msg success";

}

4.1.2 發送請求

4.1.3 同步結果

4.2 發送可靠非同步消息

4.2.1 請求

/**
 * @param : [phoneNo]
 * @return : java.lang.String
 * @author : huayu
 * @date : 30/11/2022
 * @description : 測試roketmq-發送可靠非同步消息
 */
@RequestMapping("/testRocketMQSendMsgAsync")
public String testRocketMQSendMsgAsync(@RequestParam String asyncMsg) {
    log.info("------ 使用RocketMQ,發送可靠非同步消息:{} -------", asyncMsg);

    //使用RocketMQ發送消息
    rocketMQTemplate.asyncSend("rocketmq-sync-msg-kh96",
            asyncMsg,
            new SendCallback() {
                @Override
                public void onSuccess(SendResult sendResult) {
                    log.info("------  可靠非同步發送成功回調  ------");
                }

                @Override
                public void onException(Throwable throwable) {
                    log.info("------  可靠非同步發送失敗回調  ------");
                }
            });

    return "send async msg success";

}

4.2.2 發送請求

4.2.3 回調結果

4.3 發送單項消息，只發不收結果

4.3.1 請求

/**
 * @param : [phoneNo]
 * @return : java.lang.String
 * @author : huayu
 * @date : 30/11/2022
 * @description : 測試roketmq-發送單向消息，只發不收結果
 */
@RequestMapping("/testRocketMQSendMsgOneWay")
public String testRocketMQSendMsgOneWay(@RequestParam String oneWayMsg) {
    log.info("------ 使用RocketMQ,發送單向消息給:{} -------", oneWayMsg);

    //使用RocketMQ發送消息
    rocketMQTemplate.sendOneWay("rocketmq-oneWay-msg-kh96", oneWayMsg);

    return "send oneWay msg success";

}

4.3.2 發送請求

4.3.3 日誌查看

4.4 發送順序消息

4.4.1 請求

/**
 * @param : [phoneNo]
 * @return : java.lang.String
 * @author : huayu
 * @date : 30/11/2022
 * @description : 測試roketmq-發送順序消息
 */
@RequestMapping("/testRocketMQSendMsgOrderly")
public String testRocketMQSendMsgOrderly(@RequestParam String orderlyMsgs) {
    log.info("------ 使用RocketMQ,發送順序消息:{} -------", orderlyMsgs);

    //使用RocketMQ發送順序消息,必須要提供一個唯一的標識di,比如用戶編號等
    String userId = UUID.randomUUID().toString().replace("-", "");

    //發送多條順序消息,模擬iang消息分割成多個符號發送
    Arrays.asList(orderlyMsgs.split("")).
            forEach(orderlyMsg -> rocketMQTemplate.syncSendOrderly("rocketmq-orderly-msg-kh96", orderlyMsg, userId));

    return "send orderly msg success";

}

4.4.2 監聽器

/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: RocketMQ 監聽順序消息
 */
@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "rocketmq-orderly-sms-group",
        topic = "rocketmq-orderly-msg-kh96",
        consumeMode = ConsumeMode.ORDERLY)
public class RocketMQOrderlyMsgListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String orderlyMsg) {
        log.info("------接收順序消息 :{} ------", orderlyMsg);
    }


}

4.2.3 發送請求

4.2.4 消費消息

4.5 發送事務消息(重點)

4.5.1 發送事務消息流程

4.5.1.1 流程圖

4.5.1.2 流程解析
  • 正常事務發送與提交階段
  1. 生產者發送一個半消息給broker(半消息是指的暫時不能消費的消息)；
  2. 服務端響應；
  3. 開始執行本地事務；
  4. 根據本地事務的執行情況執行Commit或者Rollback
  • 事務信息的補償流程
  1. 如果broker長時間沒有收到本地事務的執行狀態,會向生產者發起一個確認會查的操作請求；
  2. 生產者收到確認會查請求後,檢查本地事務的執行狀態；
  3. 根據檢查後的結果執行Commit或者Rollback操作 補償階段主要是用於解決生產者在發送Commit或者Rollbacke操作時發生超時或失敗的情況；

4.5.2 RocketMQ事務流程關鍵

  • 事務消息在一階段對用戶不可見、

    ​ 事務消息相對普通消息最大的特點就是一階段發送的消息對用戶是不可見的,也就是說消費者不能直接消費.這裡RocketMQ實現方法是原消息的主題與消息消費隊列,然後把主題改成RMQ_SYS_TRANS_HALF_TOPIC.這樣由於消費者沒有訂閱這個主題,所以不會消費；

  • 如何處理第二階段的發送消息?

    ​ 在本地事務執行完成後迴向Broker發送Commit或者Rollback操作,此時如果在發送消息的時候生產者出故障了,要保證這條消息最終被消費,broker就會向服務端發送回查請求,確認本地事務的執行狀態.當然RocketMQ並不會無休止的發送事務狀態回查請求,預設是15次,如果15次回查還是無法得知事務的狀態,RocketMQ預設回滾消息(broker就會將這條半消息刪除)；

4.5.3 RocketMQ事務消息原理

  • 設計思想

    ​ 在RocketMQ事務消息的主要流程中，一階段的消息如何對用戶不可見。其中，事務消息相對普通消息最大的特點就是一階段發送的消息對用戶是不可見的。那麼，如何做到寫入消息但是對用戶不可見呢？RocketMQ事務消息的做法是：如果消息是half消息，將備份原消息的主題與消息消費隊列，然後改變主題為RMQ_SYS_TRANS_HALF_TOPIC。由於消費組未訂閱該主題，故消費端無法消費half類型的消息。

  • 如何實現事務回查？

    ​ Broker會啟動一個消息回查的定時任務，定時從事務消息queue中讀取所有待反查的消息。針對每個需要反查的半消息，Broker會給對應的Producer發一個要求執行事務狀態反查的RPC請求。然後根據RPC返迴響應中的反查結果，來決定這個半消息是需要提交還是回滾，或者後續繼續來反查。最後，提交或者回滾事務，將半消息標記為已處理狀態【將消息存儲在主題為：RMQ_SYS_TRANS_OP_HALF_TOPIC的主題中，代表這些消息已經被處理（提交或回滾）】。 如果是提交事務，就把半消息從半消息隊列中複製到該消息真正的topic和queue中； 如果是回滾事務，則什麼都不做。

參考博客1：https://blog.csdn.net/Weixiaohuai/article/details/123733518

參考博客2：https://blog.csdn.net/qq_42877546/article/details/125404307

4.5.4 實現代碼

4.5.4.1 業務層
4.5.4.1.1 介面
/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 事務消息的業務 介面
 */
public interface RocketMQTxService {

    /**
     * @param : [kgcMallOrder]
     * @return : void
     * @author : huayu
     * @date : 30/11/2022
     * @description : 發送生成訂單的半事務消息
     */
    void sendCreateOrderHalfTx(KgcMallOrder kgcMallOrder);


    /**
     * @param : [txId, kgcMallOrder]
     * @return : void
     * @author : huayu
     * @date : 30/11/2022
     * @description : 執行本地生成訂單的事務操作
     */
    void executeCreateOrderLocalTx(String txId, KgcMallOrder kgcMallOrder);

}
4.5.4.1.2 實現類
/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 事務消息的業務 處理類
 */
@Service
@Slf4j
public class RocketMQTxServiceImpl implements RocketMQTxService {

    @Autowired(required = false)
    private RocketMQTemplate rocketMQTemplate;

    @Autowired
    private KgcMallOrderRepository kgcMallOrderRepository;

    @Autowired
    private KgcMallTxlogrepisitory kgcMallTxlogrepisitory;

    @Override
    @Transactional

    public void sendCreateOrderHalfTx(KgcMallOrder kgcMallOrder) {

        log.info("###### 1. 開始發送生成訂單的半事務消息 到 rocketmq服務端   ######");

        //自定義事務編號
        String txId = UUID.randomUUID().toString().substring(0, 8);

        //發送半事務消息,返回發送結果
        TransactionSendResult transactionSendResult =
                rocketMQTemplate.sendMessageInTransaction("rocketmq-tx-msg-group", //組
                        "rocketmq-tx-msg-kh96",  //隊列
                        MessageBuilder.withPayload(kgcMallOrder).setHeader("txId", txId).build(), // 消息體
                        kgcMallOrder); //發送內容

        log.info("###### 2. 開始發送生成訂單的半事務消息rocketmq服務端成功，響應：{}   ######", transactionSendResult);

    }

    @Override
    @Transactional
    public void executeCreateOrderLocalTx(String txId, KgcMallOrder kgcMallOrder) {

        log.info("###### 3.1 本地開始執行生成訂單的事務操作  ######");

        //開始插入訂單
        kgcMallOrderRepository.save(kgcMallOrder);

        log.info("###### 3.2 本地執行生成訂單的事務操作 成功  ######");

        // 模擬本地事務處理失敗
//        int a = 10 / 0;

        log.info("###### 3.3開始生成用於事務回查的本地事務日誌  ######");
        //創建事務對象
        KgcMallTxlog kgcMallTxlog = KgcMallTxlog.builder()
                .id(txId)
                .txDetail("本地事務日誌")
                .txTime(new Date())
                .build();

        //事務日誌入庫
        kgcMallTxlogrepisitory.save(kgcMallTxlog);
        log.info("###### 3.4 生成用於事務回查的本地事務日誌成功 ######");

    }


}
4.5.4.2 監聽器
4.5.4.2.1 RocketMQExecuteLocalTxListener
/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 事務消息，本地執行事務監聽，半事務消息發送成功後，此監聽會收到本地事務處理的通知
 */
@Slf4j
@Component
@RocketMQTransactionListener(txProducerGroup = "rocketmq-tx-msg-group")
public class RocketMQExecuteLocalTxListener implements RocketMQLocalTransactionListener {


    @Autowired
    private RocketMQTxService rocketMQTxService;

    @Autowired
    private KgcMallTxlogrepisitory kgcMallTxlogrepisitory;

    //執行本地事務
    @Override
    public RocketMQLocalTransactionState executeLocalTransaction(Message msg, Object arg) {

        try {
            //調用本地事務執行的業務處理介面
            log.info("###### 3 半事務消息發送成功， 執行本地事務  ######");
            rocketMQTxService.executeCreateOrderLocalTx((String) msg.getHeaders().get("txId"), (KgcMallOrder) arg);

            //響應本地事務執行成功結果給服務端，服務端接收到此提交結果，會投遞消息
            log.info("###### 4 本地事務處理成功，響應事務處理結果給服務端 ######");
            return RocketMQLocalTransactionState.COMMIT;
        } catch (Exception e) {
            log.error("###### 本地事務執行異常：{} ######", e.getMessage());
        }

        //響應本地事務執行失敗結果給服務端，服務端接收到此回滾結果，不會投遞消息(緩存，並定期刪除)
        log.info("###### 4 本地事務處理失敗，響應事務處理結果給服務端 #######");
        return RocketMQLocalTransactionState.ROLLBACK;
    }


    //回查本地事務
    @Override
    public RocketMQLocalTransactionState checkLocalTransaction(Message msg) {

        log.info("###### 5 未收到第4步本地事務處理結果，回查事務狀態 ######");
        //在網路閃斷或者服務重啟，沒有及時通知服務斷事務處理結果，進行會查操作
        //如果回查本地事務執行成功(看事物日誌是否存在，如果存在就是處理成功如果不存在就是處理失敗)，通知服務端投遞消息，否則不能投遞
        log.info("###### 6 檢查本地事務處理結果，響應事務處理結果給服務端 ######");
        if (kgcMallTxlogrepisitory.findById((String) msg.getHeaders().get("txId")).orElse(null) == null) {
            //本地事務入庫失敗，代表本地事務沒有處理成功，步投遞消息(緩存，並定期刪除)
            log.info("###### 7 檢查本地事務處理結果失敗 ######");
            return RocketMQLocalTransactionState.ROLLBACK;
        }

        //本地事務入庫成功，代表本地事務處理成功，投遞消息
        log.info("###### 7 檢查本地事務處理結果成功 ######");
        return RocketMQLocalTransactionState.COMMIT;
    }


}
4.5.4.2.2 RocketMQConsumerTxMsgListener
/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 事務消息，消費監聽，如果本地事務處理成功，會收到投遞的消息，如果失敗，收不到消息
 */
@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "rocket-tx-msg-consumer-group",
        topic = "rocket-tx-msg-kh96"
)
public class RocketMQConsumerTxMsgListener implements RocketMQListener<Object> {

    @Override
    public void onMessage(Object message) {
        log.info("######  8 消費端，收到生成訂單成功的事務消息：{} ###### ", message);
    }

}
4.5.4.3 控制器
/**
 * Created On : 30/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: RocketMQ 消息隊列 測試消息入口
 */
@Slf4j
@RestController
public class RocketMQController {

    @Autowired(required = false)
    private RocketMQTemplate rocketMQTemplate;

    @Autowired
    private RocketMQTxService rocketMQTxService;


    /**
     * @param : [phoneNo]
     * @return : java.lang.String
     * @author : huayu
     * @date : 30/11/2022
     * @description : 測試發送消息到用戶中心，用戶中心給手機號發信息
     */
    @RequestMapping("/testRocketMQSendMsg")
    public String testRocketMQSendMsg(@RequestParam String phoneNo) {
        log.info("------ 使用RocketMQ,測試給手機:{}，發送消息 -------", phoneNo);

        //使用RocketMQ發送消息
        rocketMQTemplate.convertAndSend("rocketmq-send-sms-kh96", phoneNo);

        return "send msg success";

    }

    /**
     * @param : [phoneNo]
     * @return : java.lang.String
     * @author : huayu
     * @date : 30/11/2022
     * @description : 測試roketmq-發送可靠同步消息
     */
    @RequestMapping("/testRocketMQSendMsgSync")
    public String testRocketMQSendMsgSync(@RequestParam String syncMsg) {
        log.info("------ 使用RocketMQ,發送可靠同步消息{} -------", syncMsg);

        //使用RocketMQ發送消息,拿到同步結果
        SendResult sendResult = rocketMQTemplate.syncSend("rocketmq-sync-msg-kh96", syncMsg);

        log.info("------ 使用RocketMQ,發送可靠同步消息結果:{} -------", sendResult);

        return "send sync msg success";

    }

    /**
     * @param : [phoneNo]
     * @return : java.lang.String
     * @author : huayu
     * @date : 30/11/2022
     * @description : 測試roketmq-發送可靠非同步消息
     */
    @RequestMapping("/testRocketMQSendMsgAsync")
    public String testRocketMQSendMsgAsync(@RequestParam String asyncMsg) {
        log.info("------ 使用RocketMQ,發送可靠非同步消息:{} -------", asyncMsg);

        //使用RocketMQ發送消息
        rocketMQTemplate.asyncSend("rocketmq-sync-msg-kh96",
                asyncMsg,
                new SendCallback() {
                    @Override
                    public void onSuccess(SendResult sendResult) {
                        log.info("------  可靠非同步發送成功回調  ------");
                    }

                    @Override
                    public void onException(Throwable throwable) {
                        log.info("------  可靠非同步發送失敗回調  ------");
                    }
                });

        return "send async msg success";

    }


    /**
     * @param : [phoneNo]
     * @return : java.lang.String
     * @author : huayu
     * @date : 30/11/2022
     * @description : 測試roketmq-發送單向消息，只發不收結果
     */
    @RequestMapping("/testRocketMQSendMsgOneWay")
    public String testRocketMQSendMsgOneWay(@RequestParam String oneWayMsg) {
        log.info("------ 使用RocketMQ,發送單向消息:{} -------", oneWayMsg);

        //使用RocketMQ發送消息
        rocketMQTemplate.sendOneWay("rocketmq-oneWay-msg-kh96", oneWayMsg);

        return "send oneWay msg success";

    }

    /**
     * @param : [phoneNo]
     * @return : java.lang.String
     * @author : huayu
     * @date : 30/11/2022
     * @description : 測試roketmq-發送順序消息
     */
    @RequestMapping("/testRocketMQSendMsgOrderly")
    public String testRocketMQSendMsgOrderly(@RequestParam String orderlyMsgs) {
        log.info("------ 使用RocketMQ,發送順序消息:{} -------", orderlyMsgs);

        //使用RocketMQ發送順序消息,必須要提供一個唯一的標識di,比如用戶編號等
        String userId = UUID.randomUUID().toString().replace("-", "");

        //發送多條順序消息,模擬iang消息分割成多個符號發送
        Arrays.asList(orderlyMsgs.split("")).
                forEach(orderlyMsg -> rocketMQTemplate.syncSendOrderly("rocketmq-orderly-msg-kh96", orderlyMsg, userId));

        return "send orderly msg success";

    }


    /**
     * @param : [phoneNo]
     * @return : java.lang.String
     * @author : huayu
     * @date : 30/11/2022
     * @description : 測試roketmq-發送事務消息
     */
    @RequestMapping("/testRocketMQSendMsgTx")
    public String testRocketMQSendMsgTx(@RequestParam String txmsg) {
        log.info("------ 使用RocketMQ,發送事務消息:{} -------", txmsg);

        //使用RocketMQ發送事務消息,模擬生成一筆訂單
        KgcMallOrder kgcMallOrder = KgcMallOrder.builder()
                .userId(2)
                .userName("RocketMQ_tx")
                .prodId(2)
                .prodName(txmsg)
                .totalPrice(96.0)
                .build();

        //發送事務消息
        rocketMQTxService.sendCreateOrderHalfTx(kgcMallOrder);

        return "send tx msg success";

    }

}

4.5.5 測試

4.5.5.1 發送事務消息成功
4.5.5.1.1 發送請求

4.5.5.1.2 日誌查看

4.5.5.2 發送事務消息失敗(模擬異常)
4.5.5.2.1 發送請求

4.5.5.2.2 日誌查看





您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 除了 filter 還有什麼置灰網站的方式？
    大家都知道，當一些重大事件發生的時候，我們的網站，可能需要置灰，像是這樣： 當然，通常而言，全站置灰是非常簡單的事情，大部分前端同學都知道，僅僅需要使用一行 CSS，就能實現全站置灰的方式。 像是這樣，我們僅僅需要給 HTML 添加一個統一的濾鏡即可： html { filter: grayscal ...
  • 談談過度設計：因噎廢食的陷阱
    寫軟體和造樓房一樣需要設計，但是和建築行業嚴謹客觀的設計規範不同，軟體設計常常很主觀，且容易引發爭論。 設計模式被認為是軟體設計的“規範”，但是在互聯網快速發展的過程中，也暴露了一些問題。相比過程式代碼的簡單與易於修改，設計模式常常導致代碼複雜，增加理解與修改的成本，我們稱之為 “過度設計”。... ...
  • 我的第一個項目(五)：(前後端)註冊用戶名查重
    好家伙, bug終究還是來了,而且是很離譜的bug 來吧,發現問題,再解決問題 1.註冊無法檢測到用戶名重覆 也就是說一個用戶名可無限註冊, 來看bug（。。。） (看來是後端驗證邏輯出了問題) 要是這麼上線估計直接寄了 2.完成註冊用戶名查重 大概率是後端出了問題 這裡我們先去看看後端,從後端去改 ...
  • 【Java併發入門】03 互斥鎖（上）：解決原子性問題
    原子性問題的源頭是線程切換 Q：如果禁用 CPU 線程切換是不是就解決這個問題了？ A：單核 CPU 可行，但到了多核 CPU 的時候，有可能是不同的核在處理同一個變數，即便不切換線程，也有問題。 所以，解決原子性的關鍵是「同一時刻只有一個線程處理該變數，也被稱為互斥」。 如何做到呢？用「鎖」... ...
  • python中的公共操作與列表推導式
    1.公共操作 # + 合併 將兩個相同類型序列進行連接 字元串、 列表、元組 l1 = [1, 2, 3] l2 = [4, 5, 6] print(l1+l2) # [1, 2, 3, 4, 5, 6] # * 複製 將裡面的數據進行複製 字元串、列表、元組 l1 = [1, 2, 3] prin ...
  • 記錄--從AI到美顏全流程講解
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 美顏和短視頻 美顏相關APP可以說是現在手機上的必備的軟體，例如抖音，快手，拍出的“照騙”和視頻不加美顏效果，估計沒有人敢傳到網上。很多人一直好奇美顏類APP是如何開發出來的。本文就大致講一下在Android上如何實現實時修改唇色效果。其 ...
  • Python中內置資料庫！SQLite使用指南！ ⛵
    使用Python內置庫SQLite，可以方便地完成建表、插入數據、查詢數據等資料庫操作，也可以配合pandas進行靈活使用！高效工具庫get！ ...
  • day12_內部類&API
    1、參數傳遞 1.1 類名作為形參和返回值 類名——方法形參 方法的形參是類名，需要的是該類的對象；實際傳遞的是該對象的地址值 類名——返回值 方法的返回值是類名，返回的是該類的對象；實際傳遞的是該對象的地址值 示例代碼 public class Cat { public void eat(){ S ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類