A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

根据官方文档Local DRPC模式开发可以很容易的写出代码

下面是我运行过的代码:

package cn.ysjh.drpc;

import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.LocalDRPC;
import org.apache.storm.drpc.LinearDRPCTopologyBuilder;
import org.apache.storm.task.OutputCollector;
import org.apache.storm.task.TopologyContext;
import org.apache.storm.topology.OutputFieldsDeclarer;
import org.apache.storm.topology.base.BaseRichBolt;
import org.apache.storm.tuple.Fields;
import org.apache.storm.tuple.Tuple;
import org.apache.storm.tuple.Values;

import java.util.Map;

public class LocalDRPCStorm {

  public static class MyBolt extends BaseRichBolt{

      private  OutputCollector outputCollector;

      @Override
      public void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector) {
        this.outputCollector=outputCollector;
      }

      @Override
      public void execute(Tuple tuple) {

          Object value = tuple.getValue(0);
          String name = tuple.getString(1);

          String result="My name:"+name;
          this.outputCollector.emit(new Values(value,result));


      }

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

  public static void main(String[] ages){

      LinearDRPCTopologyBuilder builder = new LinearDRPCTopologyBuilder("addUser");
      builder.addBolt(new MyBolt());

      LocalDRPC drpc = new LocalDRPC();
      LocalCluster cluster = new LocalCluster();

     cluster.submitTopology("localDRPC",new Config(),builder.createLocalTopology(drpc));

      String execute = drpc.execute("addUser", "ysjh");

      System.err.println("成功"+execute);

      cluster.shutdown();
      drpc.shutdown();

  }

}
运行结果:



如果运行代码后找不到结果,可以使用Debug模式打个断点
---------------------
作者:ysjh0014
来源:CSDN
原文:https://blog.csdn.net/ys_230014/article/details/84073911
版权声明:本文为博主原创文章,转载请附上博文链接!

2 个回复

正序浏览
回复 使用道具 举报
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马