zoukankan      html  css  js  c++  java
  • ActiveMQ使用的设计模式

    注:接收不需要连接池,而发送需要连接池,是因为,接收在启动项目时就要注册监听,数目是固定的,而发送则会随着时间数目不断在变动,需要连接池,性能更优。 

    重点代码:

    private static void initMQObjectPool() {

      

       private static Map<String, GenericObjectPool<MQObject>> mqObjectPool = new ConcurrentHashMap<String, GenericObjectPool<MQObject>>(100);

    MQObjectFactory factory = new ActiveMQObjectFactory(bean.getBrokerId());

     

    GenericObjectPoolConfig config = new GenericObjectPoolConfig();

    config.setMaxTotal(MaxTotal());

    config.setBlockWhenExhausted(BlockWhenExhausted());

    config.setMaxWaitMillis(MaxWaitMillis());

    config.setNumTestsPerEvictionRun(NumTestsPerEvictionRun());

    config.setTestOnBorrow(TestOnBorrow());

    config.setTestOnReturn(TestOnReturn());

    config.setTestWhileIdle(TestWhileIdle());

    config.setTimeBetweenEvictionRunsMillis(TimeBetweenEvictionRunsMillis());

    config.setMinEvictableIdleTimeMillis(MinEvictableIdleTimeMillis());

     

    GenericObjectPool<MQObject> pool = new GenericObjectPool<MQObject>(factory, config);

    mqObjectPool.put(bean.getBrokerId(), pool);

    }

    }

  • 相关阅读:
    反射
    EFCore笔记之异步查询
    EFCore笔记之查询数据
    Json扩展 (转)
    C语言学习笔记之成员数组和指针
    asp中cookie欺骗/注入原理与防范
    简单的php Mysql类(查询 删除 更新)
    PHP四舍五入精确小数位及取整
    CentOS中配置LNMP环境打开提示File not found
    WIN中SharePoint Server 2010 入门安装部署详解
  • 原文地址:https://www.cnblogs.com/incognitor/p/8318501.html
Copyright © 2011-2022 走看看