文件名称：servicebus:简单的服务总线，用于使用amqp在进程之间发送事件
文件大小：91KB
文件格式：ZIP
更新时间：2024-05-02 18:35:25
javascript middleware node rabbitmq amqp
服务总线 简单的服务总线，用于使用amqp在进程之间发送事件。 允许通过RabbitMQ发送/接收和发布/订阅模式消息。 配置 发送和接收 Servicebus允许以1：1 sender：listener配置简单地发送和接收消息。 以下两个进程将通过RabbitMQ从进程A到进程B每秒钟发送一次名为“ my.event”的事件消息，并打印出发送的事件： 流程A： var bus = require ( 'servicebus' ) . bus ( ) ; bus . listen ( 'my.event' , function ( event ) { console . log ( event ) ; } ) ; 流程B： var bus = require ( 'servicebus' ) . bus ( ) ; setInterval ( function ( ) {
【文件预览】：
servicebus-master
----.travis.yml(417B)
----index.js(34B)
----renovate.json(41B)
----package.json(1KB)
----__tests__()
--------rabbitmq()
----test()
--------child_processes()
--------send-listen.js(5KB)
--------publish-subscribe.js(5KB)
--------bus-shim.js(551B)
--------send-listen-child_process.js(633B)
--------bus-confirm-shim.js(557B)
--------middleware()
--------subscribe-unsubscribe.js(4KB)
--------properties.js(2KB)
--------conn-channel-events.js(1KB)
----bus()
--------formatters()
--------index.js(374B)
--------rabbitmq()
--------middleware()
--------bus.js(2KB)
----LICENSE(1KB)
----package-lock.json(303KB)
----makefile(367B)
----docker-compose.yml(387B)
----.gitignore(61B)
----jest.json(164B)
----README.md(6KB)
----.editorconfig(214B)