本文整理了Java中org.apache.thrift.transport.TTransportException类的一些代码示例，展示了TTransportException类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TTransportException类的具体详情如下：
包路径：org.apache.thrift.transport.TTransportException
类名称：TTransportException

TTransportException介绍

[英]Transport exceptions.
[中]运输例外。

代码示例

代码示例来源：origin: thinkaurelius/titan

socket = TSSLTransportFactory.getClientSocket(hostname, cfg.port, cfg.timeoutMS, params);
} else {
  socket = new TSocket(hostname, cfg.port, cfg.timeoutMS);
TBinaryProtocol protocol = new TBinaryProtocol(transport);
Cassandra.Client client = new Cassandra.Client(protocol);
if (!transport.isOpen()) {
  transport.open();
    client.login(new AuthenticationRequest(credentials));
  } catch (Exception e) { // TTransportException will propagate authentication/authorization failure
    throw new TTransportException(e);

代码示例来源：origin: prestodb/presto

private static TTransportException rewriteException(TTransportException e, HostAndPort address)
{
  return new TTransportException(e.getType(), String.format("%s: %s", address, e.getMessage()), e);
}

代码示例来源：origin: linkedin/indextank-engine

public static void main(String[] args) {
  TTransport transport;
  try {
    transport = new TSocket("localhost", 2000);
    TProtocol protocol = new TBinaryProtocol(transport);
    Suggestor.Client client = new Suggestor.Client(protocol);
    transport.open();
    List<String> suggestions = client.complete(args[0], "text");
    transport.close();
    System.out.println(suggestions);
  } catch (TTransportException e) {
    e.printStackTrace();
  } catch (TException e) {
    e.printStackTrace();
  }
}

代码示例来源：origin: org.apache.airavata/airavata-gfac-stubs

public static GfacService.Client createGFacClient(String serverHost, int serverPort){
     try {
       TTransport transport = new TSocket(serverHost, serverPort);
       transport.open();
       TProtocol protocol = new TBinaryProtocol(transport);
       return new GfacService.Client(protocol);
     } catch (TTransportException e) {
       e.printStackTrace();
     }
     return null;
   }
}

代码示例来源：origin: apache/accumulo

} catch (IOException e) {
 log.warn("Failed to open transport to {}", address);
 throw new TTransportException(e);
 transport.open();
} catch (TTransportException e) {
 log.warn("Failed to open SASL transport", e);
} catch (IOException e) {
 log.warn("Failed to open SASL transport", e);
 throw new TTransportException(e);
 transport = new TSocket(address.getHost(), address.getPort());
 transport.open();
} else {
 try {
 } catch (IOException ex) {
  log.warn("Failed to open transport to {}", address);
  throw new TTransportException(ex);
 transport.open();

代码示例来源：origin: palantir/atlasdb

private static Cassandra.Client getRawClient(InetSocketAddress addr, CassandraKeyValueServiceConfig config)
    throws TException {
  TSocket thriftSocket = new TSocket(addr.getHostString(), addr.getPort(), config.socketTimeoutMillis());
  thriftSocket.open();
  try {
    thriftSocket.getSocket().setKeepAlive(true);
    thriftSocket.getSocket().setSoTimeout(config.socketQueryTimeoutMillis());
  } catch (SocketException e) {
      success = true;
    } catch (IOException e) {
      throw new TTransportException(e);
    } finally {
      if (!success) {
      login(client, config.credentials().get());
    } catch (TException e) {
      client.getOutputProtocol().getTransport().close();
      log.error("Exception thrown attempting to authenticate with config provided credentials", e);
      throw e;

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.databridge.agent

@Override
public Object createClient(String protocol, String hostName, int port) throws DataEndpointException,
    DataEndpointAgentConfigurationException {
  if (protocol.equalsIgnoreCase(DataEndpointConfiguration.Protocol.TCP.toString())) {
    int socketTimeout = AgentHolder.getInstance().getDataEndpointAgent(DataEndpointConstants.THRIFT_DATA_AGENT_TYPE).
        getAgentConfiguration().getSocketTimeoutMS();
    TTransport receiverTransport = new TSocket(hostName, port, socketTimeout);
    TProtocol tProtocol = new TBinaryProtocol(receiverTransport);
    ThriftEventTransmissionService.Client client = new ThriftEventTransmissionService.Client(tProtocol);
    try {
      receiverTransport.open();
    } catch (TTransportException e) {
      throw new DataEndpointException("Error while making the connection." + e.getMessage(), e);
    }
    return client;
  }
  throw new DataEndpointException("Unsupported protocol :" + protocol
      + " used to authenticate the client, only " + DataEndpointConfiguration.Protocol.TCP.toString()
      + " is supported");
}

代码示例来源：origin: org.apache.thrift/libthrift

throw new TTransportException("SASL transport already open");
if (!underlyingTransport.isOpen())
 underlyingTransport.open();
  if (message.status != NegotiationStatus.COMPLETE &&
    message.status != NegotiationStatus.OK) {
   throw new TTransportException("Expected COMPLETE or OK, got " + message.status);
  message = receiveSaslMessage();
  if (message.status != NegotiationStatus.COMPLETE) {
   throw new TTransportException(
    "Expected SASL COMPLETE, but got " + message.status);
  throw sendAndThrowMessage(NegotiationStatus.BAD, e.getMessage());
 } finally {
  underlyingTransport.close();
 if (!readSaslHeader && e.getType() == TTransportException.END_OF_FILE) {
  underlyingTransport.close();
  LOGGER.debug("No data or no sasl data in the stream");

代码示例来源：origin: prestodb/presto

private static TTransport createRaw(HostAndPort address, Optional<SSLContext> sslContext, Optional<HostAndPort> socksProxy, int timeoutMillis)
    throws TTransportException
{
  Proxy proxy = socksProxy
      .map(socksAddress -> new Proxy(SOCKS, InetSocketAddress.createUnresolved(socksAddress.getHost(), socksAddress.getPort())))
      .orElse(Proxy.NO_PROXY);
  Socket socket = new Socket(proxy);
  try {
    socket.connect(new InetSocketAddress(address.getHost(), address.getPort()), timeoutMillis);
    socket.setSoTimeout(timeoutMillis);
    if (sslContext.isPresent()) {
      // SSL will connect to the SOCKS address when present
      HostAndPort sslConnectAddress = socksProxy.orElse(address);
      socket = sslContext.get().getSocketFactory().createSocket(socket, sslConnectAddress.getHost(), sslConnectAddress.getPort(), true);
    }
    return new TSocket(socket);
  }
  catch (Throwable t) {
    // something went wrong, close the socket and rethrow
    try {
      socket.close();
    }
    catch (IOException e) {
      t.addSuppressed(e);
    }
    throw new TTransportException(t);
  }
}

代码示例来源：origin: org.apache.thrift/libthrift

protected TSocket acceptImpl() throws TTransportException {
 if (serverSocket_ == null) {
  throw new TTransportException(TTransportException.NOT_OPEN, "No underlying server socket.");
 }
 try {
  Socket result = serverSocket_.accept();
  TSocket result2 = new TSocket(result);
  result2.setTimeout(clientTimeout_);
  return result2;
 } catch (IOException iox) {
  throw new TTransportException(iox);
 }
}

代码示例来源：origin: apache/hive

@Override
 protected TSocket acceptImpl() throws TTransportException {
  TSocket ts = super.acceptImpl();
  try {
   ts.getSocket().setKeepAlive(true);
  } catch (SocketException e) {
   throw new TTransportException(e);
  }
  return ts;
 }
}

代码示例来源：origin: apache/hive

public Server() throws TTransportException {
 try {
  realUgi = UserGroupInformation.getCurrentUser();
  clientValidationUGI = UserGroupInformation.getCurrentUser();
 } catch (IOException ioe) {
  throw new TTransportException(ioe);
 }
}
/**

代码示例来源：origin: Netflix/metacat

private static TTransportException rewriteException(final TTransportException e, final String host) {
  return new TTransportException(e.getType(), String.format("%s: %s", host, e.getMessage()), e.getCause());
}

代码示例来源：origin: org.apache.thrift/libthrift

private void readFrame() throws TTransportException {
 underlying.readAll(i32buf , 0, 4);
 int size = TFramedTransport.decodeFrameSize(i32buf);
 if (size < 0) {
  close();
  throw new TTransportException(TTransportException.CORRUPTED_DATA, "Read a negative frame size (" + size + ")!");
 }
 if (size > maxLength) {
  close();
  throw new TTransportException(TTransportException.CORRUPTED_DATA,
    "Frame size (" + size + ") larger than max length (" + maxLength + ")!");
 }
 readBuffer.fill(underlying, size);
}

代码示例来源：origin: shunyang/thrift-all

/**
   * 验证对象有效性
   * @param pooledObject
   * @return
   */
  public boolean validateObject(PooledObject<TProtocol> pooledObject){
    if (pooledObject.getObject() != null){
      if (pooledObject.getObject().getTransport().isOpen()){
        return true;
      }
      try {
        pooledObject.getObject().getTransport().open();
        return  true;
      } catch (TTransportException e) {
        e.printStackTrace();
      }
    }
    return false;
  }
}

代码示例来源：origin: org.apache.thrift/libthrift

/**
  * Performs the client side of the initial portion of the Thrift SASL
  * protocol. Generates and sends the initial response to the server, including
  * which mechanism this client wants to use.
  */
 @Override
 protected void handleSaslStartMessage() throws TTransportException, SaslException {
  SaslClient saslClient = getSaslClient();

  byte[] initialResponse = new byte[0];
  if (saslClient.hasInitialResponse())
   initialResponse = saslClient.evaluateChallenge(initialResponse);

  LOGGER.debug("Sending mechanism name {} and initial response of length {}", mechanism,
    initialResponse.length);

  byte[] mechanismBytes;
  try {
    mechanismBytes = mechanism.getBytes("UTF-8");
  } catch (UnsupportedEncodingException e) {
    throw new TTransportException(e);
  }
  sendSaslMessage(NegotiationStatus.START,
          mechanismBytes);
  // Send initial response
  sendSaslMessage(saslClient.isComplete() ? NegotiationStatus.COMPLETE : NegotiationStatus.OK,
          initialResponse);
  underlyingTransport.flush();
 }
}

代码示例来源：origin: org.apache.thrift/libthrift

/**
 * Flushes to the underlying transport. Wraps the contents if a QOP was
 * negotiated during the SASL handshake.
 */
@Override
public void flush() throws TTransportException {
 byte[] buf = writeBuffer.get();
 int dataLength = writeBuffer.len();
 writeBuffer.reset();
 if (shouldWrap) {
  LOGGER.debug("data length before wrap: {}", dataLength);
  try {
   buf = sasl.wrap(buf, 0, dataLength);
  } catch (SaslException e) {
   throw new TTransportException(e);
  }
  dataLength = buf.length;
 }
 LOGGER.debug("writing data length: {}", dataLength);
 writeLength(dataLength);
 underlyingTransport.write(buf, 0, dataLength);
 underlyingTransport.flush();
}

代码示例来源：origin: org.alluxio/alluxio-core-common

@Override
public void write(byte[] buf, int off, int len) throws TTransportException {
 if (!mTransport.isOpen()) {
  throw new TTransportException("transport is not open");
 }
 mTransport.write(buf, off, len);
}

代码示例来源：origin: shunyang/thrift-all

public TransfortWrapper(TTransport transport, String host, int port,boolean isOpen) {
  this.transport = transport;
  this.host = host;
  this.port = port;
  this.lastUseTime =new Date();
  if (isOpen) {
    try {
      transport.open();
    } catch (TTransportException e) {
      //e.printStackTrace();
      System.err.println(host + ":" + port + " " + e.getMessage());
      isDead =true;
    }
  }
}

代码示例来源：origin: org.alluxio/alluxio-core-common

@Override
public int read(byte[] buf, int off, int len) throws TTransportException {
 if (!mTransport.isOpen()) {
  throw new TTransportException("transport is not open");
 }
 return mTransport.read(buf, off, len);
}