> 文章列表 > redis学习

redis学习

redis学习

Redis

1.安装

 vi /etc/sysconfig/network-scripts/ifcfg-ens33  #修改网络

安装gcc依赖

yum install -y gcc tclcd redis-6.2.11
make && make installcp redis.conf.bck redis.conf
#修改redis.conf
bind 0.0.0.0
daemonize yes
requirepass 123456cd /usr/local/src/redis-6.2.11/src
redis-server /usr/local/src/redis-6.2.11/redis.confredis-cli -h 192.168.0.138 -p 6379 -a 123456

下载客户端

https://github.com/lework/RedisDesktopManager-Windows/releases

String类型常见命令

keys *
del age
EXISTS name
expire age 30
ttl age
incr age
incrby age 2
set score 10.1
INCRBYFLOAT score 0.5
setnx name lisi
setex  name 10 jack

2.redis使用

2.1常用的操作redis的客户端工具

jedis
Jedis 是 Redis 官方推荐的 Java 连接开发工具,jedis非线程安全。

但是可以通过JedisPool连接池去管理实例,在多线程情况下让每个线程有自己独立的jedis实例,可变为线程安全。

Lettuce
Lettuce 是基于 Netty框架(NIO)的事件驱动的通信,支持同步和异步调用的,可扩展的 redis client,多个线程可以共享一个 RedisConnection,线程安全。

SpringBoot2.0之后默认都是使用的Lettuce这个客户端连接Redis服务器。Lettuce 是一种可扩展的、线程安全的 Redis 高级客户端。

Redisson
Redisson 是一个在 Redis 的功能基础上实现的 Java 驻内存数据网格客户端。实现了分布式和可扩展的 Java 数据结构,提供很多分布式相关操作服务,例如分布式锁,分布式集合,可通过 Redis 支持延迟队列。

小结
Jedis 和 Lettuce 两者相比,Jedis 的性能比较差,其他方面并没有太明显的区别,所以如果你不需要使用 Redis 的高级功能的话,优先推荐使用 Lettuce。

相比于 Jedis、Lettuce 等基于 redis 命令封装的客户端,Redisson 提供的功能更加高端和抽象,逼格简单使用

2.2Jedis测试

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>3.7.0</version>
</dependency>
private Jedis jedis;@BeforeEach
void setUp() {jedis = new Jedis("192.168.0.138", 6379);jedis.auth("123456");jedis.select(0);
}@Test
void testString() {String result = jedis.set("name", "胡歌");System.out.println("result = " + result);String name = jedis.get("name");System.out.println(name);
}@Test
void testHash(){jedis.hset("user:1","name","jack");jedis.hset("user:1","age","21");//获取Map<String, String> map = jedis.hgetAll("user:1");System.out.println(map);
}@AfterEach
void tearDown() {if (jedis != null) jedis.close();
}

Jedis连接池

Jedis本身是线程不安全的,并且频繁的创建和销毁连接会有性能损耗,因此我们推荐大家使用Jedis连接池代替Jedis的连接方式。

通过JedisPool连接池去管理实例,在多线程情况下让每个线程有自己独立的jedis实例,可变为线程安全。

public class JedisConctionFactory {private static final JedisPool jedisPool;static {JedisPoolConfig poolConfig = new JedisPoolConfig();//设置最大连接数poolConfig.setMaxTotal(8);//设置最大空闲连接数poolConfig.setMaxIdle(6);// 设置最小空闲连接数 (就是隔段时间后,一直没有连接,会销毁剩于至1)poolConfig.setMinIdle(1);poolConfig.setMaxWaitMillis(1000);jedisPool = new JedisPool(poolConfig,"192.168.0.138",6379,1000,"123456");}public static Jedis getJedis(){return jedisPool.getResource();}
}
@SpringBootTest
public class RedisApplicationTests {private Jedis jedis;@BeforeEachvoid setUp() {
//        jedis = new Jedis("192.168.0.138", 6379);jedis = JedisConctionFactory.getJedis();jedis.auth("123456");jedis.select(0);}@Testvoid testString() {String result = jedis.set("name", "胡歌");System.out.println("result = " + result);String name = jedis.get("name");System.out.println(name);}@Testvoid testHash(){jedis.hset("user:1","name","jack");jedis.hset("user:1","age","21");//获取Map<String, String> map = jedis.hgetAll("user:1");System.out.println(map);}@AfterEachvoid tearDown() {if (jedis != null) jedis.close();}
}

2.3SpringDataRedis

  • 提供了对不同Redis客户端的整合(Lettuce和Jedis)
  • RedisTemplate统一操作
  • 支持发布订阅
  • 支持哨兵和集群
  • 支持基于Lettuce的响应式编程
  • 支持基于JDK、JSON、字符串、Spring对象的数据序列化和反序列化(如原始的jedis客户端只是支持String)
  • 支持基于Redis的JDKCollection实现
<!--        redis依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>
<!--        连接池依赖--><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency>
spring:redis:host: 192.168.0.138port: 6379password: 123456jedis:pool:max-active: 8max-idle: 8min-idle: 0max-wait: 1000ms

String类型

不序列化 默认采用JDK序列化

@Resource
private RedisTemplate redisTemplate;@Test
public void test1(){redisTemplate.opsForValue().set("name","虎哥");Object name = redisTemplate.opsForValue().get("name");System.out.println("name:" + name);
}
\\xAC\\xED\\x00\\x05t\\x00\\x06\\xE8\\x99\\x8E\\xE5\\x93\\xA5

序列化

@Configuration
public class redisConfig {@Beanpublic RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory connectionFactory){RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(connectionFactory);GenericJackson2JsonRedisSerializer jsonSerializer = new GenericJackson2JsonRedisSerializer();template.setKeySerializer(RedisSerializer.string());template.setHashKeySerializer(RedisSerializer.string());template.setValueSerializer(jsonSerializer);template.setHashValueSerializer(jsonSerializer);return template;}
}
@Resource
private RedisTemplate<String,Object> redisTemplate;
@Test
public void test2(){redisTemplate.opsForValue().set("user:100",new User("虎哥",21));User user = (User) redisTemplate.opsForValue().get("user:100");System.out.println("user:" + user);
}

查看redis数据库

{"@class": "com.cc.redis.pojo.User","name": "虎哥","age": 21
}

问题:多了 "@class": "com.cc.redis.pojo.User", 占用空间,优化方式:使用手动序列化

手动序列化不需要上面的序列化配置了

@Resource
private StringRedisTemplate stringRedisTemplate;private static final ObjectMapper mapper = new ObjectMapper();@Test
public void test2() throws Exception{User user = new User("虎哥", 21);String josn = mapper.writeValueAsString(user);stringRedisTemplate.opsForValue().set("user:200",josn);String jsonUser = stringRedisTemplate.opsForValue().get("user:200");User user1 = mapper.readValue(jsonUser, User.class);System.out.println("user:" + user);
}@Test
public void test1(){stringRedisTemplate.opsForValue().set("name","虎哥");Object name = stringRedisTemplate.opsForValue().get("name");System.out.println("name:" + name);
}

查看数据库

{"name": "虎哥","age": 21
}

Hash类型

@Test
public void test3(){stringRedisTemplate.opsForHash().put("user:400","name","虎哥");stringRedisTemplate.opsForHash().put("user:400","age","21");Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");System.out.println("entries:" + entries);
}