rocketmq


点击查看折叠代码块
/**

  • 普通消息生产者
    */
    public class Producer {
    public static void main(String[] args) throws Exception {
    // 创建一个消息发送入口对象,主要用于消息发送,指定生产者组
    DefaultMQProducer producer = new DefaultMQProducer("producerGroup");
    // 设置NameServe地址,如果是集群环境,用分号隔开
    producer.setNamesrvAddr("127.0.0.1:9876");
    // 启动并创建消息发送组件
    producer.start();
    // topic的名字
    String topic = "rocketDemo1";
    // 标签名
    String taget = "tag";
    // 要发送的数据
    String body = "hello,RocketMq";
    Message message = new Message(topic,taget,body.getBytes());
    // 发送消息
    SendResult result = producer.send(message);
    System.out.println(result);
    // 关闭消息发送对象
    producer.shutdown();
    }
    }