一、Jedis基本用法
1、访问流程
连接池建立-〉访问密码设置-〉连接超时等参数设置
2、在pom文件引入相关依赖:
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
二、使用方式
1、Jedis直接连接redis如下:
2、使用连接池方式
生产环境一般使用连接池进行操作,jedis连接redis对象放在连接池里,每次用的时候去POOL借用,用完后归还。
3、连接池代码
三、redis简单使用实例
1、生产者
package com.james.redis.queue1;
import com.james.redis.utils.JedisUtils;
public class RedisProducer {
/**
* jedis操作List
*/
public static void main(String[] args){
JedisUtils jedis = new JedisUtils("192.168.1.111", 6379,"12345678");
for(int i = 0;i<10;i++) {
jedis.lpush("informList","orderIdadb_" + i);
}
}
}
2、消费者
package com.james.redis.queue1;
public class RedisConsumer {
/**
* jedis操作List
*/
public static void main(String[] args){
ScheduleMQ mq = new ScheduleMQ();
mq.start();
}
}
package com.james.redis.queue1;
import java.util.List;
import com.james.redis.utils.JedisUtils;
class ScheduleMQ extends Thread {
JedisUtils jedis = new JedisUtils("192.168.1.111", 6379,"12345678");
@Override
public void run() {
while(true) {
//阻塞式brpop,List中无数据时阻塞
//参数0表示一直阻塞下去,直到List出现数据
List<String> list = jedis.brpop(0, "informList");
for(String s : list) {
//处理业务逻辑
System.out.println(s);
}
}
}
}
补充:JedisUtils和剩余的配置等内容可以到此下载:redis简单使用实例