RocketMQ入门级使用演示-5

简介: RocketMQ入门级使用演示-5

4. 第3节 如何使用Java发送和消费消息

本教程将简单演示如何使用纯java client发送和消费消息。当前环境已经安装了一个1Namesrv + 1Broker的集群, 演示代码路径:

cd /data/demos

1. 下载java代码demo

git clone https://github.com/ApacheRocketMQ/01-java-demos.git
cd 01-java-demos/

2. 打包,执行代码demo

如下图,找到当前实验环境的公网ip

替换mvn exec:java命令中的namesrv ip地址后,再执行命令, 可以看到正常生产和消费输出

mvn clean package
mvn exec:java -Dexec.args="xxx.xxx.xxx.xxx:9876" -Dexec.mainClass="org.apache.rocketmqdemos.Startup" -Dexec.classpathScope=runtime

3. Demo代码说明

RocketMQ Java Client使用的套路分为三个步骤

步骤1: 创建生产者、消费者实例

步骤2: 设置实例属性或者参数

步骤3: 启动

比如消费代码如下

全部代码可以查看实验本地或者github

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
消息中间件 Go C语言
RocketMQ入门级使用演示-10
RocketMQ入门级使用演示-10
163 0
RocketMQ入门级使用演示-10
|
消息中间件 Java Go
RocketMQ入门级使用演示-9
RocketMQ入门级使用演示-9
213 0
RocketMQ入门级使用演示-9
|
消息中间件 Java Go
RocketMQ入门级使用演示-8
RocketMQ入门级使用演示-8
169 0
RocketMQ入门级使用演示-8
|
消息中间件 Java Go
RocketMQ入门级使用演示-7
RocketMQ入门级使用演示-7
216 0
RocketMQ入门级使用演示-7
|
消息中间件 Java RocketMQ
RocketMQ入门级使用演示-6
RocketMQ入门级使用演示-6
131 0
RocketMQ入门级使用演示-6
|
消息中间件 RocketMQ
RocketMQ入门级使用演示-4
RocketMQ入门级使用演示-4
94 0
RocketMQ入门级使用演示-4
|
消息中间件 存储 Java
RocketMQ入门级使用演示-3
RocketMQ入门级使用演示-3
202 0
RocketMQ入门级使用演示-3
|
消息中间件 Java Apache
RocketMQ入门级使用演示-2
RocketMQ入门级使用演示-2
111 0
RocketMQ入门级使用演示-2
|
消息中间件 监控 网络协议
RocketMQ入门级使用演示-1
RocketMQ入门级使用演示-1
122 0
|
消息中间件 算法 Java
弥补延时消息的不足,RocketMQ 基于时间轮算法实现了定时消息!
弥补延时消息的不足,RocketMQ 基于时间轮算法实现了定时消息!
767 1
弥补延时消息的不足,RocketMQ 基于时间轮算法实现了定时消息!