标签: 消息中间件

共10项

Socket编程实践模拟通信

本篇记录Socket与ServerSocket进行通信过程,服务器端使用线程,一直监听客户端的请求,并返回消息给客户端。 【1】客户端代码 @Test public void testClient(){ Socket client = nu…

RocketMQ

RocketMQ是阿里巴巴开源的一款分布式消息中间件,适用于大规模消息处理应用,如:日志收集、事件通知、任务调度等。RocketMQ整体架构设计主要分为四大部分,分别是:Producer、Consumer、Broker、NameServer…

RocketMQ 的应用场景

RocketMQ的应用场景非常广泛,主要包括以下几个方面: 异步解耦:通过RocketMQ完成上游和下游业务系统的松耦合设计,使得服务部分节点异常不会影响到核心交易系统的正常运转,同时还可以通过RocketMQ重试队列实现异常重试处理。削峰…

RocketMQ如何实现日志收集

RocketMQ可以通过其日志收集功能来实现日志的统一管理和集中存储。具体实现方式如下: 在RocketMQ中,每个生产者或消费者都可以被视为一个日志收集器,它们将日志消息发送到指定的Topic中。生产者或消费者在发送日志消息时,可以指定一…