本文整理汇总了Java中org.apache.thrift7.transport.TSocket类的典型用法代码示例。如果您正苦于以下问题：Java TSocket类的具体用法？Java TSocket怎么用？Java TSocket使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
TSocket类属于org.apache.thrift7.transport包，在下文中一共展示了TSocket类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: process
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
@Override
public boolean process(final TProtocol inProt, final TProtocol outProt)
throws TException {
// populating request context
ReqContext req_context = ReqContext.context();
TTransport trans = inProt.getTransport();
// Sasl transport
TSaslServerTransport saslTrans = (TSaslServerTransport) trans;
// remote address
TSocket tsocket = (TSocket) saslTrans.getUnderlyingTransport();
Socket socket = tsocket.getSocket();
req_context.setRemoteAddress(socket.getInetAddress());
// remote subject
SaslServer saslServer = saslTrans.getSaslServer();
String authId = saslServer.getAuthorizationID();
Subject remoteUser = new Subject();
remoteUser.getPrincipals().add(new User(authId));
req_context.setSubject(remoteUser);
// invoke service handler
return wrapped.process(inProt, outProt);
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:26，代码来源:SaslTransportPlugin.java
示例2: process
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
@Override
public boolean process(final TProtocol inProt, final TProtocol outProt)
throws TException {
// populating request context
ReqContext req_context = ReqContext.context();
TTransport trans = inProt.getTransport();
if (trans instanceof TMemoryInputTransport) {
try {
req_context.setRemoteAddress(InetAddress.getLocalHost());
} catch (UnknownHostException e) {
throw new RuntimeException(e);
}
} else if (trans instanceof TSocket) {
TSocket tsocket = (TSocket) trans;
// remote address
Socket socket = tsocket.getSocket();
req_context.setRemoteAddress(socket.getInetAddress());
}
// anonymous user
req_context.setSubject(null);
// invoke service handler
return wrapped.process(inProt, outProt);
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:27，代码来源:SimpleTransportPlugin.java
示例3: process
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
public boolean process(final TProtocol inProt, final TProtocol outProt) throws TException {
//populating request context
ReqContext req_context = ReqContext.context();
TTransport trans = inProt.getTransport();
if (trans instanceof TMemoryInputTransport) {
try {
req_context.setRemoteAddress(InetAddress.getLocalHost());
} catch (UnknownHostException e) {
throw new RuntimeException(e);
}
} else if (trans instanceof TSocket) {
TSocket tsocket = (TSocket)trans;
//remote address
Socket socket = tsocket.getSocket();
req_context.setRemoteAddress(socket.getInetAddress());
}
//anonymous user
req_context.setSubject(null);
//invoke service handler
return wrapped.process(inProt, outProt);
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:25，代码来源:SimpleTransportPlugin.java
示例4: process
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
public boolean process(final TProtocol inProt, final TProtocol outProt)
throws TException {
// populating request context
ReqContext req_context = ReqContext.context();
TTransport trans = inProt.getTransport();
// Sasl transport
TSaslServerTransport saslTrans = (TSaslServerTransport) trans;
// remote address
TSocket tsocket = (TSocket) saslTrans.getUnderlyingTransport();
Socket socket = tsocket.getSocket();
req_context.setRemoteAddress(socket.getInetAddress());
// remote subject
SaslServer saslServer = saslTrans.getSaslServer();
String authId = saslServer.getAuthorizationID();
Subject remoteUser = new Subject();
remoteUser.getPrincipals().add(new User(authId));
req_context.setSubject(remoteUser);
// invoke service handler
return wrapped.process(inProt, outProt);
}
开发者ID:songtk，项目名称:learn_jstorm，代码行数:25，代码来源:SaslTransportPlugin.java
示例5: process
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
public boolean process(final TProtocol inProt, final TProtocol outProt)
throws TException {
// populating request context
ReqContext req_context = ReqContext.context();
TTransport trans = inProt.getTransport();
if (trans instanceof TMemoryInputTransport) {
try {
req_context.setRemoteAddress(InetAddress.getLocalHost());
} catch (UnknownHostException e) {
throw new RuntimeException(e);
}
} else if (trans instanceof TSocket) {
TSocket tsocket = (TSocket) trans;
// remote address
Socket socket = tsocket.getSocket();
req_context.setRemoteAddress(socket.getInetAddress());
}
// anonymous user
req_context.setSubject(null);
// invoke service handler
return wrapped.process(inProt, outProt);
}
开发者ID:songtk，项目名称:learn_jstorm，代码行数:26，代码来源:SimpleTransportPlugin.java
示例6: nimbusClientandConn
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
public static List nimbusClientandConn(String host, Integer port)
throws TTransportException {
TSocket ts = new TSocket(host, port);
TFramedTransport tt = new TFramedTransport(ts);
TBinaryProtocol prot = new TBinaryProtocol(tt);
Client nc = new Client(prot);
ts.open();
List l = new ArrayList();
l.add(nc);
l.add(tt);
return l;
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:13，代码来源:UIUtils.java
示例7: connect
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
private void connect() throws TException {
TSocket socket = new TSocket(host, port);
if (timeout != null) {
socket.setTimeout(timeout);
}
conn = new TFramedTransport(socket);
client = new DistributedRPC.Client(new TBinaryProtocol(conn));
conn.open();
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:10，代码来源:DRPCClient.java
示例8: ThriftConnection
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
/**
* Creates a connection with explicit nimbus host. Ignored if a local cluster is set
* for testing.
*
* @param nimbusHost the nimbus host name
* @param port the nimbus port number
* @see #setLocalCluster(ILocalCluster)
*/
public ThriftConnection(String nimbusHost, int port) {
if (null == localCluster) {
socket = new TSocket(nimbusHost, port);
LOGGER.info("Thrift connection info " + nimbusHost + " " + port);
transport = new TFramedTransport(socket);
protocol = new TBinaryProtocol(transport);
client = new Client(protocol);
}
}
开发者ID:QualiMaster，项目名称:Infrastructure，代码行数:18，代码来源:ThriftConnection.java
示例9: KestrelThriftClient
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
public KestrelThriftClient(String hostname, int port)
throws TException
{
_transport = new TFramedTransport(new TSocket(hostname, port));
final TProtocol proto = new TBinaryProtocol(_transport);
_client = new Kestrel.Client(proto);
_transport.open();
}
开发者ID:openimaj，项目名称:openimaj，代码行数:10，代码来源:KestrelThriftClient.java
示例10: connect
import org.apache.thrift7.transport.TSocket; //导入依赖的package包/类
private void connect() throws TException {
conn = new TFramedTransport(new TSocket(host, port));
client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
conn.open();
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:6，代码来源:DRPCInvocationsClient.java
注：本文中的org.apache.thrift7.transport.TSocket类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论