rabbitmq - 消息模式 - RabbitMQ/NestJS

Question

我正在尝试集成到使用 NestJS 完成的项目中，这是一个简单的 api，您可以在其中发布带有名称（或模式）的消息并将其发送到已实现与名称匹配的处理程序的系统。

我正在构建的系统非常小，使用 NestJS 并没有多大意义。

我遇到的问题如下：

我正在创建一个简单的 api 来触发将消息发布到队列中。消费者在使用 NestJS 的系统上。

我不知道如何为该消息提供该系统可识别的模式。例如：

假设我想发布一条名为“CreateRecord”的消息，其有效负载要从另一个系统处理，该系统具有同名的处理程序和实现。

使用 amqplib 如何给消息命名或模式？

score 2 · Accepted Answer

您可以在发布消息时在内容对象中提供模式。

publish(
  'my_exchange',
  'routing_key',
  { pattern: 'CreateRecord', data: 'Record' },
);

1 回答 1