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



    }
    }

  • 相关阅读:
    测试学习使用
    Tomcat version 6.0 only supports J2EE 1.2, 1.3, 1.4, and Java EE 5 Web modules
    web框架之Spring-MVC环境搭建
    serialVersionUID
    在eclipse中部署发布web项目 和 更改eclipseweb项目发布的路径
    servlet HttpSession 监听器
    java web 中的转发和重定向
    Spring MVC 中的 forward 和 redirect
    各个部门英语标识
    添加滚动条,内容多时显示,内容少时隐藏
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10993321.html
Copyright © 2011-2022 走看看