rabbitmq 相关问题

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

意外的标记“?”当从rabbitMQ教程运行send.js或receive.js时

我尝试学习 RabbitMQ,并使用 NodeJS 遵循 Streams 示例。我复制了 send.js 和 receive.js 的源代码,但是当我运行“npm run send”或“npm run receive”时,它

回答 1 投票 0

django应用程序中使用rabbitmqp作为代理和celery运行简单任务时出现的问题

我正在尝试学习如何设置 django 应用程序来使用 celery。我使用以下命令在 Windows 计算机上的 docker 桌面上运行rabbitmq: docker run -it --rm --namerabbitmq -p 5672:5672 -p...

回答 1 投票 0

AWS ALB 入口控制器无法为 RabbitMQ 部署创建第二个负载均衡器

因此,我们尝试在我们的 preprod AWS EKS 集群上使用 helm 和 bitnami helm 图表安装 2 个 RabbitMQ 版本。 第一个 RabbitMQ 部署 (rabbitmq-qa) 已使用专业版正确安装...

回答 1 投票 0

django应用程序中使用rabbitmqp作为代理和celery来运行simpel任务时出现问题

我正在尝试学习如何设置 django 应用程序来使用 celery。我使用以下命令在 Windows 计算机上的 docker 桌面上运行rabbitmq: docker run -it --rm --namerabbitmq -p 5672:5672 -p...

回答 1 投票 0

错误:关系“OutboxState”不存在

下面是我的Program.cs设置: var builder = WebApplication.CreateBuilder(args); // 将服务添加到容器中。 builder.Services.AddControllers(); builder.Services.AddDbContext 下面是我的 Program.cs 设置: var builder = WebApplication.CreateBuilder(args); // Add services to the container. builder.Services.AddControllers(); builder.Services.AddDbContext<AuctionDbContext>(opt => { opt.UseNpgsql(builder.Configuration.GetConnectionString("DefaultConnection")); }); builder.Services.AddAutoMapper(AppDomain.CurrentDomain.GetAssemblies()); builder.Services.AddMassTransit(x => { x.AddEntityFrameworkOutbox<AuctionDbContext>(o => { o.QueryDelay = TimeSpan.FromSeconds(10); o.UsePostgres(); o.UseBusOutbox(); }); x.AddConsumersFromNamespaceContaining<AuctionCreatedFaultConsumer>(); x.SetEndpointNameFormatter(new KebabCaseEndpointNameFormatter("auction", false)); x.UsingRabbitMq((context, cfg) => { cfg.UseRetry(r => { r.Handle<RabbitMqConnectionException>(); r.Interval(5, TimeSpan.FromSeconds(10)); }); cfg.Host(builder.Configuration["RabbitMq:Host"], "/", host => { host.Username(builder.Configuration.GetValue("RabbitMq:Username", "guest")); host.Password(builder.Configuration.GetValue("RabbitMq:Password", "guest")); }); cfg.ConfigureEndpoints(context); }); }); builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme) .AddJwtBearer(options => { options.Authority = builder.Configuration["IdentityServiceUrl"]; options.RequireHttpsMetadata = false; options.TokenValidationParameters.ValidateAudience = false; options.TokenValidationParameters.NameClaimType = "username"; }); builder.Services.AddScoped<IAuctionRepository, AuctionRepository>(); builder.Services.AddGrpc(); var app = builder.Build(); // Configure the HTTP request pipeline. app.UseAuthentication(); app.UseAuthorization(); app.MapControllers(); app.MapGrpcService<GrpcAuctionService>(); var retryPolicy = Policy .Handle<NpgsqlException>() .WaitAndRetry(5, retryAttempt => TimeSpan.FromSeconds(10)); retryPolicy.ExecuteAndCapture(() => DbInitializer.InitDb(app)); app.Run(); 启动应用程序时,我收到以下错误。 fail: MassTransit.EntityFrameworkCoreIntegration.BusOutboxDeliveryService[0] ProcessMessageBatch faulted Npgsql.PostgresException (0x80004005): 42P01: relation "OutboxState" does not exist Exception data: Severity: ERROR SqlState: 42P01 MessageText: relation "OutboxState" does not exist Position: 128 File: parse_relation.c Line: 1392 Routine: parserOpenTable 我正在将 RabbitMQ 与 MassTransit 和 PostGres 数据库结合使用。 终于解决了,问题出在EntityFramework迁移上。我没有为以下 MassTransit 表添加迁移。 protected override void OnModelCreating(ModelBuilder modelBuilder) { base.OnModelCreating(modelBuilder); modelBuilder.AddInboxStateEntity(); modelBuilder.AddOutboxMessageEntity(); modelBuilder.AddOutboxStateEntity(); }

回答 1 投票 0

Rabbit mq 错误:在线程“main”java.io.IOException 中出现异常,原因是:com.rabbitmq.client.ShutdownSignalException

这是我运行 main 时遇到的错误。我不太明白为什么第 44 行有问题:channel.basicConsume(Q,true,consumer); 我的目标是尝试存储消息

回答 1 投票 0

RabbitMQ PRECONDITION_FAILED - 未知的交付标签

我们有一个 PHP 应用程序,可以通过 WebSocket 连接将消息从 RabbitMQ 转发到连接的设备(PHP AMQP pecl 扩展 v1.7.1 和 RabbitMQ 3.6.6)。 消息是从一组

回答 7 投票 0

rabbitmq-server 无法通过 systemctl start 启动

我所在的版本: 乌班图20.04.6 rabbitmq-服务器 3.12.1-1 当我使用命令 systemctl startrabbitmq-server 时,服务器无法启动: rabbitmq-server.service 的作业失败,因为控制 p...

回答 1 投票 0

无法访问已处置的对象。对象名称:'RabbitMQ.Client.Impl.AutorecoveringModel'

我开始学习 RabbitMq 并将其与我的 C# 代码一起使用,但出现以下错误: (无法访问已处置的对象。对象名称:'RabbitMQ.Client.Impl.AutorecoveringModel'。) 我试图...

回答 3 投票 0

如何使用 JMeter 和 AMQP 插件计算往返时间?

我想用 JMeter 测试我的 RabbitMQ 实现。对于我的测试,消息从发布者到消费者所需的时间很有趣。 可以用 JMet 来计算吗...

回答 1 投票 0

为什么我无法更改 RabbitMQ 跟踪插件的日志位置?

我在 Ubuntu 上并尝试将 RabbitMQ 与rabbitmq_management 和rabbitmq_tracing 插件一起使用来记录我的队列。这实际上工作得很好。 我的问题在于我...

回答 2 投票 0

有没有办法使用像 RabbitMQ 这样的队列将数据从 Strapi 发送到我的自定义后端

我正在使用 Strapi 4,我想知道每当有创建/更新/删除从我的 Strapi 管理员到我的后端通过队列时是否可以从 stapi 发送数据?这样的解决方案可行吗?

回答 1 投票 0

dotnetcore 控制台应用程序:rabbitmq 与 docker 连接被拒绝 127.0.0.1:5672

rabbit 连接: var 工厂 = 新的 ConnectionFactory() { 主机名 = Environment.GetEnvironmentVariable("RabbitMq/Host"),

回答 2 投票 0

Rabbitmq - Docker 连接在端口 5672 上被拒绝

我有一个用 Go 编写的 Web 服务器,可以与 Rabbitmq 和 Mongodb 交互。当我在没有容器的机器上运行所有这些服务器时(rabbitmq url:amqp://guest:guest@localhost:5672)它可以工作......

回答 3 投票 0

容器应用程序Azure中的RabbitMQ,看不到UI

在azure容器应用程序中部署rabbitmq:最新版本,启用端口15672; 我看不到兔子的UI,我不知道为什么看起来一切都显示得很好。 添加环境变量: -

回答 3 投票 0

RabbitMQ - 为所有用户安装

我正在设置 Windows Server 2022,安装了最新的可用 RabbitMQ 和 Erlang OTP。 我可以正常安装,没有任何问题。 但是当其他管理员想要使用rabbitMQ时,他们却不能。

回答 1 投票 0

rabbitmq 卡在启动正在进行中

我正在使用Ubuntu 22.04并尝试使用Cloudsmith快速启动脚本安装rabbitmq。 但是安装之后rabbitmq永远不会启动。它总是卡在状态:“正在启动&q...

回答 1 投票 0

事件驱动架构中的消息排序

假设有 3 个微服务 - s1、s2 和 s3。 s1 发送消息 m1。 s2 消费消息 m1,应用一些业务逻辑,然后发送消息 m2。 问题是 s3 收到消息 m2 是...

回答 1 投票 0

在 Jest 测试中有条件地模拟@golevelup/nestjs-rabbitmq

我正在尝试为我的应用程序编写一个玩笑测试。我的应用程序使用 @golevelup/nestjs-rabbitmq 来建立连接。作为测试套件的一部分,我创建了 RabbitMQWrapperModule

回答 1 投票 0

使用masstransit在rabbitmq中的队列所需的最小只写权限

我有两个控制台应用程序。一名消费者和一名生产者。两者都有自己的用户。单独的虚拟主机中有一个队列。现在我想设置生产者的队列权限来写...

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.