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