轻量消息

final String topic = "{Topic_Name}";     // 您在控制台创建的【轻量消息】类型的 Topic 名称
final String accessKey = "{Access_Key}"; // 您在控制台创建的角色的 AccessKey
final String secretKey = "{Secret_Key}"; // 您在控制台创建的角色的 SecretKey
final String endpoints = "{EndPoints}";  // 控制台展示的集群接入点

final SessionCredentialsProvider sessionCredentialsProvider = new StaticSessionCredentialsProvider(accessKey, secretKey);
final ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
    .setEndpoints(endpoints)
    .setCredentialProvider(sessionCredentialsProvider)
    .enableSsl(false)
    .build();

final Producer producer = provider.newProducerBuilder()
    .setClientConfiguration(clientConfiguration)
    .setTopics(topic)
    .setMaxAttempts(3)
    .build();

final byte[] body = "This is a lite message of TDMQ RocketMQ".getBytes(StandardCharsets.UTF_8);
final Message message = provider.newMessageBuilder()
    .setTopic(topic)
    .setLiteTopic("{Lite_Topic_Name}") // 首次发送时会自动创建
    .setBody(body)
    .build();

try {
    final SendReceipt sendReceipt = producer.send(message);
    log.info("Sent lite message successfully, messageId {}", sendReceipt.getMessageId());
} catch (Throwable t) {
    log.error("Failed to send lite message {}, please try again", message, t);
}

// 您需要在业务进程退出前（或者不再发送消息后）关闭 Producer
producer.close();

final String topic = "{Topic_Name}";                  // 您在控制台创建的【轻量消息】类型的主题名称
final String consumerGroup = "{Consumer_Group_Name}"; // 您在控制台创建的消费组名称，注意：需要绑定正确的【轻量消息】类型主题
final String accessKey = "{Access_Key}";              // 您在控制台创建的角色的 AccessKey
final String secretKey = "{Secret_Key}";              // 您在控制台创建的角色的 SecretKey
final String endpoints = "{EndPoints}";               // 控制台展示的集群接入点

final SessionCredentialsProvider sessionCredentialsProvider = new StaticSessionCredentialsProvider(accessKey, secretKey);
final ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
    .setEndpoints(endpoints)
    .setCredentialProvider(sessionCredentialsProvider)
    .enableSsl(false)
    .build();

final LitePushConsumer litePushConsumer = provider.newLitePushConsumerBuilder()
    .setClientConfiguration(clientConfiguration)
    .setConsumerGroup(consumerGroup)
    .bindTopic(topic)
    .setMessageListener(messageView -> {
        // 业务消费代码
        log.info("Consumed messageId {}", messageView.getMessageId());
        return ConsumeResult.SUCCESS;
    })
    .build();

try {
    litePushConsumer.subscribeLite("{Lite_Topic_Name}");
    // 您可以继续订阅更多的 Lite Topic
} catch (Throwable t) {
    log.error("Failed to subscribe lite topics, please try again", t);
}

// 您需要在业务进程退出前关闭 Consumer
litePushConsumer.close();