1.消息中间件的三大功能： 异步处理 流量控制 应用解耦 大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力 消息服务中两个重要概念：消息代理（message broker）和目的地（destination）当消息发送者发送消息以后，将由消息代理接管，消
消息队列应用场景 解耦 将各服务直接解耦。有订单服务，订单服务创建订单时需要减库存、需要扣金额和需要发送优惠券。在没用消息队列前，订单创建完毕时，需要在订单服务中调用库存服务、金额服务以及优惠券服务，如果之后还需要在订单服务执行完毕之后执行一些某些操作还得需要在订单服
RabbitMQ GUI客户端工具（RabbitMQ Assistant） 平时用控制台或者网页进行管理不免有点不方便，尤其在读取消息的时候不支持过滤和批量发送消息，在此推荐一个漂亮的GUI客户端工具。 下载地址：http://www.redisant.cn/rta 生成拓扑图 为指定的vhost一键生成拓扑图，支持导出png、svg、pdf、t
RabbitMQ Compose 配置文件 点击查看代码 version: '3.9' services: rabbitmq: image: rabbitmq:3.9-management restart: always container_name: rabbitmq3.9 hostname: rabbitmq3.9 privileged: true ports: - 5672:5672 - 15
有时间，我们需要rabbitmq测试一下，如果按照原方案部署一个rabbitmq，比较麻烦，这个时候可以使用docker快速构建一个rabbitmq来使用。 rabbitmq:management （推荐） 我们可以通过官方的镜像rabbitmq:management来实现，如果是直接使用命令行： # 拉取镜像 sudo docker pull
1.单机部署 我们在Centos7虚拟机中使用Docker来安装。 1.1.下载镜像 方式一：在线拉取 docker pull rabbitmq:3.8-management 方式二：从本地加载 在课前资料已经提供了镜像包： 上传到虚拟机中后，使用命令加载镜像即可： docker load -i mq.tar 1.2.安装MQ 执行下
rabbitmq是一款消息中间件，采用erlang语言编写。基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。AMQP协议更多用在企业系统内，对数据一致性、稳定性和可靠性要求很高的场景，对性能和吞吐量的要求还在其次。消息的消费者被动拉取（rabb
生产者：product.php $conConfig = [ 'host' => '127.0.0.1', 'port' => '5672', 'login' => 'sblack', 'password' => '123456', 'vhost' => '/'
package main import ( "fmt" "github.com/streadway/amqp" "log" "time" ) func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } } func x
通过上一篇【RabbitMQ 笔记】— 基本概念，知道生产者和消费者使用到的主要类和接口有 ConnectionFactory、Connection、Channel、Consumer 等。Connection 是用来开启 Channel 的，RabbitMQ 开发工作也基本上是围绕 Connection 和 Channel 这两个类展开。 连接 RabbitMQ 多线程共享
死信交换器，Dead Letter Exchange，下文简称 DLX。当消息在一个队列中变成死信（Dead Letter）之后，它会被发送到另一个交换器中，这个交换器就是 DLX，绑定 DLX 的队列就称为死信队列。 消息变成死信一般由以下几种情况： 消息被拒绝（Basic.Reject / Basic.Nack），并且设置 requeue 参数为 false
安装 erlang 下载 erlang 安装包 wget http://erlang.org/download/otp_src_24.3.tar.gz 解压 erlang 安装包 tar -xvzf /usr/root/otp_src_24.3.tar.gz 安装 erlang 的依赖工具 yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel unixODBC-de
前言 其实rabbit 没有现成可用的延迟队列，但是可以利用其两个重要特性来实现之：1、Time To Live(TTL)消息超时机制；2、Dead Letter Exchanges（DLX）死信队列。 先理解一个概念： rabbit 中一个消息是有死亡状态的，它会被发送到一个指定的队列中，这个队列是一个普通的队列，根据他的功能，我们
本地安装RabbitMQ安装注意事项： Erlang与RabbitMQ，安装路径都应不含空格符。 Erlang使用了环境变量HOMEDRIVE与HOMEPATH来访问配置文件.erlang.cookie，应注意这两个环境变量的有效性。需要设定环境变量ERLANG_HOME，并把erlang的bin路径复制到全局路径中。 RabbitMQ使用本地computer na
问题 当时比较怪异，现象是通过rabbitmq 的management可以发送消息（消息内容比较小，很简单的），但是通过代码没有任何报错 但是消息就是不能看到（management 界面） 排错处理 开始以为是代码处理问题，但是没有异常日志，也怀疑因为代码发布造成队列错误造成消息写入错误，我一般的此类问题的方式
1 nuget包 <PackageReference Include="MassTransit.RabbitMQ" Version="8.0.2" /> 注意事项 本次使用的是docker来运行RabbitMQ 命令是： docker run -d -p 15672:15672 -p 5672:5672 -p 5671:5671 --hostname my-rabbitmq --name my-rabbitmq-container rabbitmq:3
package main import ( "fmt" "github.com/streadway/amqp" "log" ) func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } } func getConn() *amqp.Connec
RabbitMQ——工作队列 一、任务队列/工作队列 （使用Go RabbitMQ客户端） 我们编写程序从命名的队列发送和接收消息。在这一节中，我们将创建一个工作队列，该队列将用于在多个工人之间分配耗时的任务。 工作队列（又称任务队列）的主要思想是避免立即执行某些资源密集型任务并且不得不等待这
一、配置文件 1.1 pom文件 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <
手动部署RabbitMQ 1、创建并远程连接Linux实例。 2、安装erlang 1 运行以下命令，安装erlang所需要的依赖 yum install -y make gcc gcc-c++ m4 openssl openssl-devel ncurses-devel unixODBC unixODBC-devel java java-devel 2 运行以下命令，下载erlang安装包 wget http://erla
目录一、核心概念二、工作模式2.1 simple简单队列2.2 work工作队列2.3 publish/subscribe发布订阅(共享资源)2.4 路由模式2.5 topic主题模式 一、核心概念 生产者：发送消息的应用程序。 消费者：接收消息的应用程序。 队列：存储消息的缓冲区。 消息：通过RabbitMQ从生产者发送给消费者
前言 官方文档 生产者与消费者的解耦分离 使用 连接 import pika RabbitMQHost = 'localhost' conn = pika.BlockingConnection( pika.ConnectionParameters(host=RabbitMQHost) ) channel = conn.channel() conn.close() 简单模式 生产者 # 创建队列 queue_name = 'firs
生产者： 1.创建生产者SpringBoot工程 2.引入坐标依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 3.编写yml配置，基本信息配置
在RabbitMQ集群中有内存节点和磁盘节点之分 内存节点（ram）：就是将元数据都放在内存里，内存节点的话，只要服务重启，该节点的所有数据将会丢失 硬盘节点（disc）：就是将元数据都放在硬盘里，所以服务重启的话，数据也还是会存在的，所以像我们的持久化消息、持久化队列等，都会放置硬盘节点保存 在Rabbi
目录一、什么是消息队列二、RabbitMQ的优势2.1 应用解耦2.2 异步提速2.3 流量削峰三、MQ的劣势四、RabbitMQ中的相关概念 一、什么是消息队列 MQ全称 Message Queue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。消息指的是两个应用间传递的数据。
