zoukankan      html  css  js  c++  java
  • Rocketmq异步发送消息

    package com.bfxy.rocketmq.quickstart;

    import java.util.List;

    import org.apache.rocketmq.client.exception.MQBrokerException;
    import org.apache.rocketmq.client.exception.MQClientException;
    import org.apache.rocketmq.client.producer.DefaultMQProducer;
    import org.apache.rocketmq.client.producer.MessageQueueSelector;
    import org.apache.rocketmq.client.producer.SendCallback;
    import org.apache.rocketmq.client.producer.SendResult;
    import org.apache.rocketmq.client.producer.SendStatus;
    import org.apache.rocketmq.common.message.Message;
    import org.apache.rocketmq.common.message.MessageQueue;
    import org.apache.rocketmq.remoting.exception.RemotingException;

    import com.bfxy.rocketmq.constants.Const;

    public class AsyncProducer {

    public static void main(String[] args) throws MQClientException, RemotingException, MQBrokerException, InterruptedException {

    DefaultMQProducer producer = new DefaultMQProducer("test_quick_producer_name");

    producer.setNamesrvAddr(Const.NAMESRV_ADDR_MASTER_SLAVE);

    producer.start();

    for(int i = 0 ; i <5; i ++) {
    // 1. 创建消息
    Message message = new Message("test_quick_topic", // 主题
    "TagA", // 标签
    "key" + i, // 用户自定义的key ,唯一的标识
    ("Hello RocketMQ" + i).getBytes()); // 消息内容实体(byte[])

    // 2.2 异步发送消息
    producer.send(message, new SendCallback() {
    //rabbitmq急速入门的实战: 可靠性消息投递
    @Override
    public void onSuccess(SendResult sendResult) {
    System.err.println("msgId: " + sendResult.getMsgId() + ", status: " + sendResult.getSendStatus());
    }
    @Override
    public void onException(Throwable e) {
    e.printStackTrace();
    System.err.println("------发送失败");
    }
    });
    }



    }
    }

  • 相关阅读:
    openCV中cvSnakeImage()函数代码分析
    程序所有重构,升级的目标(备注,更新)
    基础总结篇之中的一个:Activity生命周期
    Tomcat全攻略
    VRRP协议具体解释
    二叉树三种遍历(递归以及非递归实现)
    AssertValid函数学习
    java定时器的使用(Timer)
    循环队列
    使用Heartbeat实现双机热备
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10993321.html
Copyright © 2011-2022 走看看