Redis 'redis.publish()' 方法有什么作用?
What does the Redis 'redis.publish()' method do?
redis.publish();
method在下面的模块中做了什么
redis.publish("WordCountTopology", exclamatedWord.toString() + "|" + Long.toString(count));
public void execute(Tuple tuple)
{
String word = tuple.getString(0);
StringBuilder exclamatedWord = new StringBuilder();
exclamatedWord.append(word).append("!!!");
_collector.emit(tuple, new Values(exclamatedWord.toString()));
long count = 30;
redis.publish("WordCountTopology", exclamatedWord.toString() + "|" + Long.toString(count));
}
它将字符串 (ExclamatedWord + "|30") 发布到名为 WordCountTopology
的 Redis 频道 - 一旦 redis.publish
执行,该频道的订阅者将收到消息。
有关 Redis 的更多信息 Pub/Sub 请参阅:http://redis.io/topics/pubsub
redis.publish();
method在下面的模块中做了什么
redis.publish("WordCountTopology", exclamatedWord.toString() + "|" + Long.toString(count));
public void execute(Tuple tuple)
{
String word = tuple.getString(0);
StringBuilder exclamatedWord = new StringBuilder();
exclamatedWord.append(word).append("!!!");
_collector.emit(tuple, new Values(exclamatedWord.toString()));
long count = 30;
redis.publish("WordCountTopology", exclamatedWord.toString() + "|" + Long.toString(count));
}
它将字符串 (ExclamatedWord + "|30") 发布到名为 WordCountTopology
的 Redis 频道 - 一旦 redis.publish
执行,该频道的订阅者将收到消息。
有关 Redis 的更多信息 Pub/Sub 请参阅:http://redis.io/topics/pubsub