溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

storm drpc怎么定義

發(fā)布時(shí)間:2021-12-23 14:28:23 來源:億速云 閱讀:115 作者:iii 欄目:云計(jì)算

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

代碼:

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寫在一起了,不知道可不可以寫在兩個(gè)進(jìn)程里,
		//想像中應(yīng)該沒問題,就像網(wǎng)絡(luò)編程一樣,但是行不行還有待驗(yàn)證。
		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();這邊好像不能定義一個(gè)變量,不然就報(bào)錯(cuò),
//      不知道是storm的原因還是java本來就不能這樣(我覺得我似乎要去學(xué)學(xué)java了- -)
        @Override
	public void execute(Tuple input, BasicOutputCollector collector) {
		String str = (String) input.getString(1);
		collector.emit(new Values(input.getValue(0), str));
	}

	@Override
	public void declareOutputFields(OutputFieldsDeclarer declarer) {
		declarer.declare(new Fields("id","result"));
	}

}

“storm drpc怎么定義”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI