读完 RocketMQ 源码,我学会了如何优雅的创建线程

图中,MyRunnable 类实现了 Runnable 接口的 run 方法,run 方法中定义具体的任务代码或处理逻辑,而Runnable 对象是作为线程构造函数的参数。

10 张图 | 一文带你用 Mac M1 跑 RocketMQ

最近在倒腾 RocketMQ 消息队列,首先就得把 RocketMQ 跑起来对吧,我们一般都是 Windows 或者 Linux 机器上,按照官方教程一下子就跑起来了,另外用 Intel 芯片的 Mac 也能轻松跑起来。

RocketMQ事务消费和顺序消费详解

在网购的时候,我们需要下单,那么下单需要假如有三个顺序,第一、创建订单 ,第二:订单付款,第三:订单完成。

消息中间件—RocketMQ的RPC通信(二

队列RPC通信部分的Netty多线程模型进行重点介绍。在看RocketMQ的RPC通信部分时候,可能有不少同学有这样子的疑问。

RocketMQ架构原理解析:消息存储

既然是消息队列,那消息的存储的重要程度不言而喻,本节我们聚焦broker服务端,看下消息在broker端是如何存储的,它的落盘策略是怎样的,又是如何保证高效。

JavaDemo案例演示RocketMQ DLedger宕机故障下的高可用

今天演示RocketMQ 宕机故障下的高可用。使用demo案例之前的文章已经上传至gitee,自己去clone一份。地址:https://gitee.

面试官:你是如何评估一个线程池需要设置多少个线程

Java并发编程是大厂第一轮面试中的高频面试题,而线程池又是其中的典型代表,本文将梳理关于线程池的工作机制,并提出灵魂之问:你对线程池的工作机制这么了解,那你在工作中是如何判断一个线程池需要创建多少个线程的呢?

一个RocketMQ文件存储的简单实现

本文介绍了RocketMQ的文件存储原理,并且用MappedByteBuffer实现了一个简单的RocketMQ文件持久化和读取。本文适合希望进一部了解RocketMQ底层文件存储原理的开发者,学习本文需要对消息队列有一定的使用经验,对Java NIO文件读写有一定的了解。

JAVA-ACE-架构师系列视频课程系列网盘下载

>百度搜索:怪兽IT学院或者直接输入guaishouxuyaun.net。培养高级Java工程师成为

RocketMQ Golang /Node.js Client发布预告

近期RocketMQGolangClient、Node.jsClient2个项目即将release新版本。欢迎有需要的公司或开发者优先使用。

网站地图