• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java TSocket类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java SPacketDestroyEntities类代码示例发布时间:2022-05-22
下一篇:
Java Content类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap