Spring-data-redis: pub/sub消息订阅
public class TopicMessageListener implements MessageListener {private RedisTemplate redisTemplate;public void setRedisTemplate(RedisTemplate redisTemplate) {this.redisTemplate = redisTemplate;}@Overridepublic void onMessage(Message message, byte[] pattern) {byte[] body = message.getBody();//请使用valueSerializerbyte[] channel = message.getChannel();//请参考配置文件,本例中key,value的序列化方式均为string。//其中key必须为stringSerializer。和redisTemplate.convertAndSend对应String itemValue = (String)redisTemplate.getValueSerializer().deserialize(body);String topic = (String)redisTemplate.getStringSerializer().deserialize(channel);//...}}
?? 2) 你会发现上述编程风格非常像JMS。需要注意的是消息体的反序列化。
?
1 楼 rox 2013-06-17 不错的文章,非常感谢!这里是去年底,研究Redis时,发现的一篇文章,也不错。推荐一下:
http://blog.springsource.org/2012/05/16/spring-mvc-3-2-preview-chat-sample/ 2 楼 QING____ 2013-06-17 rox 写道不错的文章,非常感谢!
这里是去年底,研究Redis时,发现的一篇文章,也不错。推荐一下:
http://blog.springsource.org/2012/05/16/spring-mvc-3-2-preview-chat-sample/
谢谢,稍后拜读一下你提供的资讯.