使用Redis阻塞轮询实现异步消息通信的比较（redis阻塞轮询比较）

  Redis是一个开放源代码、高性能、可基于内存存储的key-value数据库。它可以用于处理复杂数据结构，并且具有广泛的应用场景，如缓存、消息中间件等。本文尝试利用Redis的轮询机制来实现异步消息传递，通过比较该方法与其他常用的实现异步消息传输的方法的优缺点，为选择异步消息传递方法提供一定的参考意见。

  一般来说，为了实现异步消息通信，多数朋友会选择轮询的方式，也就是客户端每隔一段时间向服务器发起请求，以确认是否有可用的消息。但是，这种方式弊端明显：1.客户端发送的请求会给服务器造成巨大压力；2.由于发生卡顿，延迟，用户有可能没有来得及接收消息。

  近几年Redis作为可用于异步消息通信的中间件，也越来越受到欢迎并被越来越多的用户使用。它使用一个阻塞轮询的机制，即客户端只需保持一个持续的阻塞请求，服务端会及时响应，当有新消息时就会立即触发响应，这样客户端就可以轮询服务器而不产生过多的请求压力，且可以保证消息的及时接收。

例如下面的代码中实现了一个简易的阻塞轮询应用：

package mn
import (
 "fmt"
 "encoding/json"
 "time"
 "github.com/gomodule/redigo/redis"
)
const (
 redisJobChannelName = "job-queue"
)

func mn() {
 c, err := redis.Dial("tcp", "localhost:6379")
 if err != nil {
  panic(err)
 }

 // 先订阅，然后设置超时时间
 psc := redis.PubSubConn{Conn: c}
 psc.Subscribe(redisJobChannelName)
 c.Do("SET", redis.Args{"job-expiry", (time.Minute).Milliseconds()}) 
 // 进入轮询
 for {
  switch v := psc.Receive().(type) {
  case redis.Message:
   // 处理接收到的消息
   msg := v.Data
   job := Job{}
   if err := json.Unmarshal(msg, &job); err == nil {
    // 对消息进行处理
    handleJob(job)
   }
  case redis.Subscription:
   fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
  case error:
   psc.Unsubscribe(redisJobChannelName)
   if err := c.Close(); err != nil {
    panic(err)
   }
   return
  }
 }
}

  通过上面的代码可以看到，Redis阻塞轮询既可以减轻服务器的压力，又保证消息的实时性，因此被越来越多的用户使用，替代了之前一直使用的Ajax轮询、longpolling等客户端轮询等方式。但是，Redis的阻塞轮询也存在着一定的缺点：当消息量特别大和CPU负载特别重的时候，其响应时间会受到局限。针对Redis的性能问题，可以考虑使用服务器推送技术，如websocket和EventSource等及其它消息中间件，来解决这个问题。

  Redis的阻塞轮询机制可以帮助开发者减少对于互联网设施的依赖，在轻量级的应用中更易于部署，同时也能够充分满足异步消息传输的效率、可靠性和扩展性的要求。