storm drpc怎么定义

本篇内容介绍了“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怎么定义”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注西部数码网站，小编将为大家输出更多高质量的实用文章！

上海集锦科技网站设计关于文本部分的的隐藏规则
域名绑定后显示未接入但是已经做别名解析了的域名是别的公司空间
site域名注册一年需要多少钱？
云服务器和云空间区别
怎么做第二域名和登记二级域名
互联域名是什么意思 域名对网站优化有何影响
云服务器文件上传
域名注册管理需要注意什么？域名注册管理流程有哪些？