在SimpleMessageListenerContainer上使用addQueueNames需要更多时间
SimpleMessageListenerContainer是Spring AMQP框架中的一个组件，用于监听消息队列并处理消息。使用addQueueNames方法可以动态地向SimpleMessageListenerContainer添加需要监听的队列。
当在SimpleMessageListenerContainer上使用addQueueNames方法时，可能会导致一些额外的时间消耗。这是因为在添加新的队列之后，SimpleMessageListenerContainer需要重新初始化并重新连接到消息队列服务器。这个过程可能涉及到网络通信、重新建立连接、重新订阅队列等操作，因此会比较耗时。
然而，这个额外的时间消耗是必要的，因为它确保了SimpleMessageListenerContainer能够正确地监听新添加的队列并处理其中的消息。在实际应用中，如果需要动态地添加队列，我们可以在适当的时机调用addQueueNames方法，例如在系统启动时或者根据业务需求动态地添加队列。
SimpleMessageListenerContainer的优势在于它提供了一个简单而强大的方式来监听和处理消息队列。它可以自动管理连接、线程池、消息的接收和处理，并且提供了一些高级特性，如消息的重试、并发控制、事务管理等。通过使用SimpleMessageListenerContainer，开发人员可以更加专注于业务逻辑的实现，而无需过多关注底层的消息队列细节。
在云计算领域，SimpleMessageListenerContainer可以应用于各种场景，例如实时数据处理、消息通知、事件驱动架构等。它可以与其他云计算服务相结合，如云数据库、云存储、云函数等，构建起完整的云原生应用。
腾讯云提供了一系列与消息队列相关的产品和服务，可以与SimpleMessageListenerContainer配合使用。其中，腾讯云消息队列CMQ是一种高可用、高可靠、高性能的消息队列服务，支持消息的发布和订阅、消息的持久化和重试、消息的顺序保证等特性。您可以通过腾讯云消息队列CMQ来实现消息的发送和接收，并与SimpleMessageListenerContainer进行集成。
腾讯云消息队列CMQ产品介绍链接地址：https://cloud.tencent.com/product/cmq
相关·内容
1回答
目前，我正在测试一个与spring数据库事务相关的消息传递事务的简单示例。
用例如下：
接收到消息
一条消息被发送
数据库更新
@Transactional公共void handleMessage(EventPayload event) { MyEntity实体=新的MyEntity()；entity.setName(event.getName())；rabbitTemplate.convertAndSend("myExchange"，"payload.create"，有效载荷)；MyEntity savedEntity =entityReposit
浏览 3提问于2016-02-02得票数 4
回答已采纳
我正在尝试使用属性激活rabbitmq上的死信队列
spring.rabbitmq.listener.simple.retry.enabled=true
spring.rabbitmq.listener.simple.retry.max-attempts=10
当我使用注解时，它工作得很好
public class SimpleConsumer {
@RabbitListener(queues = "messages.queue")
public void handleMessage(String message){
throw new Run
浏览 16提问于2021-05-07得票数 0
我有一个项目与Spring-AMQP。它工作正常。我使用CachingConnectionFactory和SimpleMessageListenerContainer，并且我有一个CompositeConnectionListener来检测连接何时关闭。
但是现在我需要检测代理何时关闭(我可以用CompositeConnectionListener检测到它)，然后在不同的服务器上建立到不同代理的新连接，并使用新连接重新启动SimpleMessageListenerContainer。
我已经试了一段时间了，但我还没找到路。
有人能帮上忙吗？
谢谢!
浏览 2提问于2015-04-24得票数 0
我正在使用spring amqp rabbitmq，并使用
Message message = MessageBuilder
.withBody(item.toString().getBytes())
.setReplyTo("importReply")
.setCorrelationId(item.toString().getBytes()).build();
我的消息处理程序是
public class Foundation {
public Message importExchange(Message exchange) {
System.o
浏览 0提问于2014-04-23得票数 5
回答已采纳
1回答
我们使用基于spring的侦听器容器--大约有40个消费者，预取计数1。消息to在到达死信队列前大约60秒。
每个使用者执行的操作是一个数据库更新--这比消息到达队列的速度慢。
过了一段时间，队列中的消息堆积在一起--消费者利用率降到零。我当时的印象是，消费者在数据库上被屏蔽了。但是，如果我查看线程转储，所有使用者都处于兔子mq上的等待状态--没有消息正在处理。
"SimpleAsyncTaskExecutor-7" #51 prio=5 os_prio=0 tid=0x00007fcb01ad0800 nid=0x58f7 waiting on condition [
浏览 1提问于2016-10-06得票数 1
我有一个运行了几个月的应用程序，但是最近mq在接收消息时抛出了一个错误。当抛出错误时，应用程序不要使用更多的消息。重新启动应用程序消息的消耗正在正常运行。
错误: 4644201:2018-10-02 10:34:31,068错误SimpleAsyncTaskExecutor-1 o.s.a.r.l.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1473) -消费者线程错误，线程中止。4644418-java.lang.NoClassD
浏览 0提问于2018-10-02得票数 0
1回答
我在3个不同的服务器上有监听器。在部署时，当我在server1部署应用程序时，我希望server1上的监听器停止侦听新消息.But我希望此服务器上的监听器完成他们已经在处理的任务。我的Xml配置是Rabbit.xml
<rabbit:connection-factory id="connectionFactory" host="localhost" username="guest" password="guest" virtual-host="/"/>
<rabbit:template
浏览 3提问于2015-05-22得票数 2
在下面的示例中，我将最大和核心池大小设置为1。但是没有处理任何消息。当我启用调试日志时，我能够看到从SQS中提取的消息，但我猜它没有被处理/删除。但是，当我将核心和最大池大小增加到2时，消息似乎会被处理。
编辑
我相信Spring可能会为接收者分配一个线程，用于从队列中读取数据，因此它无法将线程分配给正在处理消息的侦听器。当我将核心池大小增加到2时，我看到消息正在从队列中读取。当我添加另一个侦听器(对于死信队列)时，我遇到了同样的问题--2个线程不够，因为消息没有被处理。当我将核心池大小增加到3时，它开始处理消息。在本例中，我假设分配了一个线程来读取队列中的消息，每个线程分配了两个侦听器。
@
浏览 1提问于2018-04-27得票数 13
回答已采纳
我有以下RabbitMQ配置
@Configuration
@IntegrationComponentScan
public class RabbitConfig {
@Autowired // TODO constructor!
private ConnectionFactory connectionFactory;
public RabbitConfig(
@Value("${article.inbound.queue}") String queueName,
@Value("${article.inbound.exchange}
浏览 0提问于2018-09-20得票数 0
回答已采纳
3回答
我使用的是一个SimpleMessageListenerContainer，每隔一个小时左右，队列就会被卡住，没有任何东西会因为破解消息而被处理。
我确信这是由于一个错误，它没有被正确捕获，但无法跟踪问题。
我已经将确认模式设置为NONE，这个“修正”了问题，但它实际上只是隐藏了问题。另外，如果我想抛出一个AmqpException并重新排队，这个消息就不能工作，确认模式设置为NONE。
我的问题是，如何跟踪队列卡住的问题，是否有方法查看unack‘s消息的有效负载？或者，如果抛出异常，是否存在允许不需要确认但重新队列消息的确认模式？
下面是我如何注册一个听者：
final SimpleMes
浏览 2提问于2015-02-02得票数 2
回答已采纳
我已经向特定的队列发布了50K个对象。我有一个监听器，它挑选每个对象并对其进行处理。但显然，处理所有50k对象将需要更多时间。所以我想多放3个监听器，它们可以并行处理这些对象。为此，我是否需要再编写两个侦听器类？用同样的代码？这将是重复的代码。有没有什么方法可以配置我们想要的监听器数量，以便在内部为同一个监听器创建实例来处理负载?有没有人能帮助我更好地支持3个以上的侦听器来处理负载以增加处理。
code=============的====Rabbit mq配置文件片段
@Bean
public SubscriberGeneralQueue1 SubscriberGeneralQueue
浏览 0提问于2018-10-19得票数 0
我的问题非常类似于这个问题：
我可以看到消息侦听器的两个调用之间存在延迟，即使队列中充满了消息。我放置了一条日志消息，其中包括方法刚开始时的时间、结束的时间以及该方法所花费的时间(以毫秒为单位)：
开始-结束-时间
2016-09-21T10:08:55.263；- 2016-09-21T10:08:55.278；- 15；
2016-09-21T10:08:55.356；- 2016-09-21T10:08:55.356；- 0；
2016-09-21T10:08:55.388；- 2016-09-21T10:08:55.388；- 0；
2016-09-21T10:08:55.466；-
浏览 2提问于2016-09-21得票数 1
我有两个RabbitMQ队列，我正在监听。对于一个队列，我需要一个使用者来确保一次只处理一条消息。第二个队列可以在一秒钟内接收大量的消息，我需要一次能够处理多条消息。
我有下面的代码，它确实像我所期望的那样工作。但我想看看是否有更好的方法来做到这一点。
@Bean
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
SimpleMessageListenerContainer cont
浏览 2提问于2018-04-05得票数 4
回答已采纳
我有2个jms监听器应用程序，一个应用程序使用DefaultMessageListenerContainer，另一个应用程序使用SimpleMessageListenerContainer。
使用DefaultMessageListenerContainer的应用程序是able，用于在EMS代理故障转移上重新连接，下面是日志
Setup of JMS message listener invoker failed for destination 'SOME.TOPIC.T' - trying to recover. Cause: Connection is closed
Cou
浏览 1提问于2018-11-13得票数 1
回答已采纳
我有一个项目，在该项目中，我从RabbitMQ队列发送和接收消息。
系统发布消息的顺序是OK的，但是它在接收消息之后的顺序是不正确的。
因此，我找到了这个段落()，并将侦听器配置为：simpleMessageListenerContainer.setPrefetchCount(1);。
我们做了一些测试，效果很好。然而，大约一周后，它开始给出类似的订购问题。
让我再解释一下：
我在一个弹簧集成应用程序中有两个流(IntegrationFlows)。
在第一个IntegrationFlow中，它创建消息并将每条消息发布到兔子队列中。
就在发布之前，它会记录每条消息，我可以确认sequenceNu
浏览 7提问于2020-04-29得票数 0
1回答
我正在定义一个消息侦听器，类似于下面定义的内容。这些消息是查询语句。将消息按顺序推送到队列中，这样在将消息推送到表时不会违反任何外键规则。当我将最大数量的消息设置为10时，我看到查询似乎是无序执行的。然而，当我把它设置为1时，我没有看到任何问题。当我将消息的最大值设置为大于1的值时，如何确保消息按与队列中相同的顺序读取？
@Bean
public SimpleMessageListenerContainer simpleMessageListenerContainer(AmazonSQSAsync amazonSQSAsync) {
SimpleMessageListenerConta
浏览 0提问于2018-04-25得票数 1
回答已采纳
我正在编写一个spring引导应用程序，它使用来自RabbitMQ的消息并对其进行处理。由于发行者正在高速发布消息，我希望我的消费者也能高速地处理它们。
我的消费者代码不是线程安全的。
以下是一种可行的方法，我想实施：
将消费者范围标记为“原型”和
在"SimpleMessageListenerContainer“中为同一个类注入多个使用者
如何使用下面的代码实现这一点？
@Bean
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
MessageListenerA
浏览 0提问于2018-03-28得票数 0
回答已采纳
我正在使用MessageListener从指定的队列中读取消息，并希望在获得队列中的消息后执行处理。
以下是我的代码
@Bean
public MessageListenerContainer messageListenerContainer()
{
SimpleMessageListenerContainer messageListenerContainer = new SimpleMessageListenerContainer();
messageListenerContainer.setConnectionFactory(connectionFactory());
浏览 0提问于2016-07-27得票数 0
我是一个经验丰富的Java程序员，我第一次尝试Spring。
我遵循了消息传递--兔the教程，完全是使用Maven的。
我是作为用户帐户在CentOS上运行的。
当我在教程的最后使用java -jar target/gs-messaging-rabbitmq-0.1.0.jar运行应用程序时，我得到了下面的连接拒绝错误。有人能帮忙吗？
prompt> java -jar target/gs-messaging-rabbitmq-0.1.0.jar
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ _
浏览 7提问于2015-05-13得票数 3
回答已采纳
我试图实现的是每15分钟从RabbitMQ队列中读取消息。从文档中可以看到，我可以使用"receiveTimeout“方法来设置间隔。
轮询消费者
AmqpTemplate本身可以用于轮询消息接收。默认情况下，如果没有可用的消息，则立即返回null。没有阻塞。从版本1.5开始，您可以设置一个receiveTimeout，以毫秒为单位，接收方法阻塞时间长达那么长，等待消息。
但是我试着用sprint集成来实现它，receiveTimeout并没有像我预期的那样工作。
下面给出了我的测试代码。
@Bean
Queue createMessageQueue() {
浏览 1提问于2021-09-27得票数 0
回答已采纳
我正在使用AyncRabbitTemplate发布消息。在发布时给出一个不正确的(不存在的)队列名-它会静默地删除消息。
我已经尝试在AyncRabbitTemplate上启用confirm和mandate，并添加了所需的回调方法，如下所示：
@Bean
AsyncRabbitTemplate template() {
RabbitTemplate rabbit = rabbitTemplate();
rabbit.setChannelTransacted(true); //to throw error when channel shuts down in ca
浏览 0提问于2018-04-26得票数 0
我有一个dsl流，这与队列通道工作得很好。然而，当我使用Rendezvous通道使其同步时，我得到的确认速率最多为30条消息/秒。我的处理程序只用了350微秒就完成了这个过程，但确认率一直很低。这极大地堆积了兔子队列。我甚至将并发用户扩展到10个，并增加了预取，但这并没有帮助。然后我自己添加了几个更大规模的实例，但这有助于将ack速率提高到45/秒左右。
怎样才能让flow faster更快？我期望的速度超过每秒500。
Dsl流：
SimpleMessageListenerContainer simpleMessageListenerContainer = profileTagRabbitM
浏览 0提问于2018-03-04得票数 1
我想在java RabbitMq( SpringBoot )中实现一个AMQP消息，但是当我收到消息时，它说不能反序列化这个message，因为即使我在类路径中有该类，也找不到我应该接收的对象的类。
RabbitMqListener.java:
@EnableRabbit
@Component
public class RabbitMqListener {
Logger logger = Logger.getLogger(RabbitMqListener.class);
@RabbitListener(queues = "queue2")
public
浏览 10提问于2016-07-11得票数 1
回答已采纳
我在@Service类中的方法上使用了@Retryable批注
@Service
@EnableRetry
public class PushService {
@Retryable(maxAttempts=5)
public Result pushIt(myMessage messageIn) {
...
}
}
它的工作方式很简单:我直接从RabbitMQ收到一条消息，直到没有错误或尝试次数达到5次时才会得到确认，此时消息会直接到达DLQ，就像我想要的那样。
我唯一的问题是，我需要从属性文件中动态设置maxAttempts。解决方案应该是设置一个
浏览 0提问于2015-04-08得票数 4
回答已采纳
我想以编程的方式注册一个spring，(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer)
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueueNames(queueName);
container.setMessageListener(listenerAd
浏览 5提问于2017-05-24得票数 0
回答已采纳
我有一个spring引导项目，在这个项目中，我试图与一个rabbitmq服务器集成，这样我就可以将消息发布到/从队列中读取。
以下是我的rabbitmq配置(编辑后只显示相关细节)：
@Configuration
@ConfigurationProperties(prefix="rabbit")
public class RabbitConfig {
private String queue;
@Bean
Queue queue() {
return new Queue(queue, durable);
}
@Bean
浏览 20提问于2017-08-22得票数 3
回答已采纳
1回答
我刚接触过rabbitmq，我正在尝试在rabbitmq中发送一个.sh文件。我已经安排好了排队和交换。我使用的是spring-amqp，我可以用listerner容器发送json消息。
public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
container.setQueues(top
浏览 2提问于2015-04-16得票数 0
回答已采纳
我正在尝试建立从我的应用程序到兔子经纪人的最大重试次数。我有重试拦截器
@Bean
public RetryOperationsInterceptor retryOperationsInterceptor() {
return RetryInterceptorBuilder.stateless()
.maxAttempts(CommonConstants.MAX_AMQP_RETRIES)
.backOffOptions(500, 2.0, 3000)
.build();
}
这个在侦听器容器中使用，
contai
浏览 4提问于2017-02-21得票数 0
回答已采纳
1回答
我正在构建一个使用AWS SQS队列的Spring应用程序。我能够使用队列，但是我似乎不能在多个并发的消费者中这样做。
当从命令行mvn spring-boot:run运行时，它会连接到SQS，每次只接收一个消息。侦听器方法有额外的代码，这会导致几个第二个延迟，在此期间，我希望接收和处理第二条消息。
就好像配置没有被使用一样。
pom.xml：
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent<
浏览 1提问于2018-10-02得票数 7
我正在使用Spring库来轮询SQS。如何设置投票间隔？
@Bean
@Primary
public AmazonSQSAsync amazonSQSAsync() {
return AmazonSQSAsyncClientBuilder.standard().
withCredentials(awsCredentialsProvider()).
withClientConfiguration(clientConfiguration()).
build();
}
@Bean
@ConfigurationProp
浏览 2提问于2018-04-27得票数 4
回答已采纳
RabbitMQ提供了可选设置预取计数的能力。
使用spring的SimpleMessageListenerContainer，我注意到预取计数总是被设置的。我不能将预取计数设置为0，因为SimpleMessageListenerContainer将其设置为至少txSize，该值必须大于零(即使不涉及事务)。那么是否有一种方法可以禁用预取计数，即使其不受限制？
以下是spring的相关代码：
SimpleMessageListenerContainer.createBlockingQueueConsumer()这样做：
int actualPrefetchCount = prefetc
浏览 5提问于2016-06-11得票数 1
回答已采纳
使用spring 4。我正在创建一个
SimpleMessageListenerContainer
从工厂的方法
@Configuration @Bean
@Bean( name = "container" )
SimpleMessageListenerContainer container(){
...
...
如何在JMX上公开这个实例？因为@ManagedResource只能应用于类
浏览 5提问于2015-11-15得票数 0
回答已采纳
1回答
我们正试图关闭所有在微服务中运行的进程。
任何消费者在试图破解当前消息时都在做一些工作
频道上的任何其他动作。我想让消费者完成他们正在处理的任何消息，然后关闭所有的东西。
如果我们停止正在运行的进程并允许数据传输，那么等待到关闭钩子超时中提到的指定时间段，然后它被终止。
我们创建了如下所示的bean
@Bean
public SimpleMessageListenerContainer SimpleMessageListenerContainer() {
SimpleMessageListenerContainer container = new Sim
浏览 1提问于2018-02-12得票数 0
回答已采纳
1回答
确切的用法如下：
@Slf4j
public class Client<E, Key> {
@Getter @NonNull private final UpdateListener<E, Key> updateListener;
@NonNull private final SubscriptionFactory subscriptionFactory;
@NonNull private final Map<Key, Instant> updatedRegistry = new ConcurrentHashMap<&g
浏览 1提问于2015-04-28得票数 1
回答已采纳
我有一个使用SimpleMessageListenerContainer从队列中消费消息的场景。当这些订阅队列中的任何一个被删除时，我希望得到通知或事件。
SimpleMessageListenerContainer simpleMessageListenerContainer
= new SimpleMessageListenerContainer(cachingConnectionFactory);
simpleMessageListenerContainer.setQueueNames(
"testQueue1","testQueu
浏览 1提问于2015-06-23得票数 1
我使用的是:SpringBoot1.4.7，SpringIntegration4.3.10，RabbitMQ 3.6.5
我有一个Spring应用程序，它有几个流，这些流向rabbitMQ代理发送和接收消息。
我有一个问题，当“关闭”执行器被称为应用程序时，并不总是干净地关闭。
在执行线程转储之后，我可以看到一个"SimpleMessageListenerContainer“线程在”发送“操作中被阻塞到代理：
"org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer#0-1" #81
浏览 3提问于2017-08-23得票数 1
回答已采纳
我正在使用来自几个服务器的AmqpTemplate.sendAndReceive功能，它可以工作，并且在rabbitmq重新启动或网络问题之后重新连接工作。
它工作了几个星期，但是突然间，我的一个服务器对每个sendAndReceive调用都超时了，rabbitmq正在接收消息，并且正在处理它，但是sendAndReceive没有得到响应(回复超时设置为60秒，处理消息只需几秒钟)。其他服务器在同一时间使用相同的代码和使用相同的队列。
只有在我重新启动服务器上的服务之后，服务器才返回工作。
我认为这是一些重新连接的问题(即使成功地发送到rabbitmq的消息)，也许AmqpTemplate响应
浏览 0提问于2015-06-09得票数 1
回答已采纳
正如标题所述，我正在寻找一个关于DSL流中的errorHandling的好例子。具体来说，我希望处理来自服务激活器的错误。
示例：
IntegrationFlows.from(Amqp.inboundAdapter(simpleMessageListenerContainer()))
.transform(new JsonToObjectTransformer(AlbumDescriptor.class))
.handle(AlbumDescriptor.class, (p,h) -> transformXml(p))
.transform(new ObjectT
浏览 2提问于2014-09-17得票数 4
回答已采纳
1回答
在某些有意发生的情况下，我使用了一些异常来拒绝消息，但是在控制台中显示了异常，乍一看，这看起来不太好。
如何在控制台/文件上登录时隐藏特定的异常？
我用的是弹簧引导和默认的记录器！
public static class UndispatchException extends
AmqpRejectAndDontRequeueException{
public UndispatchException() {
super("Dispatch still looking for a driver");
}
}
在这里，李斯特
@Ra
浏览 2提问于2018-05-15得票数 2
回答已采纳
我正在尝试使用Spring创建一个RabbitMQ配置类。文档中没有提到如何在TopicExchange中设置多个主题。我该怎么做？到目前为止，我有这段Java代码，但我不清楚如何在下面的绑定方法中设置多个主题，因为它只返回一个绑定。如果我需要多个主题，我不需要多个绑定吗？
@Configuration
@EnableRabbit
public class MessageReceiverConfiguration {
final static String queueName = "identity";
final static String topic1 =
浏览 9提问于2015-10-12得票数 8
回答已采纳
1回答
@Transactional
public void handleMessage(EventPayload event) {
Shop shop = new Shop();
shop.setName(event.getName());
Shop savedShop = shopService.create(shop);
log.info("Created shop {} from event {}", shop, event);
}
在shopService.create中，我保存了商店并发
浏览 0提问于2015-11-10得票数 2
我有一个线程睡眠的MessageListener.onMessage。我正在模拟实际的处理时间，onMessage方法将通过上面提到的线程睡眠。然而，我注意到的是，对其余消息连续多次调用，直到它们被onMessage方法处理为止。我认为这是一种低效率的行为。
实际消息计数到队列: 1000
点击率运行号码的输出
onMessage<<15656
onMessage<<15657
onMessage<<15658
onMessage<<15659
onMessage<<15660
onMessage<<15661
onMes
浏览 3提问于2020-01-24得票数 0
回答已采纳
我在10个不同的虚拟主机中有大约10个不同的rabbit队列可供连接。对于每个队列，在我的spring boot应用程序中定义了一个单独的SimpleMessageListenerContainer bean，并使用每个特定的SimpleMessageListenerContainer创建了一个单独的Spring Integration流。
SimpleMessageListenerContainer的并发性设置为1-3。每个SimpleMessageListenerContainer bean都使用单独的CachingConnectoryFacory bean。Connection F
浏览 22提问于2021-05-27得票数 0
回答已采纳
在中，它有以下代码将记录从表中取出，并将它们转换为消息并发送到通道。但是我的系统是rabbitmq，所以我想要来自jdbc的消息存储在rabbitmq中，并由rabbitmq客户端消费。如何使用spring集成和spring rabbitmq实现这一目的？
<int-jdbc:inbound-channel-adapter query="select * from item where status=2"
channel="target" data-source="dataSource"
update="update
浏览 1提问于2014-12-25得票数 1
回答已采纳
我正在尝试实现此中描述的死信消息的重新路由。我使用的是Spring config。我不知道如何读取headers来获取原始的路由键和原始队列。以下是我的配置：
@Configuration
public class NotifEngineRabbitMQConfig {
@Bean
public MessageHandler handler(){
return new MessageHandler();
}
@Bean
public Jackson2JsonMessageConverter messageConverter(){
浏览 0提问于2016-06-02得票数 3
1回答
我正在使用spring批处理远程分区来读取输入文件并处理它们。为了使输入文件在所有服务器上可用，我添加了步骤监听器，它检查是否存在输入文件，并从主服务器下载它们。
<step id="importExchangesStep">
<tasklet transaction-manager="transactionManager">
<chunk reader="importExchangesFileItemReader" writer="importExchangesItemWriter&
浏览 2提问于2014-06-26得票数 1
1回答
，我有这个代码
@Bean
open fun messageConverter(om: ObjectMapper): MessageConverter {
return Jackson2JsonMessageConverter(om)
}
@Bean
open fun rabbitListenerContainerFactory(cf: ConnectionFactory, mc: MessageConverter ): SimpleRabbitListenerContainerFactory {
val factory = SimpleRabbitListenerConta
浏览 2提问于2019-03-06得票数 1
回答已采纳
我昨天安装了Memcached，并最终使Spring @Cachable注释工作..。
这个代码块完美地缓存：
@Component("CacheProcessor")
public class CacheProcessor {
@Cacheable(value = "defaultCache", key="'dateTime-'.concat(#anything)")
public String getDateTime2(String anything) {
Date d = new Date()
浏览 2提问于2015-08-20得票数 0
回答已采纳
为了从队列中接收消息，我很难获得与RabbitMQ集成的Spring 3应用程序(我不需要发送消息)。
挑战的一部分是现在与Spring相关的大部分文档。是有用的，但是在我的例子中，遵循这些步骤似乎不起作用。例如，指南包括以下案文：
消息侦听器容器和接收方bean是侦听消息所需的全部。
因此，我使用以下代码设置了侦听器容器和接收方bean。
设置消息处理程序
@Component
public class CustomMessageHandler {
public void handleMessage(String text) {
System.out.pri
浏览 1提问于2019-10-31得票数 0
我对Spring模块非常陌生。我成功地创建了一个生成和使用消息的简单项目。我不明白的是：
如果在SimpleMessageListenerContainer中只有一个侦听器，并且配置了多个并发使用者，那么它将如何提高性能？根据我的理解，只要我有一个处理消息的侦听器，那么无论有多少使用者(线程)从队列中接收消息并不重要。
这是我的代码供你参考：
@Bean
public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleM
浏览 0提问于2016-03-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
