1. 开启远程连接
Redis默认不支持远程连接，需要手动开启。
进入redis.conf
-
注释掉以下绑定 bind
-
取消注释并设置密码 （开启密码校验）
requirepass 123456 -
然后启动redis
2. Jedis
- 创建一个普通Maven项目
- 添加Jedis依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>4.0.1</version>
</dependency>
- 创建测试方法
public class MyJedis {
public static void main(String[] args) {
//1. 构造Jedis对象 因为使用默认端口6379,可以不用配置端口
Jedis jedis = new Jedis("192.168.xx.xx",6379);
//2. 密码认证
jedis.auth("123456");
//3. 测试是否连接成功(ping)
String ping=jedis.ping();
//4. 返回pong表示连接成功
System.out.println(ping);
}
}
输出PONG即连接成功：
要是未连接成功——确认配置无误，redis服务已经打开——还是不行——重启或许是最好的方法
在jedis中，由于方法的API和redis的命令高度一致，所以，jedis中的方法可以直接使用。
连接池
在实际应用中，jedis实例一般通过连接池获取，由于jedis对象不是线程安全的，所以，当我们使用jedis对象时，从连接池获取jedis，使用完成后还给连接池。
public class JedisPoolTest {
public static void main(String[] args) {
//1. 构造一个Jedis连接池
JedisPool pool = new JedisPool("192.168.", 6379);
//2. 从连接池中获取Jedis；连接
Jedis jedis = pool.getResource();
//3. Jedis操作
jedis.auth("123456");
String ping = jedis.ping();
System.out.println(ping);
//4. 归还连接
jedis.close();
}
}
如果步骤3出现异常，那么连接无法关闭，无法归还连接，连接被持久占用。
因此要进行优化–finally
package org.kk.jedis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
/**
* @program: jedis
* @description:
* @author: zjx
* @create: 2022-01-28 21:39
**/
public class JedisPoolTest {
public static void main(String[] args) {
Jedis jedis = null;
//1. 构造一个Jedis连接池
JedisPool pool = new JedisPool("192.168.", 6379);
//2. 从连接池中获取Jedis；连接
jedis = pool.getResource();
//3. Jedis操作
try {
jedis.auth("123456");
String ping = jedis.ping();
System.out.println(ping);
} catch (Exception e) {
e.printStackTrace();
} finally {
//4. 归还连接
if(jedis!=null){
jedis.close();
}
}
}
}
再优化：
利用JDK1.7中的try-with-resource特性，可以对上面的代码进行改造：
package org.kk.jedis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
/**
* @program: jedis
* @description:
* @author: zjx
* @create: 2022-01-28 21:39
**/
public class JedisPoolTest {
public static void main(String[] args) {
JedisPool pool = new JedisPool("192.168.", 6379);
try(Jedis jedis=pool.getResource()) {
jedis.auth("123456");
String ping = jedis.ping();
System.out.println(ping);
}
}
}
似乎还是不可靠。。。上面这段代码无法实现强约束，我们可以做进一步的改进：
写一个接口，然后真正调用的时候去实现这个接口。
首先定义接口：
package org.kk.jedis;
import redis.clients.jedis.Jedis;
public interface CallWithJedis {
void call(Jedis jedis);
//对这个接口做一个实现类，实现类里面传Jedis进来
}
然后实现方法Redis：
package org.kk.jedis;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
/**
* @program: jedis
* @description:
* @author: zjx
* @create: 2022-01-28 22:19
**/
public class Redis {
private JedisPool pool;
public Redis(){ //作初始化
GenericObjectPoolConfig config=new GenericObjectPoolConfig();
pool=new JedisPool(config,"192.168.10.14",6379);
//或者写全参数 timeout，password
}
public void execute(CallWithJedis callWithJedis){
try(Jedis jedis=pool.getResource())
{
callWithJedis.call(jedis);
}
}
}
测试：
public static void main(String[] args) {
Redis redis = new Redis();
redis.execute(jedis -> {
jedis.auth("123456");
System.out.println(jedis.ping());
});
}
一些配置：
public Redis(){ //作初始化
GenericObjectPoolConfig config=new GenericObjectPoolConfig();
config.setMaxIdle(300);//连接池最大空闲数
config.setMaxTotal(1000);//最大连接数
config.setMaxWaitMillis(10000);//连接最大等待时间 如果是-1 表示没有限制
config.setTestOnBorrow(true);//在空闲时检查有效性
pool=new JedisPool(config,"192.168.10.14",6379);
}
3. Lettuce
github搜索即可。
Lettuce和Jedis的比较：
- Jedis在实现的过程中是直接连接Redis的，在多个线程之间共享一个Jedis实例，这是线程不安全的。如果想在多线程场景下使用Jedis，就得使用连接池，这样，每个线程都有自己的Jedis实例，需要许多物理资源
- Lettuse基于目前很火的Netty NIO框架来构建，所以克服了Jedis中线程不安全的问题，支持同步、异步、响应式调用，多个线程可以共享一个连接实例。
使用Lettuse，创建普通的maven项目并添加依赖。
Basic Use
注意：密码写在连接里面
RedisClient client = RedisClient.create("redis://password@192.168.");
StatefulRedisConnection<String, String> connection = client.connect();
RedisStringCommands sync = connection.sync();
sync.set("key","123");
String value = sync.get("key");