文件名称:redis-message-queue
文件大小:20KB
文件格式:ZIP
更新时间:2024-05-20 15:54:56
JavaScript
如何用消息队列分离功能 一般在设计微服务时,会将功能进行一些拆分到独立的服务中。两个服务之间的通信一般采用 http 或 rpc 。 不管是 http 还是 rpc 通信,当服务 A 向服务 B 发起一个 http(rpc)请求,该请求的处理过程影响了整个路径的时间。一旦请求处理错误还会影响整个处理过程。 解决这种服务之间的耦合性可以适当的采用消息队列机制。 消息(数据)的生产者(服务)将消息发送给消息队列(服务),消息的消费者(服务)从消息队列(服务)里拿数据进行处理。在这个过程中只需要定义好消息的结构体即可进行通信。 采用消息队列不仅可以解决服务之间的耦合性,还能提高主流程的处理时间以及并发量比较大的时候获得流量消峰的效果。 该项目(sample)采用 redis 当着消息队列,分别起了3个服务。 consumer.js 消息的消费者服务(收到消息后发送邮件) producer.js
【文件预览】:
redis-message-queue-master
----config()
--------index.js(232B)
----producer.js(557B)
----package.json(282B)
----process.yml(311B)
----monitor.js(187B)
----.gitignore(25B)
----consumer.js(1KB)
----README.md(1KB)
----yarn.lock(57KB)