Storm中进行简单的压力测试代码怎么写

本篇文章给大家分享的是有关 Storm中进行简单的压力测试代码怎么写，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

代码比较简单，看图说话：

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中进行简单的压力测试代码怎么写，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注行业资讯频道。