tencent cloud

  <dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client-java</artifactId>
    <version>5.0.6</version>
</dependency>

public class ProducerTransactionMessageDemo {

    private static final Logger log = LoggerFactory.getLogger(ProducerTransactionMessageDemo.class);

    private static boolean executeLocalTransaction() {
        // Simulate a local transaction (such as a database insert operation). Assume it succeeds here.
        return true;
    }

    private static boolean checkTransactionStatus(String orderId) {
        // Simulate querying the result of the local transaction, such as querying whether the order ID has been stored in the database. Return true if found.
        return true;
    }


    public static void main(String[] args) throws ClientException {

        final ClientServiceProvider provider = ClientServiceProvider.loadService();
        // Obtain the AccessKey and SecretKey from the Permission Management page in the console.
        String accessKey = "your-ak";
        String secretKey = "your-sk";
        SessionCredentialsProvider sessionCredentialsProvider =
            new StaticSessionCredentialsProvider(accessKey, secretKey);

        // Obtain the access address provided by Tencent Cloud from the console and specify it here.
        String endpoints = "https://your-endpoints";
        ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
            .setEndpoints(endpoints)
            .enableSsl(false)
            .setCredentialProvider(sessionCredentialsProvider)
            .build();

        String topic = "tran_topic";
        TransactionChecker checker = messageView -> {
            log.info("Receive transactional result check request, message={}", messageView);
            // The server proactively checks the local transaction status.
            String orderId = messageView.getProperties().get("orderId");
            boolean isSuccess = checkTransactionStatus(orderId);
            return isSuccess ? TransactionResolution.COMMIT : TransactionResolution.ROLLBACK;
        };

        // Create a producer and set the transaction checker.
        Producer producer = provider.newProducerBuilder()
            .setClientConfiguration(clientConfiguration)
            .setTopics(topic)
            .setTransactionChecker(checker)
            .build();

        // Start a transaction.
        final Transaction transaction = producer.beginTransaction();

        byte[] body = "This is a transaction message for Apache RocketMQ".getBytes(StandardCharsets.UTF_8);
        String tag = "tagA";
        final Message message = provider.newMessageBuilder()
            .setTopic(topic)
            .setTag(tag)
            .setKeys("your-key-565ef26f5727")
            // Typically, a unique ID associated with the local transaction is set for transactional messages to verify the local transaction checkback.
            .addProperty("orderId", "0001")
            .setBody(body)
            .build();

        // Send a half message.
        try {
            final SendReceipt sendReceipt = producer.send(message, transaction);
            log.info("Send transaction message successfully, messageId={}", sendReceipt.getMessageId());
        } catch (Throwable t) {
            log.error("Failed to send message", t);
            return;
        }

        // Execute the local transaction.
        boolean localTxSuccess = executeLocalTransaction();
        if (localTxSuccess) {
            // If the local transaction succeeds, the secondary confirmation status is Commit.
            transaction.commit();
        } else {
            // If the local transaction fails, the secondary confirmation status is Rollback.
            transaction.rollback();
        }
        // producer.close();
    }
}


private static boolean executeLocalTransaction() {
    // The local transaction fails.
    return false;
}

private static boolean checkTransactionStatus(String orderId) {
    // The checkback result is rollback, so return false.
    return false;
}