zoukankan      html  css  js  c++  java
  • rocketmq的生产者生产消息

    package com.bfxy.rocketmq.model;

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

    import com.bfxy.rocketmq.constants.Const;

    public class Producer {

    public static void main(String[] args) throws MQClientException, InterruptedException {
    String group_name = "test_model_producer_name";
    DefaultMQProducer producer = new DefaultMQProducer(group_name);
    producer.setNamesrvAddr(Const.NAMESRV_ADDR_MASTER_SLAVE);
    producer.start();

    for (int i = 0; i < 10; i++) {
    try {
    String tag = (i % 2 ==0) ? "TagA":"TagB";
    Message msg = new Message("test_model_topic2",// topic
    tag,// tag
    ("信息内容" + i).getBytes()// body
    );
    SendResult sendResult = producer.send(msg);
    System.out.println(sendResult);
    }
    catch (Exception e) {
    e.printStackTrace();
    Thread.sleep(1000);
    }
    }

    producer.shutdown();
    }
    }

  • 相关阅读:
    禁止鼠标多次点击选中div中的文字
    深入浅出 Nodejs 学习笔记 1
    svn 树冲突
    nodejs 按行读取 readline
    git版本控制器的基本使用
    规范javascript书写
    media query
    软件工程
    The sixth day
    The fifth day
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10351555.html
Copyright © 2011-2022 走看看