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