rabbitmq 相关问题

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

使用kubernetes进行rabbit-mq部署

我正在从docker-compose迁移到kuberenetes。我们使用的服务之一是rabbit-mq。当我尝试部署rabbit-mq 3.6.16-management时,我收到错误:/ usr / local / bin / ...

回答 1 投票 1

如何检查RabbitMQ firehose是否开启

我知道如果我们使用rabbitmqctl trace_on我们可以启用firehose但是,在集群模式下,我们需要每个trace_on。有没有办法知道rabbitmq节点跟踪是否开启?哪个配置可以设置...

回答 1 投票 0

是否有可能在RabbitMq消息之后坚持下去?

在向任何rabbitMq队列发布消息时,我们可以通过传递选项对象{persistent:true}使它们持久化,我想知道是否有可用的选项...

回答 1 投票 0

死信队列Qpid

我在测试环境中使用带有qpid代理的兔子模板。除了死信队列不起作用外,一切正常。他们收到消息,但他们从未传递消息。一切 ...

回答 1 投票 1

在rabbitmq消息中添加了额外的字符

我正在尝试一个简单的生产者和消费者的rabbitMQ实例。 public void newCustomerToQueue(Custom custom)throws Exception {ConnectionFactory factory = new ConnectionFactory(); ...

回答 1 投票 1

如何使用spring rabbitmq配置不同队列中的超时,重试或最大尝试次数

是否可以为每个队列进行这些设置?我有重要的队列,所以我需要更多的重试,但有不太重要的队列,我不想配置重试,...

回答 3 投票 2

调用wcf方法时通知rabbitmq队列用户[关闭]

我们有一个托管WCF接口(ServiceHost)的Windows服务。该服务提供例如方法AddProduct。现在,如果没有错误或其他不可预见的事情发生,应通过......发送消息

回答 1 投票 -2

AMQP convertSendAndReceive无法从Spring Boot 1.5移动到2

我正在将代码从Spring Boot 1.5.x迁移到2.0.3.RELEASE。它使用RabbitMQ使用convertSendAndReceive(...)方法对一组远程引擎进行RPC样式调用。一切正常,1.5,......

回答 1 投票 2

带有rabbitmq集群和spring amqp的负载均衡器

我想在负载均衡器后面设置一个rabbitmq集群,并使用spring amqp连接到它。问题:Spring客户端是否需要知道RMQ集群中每个节点的地址,或者它是......

回答 1 投票 0

EasynetQ bus.Subscribe不开火 - 抛出“messageType不能为空”

我可以使用以下代码成功发布消息:using(IAdvancedBus bus = RabbitHutch.CreateBus(“host = 192.168.153.128:5672; username = user; password = pass”)。Advanced){...

回答 2 投票 2

Docker网络最佳实践

我有~4个微服务,一个Keycloak和一个RabbitMQ服务器,我想通过Docker部署。每个微服务都必须能够与Keycloak对话,有些人需要与RabbitMQ对话。为了保持清洁我...

回答 2 投票 7

像RabbitMq .net核心的描述一样摇摆

我们尝试使用rabbitmq进行消息传递,消息很小,目前没有太多不同的队列,因为会有许多dirrefent公司将与我们整合和数量...

回答 1 投票 1

Message Broker - 作业之间的依赖关系

我正在尝试找到一个好的队列服务器/消息代理,它可以让我将作业推送到队列,但也可以:在作业之间建立依赖关系(例如,在作业A完成后运行作业B)...

回答 1 投票 1

是否可以配置RabbitMQ Management Plugin使用的密码套件?

我有一个运行RabbitMQ 3.7.7管理映像的实例。它启用了rabbitmq-management插件,并根据文档配置为使用HTTPS:management.listener.port = 15671 ...

回答 1 投票 0

使用Spring Cloud Stream为RabbitMQ定义消费者标记

是否可以使用spring cloud stream为rabbitmq绑定定义使用者标记?例如,我绑定到rabbitmq并在管理控制台中看到以下消费者标记:...

回答 1 投票 0

NLog - RabbitMQ集群目标

我们在.Net应用程序中使用NLog将日志提供给ELK。数据流如下,NLog - > RabbitMQ - > Logstash - > Elasticsearch - > Kibana我们创建了RabbitMQ集群(3个节点带...

回答 1 投票 1

无法使用add_user命令将用户添加到RabbitMQ

我使用下面的命令将用户添加到RabbitMQ rabbitmqctl add_user heartbeat alive我得到以下错误添加用户“heartbeat”...错误:{:undef,[{:crypto,:hash,[:sha256,<< 94, 223,......

回答 1 投票 0

气流芹菜乔布斯陷入了运行状态

我正在尝试使用CeleryExecutor设置Airflow。我使用postgres作为数据库,rabbitmq作为消息代理。所有气流预定作业都将进入运行状态,但它们从未运行过。我不 ...

回答 1 投票 0

RabbitMQ - 消息传递顺序

我需要为我的新项目选择一个新的队列代理。这次我需要一个支持pub / sub的可伸缩队列,并且必须保持消息排序。我读过亚历克西斯的评论:他写道:“......

回答 4 投票 44

Node.js amqplib - 在连接关闭的情况下无法实现重新连接

当连接失败到rabbitmq队列服务器时,我正在尝试实现重新连接机制。这段代码仅用于消费消息,下面是我的代码(通道Init函数需要注意...

回答 1 投票 0

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