Storm中进行简单的压力测试代码怎么写
本篇文章给大家分享的是有关 Storm中进行简单的压力测试代码怎么写,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。
成都创新互联是专业的鸡泽网站建设公司,鸡泽接单;提供成都网站设计、网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行鸡泽网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
代码比较简单,看图说话:
package storm.benchmark; import backtype.storm.Config; import backtype.storm.StormSubmitter; import backtype.storm.spout.SpoutOutputCollector; import backtype.storm.task.TopologyContext; import backtype.storm.topology.BasicOutputCollector; import backtype.storm.topology.OutputFieldsDeclarer; import backtype.storm.topology.TopologyBuilder; import backtype.storm.topology.base.BaseBasicBolt; import backtype.storm.topology.base.BaseRichSpout; import backtype.storm.tuple.Fields; import backtype.storm.tuple.Tuple; import backtype.storm.tuple.Values; import java.util.Map; import java.util.Random; public class ThroughputTest { public static class GenSpout extends BaseRichSpout { private static final Character[] CHARS = new Character[] { 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h'}; SpoutOutputCollector _collector; int _size; Random _rand; String _id; String _val; public GenSpout(int size) { _size = size; } @Override public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) { _collector = collector; _rand = new Random(); _id = randString(5); _val = randString(_size); } @Override public void nextTuple() { _collector.emit(new Values(_id, _val)); } private String randString(int size) { StringBuffer buf = new StringBuffer(); for(int i=0; i以上就是 Storm中进行简单的压力测试代码怎么写,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。
网站标题:Storm中进行简单的压力测试代码怎么写
文章出自:http://myzitong.com/article/ghdoei.html