一、broker消息存储 本节揭露broker上消息存储的真实目录结构+存储方式。 1.1 目录、文件结构 有3个比较重要的文件: commitLog消息日志:消息主体以及元数据的存储主体,存储Producer端写入的消息主体内容, consumequeue逻辑消费队列:存储了commitLog的起 ...
分类:
其他好文 时间:
2021-07-21 17:31:03
阅读次数:
0
?简介: 我们在几年前决定引入 MQ 时,市场上已经有不少成熟的解决方案,比如 RabbitMQ , ActiveMQ,NSQ,Kafka 等。考虑到稳定性、维护成本、公司技术栈等因素,我们选择了 RocketMQ。 ? 背景介绍 ? 为何选择 RocketMQ ? 我们在几年前决定引入 MQ 时, ...
分类:
其他好文 时间:
2021-07-02 16:09:00
阅读次数:
0
一 概述 NameServer的主要作用是, 1 路由功能。生产者查询NameServer,根据Topic选择它要发送的MessageQueue。 2 通过和每个broker发送心跳,更新注册信息,剔除失效broker 二 主要成员变量 public class RouteInfoManager { ...
分类:
其他好文 时间:
2021-06-28 18:43:42
阅读次数:
0
1. 为什么你们公司选择RabbitMQ作为消息中间件 在消息队列选型时,我们调研了市场上比较常用ActiveMQ,RabbitMQ,RocketMQ,Kafka。 RabbitMQ相对成熟稳定,这是我们选择它最主要的原因。 社区比较活跃,有完善的资料可以参考。 Rabbitmq的吞吐量可以达到万级 ...
分类:
其他好文 时间:
2021-06-22 18:28:57
阅读次数:
0
Redis Redis 简介 Redis 一个开源的,内存中的数据结构存储系统,它可以用作数据库,缓存和消息中间件。 它支持多种类型的数据结构,如 字符串 string 、散列 hashes 、列表 list 、集合 set 、有序集合 zset 和 范围查询,bitmaps 、hyperloglo ...
分类:
其他好文 时间:
2021-06-18 19:52:49
阅读次数:
0
1.org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, MyTopic 报错信信息如下: Exception in thread "main" org.apache.rocketmq ...
分类:
其他好文 时间:
2021-06-11 18:46:49
阅读次数:
0
title: ActiveMQWithCpp author: Youdias date: 2021-06-10 15:29:26 tags: ActiveMQ C++ VS2019 win32 ActiveMQ简介 Apache下的一个子项目,一个消息中间件,支持点对点和订阅发布模式,支持多种语言客 ...
分类:
编程语言 时间:
2021-06-11 18:19:46
阅读次数:
0
1. Cannot allocate memory RocketMQ默认安装需要使用8G的内存,所以如果内存不够会导致启动失败,这时需要修改配置文件bin/runbroker.sh,修改xms、xmx和xmn。参考https://www.cnblogs.com/freeweb/p/7817968.h ...
分类:
其他好文 时间:
2021-06-08 23:24:24
阅读次数:
0
现在我们从源码来分析(一)中所涉及的东西 提问 问一下自己想从源码中知道什么, 带着目的去看源码才容易搞懂. 从下述的代码中发现定义了一个Function的Bean和在yaml中定义了definition, 那么这两个定义的作用是什么呢? Function是怎么样去绑定、注册的呢? 带着问题我们就可 ...
分类:
编程语言 时间:
2021-06-02 14:52:40
阅读次数:
0
Start Name Server > nohup sh bin/mqnamesrv & > tail -f ~/logs/rocketmqlogs/namesrv.log The Name Server boot success... 1、先启动NameServer: 在bin下执行: nohup ...
分类:
其他好文 时间:
2021-06-02 13:47:34
阅读次数:
0