Redis实现非阻塞订阅传输（redis 非阻塞订阅）

Redis是一款高效的分布式内存存储数据库，其中，其实现出了非阻塞订阅传输的功能。原理是首先Redis实现了一套消息队列，可以使客户端和服务器之间很容易的进行信息交互。Redis利用发布/订阅（Pub/Sub）模式实现了订阅传输，这样可以更好的满足多客户端订阅所需的消息数据。

那么，Redis实现非阻塞的订阅传输的底层运行原理是什么呢？Redis实现了一套消息队列，当客户端进行消息订阅时，服务器会把消息写入该消息队列中。然后，客户端会不断检测消息队列中是否有新消息，如果有，则可以通过消息队列取出消息并返回给客户端，此时可以实现一种非阻塞的订阅传输。代码如下：

//客户端

subscribe:

channel = redis.subscribe(“channel”);

while(true)

{

message = channel.nextMessage(); //读取消息

//处理消息

//……

}

//服务器端

publish:

redis.publish(“channel”, message); //发送消息

当然，如果想要更可靠的消息投递，可以使用Redis的持久化特性（AOF）来保证消息的投递。通过这样的方法Redis实现了非阻塞订阅传输，可以更好的满足多客户端订阅请求所需的消息。