当前位置: 首页 > news >正文

RabbitMQ多线程配置和异常解决办法

(1)RabbitMQ多线程配置
RabbitMqConfig.java
@Bean("customContainerFactory")
public SimpleRabbitListenerContainerFactory containerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, 
        ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConcurrentConsumers(10);  // 设置线程数
    factory.setMaxConcurrentConsumers(10); // 最大线程数
    configurer.configure(factory, connectionFactory);
    return factory;
}
XxxListener.java
@RabbitListener(queues = "xxx", containerFactory = "customContainerFactory")
(2)inequivalent arg 'x-max-length' for queue 'xxx' in vhost '/': received none but current is the value '200000' of type 'long',异常解决办法
RabbitMqConfig.java
@Bean
public Queue xxx() {
    Map<String, Object> args = new HashMap<String, Object>();
    args.put("x-max-length", 200000);
    return new Queue("xxx", true, false, false, args);
}
 

http://www.lryc.cn/news/231530.html

相关文章:

  • 【原创】java+swing+mysql车辆维修管理系统设计与实现
  • 无法在 DLL“SQLite.Interop.dll”中找到名为”sIb4c632894b76cc1d“
  • linux高级篇基础理论一(详细文档、Apache,网站,MySQL、MySQL备份工具)
  • 周赛370(模拟、树形DP(正难则反)、树状数组优化DP)
  • python实现一个简单的桌面倒计时小程序
  • 解决STM32F429烧录程序后还需复位才能植入程序的bug
  • 使用Golang调用摄像头
  • 【Linux网络】1分钟使用shell脚本完成DNS主从解析服务器部署(适用于centos主机)
  • 基于SSM的校园停车场管理系统设计与实现
  • 块设备 I/O 请求送达到外部设备
  • 【ArcGIS Pro二次开发】(76):面积平差工具
  • 4、智能家居框架设计和代码文件工程建立
  • 网络编程TCP/UDP
  • 移远EC600U-CN开发板 11.15
  • Docker - MySQL Database is uninitialized and password option is not specified
  • Elasticsearch 之聚合分析
  • Django(七、模型层)
  • LeetCode105. Construct Binary Tree from Preorder and Inorder Traversal
  • python链表_递归求和_递归求最大小值
  • Java中生成指定字体的印章
  • Winodws核心编程 多线程
  • 旺店通·企业版对接打通金蝶云星空查询调拨单接口与分布式调入单新增接口
  • 关于对Java中volatile关键字的理解与简述
  • 37 _ 贪心算法:如何用贪心算法实现Huffman压缩编码?
  • Unity中Shader矩阵的逆矩阵
  • 我给网站做公安备案年度安全评估
  • iceoryx(冰羚)-通信中间件解析
  • Windows系统CMake+VS编译protobuf
  • HarmonyOS开发(三):ArkTS基础
  • Java排序算法之堆排序