《rabbitmq》专题
-
WebSphere JNDI查找失败，而试图创建一个线程从servlet侦听Rabbitmq队列
1. 在查找jdbc数据源的JNDI连接时，我遇到以下错误： javax。命名。ConfigurationException:无法完成“java:”名称上的JNDI操作，因为服务器运行时无法将该操作的线程与任何J2EE应用程序组件关联。当使用“java:”名称的JNDI客户端未在服务器应用程序请求的线程上执行时，可能会出现这种情况。确保J2EE应用程序不会在静态代码块或该J2EE应用程序创建的线程
-
在RabbitMQ上运行时，Masstransit的开销是多少？
在使用Masstransit和RabbitMQ时，我看到了一个令人失望的性能。递送/获取下降到0.20/秒。我用一个简单的测试应用程序开始调查这个问题。这个应用程序并行运行，一个线程使用RabbitMQ客户机库向RabbitMQ发送消息，另一个线程使用Masstransit库向RabbitMQ发送相同的消息。RabbitMQ客户端库发送的消息是Masstransit库的10倍。 RabbitMQ运
-
向windows rabbitmq broker循环发送消息时出现问题
> 我有这样一种情况，即通过RabbitMQ从一台机器向另一台机器循环发送大约15条消息。 在发送和接收计算机之间有NAT设置。 我将spring rabbitmq用于所有rabbitmq操作。 如果我在循环中向rabbitmq发送消息，如果它不能处理，它是否有可能拒绝某些消息？15条消息的总大小接近8MB. 即使在执行向RabbitMQ发送消息之后，我也没有看到任何异常。 发送机器码
-
RabbitMQ队列在一段时间内堆满了消息，即使有与这些队列相关联的监听器
涉及2个虚拟机。 这两个VM在循环中每7秒发送25MB大小的消息。 设置了用于在机器之间传输消息的铲。 这两台机器都有侦听器来使用另一台机器发送的消息。 监听器只需使用消息并出来。侦听器端不涉及任何处理。 rabbitmQ代理已启用SSL。 我正在使用Spring RabbitMQ. 我正在使用SimpleMessageListenerContainer进行监听。 我的问题： > 在一段时间内，例
-
RabbitMQ“什么是”准备好的“和”未加载的“类型的消息？
它们之间有什么区别？ 我如何知道消费者读取了多少消息？
-
使用AsyncRabbitTemplate时回复超时：：SendandReceive-RabbitMQ
我最近在Spring Boot应用程序中从使用标准Rabbit模板改为使用异步Rabbit模板。在此过程中，我从标准的方法切换到使用方法。 进行此更改似乎不会影响向RabbitMQ发布消息，但是现在在发送消息时，我确实看到了如下所示的堆栈跟踪： 我确信我只是缺少一个配置选项，但任何帮助都将是徒劳的。 谢谢。：）
-
如何在应用程序中过滤RabbitMQ控制台侦听消息
我使用spring amqp和rabbitmq在我的应用程序中交换消息。一旦我的应用程序启动，我将在我的tomcat控制台中不断看到大量的消息监听日志。我想禁用。怎么做？ 下面是我的log4j配置。尽管我只提到了文件appender，但所有侦听器日志都在我的应用服务器控制台中打印。 需要添加任何配置吗？ 编辑帖子： 我添加了在JAVA_OPTS中。请在下面找到日志。 我的项目结构如下所示。 项目结
-
在docker容器中运行RabbitMQ
Debug.DockerFile 运行命令 正在连接RabbitMQ
-
aws ecs中docker容器间通过rabbitmq的通信
如果我们在不同的服务器上使用rabbitmq，它如何与不同的微服务进行对话？我在taskdefinition中使用网络模式作为“默认网络”，我应该将其更改为AWSVPC吗？
-
zipkin无法建立到RabbitMQ服务器的连接
我在Windows10机器上尝试将RabbitMQ(3.6.11版本与Erlang 20一起安装）连接到ZipKin，但我得到了以下错误： 原因：org.springframework.beans.factory.unsatisfieddependencyException：创建名为“server configurator”的bean时出错，该bean在zipkin2.server.interna
-
RabbitMQ embedded broker不是从Spring Boot应用程序启动的
我无法在rabbitmq代理“CustomerQ”队列中发送消息。我已经通过spring Boot将rabbitmq broker配置为嵌入式服务器。 当代码试图连接/放入队列中的任何消息时，我得到以下错误： 路径为[]的上下文中servlet[dispatcherServlet]的servlet.Service（）引发异常[请求处理失败；嵌套异常为org.SpringFramework.Mess
-
Kubernetes中的Rabbitmq：找不到命令
尝试在K8s中启动rabbitmq，同时附加configmap时会出现以下错误： 以下是我的部署中的一个片段： 配置如下：
-
axon 3通过RabbitMQ分离命令和查询服务：json vs.xml
这是有效的，当我将命令发送到命令服务时，我可以检查RabbitMQ队列中正确的JSON格式。 我的聚合接收命令和触发器事件，它们正确地存储在mySQL-EventStore中。在这里，事件是xml格式的。 现在来了棘手的部分。我使用axon-springboot通过属性再次将事件发送到rabbit队列： 警告，并且从未调用我的h2-repository-service。 我担心我为rabbit配置
-
RabbitMQ&Spring amqp重试而不阻止使用者
我正在使用RabbitMQ和Spring amqp,我希望它们不会丢失消息。通过对重试使用指数回退策略，我可能会阻止我的消费者，因为他们可能正在处理他们可以处理的消息。我想给失败的消息几天时间重试指数回退策略，但我不想让使用者阻塞几天，我想让它继续对其他消息工作。 我知道我们可以通过ActiveMQ（在将来的某个时刻重试消息（ActiveMQ））实现这种功能，但无法为RabbitMQ找到类似的解决
-
如何使用Spring AMQP从RabbitMQ接收相关ID的消息
我浏览了RabbitTemplate的API。它只提供从队列中获取消息的receive方法。但是，无法获得具有特定关联ID的消息。你能帮我理解一下我在这里错过了什么吗。 目前，我正在使用ActiveMQ的JMS API接收消息，使用以下代码创建带有消息选择器的Consumer。希望对Spring AMQP和RabbitMQ执行同样的操作：