连接池

每个服务都会有一个连接池，根据连接池名称区别是哪个连接池。连接池定义由两部分组成，连接池和连接池配置。

连接池配置

连接池配置和之前一样，继承PoolProperties类，通过properties和env方法配置数据，env会覆盖properties。

  1. class UserPoolConfig extends PoolProperties
  2. {
  3.     /**
  4.      * the name of pool
  5.      *
  6.      * @Value(name="${config.service.user.name}", env="${USER_POOL_NAME}")
  7.      * @var string
  8.      */
  9.     protected $name = "";
  11.     /**
  12.      * Minimum active number of connections
  13.      *
  14.      * @Value(name="${config.service.user.minActive}", env="${USER_POOL_MIN_ACTIVE}")
  15.      * @var int
  16.      */
  17.     protected $minActive = 5;
  19.     /**
  20.      * the maximum number of active connections
  21.      *
  22.      * @Value(name="${config.service.user.maxActive}", env="${USER_POOL_MAX_ACTIVE}")
  23.      * @var int
  24.      */
  25.     protected $maxActive = 50;
  27.     /**
  28.      * the maximum number of wait connections
  29.      *
  30.      * @Value(name="${config.service.user.maxWait}", env="${USER_POOL_MAX_WAIT}")
  31.      * @var int
  32.      */
  33.     protected $maxWait = 100;
  35.     /**
  36.      * Maximum waiting time
  37.      *
  38.      * @Value(name="${config.service.user.maxWaitTime}", env="${USER_POOL_MAX_WAIT_TIME}")
  39.      * @var int
  40.      */
  41.     protected $maxWaitTime = 3;
  43.     /**
  44.      * Maximum idle time
  45.      *
  46.      * @Value(name="${config.service.user.maxIdleTime}", env="${USER_POOL_MAX_IDLE_TIME}")
  47.      * @var int
  48.      */
  49.     protected $maxIdleTime = 60;
  51.     /**
  52.      * the time of connect timeout
  53.      *
  54.      * @Value(name="${config.service.user.timeout}", env="${USER_POOL_TIMEOUT}")
  55.      * @var int
  56.      */
  57.     protected $timeout = 200;
  59.     /**
  60.      * the addresses of connection
  61.      *
  62.      * <pre>
  63.      * [
  64.      *  '127.0.0.1:88',
  65.      *  '127.0.0.1:88'
  66.      * ]
  67.      * </pre>
  68.      *
  69.      * @Value(name="${config.service.user.uri}", env="${USER_POOL_URI}")
  70.      * @var array
  71.      */
  72.     protected $uri = [];
  74.     /**
  75.      * whether to user provider(consul/etcd/zookeeper)
  76.      *
  77.      * @Value(name="${config.service.user.useProvider}", env="${USER_POOL_USE_PROVIDER}")
  78.      * @var bool
  79.      */
  80.     protected $useProvider = false;
  82.     /**
  83.      * the default balancer is random balancer
  84.      *
  85.      * @Value(name="${config.service.user.balancer}", env="${USER_POOL_BALANCER}")
  86.      * @var string
  87.      */
  88.     protected $balancer = BalancerSelector::TYPE_RANDOM;
  90.     /**
  91.      * the default provider is consul provider
  92.      *
  93.      * @Value(name="${config.service.user.provider}", env="${USER_POOL_PROVIDER}")
  94.      * @var string
  95.      */
  96.     protected $provider = ProviderSelector::TYPE_CONSUL;
  97. }

连接池配置

每个服务连接池，需要定义一个名称，且和熔断器一样，缺省使用类名。

  1. /**
  2.  * the pool of user service
  3.  *
  4.  * @Pool(name="user")
  5.  */
  6. class UserServicePool extends ServicePool
  7. {
  8.     /**
  9.      * @Inject()
  10.      *
  11.      * @var UserPoolConfig
  12.      */
  13.     protected $poolConfig;
  14. }