sh --zookeeper zookeeper_ip:2181 --alter --topic test --partitions 10 删除topic：慎用，只会删除zookeeper中的元数据，消息文件须手动删除 方法一： ./kafka-topics.sh --delete --zookeeper zookeeper_ip:2181 --topic topic_name 方法二：待验证 ./k...

ream的文章不少  但我更想以观众能够轻松理解并且运用到自己的项目当中 我认为这才是技术存在的意义 下面是正片 按照自己的口味来食用哦（有比较难懂的地方） Spring Cloud Stream: 消息驱动架构 引言 随着云计算、微服务和大数据技术的快速发展，构建可扩展、高性能和弹性的应用程序变得越来越重要。为了满足这些要求，许多开发人员转向了事件驱动架构，它允许应用程序通过基于事件的方式相互通信，...

本文深入介绍了RabbitMQ消息模型，涵盖了基本消息队列、工作消息队列、广播、路由和主题等五种常见消息模型。每种模型都具有独特的特点和适用场景，为开发者提供了灵活而强大的消息传递工具。通过这些模型，RabbitMQ实现了解耦、异步通信以及高效的消息路由，为分布式系统的开发和部署提供了可靠的基础。阅读本文，读者将深入了解RabbitMQ不同消息模型的应用场景和使用方法，为构建可靠的消息传递系统提供了有...

IPC（Inter-Process Communication，进程间通信）         常用的 IPC 对象包括管道（pipe）、消息队列（message queue）、信号量（semaphore）和共享内存（shared memory）等     1.ipcs           查看系统重的消息队列、共享内存、信号灯的信息         2.ipcrm        删除消息队列、共享内存...

1.什么是延迟消息？你有没有用过？可以用来解决什么问题？ 定时任务：延迟消息可以用于实现定时任务，例如在未来的某个时间点发送电子邮件或推送通知。 缓解突发流量：如果你的系统在短时间内接收到大量请求，可以使用延迟消息将这些请求分散到一个更长的时间段，以减轻系统压力。 重试策略：在分布式系统中，如果某个操作失败，你可能想要在一段时间后重试。延迟消息可以用于实现这种重试策略。 订单处理：例如，在电子商务应用...

消息队列是现代分布式系统中常用的通信机制，用于在不同的服务之间传递消息。在Spring Cloud框架中，我们可以利用RabbitMQ实现强大而可靠的消息队列系统。本篇博客将详细介绍如何在Spring Cloud项目中集成RabbitMQ，并创建一个简单的消息队列。 一、SpringCloud调用RabbitMQ架构图 这里是一个简单的RabbitMQ消息队列架构图，表示了Spring Cloud框...

一、消息队列介绍 MQ (MessageQueue) ，中文是消息队列，字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。消息队列是一种基于生产者-消费者模型的通信方式，通过在消息队列中存放和传递消息，实现了不同组件、服务或系统之间的异步通信。 二、消息队列的原理 消息队列的核心原理是基于生产者和消费者模型的异步通信。在这个模型中，生产者负责产生消息并将其发送到消息队列，而消费者则从队...

当一条消息因为一些原因无法被成功消费，那么这这条消息就叫做死信，如果包含死信的队列配置了dead-letter-exchange属性指定了一个交换机，队列中的死信都会投递到这个交换机内，这个交换机就叫死信交换机，死信交换机再绑定一个队列，死信最终会进入到这个存放死信的队列，这个专门存放死信的队列成为死信队列。消息会成为死信原因会有很多。 比如消费者使用basic.reject或basic.nack声明...

最近工作室的一个业务跟另一个业务合并 自然要用到MQ（消息队列Message Queue）那么很显然 就要部署个RabbitMQ到服务器上了   我们用的是云托管的的服务 那自然是部署中间件到云服务上去了 服务是一路开通 结果到了需要调试的时候 怎么也连不上 （说是内网直连，但关键是 同事们都在线下做本地测试的呀） 直接无语了 面对这一场景 怎么办？业务还要继续 等着交货的  于是我想起了之前学过的...

，异步通讯较同步通讯而言，通过调用事件驱动模型Broker，无需等待服务器返回结果，微服务之间耦合度更低，微服务无需等待订阅者处理完成性能更好，并且做到了故障隔离，不存在级联失败等问题。 MQ，意思为消息队列，分布式系统中的重要组件，用它就可以实现应用解耦、异步消息、流量削峰等问题。消息队列产品有很多，企业级应用较广泛的就是RabbitMQ。 消息队列中的消息分为两类传输模型点对点模型（一个生产者发送...