rabbitmq 相关问题

RabbitMQ是一个开源消息代理，最初实现AMQP协议，并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用，或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的，以及正在使用的OS和编程语言。

微服务前端的后端。 HTTP 或 RPC 与 RabbitMQ 进行通信？

我正在实现一个微服务架构，我需要使用Backend for Frontends，但是我对如何实现它与微服务的通信有疑问。您如何看待使用

rest design-patterns architecture rabbitmq microservices

回答 1 投票 0

docker 上的 Rabbitmq：应用程序 mnesia 退出原因：已停止

我正在尝试使用 docker-compose 以及 DRF 和 Celery 启动 Rabbitmq。这是我的 docker-compose 文件。除 rabbitmq 外，其他一切正常：版本：'3.7' 服务：博士：建立...

docker docker-compose rabbitmq

回答 2 投票 0

Rabbitmq 不以 docker-compose 启动

我面临下一个问题。我想在 docker 容器中运行 rabbitmq。当我使用下一个命令运行 docker image 时： docker run -it --rm --name rabbit -e RABBITMQ_DEFAULT_USER=aaa -e RABBITMQ_DEFAULT_P...

docker kubernetes rabbitmq

回答 3 投票 0

Spring RabbitMq 垃圾邮件

应用：Spring boot、RabbitMq、Logback 我使用 AmqpLogbackAppender 将日志推送到 kibana，还使用另一个 rabbitMq 进行微服务之间的通信。当我尝试连接到拉比时......

spring rabbitmq logback

回答 0 投票 0

Rabbitmq 为每个用户提供多个频道

需要：每个用户必须创建多个频道并长期保持打开状态以接收消息每个用户必须有一个免费频道才能发送消息（频道打开并......

rabbitmq chat

回答 0 投票 0

连接拒绝 AMPQ Spring 到 RabbitMq

我有一个 docker container runnig spring app consumer 但是当我想用邮递员 http://localhost:8087/queues/projqueue/size 测试这个 API 时我得到连接错误 2023-03-14 10:28:32.959 错误...

spring docker rabbitmq containers

回答 0 投票 0

不同语言客户端之间的 Rabbitmq 标头兼容性

我想使用 .NET 客户端和 AMQPCPP（C++，基于 rabbitmq-c 库）来发送和接收消息。我在不使用标头的情况下一直可以很好地发送和接收消息，但是我有

c# c++ .net rabbitmq message-queue

回答 0 投票 0

nestjs 上的模拟 rabbitMQ

我正在尝试在 nestjs 应用程序上编写端到端测试，并且我有一个 rabbitMQ 连接输入 MockType = { [P in keyof T]?: jest.Mock; }; const 模拟工厂：() => 我正在尝试在 nestjs 应用程序上编写端到端测试，并且我有一个 rabbitMQ 连接 type MockType<T> = { [P in keyof T]?: jest.Mock<object>; }; const mockFactory: () => MockType<AmqpConnection> = jest.fn(() => ({ publish: jest.fn(() => AmqpConnection), })); const moduleRef = await Test.createTestingModule({ providers: [ RabbitMQModule, { provide: AmqpConnection, useFactory: mockFactory }, ], imports: [ChallengeModule], }) .useMocker((token) => { if (token === ChallengeService) { return challengeService; } else { const mockMetadata = moduleMocker.getMetadata( token, ) as MockFunctionMetadata<any, any>; const Mock = moduleMocker.generateFromMetadata(mockMetadata); return new Mock(); } }) .overrideProvider(ChallengeService) .useValue(challengeService) .compile(); app = moduleRef.createNestApplication(); await app.init(); }); 我得到错误：错误 [AmqpConnection] 与 RabbitMQ 代理断开连接（默认）类型错误：无效的网址有帮助吗？

rabbitmq nestjs ts-jest

回答 0 投票 0

NodeJS amqp：是否可以在通道关闭操作完成之前调用 channel.close() 方法后立即使用消息？

我有一个 nodejs 应用程序，它使用 amqp 从远程服务器侦听 RabbitMQ 队列，并使用队列中的作业。 // 连接到rabbitMQ服务器并创建通道 ...

node.js multithreading asynchronous rabbitmq amqp

回答 1 投票 0

增加 Spring 应用程序中可运行线程的数量

我有一个 Spring 应用程序，它基本上在 RabbitMQ 中监听一些队列并使用消息并将它们存储在数据库中。队列的发布速率是每秒 200 条消息，我...

java spring multithreading spring-boot rabbitmq

回答 0 投票 0

How to send headers/metadata via rabbitmq in nestjs?

我想根据任何请求将本地化代码发送到我的微服务。有没有机会在 nestjs 中不使用 body 来做到这一点？像标题或元数据之类的东西。就像是 @Post('/路线')...