如何使用Jedis操做Redis消息隊列

資源連接

Jedis的jar包
Commons-io的jar包redis

使用方法

代碼樣例以下,使用前,注意打開redis的server程序。this

代碼樣例

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);
        }
	}
}
相關文章
相關標籤/搜索