rocketmq

Posted 2021-03-18 kaischoolmate

点击查看折叠代码块

/**

• 普通消息生产者
  */
  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();
  }
  }