rabbitmq 相关问题

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

EventDispatcher与Messenger之间的差异

[通过Messenger发送事件和通过Symfony EventDispatcher组件发送事件之间的基本区别是什么?]

回答 1 投票 0

在单个计算机上将两个RabbitMQ实例作为Windows服务运行

我已经尝试并成功配置并运行了两个Rabbitmq实例作为Windows Server 2012中的应用程序。按照下面的教程,https://lazareski.com/multiple-rabbitmq-instances-on-1 -...

回答 1 投票 0

SpringBoot-微服务的Docker化,+ Angular + MySQL + RabbitMQ

我正在学习docker。在部署我的应用程序(Angular,SpringBoot,RabbitMQ,MySQL)时,我能够访问UI,但是由于服务与MySQL之间的连接错误而导致服务失败,并且...

回答 2 投票 0

如何在回调函数中调用函数以更改状态?

我正在实现一个Welcome Display Web应用程序,该应用程序将从RabbitMQ接收来宾姓名,并将其填充到屏幕上。在stompClient.subscribe(...的回调函数中,我想调用...

回答 1 投票 0

Spring cloud stream RabbitMQ随机失败,出现队列NOT_FOUND错误

我已经配置RabbitMQ集群,并且在RabbitMQ上使用Spring Cloud Stream进行了这样的配置:import org.springframework.cloud.stream.annotation.Input;导入org.springframework.messaging ....

回答 1 投票 0

寻求发布/订阅系统的澄清,以及API网关如何发挥作用

我是微服务架构的新手,我希望了解服务之间应该/如何进行交互。要接受我当前的故事,我需要:通过电子邮件发送文档备份...

回答 1 投票 0

为RabbitMQ客户端连接创建类

我想创建一个类(类似于RabbitMQ连接的包装器),以将消息发布到交易所。这将是另一个系统使用的类库。我的问题很漂亮...

回答 1 投票 1

我可以使用Celery发布和订阅主题吗?

我所见过的执行/安排Celery任务的所有示例都是这样的:add.delay()我想知道是否可以使用Celery做这样的事情:celery_app.publish(topic ='my-topic')And。 ..

回答 1 投票 0

ClassNotFoundException:org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig $ Builder

我正在使用flink 1.9.0和Rabbitmq连接器读取数据,我可以成功编译代码,但是当我运行代码时,出现以下错误:java.lang.NoClassDefFoundError:org / apache / flink / ...

回答 1 投票 0

如何从我的ReactJS应用程序连接到RabbitMQ?

连接到RabbitMQ实例时遇到问题,因此找不到很好的教程或指南。我可以通过var ws = new WebSocket('ws:// localhost:15674 / ws')...

回答 1 投票 0

helm / rabbitmq-ha是否经过istio的严格许可? Rabbitmq是否有一个像redis cluster这样的集群来宣布ip var?

我目前在部署helm / rabbitmq-ha时遇到问题。当Istio设置为“严格”时,它不起作用,而仅当Istio设置为“允许”时,它才起作用。最初的问题似乎是因为...

回答 1 投票 0

在运行时使用SmartLifecycle问题添加队列

因此,这是与此相关的新问题,我创建了一个案例,其中ListenerContainer实际上在阶段0的@Bean之前运行,即使它具有阶段Integer.MAX_INT。这是代码:...

回答 2 投票 0

为什么我使用op-rabbit而不是NewMotion / Akka获得ACCESS_REFUSED?

使用这些参数:canada {hosts = [“ dd.weather.gc.ca”] username =“ anonymous”密码=“ anonymous” port = 5671 exchange =“ xpublic” queue =“ q_anonymous_gsk” routingKey =“ v02。 ..

回答 1 投票 0

[使用RabbitMq服务器基于IP地址的用户限制

我们要在用户连接Rabbitmq服务器连接时限制基于IP地址的用户

回答 1 投票 0

消息队列(例如RabbitMQ)或用于微服务的Kafka?

我们正在开始一个新项目,我们在其中评估用于微服务之间异步通信的技术堆栈吗?我们正在为此考虑使用RabbitMQ和Kafka。任何人都可以阐明...

回答 1 投票 0

使用Spring AMQP自动恢复AMQP连接期间的AlreadyClosedException

我们在绑定到Rabbit MQ实例的Java应用程序的日志中遇到以下异常的情况。这是必须要解决的问题,它表示......>

回答 1 投票 0

spring-boot shutdown rabbit NoClassDefFoundError

有时会提示NoClassDefFoundError退出JVM进程,从而导致JVM进程正常退出。 https://github.com/spring-projects/spring-amqp/issues/822我使用:编译“ org ....

回答 1 投票 1

在普罗米修斯量规中处理陈旧数据

上下文:我想为RabbitMQ构建自己的导出器。为此,我设置了一个查询管理API的HTTP服务器,解析了响应并使用Prometheus格式构建了适当的响应...

回答 1 投票 0

无法与rabbitmq建立ssl连接

我正在尝试与Rabbitmq代理建立ssl连接。我遵循此页面为我提供帮助,并且找到了我的错误,但是我不知道该由谁来解决。我被困在与经纪人的测试连接中:...

回答 1 投票 3

RabbitMQ交换/队列设计-一个或几个消息

我尝试将消息路由到不同的队列,但是如果我的应用程序应该发送多条消息或仅发送一条消息,我就无法解决这个问题(可能是一个简单的问题)。例如,我想开始一个...

回答 1 投票 0

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