实现消息持久化循环拉取Redis消息（循环拉取redis消息）

消息持久化是在不同的应用间传送消息时常遇到的问题，例如应用服务器和消息队列之间。消息持久化可以保障应用消息能够被持久化，以防止分布式系统数据丢失。

Redis是一种开源的NoSQL内存数据库，它可以作为一种消息缓存的解决方案，它的数据也可以被消息持久化保存下来。本文给出了一种循环拉取Redis消息的实现方式。

需要定义循环拉取消息：

 //编写方法实现循环拉取消息
public static void getMessages(Jedis jedis) {
  //订阅消息并监听
   jedis.subscribe(new JedisPubSub(){
     //从redis中拉取消息
     @Override
     public void onMessage(String channel, String message) {
       //订阅拉取消息后的回调，提取消息将其进行持久化
       if (channel.equals("redisChannel")) {
         //持久化消息
         persistMessage(message);
       }
     }
   }, "redisChannel");
}

第二步持久化消息，也就是把拉取到的消息持久化到数据库中：

//持久化消息
public static void persistMessage(String message) {
  //将消息序列化
  Message msg = serializeMessage(message);
  //将消息存入数据库中
  saveMessage(msg);
}

就可以循环拉取和持久化Redis消息了：

//客户端从Redis中拉取消息
public static void mn(String[] args) {
  Jedis jedis = new Jedis("localhost");
  getMessages(jedis);
}    

通过以上代码，我们可以实现循环拉取Redis消息并持久化的功能。此外，我们还可以使用非阻塞的方式，在用户客户端不停的向Redis拉取消息，这样用户可以立即得到消息，也可以实现消息的持久化。