本篇内容介绍了“storm drpc怎么定义”的有关知识，在实际案例的操作过程中，许多人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
代码
package main.java;import main.java.bolt.requestcounter;import backtype.storm.config;import backtype.storm.localcluster;import backtype.storm.localdrpc;import backtype.storm.stormsubmitter;import backtype.storm.drpc.lineardrpctopologybuilder;import backtype.storm.utils.drpcclient;/** * drpc example * * @author sjyu * */public class drpctopologymain {public static void main(string[] args) throws exception {//localdrpc drpc = new localdrpc();drpcclient drpc = new drpcclient(192.168.1.240, 3772);lineardrpctopologybuilder builder = new lineardrpctopologybuilder(test,func);builder.addbolt(new requestcounter(), 2);config conf = new config();conf.setdebug(true);stormsubmitter.submittopology(drpc,test, conf, builder.createremotetopology());//localcluster cluster = new localcluster();//cluster.submittopology(local,cluster, conf, builder.createlocaltopology(drpc));string str = drpc.execute(test,func, this is a test);//这边drpc的client和server写在一起了，不明白可不可以写在两个进程里，//想像中应该没问题，宛如网络编程一样，但是行不行还有待验证。system.out.println(str);}}package main.java.bolt;import backtype.storm.topology.basicoutputcollector;import backtype.storm.topology.outputfieldsdeclarer;import backtype.storm.topology.base.basebasicbolt;import backtype.storm.tuple.fields;import backtype.storm.tuple.tuple;import backtype.storm.tuple.values;public class requestcounter extends basebasicbolt {//object id = new object();这边好像不能定义一个变量，不然就报错，// 不明白是storm的原因还是java本来就不能这样（我认为我似乎要去学学java了- -） @overridepublic void execute(tuple input, basicoutputcollector collector) {string str = (string) input.getstring(1);collector.emit(new values(input.getvalue(0), str));}@overridepublic void declareoutputfields(outputfieldsdeclarer declarer) {declarer.declare(new fields(id,result));}}“storm drpc怎么定义”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！