Redis的Java客户端

Redis的Java客户端

Jedis线程不安全，lettuce线程安全
Jedis

测试

引入依赖

1. <dependencies>
2.     <dependency>
3.         <groupId>redis.clients</groupId>
4.         <artifactId>jedis</artifactId>
5.         <version>3.7.0</version>
6.     </dependency>
7.     <dependency>
8.         <groupId>org.junit.jupiter</groupId>
9.         <artifactId>junit-jupiter</artifactId>
10.         <version>5.7.0</version>
11.     </dependency>
12. </dependencies>

复制代码

Test.java

1. public class JedisTest {
2.     private Jedis jedis;
4.     @BeforeEach
5.     void setUp() {
6.         //1.建立连接
7.         jedis=new Jedis("192.168.164.128",6379);
8.         //2.设置密码
9.         jedis.auth("123456");
10.         //3.选择库
11.         jedis.select(0);
12.     }
14.     @Test
15.     void testString() {
16.         //存入
17.         String result=jedis.set("name","熊哥");
18.         System.out.println("result="+result);
19.         //获取
20.         String name=jedis.get("name");
21.         System.out.println("name="+name);
23.         //存入
24.         jedis.hset("user:1","name","Jack");
25.         jedis.hset("user:1","age","21");
26.         //获取
27.         Map<String, String> map = jedis.hgetAll("user:1");
28.         System.out.println(map);
29.     }
31.     @AfterEach
32.     void tearDown() {
33.         //关闭连接
34.         if(jedis!=null){
35.             jedis.close();
36.         }
37.     }
38. }

复制代码

Jedis连接池

Jedis本身是线程不安全的，且频繁的创建和销毁连接有性能损耗，因此推荐使用Jedis连接池代替Jedis直接连接

JedisConnectionFactory.java

1. public class JedisConnectionFactory {
2.     //连接池对象
3.     private static final JedisPool jedisPool;
5.     //初始化
6.     static {
7.         //配置连接池
8.         JedisPoolConfig poolConfig = new JedisPoolConfig();
9.         poolConfig.setMaxTotal(8);  //最大8个连接
10.         poolConfig.setMaxIdle(8);   //最大空闲数量
11.         poolConfig.setMinIdle(0);   //最小空闲数量
12.         poolConfig.setMaxWaitMillis(1000);  //当池内没有返回对象时最大等待时间
14.         //创建连接池对象(JedisPoolConfig,ip,port，timeout,password)
15.         jedisPool=new JedisPool(poolConfig,"192.168.164.128",6379,1000,"123456");
16.     }
17.     public static Jedis getJedis(){
18.         return jedisPool.getResource();
19.     }
20. }

复制代码

Test.java（改变建立连接的语句）

1. public class JedisTest {
2.     private Jedis jedis;
4.     @BeforeEach
5.     void setUp() {
6.         //1.建立连接
7. //        jedis=new Jedis("192.168.164.128",6379);
8.         jedis= JedisConnectionFactory.getJedis();
9.         //2.设置密码
10.         jedis.auth("123456");
11.         //3.选择库
12.         jedis.select(0);
13.     }
15.     @Test
16.     void testString() {
17.         //存入
18.         String result=jedis.set("name","熊哥");
19.         System.out.println("result="+result);
20.         //获取
21.         String name=jedis.get("name");
22.         System.out.println("name="+name);
24.         //存入
25.         jedis.hset("user:1","name","Jack");
26.         jedis.hset("user:1","age","21");
27.         //获取
28.         Map<String, String> map = jedis.hgetAll("user:1");
29.         System.out.println(map);
30.     }
32.     @AfterEach
33.     void tearDown() {
34.         //关闭连接
35.         if(jedis!=null){
36.             jedis.close();
37.         }
38.     }
39. }

复制代码

SpringDataRedis

SpringDataRedis中提供RedisTemplate工具类，封装了各种对Redis的操作。springboot2.x以前默认支持Jedis，以后默认支持lettuce
依赖

1. <dependency>
2.     <groupId>org.springframework.boot</groupId>
3.     <artifactId>spring-boot-starter-data-redis</artifactId>
4. </dependency>
6. <dependency>
7.     <groupId>org.apache.commons</groupId>
8.     <artifactId>commons-pool2</artifactId>
9. </dependency>

复制代码

application.yaml

1. spring:
2.   redis:
3.     host: 192.168.164.128
4.     port: 6379
5.     password: 123456
6.     database: 0
7.     lettuce:
8.       pool:
9.         max-active: 8
10.         max-idle: 8
11.         min-idle: 0
12.         max-wait: 100ms

复制代码

Test.java

1. @SpringBootTest
2. class RedisDemoApplicationTests {
3.     @Resource
4.     private RedisTemplate<String,Object> redisTemplate;
6.     @Test
7.     void contextLoads() {
8.         //写入一条String数据
9.         redisTemplate.opsForValue().set("name","王五");
10.         //获取
11.         Object name=redisTemplate.opsForValue().get("name");
12.         System.out.println(name);
13.     }
14. }

复制代码

序列化以实现跨平台存储（在上面的基础上修改）

添加配置类RedisConfig.java

1. @Configuration
2. public class RedisConfig {
3.     @Bean
4.     public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory connectionFactory){
5.         //创建RedisTemplate对象
6.         RedisTemplate<String, Object> template = new RedisTemplate<>();
7.         //设置连接工厂
8.         template.setConnectionFactory(connectionFactory);
9.         //创建JSON序列化工具
10.         GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
11.         //设置Key的序列化
12.         template.setKeySerializer(RedisSerializer.string());
13.         template.setHashKeySerializer(RedisSerializer.string());
14.         //设置Value的序列化
15.         template.setValueSerializer(jsonRedisSerializer);
16.         template.setHashValueSerializer(jsonRedisSerializer);
17.         //返回
18.         return template;
19.     }
20. }

复制代码

Test.java中修改下面这行

1. private RedisTemplate<String,Object> redisTemplate;

复制代码

若linux下还是显示乱码，在启动客户端时最后加上 --raw

StringRedisTemplate(上面的经典白学)

Spring默认提供了一个StringRedisTemplate类，它的key和value的序列化方式默认是String方式。省去了自定义RedisTemplate的过程

Test.java

1. @SpringBootTest
2. public class RedisStringTest {
3.     @Autowired
4.     private StringRedisTemplate stringRedisTemplate;
6.     @Test
7.     void contextLoads() {
8.         //写入一条String数据
9.         stringRedisTemplate.opsForValue().set("name","王五");
10.         //获取
11.         Object name=stringRedisTemplate.opsForValue().get("name");
12.         System.out.println(name);
13.     }
14. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！