RocketMQ负载均衡

相关文章： RocketMQ延时消息解析！ RocketMQ消息重试机制解析！ RocketMQ事务消息解析！ 消费者在消费消息的时候，需要知道从Broker的哪一个消息队列中去获取消息。 所以，在消费者端必须要做负载均衡，即Broker端中多个消费队列分配给同一个消费者组中的哪些消费者消费。 ...
2024-11-14 公众号文章

RocketMQ消息重试

由于网络抖动、服务宕机等一些不确定的因素，RocketMQ在发送消息的时候很有可能出现消息发送或者消费失败的问题。 所以RocketMQ消息重试分为2种： Producer端重试和Consumer端重试。 Producer端重试 生产者端的消息失败，也就是Producer往MQ上发消息没 ...
2024-11-12 公众号文章

RocketMQ顺序消息

相关文章： RocketMQ延时消息解析！ RocketMQ消息重试机制解析！ RocketMQ事务消息解析！ 顺序消息是消息队列 RocketMQ 提供的一种高级消息类型。 对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费。 即先发送的消息先消费，后发送的消 ...
2024-11-11 公众号文章

Web实时通信

Web端即时通讯 服务器端可以即时地将数据的更新或变化反应到客户端，例如消息即时推送等功能。 但是在Web中，由于浏览器的限制，实现即时通讯需要借助一些方法。 这种限制出现的主要原因是： 一般的Web通信都是浏览器先发送请求到服务器，服务器再进行响应完成数据的现实更新。 实现Web端即时通讯 ...
2024-11-03 公众号文章

Tomcat线程池

Tomcat的线程池Executor除了实现Lifecycle接口外，基本和JDK的ThreadPoolExecutor一致。 以前是直接继承了JDK的ThreadPoolExecutor，并改写部分逻辑。 在最新的代码上（Tomcat 10，2021.7.22以后），甚至是直接抄了一份，改写部分 ...
2024-11-03 公众号文章

幂等性设计

重复请求 生产环境经常出现重复的数据，而这个绝大部分原因是发生了重复的请求。 重复请求是指同一个请求因为某些原因被多次提交。 导致这个情况会有几种场景： 微服务场景**：** 在微服务架构下，接口超时，微服务框架会进行重试。 用户交互的时候多次点击，如：快速点击按钮多次。 MQ消息中间件： ...
2024-11-01 公众号文章

RocketMQ延时消息

什么是延时消息? 指的是当消息写入到Broker后，不能立刻被消费者消费，需要等待指定的时长后才可被消费处理的消息。 延时消息等级 RocketMQ延时消息的延迟时长不支持随意时长的延迟。 是通过特定的延迟等级来指定的。 默认支持18个等级的延迟消息。 延时等级定义在RocketMQ服务 ...
2024-10-28 公众号文章

RocketMQ事务消息

相关文章： RocketMQ延时消息解析：https://mp.weixin.qq.com/s/ta2f5-T63so3AJvuOW-BlQ RocketMQ消息重试机制解析：https://mp.weixin.qq.com/s/Ei-eYFfE0devt_vq0ZRfuw 单体架构下的事务 在 ...
2024-10-28 公众号文章

正则表达式

在工作中一般使用正则表达式来匹配，替换，检索文本，可以大大提高了工作效率。 简介 正则表达式，又称规则表达式，通常被用来检索、替换那些符合某个模式(规则)的文本。 许多程序设计语言都支持利用正则表达式进行字符串操作。 例如，在Perl中就内建了一个功能强大的正则表达式引擎。 学会使用正则表达式 ...
2024-10-21 公众号文章

Redis延时队列

所谓延时队列就是延时的消息队列，下面说一下一些业务场景。 实践场景 订单支付失败，每隔一段时间提醒用户。 用户并发量的情况，可以延时2分钟给用户发短信。 先来看看Redis实现普通的消息队列 我们知道，对于专业的消息队列中间件，如Kafka和RabbitMQ，消费者在消费消息之前要进行一系列的 ...
2024-10-20 公众号文章
12