ddzyan/node-amqplib

nodejs 使用 amqplib 模块连接 rabbitmq服务，实现消息的发送和接收

[TOC]

此文章内容核心为 nodejs 如何实现 rabbitMq 的五种常见的工作模式，其余内容来自于百度/谷歌。

RabbitMq 环境创建

docker 构建

# 拉去镜像 management 为带管理界面
docker pull rabbitmq:management

# 启动
docker run -dit --name Myrabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 rabbitmq:management

使用

RabbitMQ 后台管理界面地址：http://192.168.100.117:15672

默认账号：admin

默认密码：admin

RabbitMQ 核心内容

rabbitMq 采用的消息体为 amqp(advance message queue protocol)高级消息队列协议，支持 restFul-Api 调用，支持跨语言。

消息队列的主要作用：

1. 服务解耦：承担微服务之间的消息通讯
2. 任务异步：将任务推送到消息队列种集中处理，不影响主进程处理进度。
3. 流量削峰：定时定量统一处理任务，防止因为高流量导致服务奔溃。

备注

1. 多个消费者绑定一个消息队列的时候，将只有一个消费者获取到信息。

5 种工作模式

简单模式(hello word)

生产者 P 往一个消息通道 Q 发送消息，并且由一个消费者 C 进行消费

工作模式(work)

生产者 P 往一个消息通道 Q 发送消息，并且由多个消费者 C 按照绑定顺序依次消费

---

工作模式和简单模式没有加入交换机，而订阅模式,路由模式，通配符模式则引起了交换机，生产者发送的消息将直接发送给交换机，由交换机根据设定的交换机类型，将消息转发给符合条件的消息队列。

常见的交换机类型：

1. fanout：广播，将消息发送给所有绑定交换机的队列（发布订阅模式）
2. topic：通配符，将消息发送给符合 routing parrtem 的队列种（通配符模式）
3. direct：定向，将消息发送给指定的 routing key 队列种（路由模式）

订阅模式(publish/subcribe)

生产者 P 往交换机 X 发送消息，交换机将符合条件的信息发送到绑定的队列 Q，绑定指定队列的消费者 C 接收和处理消息

消息不再直接发送给队列，而是发送给交换机，由交换机推送到指定队列。但是交换机不具备存储消息的能力，所以如果没有符合条件的队列，则消息将丢失。

如果声明多个相同名称的队列，并且都绑定到同一个交换机上，则发到交换机上此队列名称的消息，将发送完全相同的数据到这多个相同名称的队列中。

路由模式(router)

生产者 P 往交换机 X 发送消息，交换机再往符合条件的路由队列发送消息，绑定指定队列的消费者 C 接收和处理消息

通配符模式(topic)

核心逻辑与路由模式基本相同，区别在于路由模式生产者只能让交换机将消息发送给完全匹配路由的消息队列，而通配符模式可以进行路由匹配，会将消息发送给所有满足匹配规则的消息队列。

1. 通配符#可以匹配多个路由，例如 log.#则可以同时匹配 log.info,log.info.add,log.warn 路由
2. 通配符*则只能匹配到一个，例如 log.*则只能匹配 log.info，不能匹配 log.info.add

一般常用#来进行多个路由匹配