在go-micro中异步消息的收发是通过Broker这个组件来完成的，底层实现有RabbitMQ、Kafka、Redis等等很多种方式，这篇文章主要介绍go-micro使用RabbitMQ收发数据的方法和原理。

Broker的核心功能

Broker的核心功能是Publish和Subscribe，也就是发布和订阅。它们的定义是：

整体的架构图，并介绍一些基本概念：

• channel： 信道是生产者，消费者和 RabbitMQ 通信的渠道，是建立在 TCP 连接上的虚拟连接。一个 TCP 连接上可以建立成百上千个信道，通过这种方式，可以减少系统开销，提高性能。
• Broker： 接收客户端连接，实现 AMQP 协议的消息队列和路由功能的进程。
• Virtual Host： 虚拟主机的概念，类似权限控制组，一个 Virtual Host 里可以有多个 Exchange 和 Queue，权限控制的最小粒度是 Virtual Host。

在后端开发中，Spring Boot3 项目常会面临消息传递不及时、系统间通信效率低下等问题。例如，电商系统里用户下单后，库存系统无法及时更新库存，易引发超卖现象；社交平台中用户发送消息，接收方可能长时间收不到。这些问题严重影响系统性能与用户体验，接下来探讨如何利用 Spring Boot3 与 RabbitMQ 整合来解决。

在win10环境下安装RabbitMQ的步骤

第一步：下载并安装erlang

• 手撕分布式技术：限流、通讯、缓存，全部一锅端走送给你
  

前情回顾——RabbitMQ的工作模式

上篇文章：

RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）,广泛微服务系统之间，服务之间消息异步投递。如何保证消息在投递过程的中可靠性呢。下面的文章我这里探讨一下。

优质文章，及时送达

一. RabbitMQ 简介

MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。

弱小和无知并不是生存的障碍，傲慢才是。

---- ---- 面试者

在消息队列系统中，保障消息不丢失需要从生产者、消息队列服务端、消费者