Nicksxs's Blog

聊一下 RocketMQ 的消息存储三

发表于 2021-10-03 分类于 MQ ， RocketMQ ，消息队列阅读次数：

ConsumeQueue 其实是定位到一个 topic 下的消息在 CommitLog 下的偏移量，它也是固定大小的

发表于 2021-09-26 分类于 Java ， SpringBoot 阅读次数：

其实这个表示有点不太对，应该是 Druid 动态切换数据源的方法，只是应用在了 springboot 框架中，准备代码准备了半天，之前在一次数据库迁移中使用了，发现 Druid 还是很强大的，用来做动态数据源切换很方便。

发表于 2021-09-19 分类于 Java ， SpringBoot 阅读次数：

这个话题是由一次组内同学分享引出来的，首先在 springboot 2.x 开始默认使用了 cglib 作为 aop 的实现，这里也稍微讲一下，在一个 1.x 的老项目里，可以看到AopAutoConfiguration 是这样的

发表于 2021-09-12 分类于 MQ ， RocketMQ ，消息队列阅读次数：

CommitLog 是 rocketmq 的服务端，也就是 broker 存储消息的的文件，跟 kafka 一样，也是顺序写入，当然消息是变长的，生成的规则是每个文件的默认1G =1024 1024 1024，commitlog的文件名fileName，名字长度为20位，左边补…

发表于 2021-09-04 分类于 MQ ， RocketMQ ，消息队列阅读次数：

这是个很大的话题了，可能会分成两部分说，第一部分就是所谓的零拷贝 ( zero-copy )，这一块其实也不新鲜，我对零拷贝的概念主要来自这篇文章，个人感觉写得非常好，在 rocketmq 中，最大的一块存储就是消息存储，也就是 CommitLog，当然还有 ConsumeQu…