rocketmq java

// RocketMQ Producer 示例代码

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

public class RocketMQProducerExample {
    public static void main(String[] args) throws Exception {
        // 创建一个生产者实例，并指定生产者组名
        DefaultMQProducer producer = new DefaultMQProducer("example_producer_group");

        // 设置NameServer地址，多个地址用分号隔开
        producer.setNamesrvAddr("localhost:9876");

        // 启动生产者
        producer.start();

        for (int i = 0; i < 100; i++) {
            // 创建消息实例，指定主题、标签和消息体
            Message msg = new Message("TopicTest", "TagA", ("Hello RocketMQ " + i).getBytes());

            // 发送消息并获取发送结果
            SendResult sendResult = producer.send(msg);

            // 打印发送结果
            System.out.printf("%s%n", sendResult);
        }

        // 关闭生产者
        producer.shutdown();
    }
}

解释说明：

1. 创建生产者实例：使用 DefaultMQProducer 类创建一个生产者实例，并指定生产者组名。
2. 设置 NameServer 地址：通过 setNamesrvAddr 方法设置 RocketMQ 的 NameServer 地址，多个地址可以用分号隔开。
3. 启动生产者：调用 start() 方法启动生产者。
4. 创建消息实例：使用 Message 类创建消息实例，指定主题（Topic）、标签（Tag）和消息体（Body）。
5. 发送消息：调用 send() 方法发送消息，并获取发送结果。
6. 关闭生产者：在所有消息发送完毕后，调用 shutdown() 方法关闭生产者。

这段代码展示了如何使用 RocketMQ 的 Java 客户端发送消息。