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("------發送失敗");
}
});
}

}
}