rocketmq发送第一条消息(三)
直接上代码
导包,pom.xml
<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.6.1</version></dependency>
生产者
public static void main(String[] args) throws Exception{DefaultMQProducer producer = new DefaultMQProducer("testGrp");// 设置nameserver地址 nameserver具备路由功能(发现服务,有点注册中心的意思),让其分配合理的broker来进行消息发送producer.setNamesrvAddr("192.168.52.11:9876");try {producer.start();} catch (MQClientException e) {e.printStackTrace();}// topic 消息将要发送的地址,消息目的地// body 消息中具体的数据Message message1 = new Message("monkeyTopic", "第1条消息".getBytes());Message message2 = new Message("monkeyTopic", "第2条消息".getBytes());Message message3 = new Message("monkeyTopic", "第3条消息".getBytes());List<Message> messageList = new ArrayList<>();messageList.add(message1);messageList.add(message2);messageList.add(message3);// 同步消息发送,等待broker返回值 sendResult是返回回来的
// SendResult sendResult = producer.send(message); // 单条消息发送SendResult sendResult = producer.send(messageList); // 多条消息同时发送,总大小官方建议小于1MSystem.out.println("sendResult: " + sendResult);producer.shutdown();}
生产者启动效果图:
消费者
public static void main(String[] args) throws Exception{DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("testConsumer");consumer.setNamesrvAddr("192.168.52.11:9876");// 每个消费者需要关注一个topic,也就说消费消息只能消息固定topic的消息,不能随便消费// topic 表示消息地址// 过滤器 * 表示不过滤consumer.subscribe("monkeyTopic","*");consumer.registerMessageListener(new MessageListenerConcurrently() {@Overridepublic ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {for (MessageExt messageExt : list){System.out.println(new String(messageExt.getBody()));}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});// 广播消息,所有的监听同一个topic的都能收到consumer.setMessageModel(MessageModel.BROADCASTING);// 集群消息,消息只能消费一次
// consumer.setMessageModel(MessageModel.CLUSTERING);consumer.start();System.out.println("consumer start .....");}
消费者消费启动效果图:
rocketmq发送第一条消息(三)相关推荐
- java tcp发消息给硬件_java – TCP客户端/服务器通信只发送第一条消息?
我在java中设置一个简单的TCP客户端服务器交互. 服务器: 服务器是用Java编写的桌面客户端: import java.io.BufferedReader; import java.io.Dat ...
- nodejs实现公众号服务URL绑定验证,nodejs实现公众号关注并回发送一条消息,以及关注之后的聊天自动回复消息
首先关注公众号的时候,公众号会发送一条 post 请求到 nodejs 服务器,这条消息是 xml 数据类型,这里就用到 xml 解析,demo 里用的是 fast-xml-parser@3.12.1 ...
- php微信公众号向指定客服发信息,微信公众号给用户发送一条消息 客服消息
可以用客服消息接口或模板消息接口实现.但是需要认证公众号才能有权限. 认证服务号可以发送客服接口消息[需要对应openid24小时内有互动]和模板消息,订阅号则没有模板消息权限. 下面是发送客服消息的 ...
- 领英如何高效加好友,领英一天最多可以发送多少条消息?
一个领英账号可以加3万好友,加为好友后彼此可相互关注,也可以直接在领英上面发站内消息,还可以直接查看到对方的电话.邮箱.社交账号等重要的联系方式.但领英对加好友是有限制的,每周都有邀请名额的限制,这就 ...
- oracle dbms_aq,oracle – dbms_aq.dequeue_array,第一条消息返回两次
介绍 使用Oracle Advanced Queuing方法时,我在Oracle SQL Server上遇到了一个非常奇怪的行为(确切地说:Oracle Database 11g企业版11.2.0.4 ...
- vs如何实现tcp连续发送多条消息_消息队列之 RabbitMQ
为什么要使用MQ消息中间件?它解决了什么问题?关于为什么要使用消息中间件?消息中间件是如何做到同步变异步.流量削锋.应用解耦的?网上已经有很多说明,我这里就不再说明.我在接下来的RabbitMq系列博 ...
- python: pc端QQ窗口发送多条消息
# coding=gb2312 ''' TTS文本.txt---为需要发送的内容,自己创建 1.打开需要发送消息的窗口 2. 3.将需要发送的内容放到QQ窗口 4.模拟按键发送enter键发送消息(Q ...
- 网包是如何到达另外一台电脑上的?当你在微信上发送一条消息时互联网发生了什么?
目录 一.前言 二.互联网.物联网.万维网.互联网+是什么? 互联网: 万维网: 物联网: 互联网+: 一.前言 互联网其实就是数以计万的服务器组成的,这些服务器通过光缆.电缆相互连接交互,甚至在距离 ...
- WinAPI: waveOutMessage - 向波形输出设备发送一条消息
//声明: waveOutMessage(hWaveOut: HWAVEOUT; {设备句柄}uMessage: UINT; {消息}dw1: DWORD {消息参数}dw2: DWORD {消息参数 ...
最新文章
- 从苦逼撸代码到年入上百亿,成为商界领袖,IT从业者想要通过自己的努力改变现状,只靠单纯写代码远远不够...
- 神经网络无法区分异同,而且这个缺陷是本质性的
- 【Curl (libcurl) 开发 之一】Cocos2dx之libcurl(curl_easy)的编程教程(帮助手册)!...
- 一份厘清「数据指标」问题的清单
- Windows7与Window2008 64位IIS7上面配置操作Excel
- [Linux]在本地修改Kali Linux系统的root密码
- stm32学习------stm32控制L298N电动机
- 无需root计算机隐藏应用,应用隐藏大师APP一款极为隐秘的黑科技软件,无需Root 支持双开...
- CVPR2004/风格分解:Separating Style and Content on a Nonlinear Manifold在非线性流形上分离样式和内容
- eechart echarts-wordcloud 生成人物词云图 词云 词少、形状问题、 解决办法
- 50个查询系列-第五个查询:查询没学过“叶平”老师课的同学的学号、姓名;...
- GRE所有填空真题 TC300RC240 高频词分享
- HttpWatch软件介绍与基本使用
- 〖2011.08.19〗秋无痕常用软件全功能装机光盘2011年八月版(支持64位WIN7)
- 富途牛牛api_k牛刮毛是改善API的好方法
- 为什么说继承是把双刃剑
- 2010年度总结-在淘宝的半年日子
- 快应用是什么软件?快应用有什么用?
- CppPrimer 学习笔记(1)
- 使用数据库进行用户身份认证
热门文章
- 冬季会增加某些疾病的发病风险吗?
- 外币评估时,错误勾选”资产负债表准备评估”的处理
- ABAP:利用SAP定时器自动刷新LIST
- 2021热度不减的在线教育,正在努力成为线下教育的有益补充
- app中传递java数据_Java实现app接口和Socket消息传递(6)servlet映射并返回Json数据
- python非阻塞输入_python_非阻塞套接字及I/O流
- c语言switch自动贩卖机,JAVA程式-自动贩卖机SWITCHCASE.doc
- 青海大学计算机专业在全国排名,青海大学专业排名
- linux 杂项设备,Linux下自动创建节点的字符杂项设备 misc_register
- 在安装one_gadget遇到 one_gadget requires Ruby version >= 2.4. 的问题解决