如何使用Jedis操作Redis消息队列-白红宇

资源链接

使用方法

代码样例如下，使用前，注意打开redis的server程序。

代码样例

package RedisExample;import redis.clients.jedis.Jedis;public class TestRedis {    public static void main(String[] args) {        Jedis redis = new  Jedis("localhost");  //      SimpleExample(redis);        //      ListExample(redis,20000);                PublishExample(redis,20000);    }    //简单添加信息    public static void SimpleExample(Jedis redis){        redis.set("key1", "I am value 1");          String ss = redis.get("key1");          System.out.println(ss);    }    //队列添加信息    public static void ListExample(Jedis redis,int number){        String messageStr = "";        int count = 0;        while(count++ < number){            messageStr =  "this is "+count+" message!";            redis.rpush("logstash-test-list",messageStr);            System.out.println(messageStr);        }    }    //发布订阅    public static void PublishExample(Jedis redis,int number){        String messageStr = "";        int count = 0;        while(count++ < number){            messageStr =  "this is "+count+" message!";            redis.publish("logstash-test-list",messageStr);            System.out.println(messageStr);        }    }}

本文转自博客园xingoo的博客，原文链接：，如需转载请自行联系原博主。