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怎么使用”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！