C++连接池

C++ 驱动的连接池提供给用户一个快速获取连接实例的途径。

连接池用法

使用类 sdbDatasource 的 getConnection 方法从连接池中获取一个连接，使用 releaseConnection 方法把取出的连接放回连接池。当连接池使用的连接数到达连接上限时，下一个请求连接的操作将会等待一段时间，若在规定的时间内无空闲的连接可用，请求将失败。类 sdbDataSourceConf 可以设置连接池的各种参数。

详情请查看相关 C++ API 介绍。

例子

  1. #include "common.hpp" // by default, this file is in /opt/sequoiadb/samples/CPP
  2. #include "sdbDataSourceComm.hpp"
  3. #include "sdbDataSource.hpp"
  4. #include <vector>
  6. using namespace std ;
  7. using namespace sdbclient ;
  8. using namespace bson ;
  10. void queryTask( sdbDataSource &ds )
  11. {
  12.    INT32                rc = SDB_OK ;
  13.    // 定义一个sdb对象用来连接数据库
  14.    sdb*                 connection ;
  15.    // 定义sdbCursor对象用来查询
  16.    sdbCursor            cursor ;
  18.    // 定义BSONObj对象
  19.    BSONObj              obj ;
  21.    // 向连接池添加一个协调节点
  22.    ds.addCoord( "192.168.20.53:50000" ) ;
  24.    // 从连接池获取一个连接
  25.    rc = ds.getConnection( connection ) ;
  26.    if ( SDB_OK != rc )
  27.    {
  28.       cout << "Fail to get a connection, rc = " << rc << endl ;
  29.       goto error ;
  30.    }
  31.    // 列出复制组
  32.    rc = connection->listReplicaGroups( cursor ) ; 
  33.    if ( SDB_OK != rc )
  34.    {
  35.       cout << "Fail to list replica groups, rc = " << rc << endl ;
  36.       goto error ;
  37.    }
  38.    // 游标向前移动
  39.    rc = cursor.next( obj ) ;
  40.    if ( SDB_OK != rc )
  41.    {
  42.       cout << "sdbCursor fail to move forward, rc = " << rc << endl ;
  43.       goto error ;
  44.    }
  45.    // 输出信息
  46.    cout << obj.toString() << endl ;
  47.    // 归还连接到连接池
  48.    ds.releaseConnection( connection ) ;
  49. done:  
  50.    return ;
  51. error:  
  52.    goto done ; 
  53. }
  56. INT32 main( INT32 argc, CHAR **argv )
  57. {
  58.    INT32                rc = SDB_OK ;
  59.    sdbDataSourceConf    conf ;
  60.    sdbDataSource        ds ;
  62.    // 设置连接池配置，userName="",passwd=""
  63.    conf.setUserInfo( "", "" ) ;  
  64.    // 初始化时预生成10个连接, 连接池中空闲连接不够用时每次生成10个连接
  65.    // 最大空闲连接数为20，连接池最多维护500个连接
  66.    conf.setConnCntInfo( 10, 10, 20, 500 ) ;        
  67.    // 每隔60秒将连接池中多于最大空闲连接数限定的空闲连接关闭，
  68.    // 并将存活时间过长（连接已停止收发超过keepAliveTimeout时间）的连接关闭。
  69.    // 0表示不关心连接隔多长时间没有收发消息。       
  70.    conf.setCheckIntervalInfo( 60, 0 ) ;
  71.    // 每隔30s从编目节点同步协调节点信息（若为0，则表示不同步）
  72.    conf.setSyncCoordInterval( 30 ) ;
  73.    // 连接池采用负载均衡策略生成连接
  74.    conf.setConnectStrategy( DS_STY_BALANCE ) ;
  75.    // 当获取一个连接时，是否检查连接的有效性
  76.    conf.setValidateConnection( TRUE ) ;
  77.    // 是否启用SSL
  78.    conf.setUseSSL( FALSE ) ;
  79.    // 提供协调节点信息
  80.    vector<string>        v ;
  81.    v.push_back( "192.168.20.53:11810" );
  82.    v.push_back( "192.168.20.53:11910" ) ;
  83.    // 初始化连接池对象
  84.    rc = ds.init( v, conf ) ;
  85.    if ( SDB_OK != rc )
  86.    {
  87.       cout << "Fail to init sdbDataSouce, rc = " << rc << endl ;
  88.       goto error ;
  89.    }
  91.    // 启动连接池
  92.    rc = ds.enable() ;
  93.    if ( SDB_OK != rc )
  94.    {
  95.       cout << "Fail to enable sdbDataSource, rc = " << rc << endl ;
  96.       goto error ;
  97.    }
  99.    // 在单线程中或多线程中使用连接池对象
  100.    queryTask( ds ) ;
  102.    // 停止连接池
  103.    rc = ds.disable() ;
  104.    if ( SDB_OK != rc )
  105.    {
  106.       cout << "Fail to disable sdbDataSource, rc = " << rc << endl ;
  107.       goto error ;
  108.    }
  110.    // 关闭连接池
  111.    ds.close() ;
  112. done:  
  113.    return 0 ;
  114. error:  
  115.    goto done ;   
  116. }