【RocketMQ】基于RocketMQ 5.1.0版本的自动故障恢复集群实践（Controller内嵌方式）

import org.apache.rocketmq.common.protocol.heartbeat.SubscriptionData;
import org.apache.rocketmq.remoting.common.RemotingHelper;
 
// 假设以下方法已经定义，用于获取NameServer地址和群组名称
private String getNameServerAddr();
private String getClientGroupName();
 
public class Producer {
    public static void main(String[] args) throws MQClientException {
        // 创建Producer组
        DefaultMQProducer producer = new DefaultMQProducer(getClientGroupName());
        // 设置NameServer地址
        producer.setNamesrvAddr(getNameServerAddr());
        // 启动Producer
        producer.start();
 
        try {
            // 创建消息，并指定Topic、Tag和消息体
            Message msg = new Message("TopicTest", "TagA", "OrderID001", "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));
            // 发送消息
            SendResult sendResult = producer.send(msg);
            // 打印发送结果
            System.out.printf("%s%n", sendResult);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭Producer
            producer.shutdown();
        }
    }
}

这个代码实例展示了如何在Java中使用RocketMQ客户端API创建一个简单的Producer，并发送一条消息到指定的Topic。注意，这里假设了两个辅助方法getNameServerAddr()和getClientGroupName()用于获取NameServer地址和客户端群组名称。在实际应用中，这些信息需要根据实际环境配置。