2015-01-26 2 views
4

Что такое redis.publish();способ сделать в следующем модуле.Что делает метод redis.publish() 'Redis?

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)); 
    } 
+0

хорошо читать: [здесь] (http://robots.thoughtbot.com/redis-pub-sub-how-does-it-work) –

ответ

6

Он публикует строку (ExclamatedWord + "| 30") к каналу Redis под названием WordCountTopology - абоненты на этот канал получит сообщение сразу redis.publish выполняется.

Для получения дополнительной информации о Pub Redis'/Sub см: http://redis.io/topics/pubsub