nodejs中使用RabbitMq消息中心系统的方式

Posted 2020-08-24 向着太阳生

方式一:通过npm安装amqp库

方式二:通过rabbit.js库http://www.squaremobius.net/rabbit.js/

AMQP：高级消息队列协议，是应用层协议的一个开放标准，RabbitMq是用Erlang语言编写的一个AMQP的开源实现。

核心组件：Exchange & Queue

Exchange称为交换器，Queue是消息队列，这两者都在服务器端，Producer和Consumer分别是生产者和消费者，在客户端

原理：

生产者发送消息给交换器Exchange并带一个RouteKey，如果RouteKey和Exchange与Queue之间的BindKey是一样的，交换器则将它发送给对应的消息队列Queue。

RouteKey和Bindkey在做比较的时候有三种类型

1,直接式direct

通过精确匹配消息的路由关键字，将消息路由到0个或多个消息队列中，判断路由关键字和绑定关键字是不是相等(绑定关键字是用来将消息队列绑定到哪个交换器，他们是多对多的关系)

2,广播式fanout

广播式交换器类型提供了这样的路由机制：不论消息的路由关键字是什么，这条消息都会被路由到所有与该交换器绑定的消息队列中

3,主题式topic

主题式交换器类型提供了这样的路由机制：通过消息的路由关键字和绑定关键字的模式匹配，将消息路由到被绑定的队列中。这种路由可以被用来支持经典的发布/订阅消息传输模型，将消息传递给部分或全部匹配主题模式的多个消费者。

这种类型下的绑定关键字必须是这种格式的：" *.xxx.# "，通配符*表示匹配任意一个单词，#匹配0个或多个单词，绑定关键字用零个或多个标记组成，每个标记之间"."符合分隔。

比如，绑定关键字*.stack.#匹配路由关键字usd.stack和abcd.stack.efg，但不匹配stack.efg。