本篇内容介绍了“storm drpc怎么定义”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
代码:
packagemain.java;importmain.java.bolt.RequestCounter;importbacktype.storm.Config;importbacktype.storm.LocalCluster;importbacktype.storm.LocalDRPC;importbacktype.storm.StormSubmitter;importbacktype.storm.drpc.LinearDRPCTopologyBuilder;importbacktype.storm.utils.DRPCClient;/***DRPCexample**@authorsjyu**/publicclassDRPCTopologyMain{publicstaticvoidmain(String[]args)throwsException{//LocalDRPCdrpc=newLocalDRPC();DRPCClientdrpc=newDRPCClient("192.168.1.240",3772);LinearDRPCTopologyBuilderbuilder=newLinearDRPCTopologyBuilder("test_func");builder.addBolt(newRequestCounter(),2);Configconf=newConfig();conf.setDebug(true);StormSubmitter.submitTopology("drpc_test",conf,builder.createRemoteTopology());//LocalClustercluster=newLocalCluster();//cluster.submitTopology("local_cluster",conf,builder.createLocalTopology(drpc));Stringstr=drpc.execute("test_func","thisisatest");//这边drpc的client和server写在一起了,不知道可不可以写在两个进程里,//想像中应该没问题,就像网络编程一样,但是行不行还有待验证。System.out.println(str);}}
packagemain.java.bolt;importbacktype.storm.topology.BasicOutputCollector;importbacktype.storm.topology.OutputFieldsDeclarer;importbacktype.storm.topology.base.BaseBasicBolt;importbacktype.storm.tuple.Fields;importbacktype.storm.tuple.Tuple;importbacktype.storm.tuple.Values;publicclassRequestCounterextendsBaseBasicBolt{//Objectid=newObject();这边好像不能定义一个变量,不然就报错,//不知道是storm的原因还是java本来就不能这样(我觉得我似乎要去学学java了--)@Overridepublicvoidexecute(Tupleinput,BasicOutputCollectorcollector){Stringstr=(String)input.getString(1);collector.emit(newValues(input.getValue(0),str));}@OverridepublicvoiddeclareOutputFields(OutputFieldsDeclarerdeclarer){declarer.declare(newFields("id","result"));}}
“storm drpc怎么定义”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注恰卡编程网网站,小编将为大家输出更多高质量的实用文章!
storm实时排序TopN怎么使用
Storm怎么写一个爬虫
Storm怎么写一个爬虫这篇文章主要讲解了“Storm怎么写一个爬...
怎么用Storm IPResolutionBolt写爬虫
怎么用StormIPResolutionBolt写爬虫本篇内容介...
Storm RandomURLSpout怎么使用
StormRandomURLSpout怎么使用本篇内容介绍了“S...
如何用Storm来写一个Crawler的工具
Storm开发细节是什么
Storm的Acker机制是什么
Storm的Acker机制是什么这篇文章主要讲解了“Storm的A...
storm使用要注意哪些点
storm使用要注意哪些点这篇文章主要讲解了“storm使用要注意...
storm topology优化思路是什么
stormtopology优化思路是什么本篇内容主要讲解“sto...
Storm的Grouping有哪些
Storm的Grouping有哪些这篇文章主要介绍“Storm的G...
用户名
密码
记住登录状态 忘记密码?
邮箱
确认密码
我已阅读并同意 用户协议