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("------发送失败");
    }
    });
    }



    }
    }

  • 相关阅读:
    白话数字签名(番外篇)签名EXE文件(下)
    浅谈javascript函数劫持(一)
    CentOS实验五:设置主机名称
    CentOS实验四:为虚拟机配置双网卡
    CentOS实验二:添加操作员帐号
    Linux命令提示符设置
    CentOS实验三:使用安装光盘建立本地软件源
    CentOS实验一:安装CentOS Server
    mount命令
    CentOS实验六:设置命令提示符
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10993321.html
Copyright © 2011-2022 走看看