【RabbitMQ教程】第八章 —— RabbitMQ – 幂等性、优先级、惰性
🌊RabbitMQ – 幂等性、优先级、惰性 幂等性 概念 用户对于同一操作发起的一次请求或者多次请求的结果是一致的，不会因为多次点击而产生了副作用。 举个最简单的例子，那就是支付，用户购买商品后支付，支付扣款成…
完美解决 RabbitMQ 可视化界面中 Overview 不显示图形的问题
🪁问题场景 场景是这样的：我使用docker启了一个RabbitMQ并下载了相关插件后，浏览器打开 localhost:15672 查看可视化界面，登录成功、消息发送成功，接收者接收成功，但Overview那块儿就是没有图形…
【Spring Cloud + RabbitMQ 实现分布式消息总线】—— 每天一点小知识
🐳使用 Spring Cloud + RabbitMQ 实现分布式消息总线 Spring Cloud 是一个用于构建分布式系统的开发工具包，而 RabbitMQ 是一种功能强大的消息代理。结合使用 Spring Cloud …
【Spring Cloud Stream 消息驱动】 —— 每天一点小知识
🐳Spring Cloud Stream 消息驱动 在微服务架构中，消息驱动是一种常见的通信方式，它通过解耦和异步处理提供了可靠的服务间通信机制。Spring Cloud Stream 是 Spring Cloud 生态系统…
RocketMQ 的应用场景
RocketMQ的应用场景非常广泛，主要包括以下几个方面： 异步解耦：通过RocketMQ完成上游和下游业务系统的松耦合设计，使得服务部分节点异常不会影响到核心交易系统的正常运转，同时还可以通过RocketMQ重试队列实现异常重试处理。削峰…
RocketMQ如何实现日志收集
RocketMQ可以通过其日志收集功能来实现日志的统一管理和集中存储。具体实现方式如下： 在RocketMQ中，每个生产者或消费者都可以被视为一个日志收集器，它们将日志消息发送到指定的Topic中。生产者或消费者在发送日志消息时，可以指定一…
Socket编程实践模拟通信
本篇记录Socket与ServerSocket进行通信过程，服务器端使用线程，一直监听客户端的请求，并返回消息给客户端。 【1】客户端代码 @Test public void testClient(){ Socket client = nu…
【RabbitMQ教程】第六章 —— RabbitMQ – 延迟队列（下）
队列 TTL 代码架构图 创建两个队列 QA 和 QB，两者队列 TTL 分别设置为 10S 和 40S，然后在创建一个交换机 X 和死信交 换机 Y，它们的类型都是direct，创建一个死信队列 QD，它们的绑定关系如下： 原先配置队列信…
【RabbitMQ教程】第七章 —— RabbitMQ – 发布确认高级
🌊RabbitMQ – 发布确认高级 在生产环境中由于一些不明原因，导致 RabbitMQ 重启，在 RabbitMQ 重启期间生产者消息投递失败， 导致消息丢失，需要手动处理和恢复。于是，我们开始思考，如何才能…
