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