消息侦听器容器配置

配置一个SimpleMessageListenerContainer(SMLC) 和DirectMessageListenerContainer(DMLC) 与交易和服务质量相关,其中一些相互交互。 适用于 SMLC、DMLC 或StreamListenerContainer(StLC)(请参阅使用 RabbitMQ 流插件)由相应列中的复选标记指示。 请参阅选择容器,了解可帮助您确定哪个容器适合您的应用程序的信息。spring-doc.cadn.net.cn

下表显示了使用命名空间配置<rabbit:listener-container/>. 这typeattribute 可以是simple(默认)或direct要指定SMLCDMLC分别。 某些属性不由命名空间公开。 这些由N/A对于属性。spring-doc.cadn.net.cn

表 1.消息侦听器容器的配置选项
财产 (属性) 描述 SMLC 公司 DMLC StLC

ackTimeout
(不适用)spring-doc.cadn.net.cn

什么时候messagesPerAck设置了 TIMEOUT 时,此 timeout 将用作发送 ACK 的替代方法。 当新消息到达时,将未确认的消息计数与messagesPerAck,并将自上次 ACK 以来的时间与此值进行比较。 如果任一条件为true,则消息将被确认。 当没有新消息到达并且有未确认的消息时,此超时是近似值,因为仅检查每个条件monitorInterval. 另请参阅messagesPerAckmonitorInterval在此表中。spring-doc.cadn.net.cn

刻度线

acknowledgeMode
(确认)spring-doc.cadn.net.cn

  • NONE:不发送确认(不兼容channelTransacted=true). RabbitMQ 将此称为“autoack”,因为代理假定所有消息都已确认,而无需使用者执行任何作。spring-doc.cadn.net.cn

  • MANUAL:侦听器必须通过调用Channel.basicAck().spring-doc.cadn.net.cn

  • AUTO:容器会自动确认消息,除非MessageListener引发异常。 请注意,acknowledgeMode是对channelTransacted— 如果通道是事务处理的,则 broker 除了需要 ACK 之外,还需要提交通知。 这是默认模式。 另请参阅batchSize.spring-doc.cadn.net.cn

刻度线
刻度线

adviceChain
(建议链)spring-doc.cadn.net.cn

应用于侦听器执行的 AOP Advice 数组。 这可用于应用其他横切关注点,例如在 broker 死亡时自动重试。 请注意,在 AMQP 错误之后的简单重新连接由CachingConnectionFactory,只要 broker 还活着。spring-doc.cadn.net.cn

刻度线
刻度线

afterReceivePostProcessors
(不适用)spring-doc.cadn.net.cn

一个MessagePostProcessor在调用侦听器之前调用的实例。 后处理器可以实现PriorityOrderedOrdered. 数组使用最后调用的无序成员进行排序。 如果后处理器返回null,则消息将被丢弃(并确认,如果适用)。spring-doc.cadn.net.cn

刻度线
刻度线

alwaysRequeueWithTxManagerRollback
(不适用)spring-doc.cadn.net.cn

设置为true在配置事务管理器时,始终在 rollback 上对消息重新排队。spring-doc.cadn.net.cn

刻度线
刻度线

autoDeclare
(自动声明)spring-doc.cadn.net.cn

当设置为true(默认),容器使用RabbitAdmin重新声明所有 AMQP 对象(队列、交换、绑定),如果它检测到在启动期间至少缺少一个队列,可能是因为它是一个auto-delete或过期的队列,但如果队列因任何原因丢失,则重新声明将继续。 要禁用此行为,请将此属性设置为false. 请注意,如果容器的所有队列都缺失,则容器将无法启动。spring-doc.cadn.net.cn

在版本 1.6 之前,如果上下文中有多个 admin,则容器将随机选择一个。 如果没有管理员,它将在内部创建一个管理员。 无论哪种情况,都可能导致意外结果。 从版本 1.6 开始,对于autoDeclare要起作用,必须只有一个RabbitAdmin中,或者必须使用rabbitAdmin财产。
刻度线
刻度线

autoStartup
(自动启动)spring-doc.cadn.net.cn

标志,指示容器应在ApplicationContextdoes(作为SmartLifecycle回调,这发生在所有 bean 初始化之后)。 默认为true,但您可以将其设置为false如果您的代理在启动时可能不可用,请调用start()稍后当您知道 broker 已准备就绪时手动作。spring-doc.cadn.net.cn

刻度线
刻度线
刻度线

batchSize
(交易大小) (批量大小)spring-doc.cadn.net.cn

当与acknowledgeMode设置为AUTO,容器会尝试在发送 ack 之前处理最多此数量的消息(等待每条消息直到接收超时设置)。 这也是提交事务通道时。 如果prefetchCount小于batchSize,则会增加以匹配batchSize.spring-doc.cadn.net.cn

刻度线

batchingStrategy
(不适用)spring-doc.cadn.net.cn

对消息进行 debatchng 时使用的策略。 违约SimpleDebatchingStrategy. 请参阅批处理使用 Batching 进行@RabbitListenerspring-doc.cadn.net.cn

刻度线
刻度线

channelTransacted
(通道事务处理)spring-doc.cadn.net.cn

Boolean 标志,表示应在事务中确认所有消息(手动或自动)。spring-doc.cadn.net.cn

刻度线
刻度线

concurrency
(不适用)spring-doc.cadn.net.cn

m-n每个侦听器的并发使用者范围(最小值、最大值)。 苟n提供,n是固定数量的使用者。 请参阅 侦听器并发spring-doc.cadn.net.cn

刻度线

concurrentConsumers
(并发)spring-doc.cadn.net.cn

每个侦听器最初要启动的并发使用者数。 请参阅 侦听器并发。 对于StLC,并发是通过重载的superStream方法;请参阅使用具有单个活动使用者的 Super Streamsspring-doc.cadn.net.cn

刻度线
刻度线

connectionFactory
(连接工厂)spring-doc.cadn.net.cn

ConnectionFactory. 使用 XML 名称空间进行配置时,默认引用的 Bean 名称为rabbitConnectionFactory.spring-doc.cadn.net.cn

刻度线
刻度线

consecutiveActiveTrigger
(min-consecutive-active)spring-doc.cadn.net.cn

在考虑启动新使用者时,使用者在未发生接收超时的情况下接收的连续消息的最小数量。 也受 'batchSize' 影响。 请参阅 侦听器并发。 默认值:10。spring-doc.cadn.net.cn

刻度线

consecutiveIdleTrigger
(min-consecutive-idle)spring-doc.cadn.net.cn

使用者在考虑停止使用者之前必须经历的最小接收超时次数。 也受 'batchSize' 影响。 请参阅 侦听器并发。 默认值:10。spring-doc.cadn.net.cn

刻度线

consumerBatchEnabled
(已启用批处理)spring-doc.cadn.net.cn

如果MessageListener支持它,将此项设置为 true 可启用离散消息的批处理,最高可达batchSize;如果没有新消息到达,将传递部分批处理receiveTimeout或收集批量消息的时间已超过batchReceiveTimeout. 如果为 false,则仅支持由 producer 创建的批处理;请参阅 批处理spring-doc.cadn.net.cn

刻度线

consumerCustomizer
(不适用)spring-doc.cadn.net.cn

一个ConsumerCustomizer用于修改容器创建的流使用者的 bean。spring-doc.cadn.net.cn

刻度线

consumerStartTimeout
(不适用)spring-doc.cadn.net.cn

等待使用者线程启动的时间(以毫秒为单位)。 如果超过此时间,则会写入错误日志。 发生这种情况的一个示例是,如果配置了taskExecutor没有足够的线程来支持容器concurrentConsumers.spring-doc.cadn.net.cn

请参阅 线程处理和异步使用者。 默认值:60000(1 分钟)。spring-doc.cadn.net.cn

刻度线

consumerTagStrategy
(消费者标签策略)spring-doc.cadn.net.cn

设置 ConsumerTagStrategy 的实现,以便为每个使用者创建一个(唯一)标签。spring-doc.cadn.net.cn

刻度线
刻度线

consumersPerQueue
(每个队列的使用者数)spring-doc.cadn.net.cn

要为每个配置的队列创建的使用者数量。 请参阅 侦听器并发spring-doc.cadn.net.cn

刻度线

consumeDelay
(不适用)spring-doc.cadn.net.cn

当使用 RabbitMQ 分片插件concurrentConsumers > 1,则存在争用条件,该条件可能会阻止使用者在分片之间均匀分布。 使用此属性可在使用者启动之间添加一个小的延迟,以避免这种争用条件。 您应该尝试各种值以确定适合您环境的延迟。spring-doc.cadn.net.cn

刻度线
刻度线

debatchingEnabled
(不适用)spring-doc.cadn.net.cn

如果为 true,则侦听器容器将对批处理消息进行 Debatch,并使用批处理中的每条消息调用侦听器。 从版本 2.2.7 开始,生产者创建的批处理将被解批处理为List<Message>如果侦听器是BatchMessageListenerChannelAwareBatchMessageListener. 否则,将一次显示一个来自批处理的消息。 默认为 true。 请参阅批处理使用 Batching 进行@RabbitListenerspring-doc.cadn.net.cn

刻度线
刻度线

declarationRetries
(declaration-retriries)spring-doc.cadn.net.cn

被动队列声明失败时的重试尝试次数。 被动队列声明发生在使用者启动时,或者从多个队列中使用时,当初始化期间并非所有队列都可用时。 当重试用尽后无法被动声明任何已配置的队列时(出于任何原因),容器行为由前面描述的“missingQueuesFatal”属性控制。 默认值:重试 3 次(总共 4 次尝试)。spring-doc.cadn.net.cn

刻度线

defaultRequeueRejected
(重新排队-被拒绝)spring-doc.cadn.net.cn

确定是否应将因侦听器引发异常而被拒绝的消息重新排队。 违约:true.spring-doc.cadn.net.cn

刻度线
刻度线

errorHandler
(错误处理程序)spring-doc.cadn.net.cn

ErrorHandler策略来处理在执行 MessageListener 期间可能发生的任何未捕获的异常。 违约:ConditionalRejectingErrorHandlerspring-doc.cadn.net.cn

刻度线
刻度线

exclusive
(独家)spring-doc.cadn.net.cn

确定此容器中的单个使用者是否具有对队列的独占访问权限。 当true. 如果另一个使用者具有独占访问权限,则容器会尝试根据recovery-intervalrecovery-back-off. 使用命名空间时,此属性显示在<rabbit:listener/>元素以及队列名称。 违约:false.spring-doc.cadn.net.cn

刻度线
刻度线

exclusiveConsumerExceptionLogger
(不适用)spring-doc.cadn.net.cn

当独占使用者无法访问队列时使用的异常记录器。 默认情况下,这记录在WARN水平。spring-doc.cadn.net.cn

刻度线
刻度线

failedDeclarationRetryInterval
(失败声明 -重试间隔)spring-doc.cadn.net.cn

被动队列声明重试尝试之间的间隔。 被动队列声明发生在使用者启动时,或者从多个队列中使用时,当初始化期间并非所有队列都可用时。 默认值:5000(5 秒)。spring-doc.cadn.net.cn

刻度线
刻度线

forceCloseChannel
(不适用)spring-doc.cadn.net.cn

如果使用者在shutdownTimeout,如果这是true,通道将被关闭,从而导致任何未确认的消息重新排队。 默认为true从 2.0 开始。 您可以将其设置为false以恢复到之前的行为。spring-doc.cadn.net.cn

刻度线
刻度线

forceStop
(不适用)spring-doc.cadn.net.cn

设置为 true 可在处理当前记录后停止(当容器停止时);导致所有预取的消息重新排队。 默认情况下,容器会取消 Consumer 并在停止之前处理所有预取的消息。 版本 2.4.14、3.0.6 的最新版本 默认为false.spring-doc.cadn.net.cn

刻度线
刻度线

globalQos
(全局 QoS)spring-doc.cadn.net.cn

如果为 true,则prefetchCount全局应用于通道,而不是通道上的每个使用者。 看basicQos.global了解更多信息。spring-doc.cadn.net.cn

刻度线
刻度线

(群展)spring-doc.cadn.net.cn

这仅在使用 namespace 时可用。 指定后,类型为Collection<MessageListenerContainer>使用此名称注册,并且 container 中每个<listener/>元素添加到集合中。 例如,这允许通过迭代集合来启动和停止容器组。 如果多个<listener-container/>元素具有相同的 group 值,集合表单中的 containers 如此指定的所有容器的集合。spring-doc.cadn.net.cn

刻度线
刻度线

idleEventInterval
(空闲事件间隔)spring-doc.cadn.net.cn

请参阅 检测空闲的异步使用者spring-doc.cadn.net.cn

刻度线
刻度线

javaLangErrorHandler
(不适用)spring-doc.cadn.net.cn

AbstractMessageListenerContainer.JavaLangErrorHandler当容器线程捕获Error. 默认实现调用System.exit(99);要恢复到之前的行为(不执行任何作),请添加 no-op 处理程序。spring-doc.cadn.net.cn

刻度线
刻度线

maxConcurrentConsumers
(最大并发)spring-doc.cadn.net.cn

如果需要,按需启动的最大并发使用者数。 必须大于或等于 'concurrentConsumers'。 请参阅 侦听器并发spring-doc.cadn.net.cn

刻度线

messagesPerAck
(不适用)spring-doc.cadn.net.cn

ack 之间要接收的消息数。 使用此选项可以减少发送到代理的 ack 数(以增加重新传送消息的可能性为代价)。 通常,您应该仅在高容量侦听器容器上设置此属性。 如果设置了此选项并且消息被拒绝(引发异常),则会确认待处理的确认并拒绝失败的消息。 不允许用于事务处理通道。 如果prefetchCount小于messagesPerAck,则会增加以匹配messagesPerAck. 默认值:ack every message 另请参阅ackTimeout在此表中。spring-doc.cadn.net.cn

刻度线

mismatchedQueuesFatal
(mismatched-queues-fatal)spring-doc.cadn.net.cn

当容器启动时,如果此属性为true(默认:false),容器会检查上下文中声明的所有队列是否与代理上已有的队列兼容。 如果不匹配的属性(例如auto-delete) 或参数(例如x-message-ttl) 存在时,容器(和应用程序上下文)无法启动并出现致命异常。spring-doc.cadn.net.cn

如果在恢复过程中检测到问题(例如,在丢失连接后),则容器将停止。spring-doc.cadn.net.cn

必须有一个RabbitAdmin在应用程序上下文中(或使用rabbitAdmin属性)。 否则,此属性必须为false.spring-doc.cadn.net.cn

如果代理在初始启动期间不可用,则容器将启动,并在建立连接时检查条件。
将针对上下文中的所有队列进行检查,而不仅仅是针对特定侦听器配置为使用的队列。 如果您希望将检查限制为容器使用的那些队列,您应该配置一个单独的RabbitAdmin对于容器,并使用rabbitAdmin财产。 有关更多信息,请参阅 条件声明
在 为@RabbitListener在标记了@Lazy. 这是为了避免潜在的死锁,这可能会使此类容器的启动延迟长达 60 秒。 使用惰性侦听器 bean 的应用程序应该在获取对惰性 bean 的引用之前检查队列参数。
刻度线
刻度线

missingQueuesFatal
(缺少队列致命)spring-doc.cadn.net.cn

当设置为true(默认),如果代理上没有任何配置的队列可用,则将其视为致命队列。 这会导致应用程序上下文在启动期间无法初始化。 此外,在容器运行时删除队列时,默认情况下,使用者会重试 3 次以连接到队列(间隔 5 秒),并在这些尝试失败时停止容器。spring-doc.cadn.net.cn

这在以前的版本中是不可配置的。spring-doc.cadn.net.cn

当设置为false,在进行 3 次重试后,容器将进入恢复模式,就像其他问题(如代理关闭)一样。 容器尝试根据recoveryInterval财产。 在每次恢复尝试期间,每个使用者再次尝试四次,以 5 秒的间隔被动声明队列。 这个过程无限期地持续下去。spring-doc.cadn.net.cn

您还可以使用 properties Bean 为所有容器全局设置属性,如下所示:spring-doc.cadn.net.cn

<util:properties
        id="spring.amqp.global.properties">
    <prop key="mlc.missing.queues.fatal">
        false
    </prop>
</util:properties>

此全局属性不适用于具有显式missingQueuesFatal属性集。spring-doc.cadn.net.cn

默认重试属性(每隔 5 秒重试 3 次)可以通过设置以下属性来覆盖。spring-doc.cadn.net.cn

在 为@RabbitListener在标记了@Lazy. 这是为了避免潜在的死锁,这可能会使此类容器的启动延迟长达 60 秒。 使用惰性侦听器 bean 的应用程序应该在获取对惰性 bean 的引用之前检查队列。
刻度线
刻度线

monitorInterval
(监控间隔)spring-doc.cadn.net.cn

使用 DMLC 时,将计划在此间隔运行任务,以监控使用者的状态并恢复任何失败的状态。spring-doc.cadn.net.cn

刻度线

noLocal
(不适用)spring-doc.cadn.net.cn

设置为true以禁用从服务器向使用者传送在同一通道连接上发布的消息。spring-doc.cadn.net.cn

刻度线
刻度线

phase
(阶段)spring-doc.cadn.net.cn

什么时候autoStartuptrue,此容器应在其中启动和停止的生命周期阶段。 值越低,此容器开始得越早,停止得越晚。 默认值为Integer.MAX_VALUE,这意味着容器会尽可能晚地启动并尽快停止。spring-doc.cadn.net.cn

刻度线
刻度线

possibleAuthenticationFailureFatal
(可能的身份验证失败致命)spring-doc.cadn.net.cn

当设置为true(SMLC 的默认值),如果PossibleAuthenticationFailureException在连接期间引发,则被视为致命的。 这会导致应用程序上下文在启动期间无法初始化(如果容器配置了自动启动)。spring-doc.cadn.net.cn

2.0 版本开始。spring-doc.cadn.net.cn

DirectMessageListenerContainerspring-doc.cadn.net.cn

当设置为false(默认),则每个使用者将尝试根据monitorInterval.spring-doc.cadn.net.cn

SimpleMessageListenerContainer (简单消息监听器容器)spring-doc.cadn.net.cn

当设置为false,在进行 3 次重试后,容器将进入恢复模式,就像其他问题一样,比如代理宕机。 容器将尝试根据recoveryInterval财产。 在每次恢复尝试期间,每个使用者将再次尝试 4 次以启动。 这个过程将无限期地持续下去。spring-doc.cadn.net.cn

您还可以使用 properties Bean 为所有容器全局设置属性,如下所示:spring-doc.cadn.net.cn

<util:properties
    id="spring.amqp.global.properties">
  <prop
    key="mlc.possible.authentication.failure.fatal">
     false
  </prop>
</util:properties>

此全局属性不会应用于具有显式missingQueuesFatal属性集。spring-doc.cadn.net.cn

默认重试属性(3 次重试,间隔 5 秒)可以使用此属性之后的属性覆盖。spring-doc.cadn.net.cn

刻度线
刻度线

prefetchCount
(预取)spring-doc.cadn.net.cn

每个使用者可以未完成的未确认消息数。 此值越高,消息的传递速度就越快,但非顺序处理的风险就越高。 如果acknowledgeModeNONE. 如有必要,将增加此值以匹配batchSizemessagePerAck. 自 2.0 起默认为 250。 您可以将其设置为 1 以恢复到之前的行为。spring-doc.cadn.net.cn

在某些情况下,prefetch 值应 低 — 例如,对于大型消息,尤其是在处理速度较慢的情况下(消息可能会累积 添加到客户端进程中的大量内存),并且如果需要严格的消息排序 (在这种情况下,prefetch 值应设置回 1)。 此外,对于低容量消息收发和多个使用者(包括单个侦听器容器实例中的并发),您可能希望减少预取,以便在使用者之间更均匀地分配消息。

另请参阅globalQos.spring-doc.cadn.net.cn

刻度线
刻度线

rabbitAdmin
(管理员)spring-doc.cadn.net.cn

当侦听器容器侦听至少一个自动删除队列,并且在启动期间发现该队列缺失时,该容器会使用RabbitAdmin来声明 queue 以及任何相关的 bindings 和 exchanges。 如果此类元素配置为使用条件声明(请参阅条件声明),则容器必须使用配置为声明这些元素的 admin。 在此处指定该管理员。 仅当使用带有条件声明的自动删除队列时,才需要它。 如果您不希望在容器启动之前声明自动删除队列,请将auto-startupfalse在 admin. 默认为RabbitAdmin声明所有非条件元素。spring-doc.cadn.net.cn

刻度线
刻度线

receiveTimeout
(接收超时)spring-doc.cadn.net.cn

等待每条消息的最长时间。 如果acknowledgeMode=NONE,这影响很小 — 容器旋转并请求另一条消息。 它对交易ChannelbatchSize > 1,因为它可能导致在超时到期之前不确认已使用的消息。 什么时候consumerBatchEnabled为 true,则如果此超时发生在批处理完成之前,则将交付部分批处理。spring-doc.cadn.net.cn

刻度线

batchReceiveTimeout
(批处理接收超时)spring-doc.cadn.net.cn

收集批处理消息的超时毫秒数。 它限制了等待填充 batchSize 的时间。 什么时候batchSize > 1并且收集批处理消息的时间大于batchReceiveTime,将交付批次。 默认值为 0 (无超时)。spring-doc.cadn.net.cn

刻度线

recoveryBackOff
(恢复回退)spring-doc.cadn.net.cn

指定BackOff如果使用者由于非致命原因而无法启动,则尝试启动使用者的间隔。 默认值为FixedBackOff每 5 秒无限次重试。 互斥与recoveryInterval.spring-doc.cadn.net.cn

刻度线
刻度线

recoveryInterval
(恢复间隔)spring-doc.cadn.net.cn

确定如果使用者由于非致命原因而无法启动,则尝试启动使用者之间的时间(以毫秒为单位)。 默认值:5000。 互斥与recoveryBackOff.spring-doc.cadn.net.cn

刻度线
刻度线

retryDeclarationInterval
(缺失队列- retry-interval)spring-doc.cadn.net.cn

如果配置的队列的子集在使用者初始化期间可用,则使用者将开始从这些队列中使用。 使用者尝试使用此间隔被动声明缺少的队列。 当此间隔过后,将再次使用 'declarationRetries' 和 'failedDeclarationRetryInterval'。 如果仍然缺少队列,使用者会再次等待此间隔,然后再尝试一次。 此过程将无限期地持续,直到所有队列都可用。 默认值:60000(1 分钟)。spring-doc.cadn.net.cn

刻度线

shutdownTimeout
(不适用)spring-doc.cadn.net.cn

当容器关闭时(例如, 如果它包含ApplicationContext已关闭),它会等待处理到此限制的 in-flight 消息。 默认为 5 秒。spring-doc.cadn.net.cn

刻度线
刻度线

startConsumerMinInterval
(最小开始间隔)spring-doc.cadn.net.cn

按需启动每个新使用者之前必须经过的时间(以毫秒为单位)。 请参阅 侦听器并发。 默认值:10000(10 秒)。spring-doc.cadn.net.cn

刻度线

statefulRetryFatal
WithNullMessageId (不适用)spring-doc.cadn.net.cn

当使用有状态重试通知时,如果缺少messageIdproperty 时,它被视为 fatal (它已停止)。 将此项设置为false丢弃(或路由到死信队列)此类消息。spring-doc.cadn.net.cn

刻度线
刻度线

stopConsumerMinInterval
(最小停止间隔)spring-doc.cadn.net.cn

在检测到空闲使用者时,自最后一个使用者停止以来,在停止使用者之前必须经过的时间(以毫秒为单位)。 请参阅 侦听器并发。 默认值:60000(1 分钟)。spring-doc.cadn.net.cn

刻度线

streamConverter
(不适用)spring-doc.cadn.net.cn

一个StreamMessageConverter将本机 Stream 消息转换为 Spring AMQP 消息。spring-doc.cadn.net.cn

刻度线

taskExecutor
(任务执行程序)spring-doc.cadn.net.cn

对 Spring 的引用TaskExecutor(或标准 JDK 1.5+Executor) 来执行侦听器调用程序。 默认值为SimpleAsyncTaskExecutor,使用内部管理的线程。spring-doc.cadn.net.cn

刻度线
刻度线

taskScheduler
(任务计划程序)spring-doc.cadn.net.cn

使用 DMLC 时,调度程序用于在 'monitorInterval' 运行监视任务。spring-doc.cadn.net.cn

刻度线

transactionManager
(事务管理器)spring-doc.cadn.net.cn

用于侦听器作的外部事务管理器。 也是对channelTransacted- 如果Channel是 transacted,则其事务将与外部事务同步。spring-doc.cadn.net.cn

刻度线
刻度线