code: @SuppressWarnings("unchecked")
  	private void createConnection() throws ThriftConnectionPoolException {
  		try {
  			transport = new TSocket(host, port, connectionTimeOut);
  			transport.open();
  			TProtocol protocol = createTProtocol(transport);
  			// 反射实例化客户端对象
  			Constructor<? extends TServiceClient> clientConstructor = clientClass.getConstructor(TProtocol.class);
  			client = (T) clientConstructor.newInstance(protocol);
  			if (logger.isDebugEnabled()) {
  				logger.debug("创建新连接成功:" + host + " 端口：" + port);
  			}
  		} catch (Exception e) {
  			throw new ThriftConnectionPoolException("无法连接服务器：" + host + " 端口：" + port);
  		}
  	}
docs: 创建原始连接的方法
  
  @throws ThriftConnectionPoolException
  创建连接出现问题时抛出该异常