如何使用Jedis操作Redis消息队列

2025-04-14 04:30:46

推荐回答（3个）

回答1：

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);
        }
    }
}

回答2：

回答3：

使用方法

代码样例如下，使用前，注意打开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);
}
}
}