3回答
Spring优先级消息
、、、、
RabbitMQ中队列中的消息优先级。它正在使用rabbitmq提供的java客户端。但它不适用于对春兔的依赖。请看一下。-- Spring --> </properties><em
浏览 8提问于2016-09-11得票数 1
回答已采纳
1回答
我在spring集成中使用了聚合器，也看到了PriorityChannel的存在。是否有可能以某种方式使用其中两种方法来达到下列要求：
aggregatorAggregator的消息是从RabbitMQ接收的，存储在具有RabbitMQ进行聚合的spring组件中，但同时它根据一些复杂的排序算法对消息进行优先发布随着时间的推移，队列中的<
浏览 4提问于2020-10-02得票数 0
回答已采纳
我刚刚开始使用Spring boot RabbitMQ。我想知道在spring boot rabbitmq (注解配置)的情况下，我们如何分别配置生产者代码和消费者代码。我的意思是，如果我想在spring boot中编写rabbitmq生产者代码，用python编写消费者代码，或者反之亦然-在spring boot中编写消费者代
浏览 2提问于2018-03-25得票数 0
我的问题是因为我试图用rabbitMQ实现优先级队列，但它总是随机的。catch (Exception ex) { }我的输出是随机的，然后从第二队列接收消息。我甚至已经在application.properties中尝试过了：
spring.
浏览 22提问于2021-03-02得票数 0
我正在编写使用STOMP进行通信的应用程序。服务器端使用Spring Boot2.1.7编写，并使用外部代理RabbitMQ 3.7.1。在客户端，我使用的是StompJS。/user/queue/some-queue Spring会将其映射到/queue/some-queue-{sessionID}，然后RabbitMQ会创建具有相应名称的队列。在订阅时，我添加了标
浏览 18提问于2019-09-07得票数 0
回答已采纳
我想要实现一个优先级工作队列，其中一组消息的优先级一旦在队列中就会改变。由于它是一个具有可变处理时间的工作队列，所以不使用循环算法分配消息，而是在资源空闲时(使用每个用户限制)从队列中提取消息。我想出了两个实施方案：
使用来自RabbitMQ的优先级队列，当出现优先级更改请求时，从队列中读取具有</
浏览 1提问于2019-05-26得票数 2
您好，我有一个从应用程序A创建的RabbitMQ队列。我想从该队列中获取消息，所以我在spring boot应用程序中使用以下依赖项创建了消息侦听器： <dependency>
<groupId>org.springframework.boot1.启动spring boot应用2.向队列发送消息 问题是监听器没有监听前两条消息。这就是为什么我只用Jav
浏览 28提问于2020-04-01得票数 2
回答已采纳
3回答
我有一个远程RabbitMQ服务器，它有一些我想要侦听的队列。queues = "queueName") System.out.println(message);但是它试图创建一个新的队列结果是可预测的-访问被拒绝。如何侦听远程服务器上的现有队列？另外，是否有一种方法来检查这个队列是否存在？org.springframewor
浏览 1提问于2018-08-30得票数 2
回答已采纳
由于一些复杂的原因，我的spring启动应用程序需要在Rabbitmq服务器启动之前启动。使用spring boot initializer生成一个简单的带有AMQP的spring boot app，添加相应的配置并@RabbitListener监听某个队列。如果Rabbitmq服务器已经运行，则app与服务器连接成功；
如果应用程序先启动，然后启动Rab
浏览 3提问于2019-06-12得票数 0
我有一个可以侦听单个RabbitMQ队列的工作应用程序。但是，当我添加另一个消耗消息的bean并试图将其绑定到另一个队列时，这两个队列都不是在RabbitMQ中创建的，手动创建时也不会从这些队列中使用任何消息。=localhostspring.rabbitmq.username=guest
<
浏览 1提问于2021-03-09得票数 0
回答已采纳
我想使用一个非常简单的spring启动应用程序向rabbitmq队列demo-queue发送消息： package com.example.demo;
import java.time.LocalDateTime但是，我没有看到rabbitmq中的队列被创建并填充了生成的消息。 pom.xml为： <?xml version="1.0" encoding="UTF-8"?<grou
浏览 32提问于2020-11-24得票数 1
回答已采纳
我们的应用程序使用RabbitMQ提供的几个队列中的数据。为了增加吞吐量，我们为每个队列启动几个线程，这些线程从这些队列中进行阻塞获取。对于一个新服务，我们希望使用Spring Boot，并且每个队列都有几个线程，这些线程从这些队列中获取数据。下面是用于处理从某个队列到达的数据的规范Spring</em
浏览 1提问于2019-02-21得票数 0
1回答
针对大数据的微服务之间的通信
、、、、
我正在构建一个spring的基于云的微服务ML管道。我有一个数据摄取服务，它(当前)从SQL获取数据，这些数据需要由预测服务使用。一般的共识是写入应该使用基于异步消息的通信，使用kafka/rabbitmq。我是否应该使用API网关来调用启动管道的摄取？
浏览 0提问于2017-06-07得票数 1
1回答
为了实现数据局部性，我需要在我的芹菜- rabbitmq设置中的使用者优先级，即消费者从特定队列中选择具有偏好的任务。我如何使用这个功能？在rabbitmq示例代码(在链接中提供)中，x-priority参数已经并提供给了basicConsume。我如何在芹菜代码中实现这一点？
浏览 4提问于2016-03-08得票数 1
回答已采纳
2回答
我读过一些讨论和论坛，但仍然不明白哪一个是更好的兔子is和activemq。我听说在rabbitmq的延迟更多，因为所有的流量首先被转移到一个中心节点。如果有人能告诉我一些文档，这些文档可以突出说明在什么场景中应该使用什么，那就太好了。谢谢大家
浏览 3提问于2017-10-21得票数 6
2回答
我无法连接到RabbitMQ.RabbitMQ不在本地机器上。看起来就像spring.rabbitmq.port=15671spring.rabbitmq.host: ConfigServletWebServerApplicationContext :在上下文初始化过程中遇到<
浏览 1提问于2019-10-15得票数 1
不过，我注意到该源代码创建了RabbitMQ绑定：
}
apply plugin: &
浏览 3提问于2016-02-05得票数 3
回答已采纳
1回答
Rabbit使用者
、、、
我在pivotal cloud foundry中部署了一个spring boot应用程序。我有4个应用程序实例在运行。应用程序使用RabbitMQ中队列中的消息并进行进一步处理。如果我在RabbitMQ中将队列的消费者数量设置为40，那么这40个消费者是否会平均分布在正在侦听的应用程序中？
浏览 2提问于2017-02-10得票数 2
实际上，在我的RabbitMQ配置中，我为每个队列声明了10个消费者。所以所有的使用者线程都是在我的Spring Boot应用程序完全启动之前创建的，所以它在应用程序启动时会花费一些时间。当我的项目结束时，我想延迟加载所有的Rabbitmq队列。我尝试在configuration类上使用@Lazy，但似乎不起作用。
有没有办法声明延迟加载队列？
浏览 2提问于2021-01-17得票数 2
1回答
我正面临以下问题，这可能是由于我对RabbitMQ的理解不足所致。如果我不为RabbitMQ专家使用术语，我很抱歉。简单地说，我想在队列中发布一些具有不同优先级的消息，我希望消费者首先处理更高的优先级。--假设10条消息，前9条具有优先级1，第10条具有更高的优先级，例如2。，它使用上述队列中的</em
浏览 9提问于2022-07-19得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
