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

Java DistributedRPC类代码示例

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

本文整理汇总了Java中backtype.storm.generated.DistributedRPC类的典型用法代码示例。如果您正苦于以下问题：Java DistributedRPC类的具体用法？Java DistributedRPC怎么用？Java DistributedRPC使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



DistributedRPC类属于backtype.storm.generated包，在下文中一共展示了DistributedRPC类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: initHandlerServer

import backtype.storm.generated.DistributedRPC; //导入依赖的package包/类
private THsHaServer initHandlerServer(Map conf, final Drpc service)
		throws Exception {
	int port = JStormUtils.parseInt(conf.get(Config.DRPC_PORT));
	int workerThreadNum = JStormUtils.parseInt(conf.get(Config.DRPC_WORKER_THREADS));
	int queueSize = JStormUtils.parseInt(conf.get(Config.DRPC_QUEUE_SIZE));

	TNonblockingServerSocket socket = new TNonblockingServerSocket(port);
	THsHaServer.Args targs = new THsHaServer.Args(socket);
	targs.workerThreads(64);
	targs.protocolFactory(new TBinaryProtocol.Factory());
	targs.processor(new DistributedRPC.Processor<DistributedRPC.Iface>(
			service));
	
	ThreadPoolExecutor executor = new ThreadPoolExecutor(workerThreadNum, 
			workerThreadNum, 60, TimeUnit.SECONDS, 
			new ArrayBlockingQueue(queueSize));
	targs.executorService(executor);

	THsHaServer handlerServer = new THsHaServer(targs);
	LOG.info("Successfully init Handler Server " + port);

	return handlerServer;
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:24，代码来源:Drpc.java


示例2: initHandlerServer

import backtype.storm.generated.DistributedRPC; //导入依赖的package包/类
private THsHaServer initHandlerServer(Map conf, final Drpc service) throws Exception {
    int port = JStormUtils.parseInt(conf.get(Config.DRPC_PORT));
    int workerThreadNum = JStormUtils.parseInt(conf.get(Config.DRPC_WORKER_THREADS));
    int queueSize = JStormUtils.parseInt(conf.get(Config.DRPC_QUEUE_SIZE));

    TNonblockingServerSocket socket = new TNonblockingServerSocket(port);
    THsHaServer.Args targs = new THsHaServer.Args(socket);
    targs.workerThreads(64);
    targs.protocolFactory(new TBinaryProtocol.Factory());
    targs.processor(new DistributedRPC.Processor<DistributedRPC.Iface>(service));

    ThreadPoolExecutor executor = new ThreadPoolExecutor(workerThreadNum, workerThreadNum, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(queueSize));
    targs.executorService(executor);

    THsHaServer handlerServer = new THsHaServer(targs);
    LOG.info("Successfully init Handler Server " + port);

    return handlerServer;
}
开发者ID:kkllwww007，项目名称:jstrom，代码行数:20，代码来源:Drpc.java


示例3: initHandlerServer

import backtype.storm.generated.DistributedRPC; //导入依赖的package包/类
private THsHaServer initHandlerServer(Map conf, final Drpc service) throws Exception {
    int port = JStormUtils.parseInt(conf.get(Config.DRPC_PORT));
    int workerThreadNum = JStormUtils.parseInt(conf.get(Config.DRPC_WORKER_THREADS));
    int queueSize = JStormUtils.parseInt(conf.get(Config.DRPC_QUEUE_SIZE));

    LOG.info("Begin to init DRPC handler server at port: " + port);

    TNonblockingServerSocket socket = new TNonblockingServerSocket(port);
    THsHaServer.Args targs = new THsHaServer.Args(socket);
    targs.workerThreads(64);
    targs.protocolFactory(new TBinaryProtocol.Factory());
    targs.processor(new DistributedRPC.Processor<DistributedRPC.Iface>(service));

    ThreadPoolExecutor executor = new ThreadPoolExecutor(
            workerThreadNum, workerThreadNum, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueSize));
    targs.executorService(executor);

    THsHaServer handlerServer = new THsHaServer(targs);
    LOG.info("Successfully inited DRPC handler server at port: " + port);

    return handlerServer;
}
开发者ID:alibaba，项目名称:jstorm，代码行数:23，代码来源:Drpc.java


示例4: connect

import backtype.storm.generated.DistributedRPC; //导入依赖的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


示例5: connect

import backtype.storm.generated.DistributedRPC; //导入依赖的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:metamx，项目名称:incubator-storm，代码行数:10，代码来源:DRPCClient.java


示例6: DRPCClient

import backtype.storm.generated.DistributedRPC; //导入依赖的package包/类
public DRPCClient(Map conf, String host, int port, Integer timeout) throws TTransportException {
    super(conf, ThriftConnectionType.DRPC, host, port, timeout, null);
    this.host = host;
    this.port = port;
    this.client = new DistributedRPC.Client(_protocol);
}
开发者ID:kkllwww007，项目名称:jstrom，代码行数:7，代码来源:DRPCClient.java


示例7: getClient

import backtype.storm.generated.DistributedRPC; //导入依赖的package包/类
public DistributedRPC.Client getClient() {
    return client;
}
开发者ID:kkllwww007，项目名称:jstrom，代码行数:4，代码来源:DRPCClient.java



注：本文中的backtype.storm.generated.DistributedRPC类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java RepositoryException类代码示例发布时间：2022-05-23
下一篇：
Java FractalSum类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

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

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