java - 使用ActiveMQ-pool建立的连接总是无任何征兆的自动关闭。
阿神
阿神 2017-04-17 16:47:50
[Java讨论组]

在消费者端使用PooledConnectionFactory建立与MQ服务器的连接,启动的时候初始化10个消费者。相关代码如下:

protected JMSConnectionUtill(String MQ_LOCATION,String userName,String password) {
        this.MQ_LOCATION=MQ_LOCATION;
        this.userName=userName;
        this.password=password;
        // ConnectionFactory :连接工厂,JMS 用它创建连接
        ActiveMQConnectionFactory connectionFactory = null;
        if(StrKit.notBlank(userName)
                && StrKit.notBlank(password)){
            connectionFactory= new ActiveMQConnectionFactory(userName, password, MQ_LOCATION);
        } else{
            connectionFactory= new ActiveMQConnectionFactory(MQ_LOCATION);
        }
        pooledConnectionFactory = new PooledConnectionFactory();
        pooledConnectionFactory.setConnectionFactory(connectionFactory);
        // 设置最大连接数
        pooledConnectionFactory.setMaxConnections(100);
        // 设置最小
        pooledConnectionFactory.setMaximumActiveSessionPerConnection(500);
        pooledConnectionFactory.setIdleTimeout(Integer.MAX_VALUE);
    }

但是连接总是隔一段时间就完全无征兆的自己关闭了。为此查了很久,都没有找到原因。哪位大神指导如何解决?

阿神
阿神

闭关修行中......

全部回复(1)
怪我咯

把这句 注释掉 pooledConnectionFactory.setIdleTimeout(Integer.MAX_VALUE);

热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号