//演示demo，模擬訂單表查詢服務(wù)，用來確認訂單事務(wù)是否提交成功。
private static boolean checkOrderById(String orderId) {
    return true;
}

//演示demo，模擬本地事務(wù)的執(zhí)行結(jié)果。
private static boolean doLocalTransaction() {
    return true;
}

public static void main(String[] args) throws ClientException {
    ClientServiceProvider provider = new ClientServiceProvider();
    MessageBuilder messageBuilder = new MessageBuilderImpl();
    //構(gòu)造事務(wù)生產(chǎn)者：事務(wù)消息需要生產(chǎn)者構(gòu)建一個事務(wù)檢查器，用于檢查確認異常半事務(wù)的中間狀態(tài)。
    Producer producer = provider.newProducerBuilder()
            .setTransactionChecker(messageView -> {
                /**
                 * 事務(wù)檢查器一般是根據(jù)業(yè)務(wù)的ID去檢查本地事務(wù)是否正確提交還是回滾，此處以訂單ID屬性為例。
                 * 在訂單表找到了這個訂單，說明本地事務(wù)插入訂單的操作已經(jīng)正確提交；如果訂單表沒有訂單，說明本地事務(wù)已經(jīng)回滾。
                 */
                final String orderId = messageView.getProperties().get("OrderId");
                if (Strings.isNullOrEmpty(orderId)) {
                    // 錯誤的消息，直接返回Rollback。
                    return TransactionResolution.ROLLBACK;
                }
                return checkOrderById(orderId) ? TransactionResolution.COMMIT : TransactionResolution.ROLLBACK;
            })
            .build();
    //開啟事務(wù)
    final Transaction transaction;
    try {
        transaction = producer.beginTransaction();
    } catch (ClientException e) {
        e.printStackTrace();
        //事務(wù)開啟失敗，直接退出。
        return;
    }
    Message message = messageBuilder.setTopic("topic")
            //設(shè)置消息索引鍵，可根據(jù)關(guān)鍵字精確查找某條消息。
            .setKeys("messageKey")
            //設(shè)置消息Tag，用于消費端根據(jù)指定Tag過濾消息。
            .setTag("messageTag")
            //一般事務(wù)消息都會設(shè)置一個本地事務(wù)關(guān)聯(lián)的唯一ID，用來做本地事務(wù)回查的校驗。
            .addProperty("OrderId", "xxx")
            //消息體。
            .setBody("messageBody".getBytes())
            .build();
    //發(fā)送半事務(wù)消息
    final SendReceipt sendReceipt;
    try {
        sendReceipt = producer.send(message, transaction);
    } catch (ClientException e) {
        //半事務(wù)消息發(fā)送失敗，事務(wù)可以直接退出并回滾。
        return;
    }
    /**
     * 執(zhí)行本地事務(wù)，并確定本地事務(wù)結(jié)果。
     * 1. 如果本地事務(wù)提交成功，則提交消息事務(wù)。
     * 2. 如果本地事務(wù)提交失敗，則回滾消息事務(wù)。
     * 3. 如果本地事務(wù)未知異常，則不處理，等待事務(wù)消息回查。
     *
     */
    boolean localTransactionOk = doLocalTransaction();
    if (localTransactionOk) {
        try {
            transaction.commit();
        } catch (ClientException e) {
            // 業(yè)務(wù)可以自身對實時性的要求選擇是否重試，如果放棄重試，可以依賴事務(wù)消息回查機制進行事務(wù)狀態(tài)的提交。
            e.printStackTrace();
        }
    } else {
        try {
            transaction.rollback();
        } catch (ClientException e) {
            // 建議記錄異常信息，回滾異常時可以無需重試，依賴事務(wù)消息回查機制進行事務(wù)狀態(tài)的提交。
            e.printStackTrace();
        }
    }
}