Storm RandomURLSpout怎么使用

本篇内容介绍了“Storm RandomURLSpout怎么使用”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

阅读背景：您需要对Storm的基本处理机制做一个详尽的了解。

package com.digitalpebble.storm.crawler.spout;

import java.util.Map;
import java.util.Random;

import backtype.storm.spout.SpoutOutputCollector;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.base.BaseRichSpout;
import backtype.storm.tuple.Fields;
import backtype.storm.tuple.Values;
import backtype.storm.utils.Utils;

public class RandomURLSpout extends BaseRichSpout {
	SpoutOutputCollector _collector;
	Random _rand;

	public void open(Map conf, TopologyContext context,
			SpoutOutputCollector collector) {
		_collector = collector;
		_rand = new Random();
	}

	public void nextTuple() {
		Utils.sleep(100);
		String[] urls = new String[] { "http://www.lequipe.fr/",
				"http://www.lemonde.fr/", "http://www.bbc.co.uk/",
				"http://www.facebook.com/", "http://www.rmc.fr" };
		String url = urls[_rand.nextInt(urls.length)];
		_collector.emit(new Values(url));
	}

	@Override
	public void ack(Object id) {
	}

	@Override
	public void fail(Object id) {
	}

	public void declareOutputFields(OutputFieldsDeclarer declarer) {
		declarer.declare(new Fields("url"));
	}

}

    在这里，我们继承的是 

BaseRichSpout

  SimpleTips，  在这里，URL 对象将源源不断的发射我们所需要的URL 对象。

“Storm RandomURLSpout怎么使用”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！