日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

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

卡若網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)公司！從網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開(kāi)發(fā)、APP開(kāi)發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項(xiàng)目制作，到程序開(kāi)發(fā)，運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)公司2013年開(kāi)創(chuàng)至今到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來(lái)保證我們的工作的順利進(jìn)行。專(zhuā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寫(xiě)在一起了，不知道可不可以寫(xiě)在兩個(gè)進(jìn)程里，//想像中應(yīng)該沒(méi)問(wèn)題，就像網(wǎng)絡(luò)編程一樣，但是行不行還有待驗(yàn)證。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();這邊好像不能定義一個(gè)變量，不然就報(bào)錯(cuò)，//不知道是storm的原因還是java本來(lái)就不能這樣（我覺(jué)得我似乎要去學(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)的知識(shí)可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！

新聞標(biāo)題：stormdrpc怎么定義
新聞來(lái)源：http://www.dlmjj.cn/article/choeci.html