-
RocketMQ消费消息
一、测试用例 package com.mq.rocket.consumer;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;import org.apache
-
RocketMQ环境搭建、环境测试、以及和SpringBoot整合代码演示
一、RocketMQ环境搭建 1、软件准备 RocketMQ最新版本:4.5.1 下载地址 2、环境要求 JDK1.8以上 Linux64位系统(CentOS Linux release 7.7.1908) 源码安装需
-
rocketmq源码分析
文章目录 前言一、NameServer路由中心二、消息存储1.消息发送存储流程2.存储文件三、消息消费1、消息者启动流程2、消息拉取1、PullMessageService实现机制2、ProcessQueue实现机制3、消息拉取基本流程
-
rocketmq源码分析
文章目录 前言一、NameServer路由中心二、消息存储1.消息发送存储流程2.存储文件三、消息消费1、消息者启动流程2、消息拉取1、PullMessageService实现机制2、ProcessQueue实现机制3、消息拉取基本流程
-
RocketMQ(一)MQ介绍
1 什么是MQ 消息队列(Message Queue,简称MQ),指保存消息的一个容器,本质是个队列。 消息队列中间件是分布式系统
-
终于来了...RocketMQ扫盲篇
java基础教程栏目今天详细介绍有关RocketMQ知识。又是好久没有写博客了,虽然可以找出无数个没有写的博客的理由,但是说到底,还是一个字“懒”。今天我终于吃了一颗治疗懒癌的药丸,决定写一篇博客。介绍什么好呢,思来想去,还是介绍下Rock