Rocketmq同步发送消息
package com.bfxy.rocketmq.quickstart;
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.SendResult;
import org.apache.rocketmq.client.producer.SendStatus;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;
import com.bfxy.rocketmq.constants.Const;
public class SyncProducer {
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[])
SendResult sr = producer.send(message);
SendStatus status = sr.getSendStatus();
System.err.println(status);
System.err.println("消息发出: " + sr);
}
producer.shutdown();
}
}
最新文章
- [转载]抓包,端口镜像,monitor session命令(转)
- 北大poj-1081
- 收藏网址 ios开源库
- 2015年p2p网络借贷平台的发展现状
- Sublime Text 使用 Emmet 补全错误问题
- java.lang.ClassNotFoundException: org.apache.jsp.WEB_002dINF.classes.views.index_jsp 问题解决方法
- Linux -- Xshell ,Xftp远程连接中文乱码怎么解决?
- angular.equals()
- db.properties是干什么用的
- HDU 1695 GCD (莫比乌斯反演模板)
- Unity发布WebGl注意事项
- JS HTML倒计时 进入页面
- iOS逆向之Reveal
- 使用UWA GOT优化Unity性能和内存
- Exchange 2013与 Office Web Apps 整合
- 第7讲:SQL Server简介
- python---基础知识回顾(八)数据库基础操作(sqlite和mysql)
- 贪心(qwq)习题题解
- Atitit. 解决unterminated string literal 缺失引号
- Python全栈day14(字符串格式化)