草庐IT

rocketMq

全部标签

小心,丢失的消息!RocketMQ投递策略帮你解决问题!博学谷狂野架构师

RocketMQ消息投递策略作者:博学谷狂野架构师GitHub:GitHub地址(有我精心准备的130本电子书PDF)只分享干货、不吹水,让我们一起加油!?前言RocketMQ的消息投递分分为两种:一种是生产者往MQBroker中投递;另外一种则是MQbroker往消费者投递(这种投递的说法是从消息传递的角度阐述的,实际上底层是消费者从MQbroker中Pull拉取的)。本文将从模型的角度来阐述这两种机制。RocketMQ的消息模型RocketMQ的消息模型整体并不复杂,如下图所示:一个Topic(消息主题)可能对应多个实际的消息队列(MessgeQueue)在底层实现上,为了提高MQ的可用性

小心,丢失的消息!RocketMQ投递策略帮你解决问题!博学谷狂野架构师

RocketMQ消息投递策略作者:博学谷狂野架构师GitHub:GitHub地址(有我精心准备的130本电子书PDF)只分享干货、不吹水,让我们一起加油!?前言RocketMQ的消息投递分分为两种:一种是生产者往MQBroker中投递;另外一种则是MQbroker往消费者投递(这种投递的说法是从消息传递的角度阐述的,实际上底层是消费者从MQbroker中Pull拉取的)。本文将从模型的角度来阐述这两种机制。RocketMQ的消息模型RocketMQ的消息模型整体并不复杂,如下图所示:一个Topic(消息主题)可能对应多个实际的消息队列(MessgeQueue)在底层实现上,为了提高MQ的可用性

SpringBoot整合RocketMQ,老鸟们都是这么玩的!

今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分,第一部分实现SpringBoot与RocketMQ的整合,第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们,第三部分介绍如何封装RocketMQ以便更好地使用。1.SpringBoot整合RocketMQ在SpringBoot中集成RocketMQ,只需要简单四步:引入相关依赖dependency>groupId>org.apache.rocketmqgroupId>artifactId>rocketmq-spring-boot-starterartifactId>dependency>添加Rocke

SpringBoot整合RocketMQ,老鸟们都是这么玩的!

今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分,第一部分实现SpringBoot与RocketMQ的整合,第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们,第三部分介绍如何封装RocketMQ以便更好地使用。1.SpringBoot整合RocketMQ在SpringBoot中集成RocketMQ,只需要简单四步:引入相关依赖dependency>groupId>org.apache.rocketmqgroupId>artifactId>rocketmq-spring-boot-starterartifactId>dependency>添加Rocke

17 个方面,综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列

​大家好,我是不才陈某~本文将从,Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ17个方面综合对比作为消息队列使用时的差异。1. 资料文档Kafka:中,有kafka作者自己写的书,网上资料也有一些。rabbitmq:多,有一些不错的书,网上资料多。zeromq:少,没有专门写zeromq的书,网上的资料多是一些代码的实现和简单介绍。rocketmq:少,没有专门写rocketmq的书,网上的资料良莠不齐,官方文档很简洁,但是对技术细节没有过多的描述。activemq:多,没有专门写activemq的书,网上资料多。2. 开发语言Kafka:Scalarabbi

17 个方面,综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列

​大家好,我是不才陈某~本文将从,Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ17个方面综合对比作为消息队列使用时的差异。1. 资料文档Kafka:中,有kafka作者自己写的书,网上资料也有一些。rabbitmq:多,有一些不错的书,网上资料多。zeromq:少,没有专门写zeromq的书,网上的资料多是一些代码的实现和简单介绍。rocketmq:少,没有专门写rocketmq的书,网上的资料良莠不齐,官方文档很简洁,但是对技术细节没有过多的描述。activemq:多,没有专门写activemq的书,网上资料多。2. 开发语言Kafka:Scalarabbi

RocketMQ 存储优化技术 解析——图解、源码级解析

?Java学习:Java从入门到精通总结?深入浅出RocketMQ设计思想:深入浅出RocketMQ设计思想?绝对不一样的职场干货:大厂最佳实践经验指南?最近更新:2023年1月13日?个人简介:通信工程本硕forNJU?、Java程序员?。做过科研paper,发过专利,优秀的程序员不应该只是CRUD?点赞?收藏⭐留言?都是我最大的动力!文章目录RocketMQ里的存储优化内存预分配`mlock`系统调用文件预热存储模型刷盘流程

RocketMQ 存储优化技术 解析——图解、源码级解析

?Java学习:Java从入门到精通总结?深入浅出RocketMQ设计思想:深入浅出RocketMQ设计思想?绝对不一样的职场干货:大厂最佳实践经验指南?最近更新:2023年1月13日?个人简介:通信工程本硕forNJU?、Java程序员?。做过科研paper,发过专利,优秀的程序员不应该只是CRUD?点赞?收藏⭐留言?都是我最大的动力!文章目录RocketMQ里的存储优化内存预分配`mlock`系统调用文件预热存储模型刷盘流程

RocketMQ详细安装教程(RocketMQ安装、RocketMQ修改默认端口、console管理后台安装)

文章目录一、RocketMQ安装1.下载2.修改启动配置3.启动二、RocketMQ修改默认端口三、Console管理后台安装1.下载2.修改配置3.修改pom4.打包5.启动结尾一、RocketMQ安装1.下载从apache的文件库下载https://archive.apache.org/dist/rocketmq/这里我们选择最新版项目解压unziprocketmq-all-4.9.3-bin-release.zip2.修改启动配置修改目录/home/rocketmq-4.9.3/bin下的配置文件:runserver.sh、runbroker.sh不然会报insufficientmemo

RocketMQ详细安装教程(RocketMQ安装、RocketMQ修改默认端口、console管理后台安装)

文章目录一、RocketMQ安装1.下载2.修改启动配置3.启动二、RocketMQ修改默认端口三、Console管理后台安装1.下载2.修改配置3.修改pom4.打包5.启动结尾一、RocketMQ安装1.下载从apache的文件库下载https://archive.apache.org/dist/rocketmq/这里我们选择最新版项目解压unziprocketmq-all-4.9.3-bin-release.zip2.修改启动配置修改目录/home/rocketmq-4.9.3/bin下的配置文件:runserver.sh、runbroker.sh不然会报insufficientmemo