Redis快速入门
我们称这种为nosql
认识Nosql
认识redis
redis安装:
1.单机安装Redis
1.1.安装Redis依赖
Redis是基于C语言编写的,因此首先需要安装Redis所需要的gcc依赖:
yum install -y gcc tcl
1.2.上传安装包并解压
tar -xzf redis-6.2.6.tar.gz
cd redis-6.2.6
运行编译命令:
make && make install
如果没有出错,应该就安装成功了。
默认的安装路径是在 /usr/local/bin
目录下:
该目录以及默认配置到环境变量,因此可以在任意目录下运行这些命令。其中:
- redis-cli:是redis提供的命令行客户端
- redis-server:是redis的服务端启动脚本
- redis-sentinel:是redis的哨兵启动脚本
1.3.启动
redis的启动方式有很多种,例如:
- 默认启动
- 指定配置启动
- 开机自启
1.3.1.默认启动
安装完成后,在任意目录输入redis-server命令即可启动Redis:
redis-server
这种启动属于前台启动
,会阻塞整个会话窗口,窗口关闭或者按下CTRL + C
则Redis停止。不推荐使用。
1.3.2.指定配置启动
如果要让Redis以后台
方式启动,则必须修改Redis配置文件,就在我们之前解压的redis安装包下(/usr/local/src/redis-6.2.6
),名字叫redis.conf:
我们先将这个配置文件备份一份:
cp redis.conf redis.conf.bck
然后修改redis.conf文件中的一些配置:
# 允许访问的地址,默认是127.0.0.1,会导致只能在本地访问。修改为0.0.0.0则可以在任意IP访问,生产环境不要设置为0.0.0.0
bind 0.0.0.0
# 守护进程,修改为yes后即可后台运行
daemonize yes
# 密码,设置后访问Redis必须输入密码
requirepass 123321
Redis的其它常见配置:
# 监听的端口
port 6379
# 工作目录,默认是当前目录,也就是运行redis-server时的命令,日志、持久化等文件会保存在这个目录
dir .
# 数据库数量,设置为1,代表只使用1个库,默认有16个库,编号0~15
databases 1
# 设置redis能够使用的最大内存
maxmemory 512mb
# 日志文件,默认为空,不记录日志,可以指定日志文件名
logfile "redis.log"
启动Redis:
# 进入redis安装目录
cd /usr/local/src/redis-6.2.6
# 启动
redis-server redis.conf
停止服务:
# 利用redis-cli来执行 shutdown 命令,即可停止 Redis 服务,
# 因为之前配置了密码,因此需要通过 -u 来指定密码
redis-cli -u 123321 shutdown
1.3.3.开机自启
首先,新建一个系统服务文件:
vi /etc/systemd/system/redis.service
内容如下:
[Unit]
Description=redis-server
After=network.target
[Service]
Type=forking
ExecStart=/usr/local/bin/redis-server /usr/local/src/redis-6.2.6/redis.conf
PrivateTmp=true
[Install]
WantedBy=multi-user.target
然后重载系统服务:
systemctl daemon-reload
现在,我们可以用下面这组命令来操作redis了:
# 启动
systemctl start redis
# 停止
systemctl stop redis
# 重启
systemctl restart redis
# 查看状态
systemctl status redis
执行下面的命令,可以让redis开机自启:
systemctl enable redis
2.Redis客户端
安装完成Redis,我们就可以操作Redis,实现数据的CRUD了。这需要用到Redis客户端,包括:
- 命令行客户端
- 图形化桌面客户端
- 编程客户端
2.1.Redis命令行客户端
Redis安装完成后就自带了命令行客户端:redis-cli,使用方式如下
redis-cli [options] [commonds]
其中常见的options有:
-h 127.0.0.1
:指定要连接的redis节点的IP地址,默认是127.0.0.1-p 6379
:指定要连接的redis节点的端口,默认是6379-a 123321
:指定redis的访问密码
其中的commonds就是Redis的操作命令,例如:
ping
:与redis服务端做心跳测试,服务端正常会返回pong
不指定commond时,会进入redis-cli
的交互控制台:
2.2.图形化桌面客户端
GitHub上的大神编写了Redis的图形化桌面客户端,地址:https://github.com/uglide/RedisDesktopManager
不过该仓库提供的是RedisDesktopManager的源码,并未提供windows安装包。
在下面这个仓库可以找到安装包:https://github.com/lework/RedisDesktopManager-Windows/releases、
2.2.1.安装
在课前资料中可以找到Redis的图形化桌面客户端:
Redis常见命令
1数据结构介绍
Redis通用命令:
就是大多数数据类型都能使用的命令:
1Kyes 不建议在生产环境下使用,因为进行的是模糊查询,速度慢,redis是单线程,很容易造成redis阻塞
2DEL 删除一个KEY或者多个KEY
3.EXISTS 判断Key是否存在
4EXPIRE 和TTL 给KEY设置有效期和查看过期时间
总结:
String类型的常见命令还有基本操作:
数据
'{"id":1, "name":"Jack", "age": 21}'
'{"id":2, "name":"Rose", "age": 18}'
'{"id":1, "name":"小米11", "price": 4999}'
'{"id":2, "name":"荣耀6", "price": 2999}'
Hash类型
List类型:
思考
Set类型:
常见应用于关注,点赞等交友互动
练习
127.0.0.1:6379> SADD zhangsan lisi wangwu zhaoliu
3
127.0.0.1:6379> SADD lisi wangwu mazi ergou
3
127.0.0.1:6379> SINRER zhangsan lisi
ERR unknown command `SINRER`, with args beginning with: `zhangsan`, `lisi`,
127.0.0.1:6379> SUBTER zhangsan lisi
ERR unknown command `SUBTER`, with args beginning with: `zhangsan`, `lisi`,
127.0.0.1:6379> SINTER zhangsan lisi
wangwu
127.0.0.1:6379> SDIFF zhangsan lisi
lisi
zhaoliu
127.0.0.1:6379> SUNION zhangsan lisi
wangwu
zhaoliu
lisi
ergou
mazi
127.0.0.1:6379> SISMEMBER zhangsan lisi
1
127.0.0.1:6379> SISMEMBER lisi zhangsan
0
127.0.0.1:6379> SREM zhangsan lisi
1
127.0.0.1:6379>
SortedSet
127.0.0.1:6379> ZADD 85 jack 89 lucy 95 Tom 78 Jerry 92 Amy 76 Miles
ERR syntax error
127.0.0.1:6379> ZADD stus 85 jack 89 lucy 95 Tom 78 Jerry 92 Amy 76 Miles
6
127.0.0.1:6379> ZADD stus 85 jack 89 82 Rose lucy 95 Tom 78 Jerry 92 Amy 76 Miles
ERR value is not a valid float
127.0.0.1:6379> ZADD stus 85 jack 89 82 Rose lucy 95 Tom 78 Jerry 92 Amy 76 Miles
ERR value is not a valid float
127.0.0.1:6379> ZADD 85 jack 89 lucy 82 Rose 95 Tom 78 Jerry 92 Amy 76 Miles
ERR syntax error
127.0.0.1:6379> ZADD stus 85 jack 89 lucy 82 Rose 95 Tom 78 Jerry 92 Amy 76 Miles
1
127.0.0.1:6379> ZREM stus Tom
1
127.0.0.1:6379> ZRANK stus Rose
2
127.0.0.1:6379> ZREVRANK stus Rose
3
127.0.0.1:6379> ZCARD stus
6
127.0.0.1:6379> ZCARD stus 0 80
ERR wrong number of arguments for 'zcard' command
127.0.0.1:6379> ZCOUNT stus 0 80
2
127.0.0.1:6379> ZINCRBY stus 2 Amy
94
127.0.0.1:6379> ZRANGE stus 0 2
Miles
Jerry
Rose
127.0.0.1:6379> ZREVRANGE stus 0 2
Amy
lucy
jack
127.0.0.1:6379> ZRANGEBYSCORE stus 0 80
Miles
Jerry
127.0.0.1:6379>
Redis JAVA 客户端
Jedis的官网地址: https://github.com/redis/jedis,我们先来个快速入门:
1.引入依赖:
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.7.0</version>
</dependency>
2.建立连接
private Jedis jedis;
@BeforeEachvoid setUp() {
// 建立连接
jedis = new Jedis("192.168.150.101", 6379);
// 设置密码
jedis.auth("123321");
// 选择库
jedis.select(0);
}
3.测试string
@Testvoid testString() {
// 插入数据,方法名称就是redis命令名称,非常简单
String result = jedis.set("name", "张三");
System.out.println("result = " + result);
// 获取数据
String name = jedis.get("name");
System.out.println("name = " + name);
}
4.释放资源
@AfterEach
void tearDown() {
// 释放资源
if (jedis != null) {
jedis.close();
}
}
代码实现
public class JedisTest {
private Jedis jedis;
/**
* @BeforeEach在每个测试方法之前执行的方法(初始化)
*/
@BeforeEach
void setUp() {
//建立连接
jedis = new Jedis("8.130.103.81", 6379);
//设置密码:
jedis.auth("Hui52818");
//选择库
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"+name);
}
@Test
void testHash(){
//插入hash数据
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 testAfter(){
if(jedis != null){
jedis.close();
}
}
}
代码
JedisConnectionFactory
package com.heima.jedis.util;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class JedisConnectionFactory {
private static final JedisPool JEDIS_POOL;
static {
//配置连接池
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
//设置最大连接数
jedisPoolConfig.setMaxTotal(8);
//最大空闲连接
jedisPoolConfig.setMaxIdle(8);
//最小空闲连接 如果一直没有访问最大的空闲连接,那么
jedisPoolConfig.setMinIdle(0);
//最大等待时间,如果没有空闲连接,那么我需要等多久,一般是-1,无线等待
jedisPoolConfig.setMaxWaitMillis(1000);
//创建连接池对象
JEDIS_POOL = new JedisPool(jedisPoolConfig,"8.130.103.81", 6379,1000,"Hui52818");
}
public static Jedis getJedis(){
return JEDIS_POOL.getResource();
}
}
@BeforeEach
void setUp() {
//建立连接
// jedis = new Jedis("8.130.103.81", 6379);
jedis = JedisConnectionFactory.getJedis();
//设置密码:
jedis.auth("Hui52818");
//选择库
jedis.select(0);
}
第二种JAVA客户端
SpringDataRedis
https://spring.io/projects/spring-data-redis
SpringDataRedis快速入门
SpringBoot已经提供了对SpringDataRedis的支持,使用非常简单:
在创建springboot项目时选择nosql中的spring data 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: 8.130.103.81
port: 6379
password: Hui52818
jedis:
pool:
max-active: 8
max-idle: 8
min-idle: 0
max-wait: 1000ms
注入测试:
@SpringBootTest
class RedisDemoApplicationTests {
@Autowired
private RedisTemplate redisTemplate;
@Test
void contextLoads() {
//写入一条String数据
redisTemplate.opsForValue().set("name","虎哥");
//获取String数据
Object name = redisTemplate.opsForValue().get("name");
System.out.println(name);
}
}
我们在redis中查看所有的keys
可以看到一个乱码的存在
SpringDataRedis的序列化方式
我们可以自定义RedisTemplate的序列化方式,代码如下:
package com.heima.redisdemo.redis.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
@Configuration
public class redisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate (RedisConnectionFactory connectionFactory){
//创建redisTemplate对象
RedisTemplate<String, Object> template = new RedisTemplate<>();
//设置连接工厂
template.setConnectionFactory(connectionFactory);
//创建json的序列化工具
GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
//设置key的序列化
template.setKeySerializer(RedisSerializer.string());
template.setHashKeySerializer(RedisSerializer.string());
//设置value的序列化
template.setValueSerializer(jsonRedisSerializer);
template.setHashValueSerializer(jsonRedisSerializer);
//返回
return template;
}
}
从新启动测试:报错,缺少依赖
添加:
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
重新测试
@Test
void testSaveUser(){
//写入数据
redisTemplate.opsForValue().set("user:100",new User("虎哥",21));
//读数据
User o = (User) redisTemplate.opsForValue().get("user:100");
System.out.println(o);
}
这时从新测试,成功
方案二:
package com.heima.redisdemo;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.heima.redisdemo.redis.pojo.User;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
@SpringBootTest
class RedisDemoApplicationTests {
private static final ObjectMapper mapper = new ObjectMapper();
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
void contextLoads() {
//写入一条String数据
stringRedisTemplate.opsForValue().set("name","虎哥");
//获取String数据
Object name = stringRedisTemplate.opsForValue().get("name");
System.out.println(name);
}
@Test
void testSaveUser() throws JsonProcessingException {
//创建对象
User user = new User("虎哥",21);
//手动序列化
String json = mapper.writeValueAsString(user);
//写入数据
stringRedisTemplate.opsForValue().set("user:200",json);
//获取数据 这时取出来的是json字符串
String stringjson = stringRedisTemplate.opsForValue().get("user:200");
//手动反序列化
User user1 = mapper.readValue(stringjson, User.class);
System.out.println(user1);
// //写入数据
// stringRedisTemplate.opsForValue().set("user:100",new User("虎哥",21));
// //读数据
// User o = (User) stringRedisTemplate.opsForValue().get("user:100");
// System.out.println(o);
}
}
这时再看已经没有class相关的了
存储hash结构的用法
@Test
void testHash(){
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);
}