storm_drpc

原创
2014/06/15 10:09
阅读数 118

最近摸了一下drpc。


代码是根据网上的例子改的,链接如下:

https://github.com/storm-book/examples-ch03-topologies/tree/master/src/main/java/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了- -)
        @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"));
	}

}

代码比较简单,不过把DRPC的流程走了一遍,下次有空写个复杂点的。

展开阅读全文
打赏
0
0 收藏
分享

作者的其它热门文章

加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部