• RocketMQ消费消息

    一、测试用例 package com.mq.rocket.consumer;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;import org.apache

    2022-4-27
    85 0 0
  • RocketMQ环境搭建、环境测试、以及和SpringBoot整合代码演示

    一、RocketMQ环境搭建 1、软件准备 RocketMQ最新版本:4.5.1 下载地址 2、环境要求 JDK1.8以上 Linux64位系统(CentOS Linux release 7.7.1908) 源码安装需

    2022-4-27
    72 0 0
  • rocketmq源码分析

    文章目录 前言一、NameServer路由中心二、消息存储1.消息发送存储流程2.存储文件三、消息消费1、消息者启动流程2、消息拉取1、PullMessageService实现机制2、ProcessQueue实现机制3、消息拉取基本流程

    2022-4-27
    64 0 0
  • rocketmq源码分析

    文章目录 前言一、NameServer路由中心二、消息存储1.消息发送存储流程2.存储文件三、消息消费1、消息者启动流程2、消息拉取1、PullMessageService实现机制2、ProcessQueue实现机制3、消息拉取基本流程

    2022-4-27
    65 0 0
  • RocketMQ(一)MQ介绍

    1 什么是MQ 消息队列(Message Queue,简称MQ),指保存消息的一个容器,本质是个队列。 消息队列中间件是分布式系统

    2022-4-25
    78 0 0
  • 终于来了...RocketMQ扫盲篇

    java基础教程栏目今天详细介绍有关RocketMQ知识。又是好久没有写博客了,虽然可以找出无数个没有写的博客的理由,但是说到底,还是一个字“懒”。今天我终于吃了一颗治疗懒癌的药丸,决定写一篇博客。介绍什么好呢,思来想去,还是介绍下Rock

    2022-4-21
    58 0 0