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();
    }
    }

  • 相关阅读:
    a 超链接标签
    select(下拉标签和textarea(文本框)
    input标签
    input 标签
    div 标签
    body 标签
    STL__网上资料
    STL_iterator返回值
    STL_算法_中使用的函数对象
    STL_std::iterator
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10351555.html
Copyright © 2011-2022 走看看