RocketMQ--生产者与消费者的简单示例

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>dym-rocketmq-test</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.8.0</version></dependency></dependencies>
</project>

Producer.java

package com.dym.simple;//发送消息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.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;public class Producer {public static void main(String[] args) throws MQClientException, RemotingException, InterruptedException, MQBrokerException {//1. 谁来发？DefaultMQProducer producer = new DefaultMQProducer("group1");//2. 发给谁？producer.setNamesrvAddr("localhost:9876");producer.start();// 3. 怎么发？// 4. 发什么？String msg="hello rocketmq";Message message = new Message("topic1", "tag1", msg.getBytes());SendResult sendResult = producer.send(message);// 5. 发的结果是什么？System.out.println(sendResult);//6. 打扫战场producer.shutdown();}
}

Consumer.java

package com.dym.simple;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.MessageExt;import java.util.List;public class Consumer {public static void main(String[] args) throws MQClientException {//1. 谁来收DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");//2. 从哪里收消息consumer.setNamesrvAddr("localhost:9876");//3. 监听哪个消息队列consumer.subscribe("topic1","*");//4. 处理业务流程  注册监听器consumer.registerMessageListener(new MessageListenerConcurrently() {public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext consumeConcurrentlyContext) {//写我们的业务逻辑for(MessageExt msg:msgs){System.out.println(msg);byte[] body = msg.getBody();System.out.println(new String(body));}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});consumer.start();System.out.println("消费者起起来了");}
}

RocketMQ--生产者与消费者的简单示例相关推荐

简单的RocketMQ生产者和消费者的开发示例demo（二）
上一篇文章介绍了RocketMQ双Master+双Slave集群+可视化控制台环境搭建,这篇主要介绍一下Producer和Consumer的简单开发示例 Producer 创建个SpringBoot项 ...
[Dubbo开发]配置简单的生产者和消费者
配置好jdk1.7.Zookeeper和Maven环境之后,开始尝试第一次搭建简单的dubbo生产者和消费者. dubbo服务的原理,引用经典的官方图(cr.Dubbo官网): 关于Dubbo的原理和 ...
从现在开始学 Kafka：SpringBoot 集成 Kafka，生产者与消费者示例
从现在开始学 Kafka:SpringBoot 集成 Kafka,生产者与消费者示例前言加依赖生产者加配置生产者代码示例消费者加配置消费者监听器示例调用关于 Serializer ...
java最简单的kafka生产者和消费者，未结合spring
目录 1 最简单的生产者和消费者 1.1 引入maven 1.2 基本的生产者和代码注释 1.3 最简单消费者 2 生产者发送消息的三种方式 2.1 直接send之后就不管了,会自动重试,可能丢失消息 ...
kafka查看broker上主副本_Kafka基础（一）：基本概念及生产者、消费者示例
本文章大部分内容均摘自朱忠华老师的<深入理解Kafka:核心设计与实践原理>,也特别推荐广大读者购买阅读. 一.概述 1. 简介 Kafka 起初是由 LinkedIn 公司采用 Sca ...
计算机操作系统生产者和消费者模型的简单介绍
同步互斥小口诀画图理解题目判断题目类型分析进程数目填写进程模板补充基本代码(伪代码) 补充PV代码检查调整代码注意事项代码是一步一步写出来的,代码是反复调整写出来的 60%是生产者和消 ...
kafka的c/c++高性能客户端librdkafka简介/使用librdkafka的C++接口实现简单的生产者和消费者
Librdkafka是c语言实现的apachekafka的高性能客户端,为生产和使用kafka提供高效可靠的客户端,并且提供了c++接口性能: Librdkafka 是一款专为现代硬件使用而设计的高 ...
多线程-线程间通信-多生产者多消费者示例
1.多线程-线程间通信-多生产者多消费者问题多生产者和多消费者.等待唤醒机制. 产生了两个问题: 1.出现了多次连续生产,未消费,或者一个商品被消费多次. 解决:必须要--------每一个被唤醒的 ...
Python中的生产者与消费者模式(转载）
利用多线程和队列可以实现生产者消费者模式.该模式通过平衡生产线程和消费线程的工作能力来提高程序整体处理数据的速度. 1.什么是生产者和消费者? 在线程世界里,生产者就是生产数据(或者说发布任务)的线程 ...

RocketMQ--生产者与消费者的简单示例

pom.xml

Producer.java

Consumer.java

RocketMQ--生产者与消费者的简单示例相关推荐

最新文章

热门文章