首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
rocketmq
相关资讯
热门
最新
代码人生
01-01 08:00
代码人生
RocketMQ 全链路灰度探索与实践
RocketMQ 全链路灰度探索与实践,本文作者:肖京,SpringCloudAlibabaPMC,阿里云智能技术专家。01全链路灰度背景介绍发布新版本时,为了有效、谨慎地验证新版本代码逻辑的正确性,通常会采用灰度发布,从而达到减小第一次变更影响面的目的。举个例子,应用的集合中可能会包含交易中心、商品中心、库存中心等多个模块。在一次新版本发布的过程中,可能有feature既修改了交易中心,又修改了
59
代码人生
01-01 08:00
代码人生
RocketMQ消息生产者是如何选择Broker的
RocketMQ消息生产者是如何选择Broker的,前言在RocketMQ中为,我们创建消息生产者时,只需要设置NameServer地址,消息就能正确地发送到对应的Broker中,那么RocketMQ消息生产者是如何找到Broker的呢?如果有多个Broker实例,那么消息发送是如何选择发送到哪个Broker的呢?从NameServer查询Topic信息通过Debug消息发送send()方法,我们
59
代码人生
01-01 08:00
代码人生
RocketMQ实战-优雅的并发编程技巧
RocketMQ实战-优雅的并发编程技巧,上一篇文章着重分析了RocketMQ限流机制的实现原理,分别从客户端或者服务端各自不同的侧重点分开来讲述了一下。本篇文章,我们着重来分析梳理一下在并发编程上面,RocketMQ给我们带来了哪些优雅的实现方式,这其中蕴含着怎样的并发编程思想,我们能够从中学习借鉴到什么,这些疑问,在接下来的文章中将会重点描述。本期重点内容RocketMQ作为一款非常优秀的消息
91
代码人生
01-01 08:00
代码人生
RocketMQ中生产者发消息前为啥一定要调用start()方法?
RocketMQ中生产者发消息前为啥一定要调用start()方法?,前言我们在使用RocketMQ发送消息时,一般都会使用DefaultMQProducer,类型的代码如下:DefaultMQProducerproducer=newDefaultMQProducer("producer_group");producer.setNamesrvAddr("42.192.50.8:9876");try{
58
代码人生
01-01 08:00
代码人生
RocketMQ安装-单机版-windows+centos
RocketMQ安装-单机版-windows+centos windows版本 解压压缩包rocketmq-all-4.7.1-bin-release.zip并复制到本地软件安装目录 环境变量添加 NAMESRV_ADDR=localhost:9876 ROCKETMQ_HOME=D:\soft\rocketmq 修改bin目录下的runbroker.cmd和runserver.cmd中的虚拟机内存
117
百科问答
01-01 08:00
百科问答
rocketmq源码解析(rocketmq源码部署)
rocketmq源码解析(rocketmq源码部署)本文主要分析RocketMQ中如何保证消息有序的。RocketMQ的版本为:4.2.0 release。一.时序图还是老规矩,先把分析过程的时序图摆出来:1.Producer发送顺序消息 2.Consumer接收顺序消息(一) 3.Consumer接收顺序消息(二) 二.源码分析 – Producer发送顺序消息1 DefaultMQProducer#send:发送消息,入参中有
105
代码人生
01-01 08:00
代码人生
RocketMQ(三)架构和设计
RocketMQ(三)架构和设计,架构设计1技术架构RocketMQ架构上主要分为四部分,如上图所示:Producer:消息发布的角色,支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递,投递的过程支持快速失败并且低延迟。Consumer:消息消费的角色,支持分布式集群方式部署。支持以push推,pull拉两种模式对消息进行消费。同时也支持集群
76
代码人生
01-01 08:00
代码人生
RocketMQ通过源码看懂NameServer
RocketMQ通过源码看懂NameServer,NameServer用来做服务注册与发现,防止服务器的单点故障导致整个系统瘫痪,不可用,集群环境下的系统都需要一个服务注册中心,现在微服务中用的比较多的是zk,也是比较成熟,但是RoctetMQ自己写了一套,主要是因为NameServer不考虑集群操作,只要实现:动态路由的发现与剔除,能够拉取路由信息即可。NameServer每台机器之间互不通信,
202
代码人生
01-01 08:00
代码人生
RocketMQ本地源码启动(rocketmq源码解析)
RocketMQ本地源码启动(rocketmq源码解析),源码下载在读RocketMQ源码的时候,我们首先需要将源码从开源网站下将源码下载到本地,然后启动起来,这样可以方便我们在读源码的时候,有些地方读不懂,可以采取本地Debug的方式来跟踪执行的结果,方便我们更好的理解作者的设计思想。源码下载地址:www.apache.org/dyn/closer.…将源码下载到本地后,导入到Idea中,配置m
265
代码人生
01-01 08:00
代码人生
RocketMQ 存储消息的流程
RocketMQ 存储消息的流程,概要总结:1、commitLog其实有两层够层,其中MappendFileQueue是逻辑的存储队列概念,里面保存着顺序增长的MappedFile文件。2、MappedFile文件是真正存储实际数据的文件3、在整个broker的存储体系中,MappedFile文件保存了commitLog、consumeQueue、Index等,是核心的数据结构。RocketMQ存
159
«
1
2
3
4
5
»