一文带你搭建rocketmq源码调试环境(代码片段)

另外我们到 logs 目录看下启动的详细日志，打开 broker.log 或者 namesrv.log 文件，如下所示：

我们直接用源码自带的示例代码来做测试。文件目录如下：

打开 Producer.java 文件，修改如下代码中的 IP 地址：

producer.setNamesrvAddr("127.0.0.1:9876");

然后在 IDEA 中启动这个类：

可以看到控制台打印了输出结果，成功发送了一条消息。注意：消费者的示例代码里面，我改成了只发送了一条消息。

接着我们启动消费者代码，看下是否成功消费了。同样需要修改这个配置：

consumer.setNamesrvAddr("127.0.0.1:9876");

然后启动 Consumer，可以看到成功消费了一条消息：

注意：消息的显示是用 ASCII 码来表示的，所以不能直接看出来发送的什么。

好了，本地的源码调试环境配置完成。

RocketMQ 也是有客户端界面来查看 RocketMQ 的运行情况的。如下所示：

- EOF -

看完本文有收获？请转发分享给更多人

关注「ImportNew」，提升Java技能

点赞和在看就是最大的支持❤️

rocketmq那些事儿之本地调试环境搭建(代码片段)

上一篇文章中我们已经介绍过rocketmq的集群环境搭建，然而在源码的学习中我们还需要进行本地的调试和问题的定位查找，毕竟还是在本地方便些，今天就说一说如何进行源码的本地调试下载编译对于rocketmq源码部分的学习，我... 查看详情

rocketmq源码本地搭建调试(代码片段)

1GitHub源码gitclonehttps://github.com/apache/rocketmq.git导入IDEA，可在命令行执行mvncompile一下，保证源码能够正确编译。本次我使用的master分支的版本-4.8.0。下面我们开始准备启动Namesrv。2启动Namesrv到namesrv模块找到NamesrvStartup，... 查看详情

rocketmq源码本地搭建调试(代码片段)

1GitHub源码gitclonehttps://github.com/apache/rocketmq.git导入IDEA，可在命令行执行mvncompile一下，保证源码能够正确编译。本次我使用的master分支的版本-4.8.0。下面我们开始准备启动Namesrv。2启动Namesrv到namesrv模块找到NamesrvStartup，... 查看详情

rocketmq源码环境搭建(代码片段)

哈喽，大家好，我是一条。相信很多小伙伴都有阅读源码的需求，但是很多开源项目的源码环境搭建起来并不是很容易，所以我会陆续讲一些中间件的源码环境搭建，来帮助大家走好源码阅读的第一步。首先... 查看详情

一文带你理解rocketmq广播模式实现机制(代码片段)

RocketMQ有两种消费模式，集群模式和广播模式。集群模式是指RocketMQ中的一条消息只能被同一个消费者组中的一个消费者消费。如下图，Producer向TopicTest这个Topic并发写入3条新消息，分别被分配到了MessageQueue1~MessageQueue3... 查看详情

3rocketmq源码解析之源代码环境搭建(代码片段)

在之前的文章中我们知道了RocketMQ里面的核心功能、架构和概念。并且也介绍了它的简单使用与SpringBoot的集成。下面开始我们对RocketMQ的源码探索，首先我们先在自己本地搭建RocketMQ的源代码环境。1、下载源代码首先我们可... 查看详情

rocketmq源码环境搭建(代码片段)

...们想要把源码在本地跑起来的原因。今天我们就来看一下RocketMQ的源码环境搭建。下载源码我们可以从github拉取代码，也可以去官网下载。导入idea，等待maven构建即可。这个时间可能会比较长，视网速而定。官网github... 查看详情

结合rocketmq源码，带你了解并发编程的三大神器(代码片段)

摘要：本文结合RocketMQ源码，分享并发编程三大神器的相关知识点。本文分享自华为云社区《读RocketMQ源码，学习并发编程三大神器》，作者：勇哥java实战分享。这篇文章，笔者结合RocketMQ源码，分享并... 查看详情

一文带你入门flinksql(代码片段)

文章目录一文带你入门flinksql写在前面环境准备正文遇到的一些问题错误一错误二错误三一文带你入门flinksql写在前面本次实战主要是通过FlinkSQLClient消费kafka的实时消息，再用各种SQL操作对数据进行查询统计。环境准备具体... 查看详情

resilience4j源码解析：简介及调试环境搭建(代码片段)

简介调试环境搭建2.1安装设置Gradle2.2安装Resilience4j2.3运行入手点3.1代码结构3.2代码量3.3源码分析方法小结参考文档相关文章：Resilience4j源码解析（1）：简介及调试环境搭建Resilience4j源码解析（2）：浅... 查看详情

vscode搭建x264源码调试环境(代码片段)

本节用到了上节Win10环境下编译和运行x264搭建的msys和mingw的环境使用的MSYS2MINGW64、gcc.exe、gdb.exe都是上一节搭建好的环境文章目录1.下载x2642.使用上一节介绍的方法为x264生成支持debug的x264.exe3.在VSCode中打开x264源码文件夹4.创建并... 查看详情

vscode搭建x264源码调试环境(代码片段)

本节用到了上节Win10环境下编译和运行x264搭建的msys和mingw的环境使用的MSYS2MINGW64、gcc.exe、gdb.exe都是上一节搭建好的环境文章目录1.下载x2642.使用上一节介绍的方法为x264生成支持debug的x264.exe3.在VSCode中打开x264源码文件夹4.创建并... 查看详情

基于源码搭建运行rocketmq主从架构(代码片段)

前言上一篇基于IDEA搭建RocketMQ-4.6源码环境我们搭建并跑通了rocketmq的源码环境.本文我们紧接上文,继续基于源码搭建并运行broker主从架构.1个NameServer节点(与前文一样)2个Broker节点,一个作为Master,一个作为Slave1个Producer生产者(与前... 查看详情

rocketmq单机环境搭建(代码片段)

大家好，我是冰河~~今天，带来一篇搭建RocketMQ单机环境的文章，为后面的分布式事务专栏做准备。RocketMQ是阿里巴巴开源的一款高性能分布式消息中间件，有关RocketMQ的详细讲解，后面会单独开设一个RocketMQ专... 查看详情

如何开始调试kafka源码(代码片段)

...a事务消息ControllerServiceKafkaListener参考链接源码系列第1弹|带你快速攻略Kafka源码之旅入门篇win10快速搭建scala环境zookeeper源码运行环境搭建Zookeeper源码启动下载地址ZookeeperGitHub仓库KafkaGitHub仓库scalaGitHub版本包下载scala官方安装包下... 查看详情

rocketmq环境搭建(代码片段)

下载RocketMQ版本：4.5.1下载地址环境Linux64位系统JDK1.8(64位)安装上传二进制包到/usr/local/rocketmq目录解压unziprocketmq-all-4.5.1-bin-release.zip-bash:unzip:未找到命令yuminstall-yunzipzip解压目录bin：启动脚本，包括shell脚本和CMD 查看详情

mac系统搭建hive源码远程调试环境(代码片段)

环境准备JDK这个一定需要，不管是Hadoop，还是Hive的运行，都依赖这个。HadoopHadoop的安装比较简单，从官网下载一个包，解压，然后配置几个核心的xml就可以了。Hive源码从官网下载一个Hive的源码包，我... 查看详情

一文带你彻底搞懂springboot-rabbitmq(代码片段)

一、环境搭建采用maven多module模式，共计创建三个子modulecommon：通用实体信息rabbitmq-publisher：消息发布者，基于SpringBootrabbitmq-subscriber：消息订阅者，基于SpringBoot在消息发布者和订阅者两个项目中加入rabbitm... 查看详情