8.3. 处理快速消费者


快速消费者可在使用消息时迅速处理消息。如果您确信消息传递系统中的消费者很快,请考虑将窗口大小设置为 -1。将窗口大小设置为此值允许在客户端上绑定消息缓冲。请谨慎使用此设置。如果使用者无法像接收消息一样快处理消息,则客户端上的内存可能会溢出。

为快速消费者设置窗口大小

以下示例演示了如何在使用 AMQ Core Protocol JMS 客户端时将窗口大小设置为 -1,该客户端是快速消费者的信息。

流程

  • 如果客户端使用 JNDI 来实例化其连接工厂,请将 consumerWindowSize 参数作为连接字符串 URL 的一部分。将 URL 存储在 JNDI 上下文环境中。以下示例使用 jndi.properties 文件来存储 URL。

    java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
    connectionFactory.myConnectionFactory=tcp://localhost:61616?consumerWindowSize=-1
  • 如果客户端不使用 JNDI 来实例化其连接工厂,请将值传递给 ActiveMQConnectionFactory.setConsumerWindowSize ()

    ConnectionFactory cf =  ActiveMQJMSClient.createConnectionFactory(...)
    cf.setConsumerWindowSize(-1);
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2026 Red Hat
返回顶部