redis的订阅发布服务 api简单易用 性能好于icestorm

binghai03

　　icestorm的订阅发布服务在我们公司使用了好几年了,使用的也非常稳定成熟了.
　　今天在本地的服务器上分别对redis的订阅发布服务 和 icestorm进行了压力测试.
　　redis的订阅发布服务性能比icestorm要高一些.
　　这次的压力测试主要分为两大块,"消息的接收能力" 和  "接收到消息后的分发能力"
　　测试的单条消息数据为20个字节
　　接收能力:
　　redis            15000次/秒
　　icestorm:        10000次/秒
　　分发能力:
　　订阅者个数   redis         icestorm
　　3            5000次/秒      3000次/秒
　　6            5000次/秒      2900次/秒
　　9            5000次/秒      2900次/秒
　　不过redis没提供集群的功能,而icestorm支持集群.
　　api介绍:
　　消息发布端:
　　php:
　　<?php
　　$redis = new Redis();
　　//连接redis server
　　$redis->connect('192.168.0.235',6379);
　　//第一个参数是你发送消息的channel,有的地方叫做topic,就像对讲机有不同的频率和频道
　　//第二个参数是你对这个channel发送消息的具体内容 只能是string类型的
　　$redis->publish('channel','i am publishing message');
　　?>
　　python:
　　import redis
　　#连接redis server
　　REDIS_CONN =  redis.Redis(host='192.168.0.235',port=6379)
　　#第一个参数是你发送消息的channel,有的地方叫做topic,就像对讲机有不同的频率和频道
　　#第二个参数是你对这个channel发送消息的具体内容 只能是string类型的
　　REDIS_CONN.publish('channel_1', 'i am publishing message')
　　消息订阅端:
　　python:
　　import redis
　　#连接redis
　　redis_conn = redis.Redis(host='192.168.0.235',port=6379)
　　#实例化一个 pubsub 对象
　　pubsub_ins = redis_conn.pubsub()
　　#订阅你关心的channel
　　#
　　# api中提供了一种批量订阅的方法
　　# pattern为 "ESUN*" 则表示订阅所有ESUN开头的channel
　　# pubsub_ins.psubscribe(pattern);
　　#
　　pubsub_ins.subscribe('channel_1')
　　#listen 开始收听该channel的消息 加上这句以后 redis server就会将你订阅的channel的消息发送过来了
　　#它将消息存储在 listen2  listen2是一个 yield 
　　listen2 =  pubsub_ins.listen()
　　while 1:
　　#next操作就会将yield中的消息一条一条的取出来了  没有消息会一直阻塞
　　msg = listen2.next()
　　print msg