实现无间断消息传递使用Redis循环拉取消息（循环拉取redis消息）

如今，越来越多的人需要在应用程序中实现无间断消息传递，尤其是在WebSocket的场景中，大家希望在浏览器主动拉取服务器上的数据，而不再依赖一定时间间隔推送的模式。五年前，Redis发布了2.1版本，使用其简单的消息队列机制就可以完美解决这个问题。本文将基于Redis来实现一种消息传递的无间断依赖方案，来帮助程序员实现实时拉取消息的目的。

基于Redis的消息循环首先要做好准备工作，为了降低Redis的消耗，我们可以在服务端设置好定时任务，定时地将新的消息放入队列中，而客户端只通过发起消息读取请求来获取消息，不需要实现定时任务。下面给出一段简单的服务端处理消息的代码：

“` java

//发送消息到Redis队列

public void sendMessage(){

Jedis jedis = new Jedis(“127.0.0.1”, 6379);

jedis.lpush(“message”,”消息内容”);

jedis.close();

}

//定时发送消息任务

public void sendTask(){

ScheduledExecutorService scheduledExecutorService

= Executors.newScheduledThreadPool(1);

scheduledExecutorService.scheduleAtFixedRate(

new Runnable() {

@Override

public void run() {

sendMessage();

}

}, 0, 10, TimeUnit.SECONDS);

}

一旦服务端消息发送完成，客户端就可以拉取Redis中的消息，下面的代码展示了客户端的实现方法：

``` java
//获取消息
public void readMessage(){
    Jedis jedis = new Jedis("127.0.0.1", 6379);
    String result = jedis.rpop("message");
    if (result != null) {
        System.out.println(result);
    }
    jedis.close();
}
//循环获取消息
public void readTask(){
    ScheduledExecutorService scheduledExecutorService 
            = Executors.newScheduledThreadPool(1);
    scheduledExecutorService.scheduleAtFixedRate(
            new Runnable() {
                @Override
                public void run() {
                    readMessage();
                }
            }, 0, 10, TimeUnit.SECONDS);
}

在这里，我们设置Redis消息发送和读取操作的时间间隔都为10秒，实现了一个循环拉取消息的依赖方案，当然，你也可以根据实际需要调整时间间隔，以满足不同的需求。通过上面的几段代码，应用程序就可以实现不间断的消息传递，大大改善了程序的可用性，而且Redis简单易用，效率也比较高，是非常适合实现此类消息处理的数据库。