本篇內(nèi)容介紹了“storm drpc怎么定義”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

卡若網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)公司！從網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項目制作，到程序開發(fā)，運(yùn)營維護(hù)。創(chuàng)新互聯(lián)公司2013年開創(chuàng)至今到現(xiàn)在10年的時間，我們擁有了豐富的建站經(jīng)驗和運(yùn)維經(jīng)驗，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)公司。

代碼：

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寫在一起了，不知道可不可以寫在兩個進(jìn)程里，//想像中應(yīng)該沒問題，就像網(wǎng)絡(luò)編程一樣，但是行不行還有待驗證。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本來就不能這樣（我覺得我似乎要去學(xué)學(xué)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怎么定義”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！

當(dāng)前題目：stormdrpc怎么定義
文章位置：http://weahome.cn/article/choeci.html