在看书梳理代码的时候发现了一个变量:compressMsgBodyOverHowmuch (在DefaultMQProducer.java中)字面意思就是:消息体超过该值则启用压缩, 默认4K。 以前看过一点压缩算法的一些东西,想看看rocket mq中是如何进行压缩的。 在DefaultMQPro ...
分类:
其他好文 时间:
2021-04-05 11:53:45
阅读次数:
0
producer: **默认超时时间** /*** Timeout for sending messages.*/private int sendMsgTimeout = 3000; // 异步发送时 重试次数,默认 2 producer.setRetryTimesWhenSendAsyncFail ...
分类:
编程语言 时间:
2021-03-31 12:15:32
阅读次数:
0
RocketMQ高级:RocketMQ集群,RocketMQ控制台,RocketMQ高级特性:主从数据复制,负载均衡,消息重试,死信队列,消息重复消费与消息幂等 ...
分类:
其他好文 时间:
2021-03-30 13:24:54
阅读次数:
0
简介: 我们都知道,服务网格(ServiceMesh)可以为运行其上的微服务提供无侵入式的流量治理能力。通过配置VirtualService和DestinationRule,即可实现流量管理、超时重试、流量复制、限流、熔断等功能,而无需修改微服务代码。 本文所述的实践是根据请求Header实现全链路 ...
分类:
其他好文 时间:
2021-03-17 15:11:04
阅读次数:
0
实例说话: 使用vscode保存,有报提示信息,可以以超级用户身份重试,于是我授权root给vscode软件,却还提示失败! 而实际上,我使用cat命令发现已经写入成功了 终端内使用cat这条shell命令,很长,很辛苦。 这是我第一次亲身体会感受到,需要vim! 需要vim! 需要vim! 超强编 ...
分类:
系统相关 时间:
2021-01-29 11:48:07
阅读次数:
0
采用微服务架构后,当分布式系统到达一定量级时,每个环境都可能出错,因此在系统设计时应该考虑如何减轻故障的影响,如何从故障中快速恢复。一般从以下两点来考察系统的稳定性: 高可用:当前服务依赖的下游服务性能降低或者失败时,该服务怎么相应,是快速失败还是重试?大促时如何应对瞬间涌入的流量? 高并发:底层服 ...
分类:
编程语言 时间:
2021-01-06 11:55:40
阅读次数:
0
参考资料: https://docs.microsoft.com/en-us/windows/security/threat-protection/security-policy-settings/account-lockout-threshold 当你找到这个博客的时候,说明你遇到了和我一样的尴尬 ...
分类:
其他好文 时间:
2021-01-05 10:56:25
阅读次数:
0
使用方式 KafkaProducer 发送消息主要有以下 3 种方式: Properties properties = new Properties(); properties.setProperty("bootstrap.servers", "localhost:9092"); propertie ...
分类:
其他好文 时间:
2021-01-05 10:45:01
阅读次数:
0
随着业务的发展,应用系统中的配置通常会越来越多,常见的一些应用配置大致会有数据源配置,数据源组件配置,业务组件配置等,对于这类配置都会比较稳定且较少变化,通常会放在文件中随应用一起发布。但实际中会有某些配置信息变化有一定频率和规律,并且希望能够做到尽量实时,比如一些营销类,或活动类应用系统,若使用传统的配置文件,加上重新发布应用可能会有些不方便,因此,才有了分布式配置管理平台,旨在能更好地解决这类
分类:
其他好文 时间:
2020-12-18 12:16:48
阅读次数:
2
Ribbon是什么? Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法 Ribbon客户端组件提供一系列完善的配置项,如连接超时,重试等。简单的说,就是在配置文件中列出后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随即连接等)去连接这些机器。我 ...
分类:
编程语言 时间:
2020-12-08 12:31:10
阅读次数:
9