Jedis 就是 Java 同 Redis 建立连接的工具。
使用 Jedis 需要先导入依赖:
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.1.0</version>
</dependency>
一、Jedis 版 HelloWorld
import org.junit.Test;
import redis.clients.jedis.Jedis;
public class HelloWorldJedis {
@Test
public void test1() {
//连接 Redis
Jedis jedis = new Jedis("127.0.0.1", 6379);
//操作 Jedis
jedis.set("key", "Hello World");
String name = jedis.get("key");
System.out.println(name);
//关闭连接
jedis.close();
}
}
运行结果:
二、Jedis 读写 Redis 数据
- 案例:服务调用次数控制 。
对试用用户的使用行为进行限速, 限制 每个用户每分钟最多发起 10 次调用 。
- 要求
① 设定A、B、C三个用户
② A用户 限制 10次/分 调用,B用户 限制 30次/分 调用,C用户不限制。
- 需求分析
① 设定一个服务方法,用于模拟实际业务调用的服务,内部采用打印模拟调用。
② 在业务调用前 服务调用控制单元,内部使用 Redis 进行控制。
③ 对调用超限 使用异常进行控制,异常处理设定为打印提示信息。
④ 主程序启动 3 个线程,分别表示 3 种不同用户的调用。
- 实现
(1)设定业务方法
void business(String id,long num) {
System.out.println("用户"+id+"发起业务调用,当前第"+num+"次");
}
(2)设置 Redis 控制方案
void service(String id){
Jedis jedis = new Jedis("localhost", 6379);
String value = jedis.get("compid:" + id);
// 判定是否具有调用计数控制,利用异常进行控制处理
if(value == null) {
// 没有控制,创建控制计数器
jedis.setex("compid:" + id, 20, ""+(Long.MAX_VALUE-10));
}else{
// 有控制,自增,并调用业务
try{
Long val = jedis.incr("compid:"+id);
business(id,10+val-Long.MAX_VALUE);
}catch (JedisDataException e){
// 调用次数溢出,弹出提示
System.out.println(" 用户:"+id+" 使用次数已达到上限,请稍后再试,或升级VIP 会员");
return;
}finally{
jedis.close();
}
}
}
(3)设置多线程类,模拟用户调用
public void run() {
while(true){
service(id);
// 模拟调用间隔,设置为 1.x 秒
try{
Random r = new Random();
Thread.sleep(1000 + r.nextInt(200));}
catch(InterruptedException e){
e.printStackTrace();
}
}
}
(4)设置启动主程序
public static void main(String[] args) {
MyThread t1 = new MyThread(" 初级用户");
t1.start();
}
三、Jedis 简易工具类开发
基于连接池获取连接
(1)封装连接参数
新建 jedis.properties:
jedis.host=localhost
jedis.port=6379
jedis.maxTotal=30
jedis.maxIdle=10
- JedisPool:Jedis 提供的连接池技术
- poolConfig:连接池配置对象
- host:Redis服务地址
- port:Redis服务端口号
(2)加载配置信息
static JedisPool jedisPool;
static{
// 读取配置文件 获得参数值
ResourceBundle rb = ResourceBundle.getBundle("jedis");
String host = rb.getString("jedis.host");
int port = Integer.parseInt(rb.getString("jedis.port"));
int maxTotal = Integer.parseInt(rb.getString("jedis.maxTotal"));
int maxIdle = Integer.parseInt(rb.getString("jedis.maxIdle"));
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxTotal(maxTotal);
poolConfig.setMaxIdle(maxIdle);
jedisPool = new JedisPool(poolConfig,host,port);
}
}
(3)获取连接
对外访问接口,提供 jedis 连接对象,连接从连接池获取。
public static Jedis getJedis(){
Jedis jedis = jedisPool.getResource();
return jedis;
}