背景 在企业发展初期,企业使用的系统很少,通常一个或者两个,每个系统都有自己的登录模块,运营人员每天用自己的账号登录,很方便。 但随着企业的发展,用到的系统随之增多,运营人员...
背景 在企业发展初期,企业使用的系统很少,通常一个或者两个,每个系统都有自己的登录模块,运营人员每天用自己的账号登录,很方便。 但随着企业的发展,用到的系统随之增多,运营人员...
一、服务注册与发现 这里会用到Spring Cloud Netflix,该项目是Spring Cloud的子项目之一,主要内容是对Netflix公司一系列开源产品的包装,它为...
引言 本文希望以另外一种维度的思考方式来学习JVM内存模型,希望自己能从设计原理的维度考虑为什么存在?有什么价值?解决什么问题? 在学习JVM内存模型之前,先回顾下前面两章的...
@空挡 谢谢博主 我大概明白了
RocketMQ源码解析(四)-Consumer消息消费方式 Consumer分为两种,PullConsumer和PushConsumer。从名字就可以看出一种是拉取的方式,一种是主动Push的方式。具体实现如下: Pul...
终于讲到Broker消息处理流程的最后一步了。讲Consumer的时候说到消费消息分为Pull和Push两种模式,底层其实都是依靠Pull实现的。在Broker这端处理Pus...
IndexFile作用 MessageStore中存储的消息除了通过ConsumeQueue提供给consumer消费之外,还支持通过MessageID或者MessageKe...
ConsumeQueue的作用 上一篇文章讲到Broker在收到消息后,通过MessageStore将消息存储到commitLog中,但是consumer在消费消息的时候是按...
从这篇文章开始,主要看一下Broker处理一条消息的完整过程:接收Producer发来的消息->存储消息->将消息推给Consumer。这一篇主要看下接收Producer消息...
博主,您好 。请问RebalanceImpl通过updateProcessQueueTableInRebalance()方法来检查新加入queue,这里要检查新加入的queue的作用是什么呢?
RocketMQ源码解析(四)-Consumer消息消费方式 Consumer分为两种,PullConsumer和PushConsumer。从名字就可以看出一种是拉取的方式,一种是主动Push的方式。具体实现如下: Pul...
消息消费方式 Consumer分为两种,PullConsumer和PushConsumer。从名字就可以看出一种是拉取的方式,一种是主动Push的方式。具体实现如下: Pul...
发送方式 producer发送消息支持3种方式,同步、异步和Oneway。 同步发送:客户端提交消息到broker后会等待返回结果,相对来说是最常用的方式。 异步发送:调用发...
RocketMQ是阿里开源的分布式消息中间件,在阿里云上有它的商业版本ONS,类似的开源消息中间件还有Kafka, ActiveMQ等。跟其它中间件相比,rocketMQ的特...