在看书梳理代码的时候发现了一个变量:compressMsgBodyOverHowmuch (在DefaultMQProducer.java中)字面意思就是:消息体超过该值则启用压缩, 默认4K。 以前看过一点压缩算法的一些东西,想看看rocket mq中是如何进行压缩的。 在DefaultMQPro ...
分类:
其他好文 时间:
2021-04-05 11:53:45
阅读次数:
0
一、什么是消息队列? 消息队列不知道大家看到这个词的时候,会不会觉得它是一个比较高端的技术,反正我是觉得它好像是挺牛逼的。 消息队列,一般我们会简称它为MQ(Message Queue),嗯,就是很直白的简写。 我们先不管消息(Message)这个词,来看看队列(Queue)。这一看,队列大家应该都 ...
分类:
其他好文 时间:
2021-04-02 13:09:28
阅读次数:
0
重装下MQ 发现网上居然没有服务器版的安装手册 记录给需要的朋友 1.下载相关软件 2.安装 Server08 默认没有装VC2015 所以安装的时候erl的时候会报错,所以要先装下 然后就是 erl 然后就是 mq 3.配置 首先看看服务 mq 有没有正常启动 有的话就安装成功了 然后就是添加一个 ...
现在的mq产品主流有4中:rabbitmq,rocketmq,activemq,kafka;有时候很意外的是:学的其中一个,公司用的又是另外一个,导致学习成本提高。有或者是 业务服务使用rabbitmq,而数据库后台使用kafka,整个项目使用了2种mq,可能会导致切换困难,维护成本高等因素。 我们 ...
分类:
编程语言 时间:
2021-02-27 12:58:02
阅读次数:
0
RocketMq灰皮书(三) MQ使用 在使用MQ之前,我们回顾一下前两篇博文的内容. 我们大致了解了RocketMQ的四个概念,分别是:Producer,Consumer,Message和Broker 我们在本地的Windows10系统上,部署了RocketMQ和其后台系统 在本篇博文中,我们会使 ...
分类:
其他好文 时间:
2021-02-19 13:45:46
阅读次数:
0
面试官心理分析 其实这是很常见的一个问题,这俩问题基本可以连起来问。既然是消费消息,那肯定要考虑会不会重复消费?能不能避免重复消费?或者重复消费了也别造成系统异常可以吗?这个是 MQ 领域的基本问题,其实本质上还是问你使用消息队列如何保证幂等性,这个是你架构里要考虑的一个问题。 面试题剖析 回答这个 ...
分类:
其他好文 时间:
2021-02-19 13:44:49
阅读次数:
0
操作步骤如下: 前提:已经安装了docker 1.docker search rocketmq 2.docker pull rocketmqinc/rocketmq 3. 创建 mq 配置文件 broker.conf,文件放置到 /opt/rocketmq/conf ,配置如下: brokerClu ...
分类:
其他好文 时间:
2021-02-03 11:08:50
阅读次数:
0
学习是一个循序渐进的过程,先别着急学习 RabbitMQ ,我们先了解一些关于MQ消息中间件的基础知识,明白MQ在业务中的使用场景 MQ消息中间件及使用场景 1、什么是MQ消息中间件 MQ消息中间件全称(MessageQueue),主要用于程序之间相互通信,实现 异步+解耦 效果。 如下图所示,一个 ...
分类:
其他好文 时间:
2021-02-01 12:37:10
阅读次数:
0
消息队列 消息队列概念 MQ全称为Message Queue,消息队列是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。 消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远 ...
分类:
其他好文 时间:
2021-01-28 11:38:39
阅读次数:
0
一、pom.xml导入依赖 <dependencies> <!-- activemq 所需要的jar 包--> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <ver ...