首页 > 基础资料 博客日记
Java操作redis常见类型数据存储
2023-11-20 18:00:55基础资料围观261次
目录
一、Java连接Redis
redis与mysq都是数据库,java操作redis其实跟操作mysql的过程是差不多的,首先都是导入依赖、建立连接,只是方式不同,redis是非关系数据库而mysql是关系数据库。
什么是关系数据库与非关系数据库?
关系数据库 是一种基于关系模型的数据库系统,其中数据以表格形式组织,并使用 SQL(Structured Query Language)进行查询和管理。在关系数据库中,数据由多个表格组成,每个表格包含多个行和列,每行代表一个记录,每列代表一个属性。关系数据库中的表格之间可以建立关系,通过这些关系可以实现数据的联合查询和更新。关系数据库最常见的例子是MySQL、Oracle和SQL Server等。
非关系数据库(NoSQL)是相对于传统的关系数据库而言的,它采用了非关系数据模型来存储和处理数据。非关系数据库通常不使用表格,而是使用其他形式的数据结构,例如键值对、文档、图形等,以便更好地处理大量非结构化数据。NoSQL数据库通常具有较高的可扩展性、灵活性和性能,并且能够处理复杂的数据处理任务。非关系数据库最常见的例子是MongoDB、Cassandra和Redis等。
1.1 导入pom依赖
在maven项目中导入redis依赖
<!--redis-->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
1.2 建立连接
首先的启动redis,Linux版与windos版启动redis方式详情文章 http://t.csdnimg.cn/UBt3Z
本次为了方便就使用了本机进行测试使用redis
package text; import redis.clients.jedis.Jedis; /** * @author 云村小威 * @create 2023-11-04 22:20 */ public class demo1 { public static void main(String[] args) { Jedis jedis = new Jedis("localhost", 6379); jedis.auth("123456"); System.out.println(jedis.ping()); } }
二、Java使用Redis
Redis支持五种基本的数据类型:字符串(string),哈希(hash),列表(list),集合(set)和有序集合(sorted set,也被称为zset)。这些数据类型在数据库中都以key-value的形式保存,所有的key都是字符串类型的。
具体来说,Redis的字符串是二进制安全的,这意味着他们可以包含任何数据,比如图片或者JSON。哈希是一个键值对的集合,适合用于存储对象。列表是简单的字符串列表,按插入顺序排序,适用于队列和栈等场景。集合是一个无序的字符串集合,用于存储不重复的数据。有序集合和集合类似,但每个元素都关联了一个分数,根据这个分数进行排序,适用于排行榜等场景。
此外,从Redis 5.0.5版本开始,还增加了两种数据类型:位图和地理位置。位图是一种压缩的字符串表示形式,可以节省空间;地理位置则用于存储地理坐标信息。
2.1 字符串 String
package text;
import redis.clients.jedis.Jedis;
/**
* @author 云村小威
* @create 2023-11-04 22:20
*/
public class demo1 {
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost", 6379);
jedis.auth("123456");
System.out.println(jedis.ping());
//string:set get del sexex ttl
jedis.select(3);//指定数据库
//添加数据
jedis.set("string_name", "云村小威");
//get key 获取
System.out.println(jedis.get("string_name"));
//type key 查看类型
System.out.println(jedis.type("string_name"));
//keys * 或 keys key 查看所有或者指定的key
System.out.println(jedis.keys("*"));
//SETEX KEY_NAME TIMEOUT VALUE 给键值对设置过期时间
jedis.setex("string_test", 100, "ready");
//ttl key 获取键值对剩余的存活时间
System.out.println(jedis.ttl("string_test"));
}
}
2.2 哈希 Hash
//Hash
jedis.select(4);//指定数据库
//hset key field1 value1 [field2 value2] 同时将多个field-value设置到哈希表key中
jedis.hset("hash_user", "name", "云村小威");
jedis.hset("hash_user", "sex", "男");
jedis.hset("hash_user", "age", "18");
//hget key field 获取指定的字段值
System.out.println(jedis.hget("hash_user", "sex"));
//hdel key field 删除指定的字段值
jedis.hdel("hash_user", "sex");
//hgetall key 查询指定key的所有字段
Map<String, String> hash_user_map = jedis.hgetAll("hash_user");
System.out.println(hash_user_map);
//hexists key field 查询指定key中的字段是否存在
Boolean hash_user = jedis.hexists("hash_user", "sex");
System.out.println(hash_user);
//hlen key 获取指定key中的长度
Long hash_user_len = jedis.hlen("hash_user");
System.out.println(hash_user_len);
优化后:
public void setHashMap(Jedis jedis, String key, Map<String, String> map) { if (map != null && map.size() > 0) { Set<String> keys = map.keySet(); for (String k : keys) { jedis.hset(key, k, map.get(k)); } } }
Map map = new HashMap<>(); map.put("name", "云村小威"); map.put("sex", "男"); map.put("age", "18"); setHashMap(jedis, "user", map);
2.3 列表 List
jedis.select(4);//指定数据库
//lpush key value1 value2 value3 将一个或多个值插入到列表头部
jedis.lpush("List_hobby", "sing", "jump", "rap", "basketball");
//llen key 获取列表的长度
System.out.println(jedis.llen("List_hobby"));
//lindex key index 根据索引获取列表中的元素
System.out.println(jedis.lindex("List_hobby", 2));
//lrange key start sop 查看指定范围内的元素
System.out.println(jedis.lrange("List_hobby", 0, 3));
2.4 集合 Set
//sadd key value1 [value2] 向集合添加一个或多个元素
jedis.sadd("set_user", "老六", "老五", "老七", "老八");
//scard key 获取集合中的元素数量
System.out.println(jedis.scard("set_user"));
//exists key 是否存在
System.out.println(jedis.exists("set_user"));
2.5 有序集合 Sorted Set
// -1 表示最后一个成员, -2 表示倒数第二个成员,以此类推。
jedis.zadd("mysort", 1.0, "飞鸟集");
jedis.zadd("mysort", 2.0, "牧羊少年的奇幻之旅");
jedis.zadd("mysort", 3.0, "皮囊");
jedis.zadd("mysort", 4.0, "我与地坛");
Map<String, Double> map = new HashMap<>();
map.put("mutouliu", 5.0);
jedis.zadd("mysort", map);
//正序排列
Set<String> mysort = jedis.zrange("mysort", 0, -1);
System.out.println(mysort);
//倒序排列
Set<String> mysort1 = jedis.zrange("mysort", -1, 0);
System.out.println(mysort1);
//命令用于计算集合中元素的数量
System.out.println(jedis.zcard("mysort"));
//命令用于计算有序集合中指定分数区间的成员数量
System.out.println(jedis.zcount("mysort", 0, 4));
//命令在计算有序集合中指定字典区间内成员数量。
System.out.println(jedis.zlexcount("mysort", "-", "+"));
三、Redis的实际应用场景
redis一般用于存储基本不会变换的数据,然后这些数据又被多个地方使用且关联。
例如:我需要查询所有的会议状态,如果不使用redis的话我还需要通过查询到的state(0,1,2...)连表查询到所翻译的字符串(0 取消会议,1 待审核)
用到redis话,就可以将这些数据进行存储起来,如图示例:当status为0时就能查到是新增操作...
会议状态亦是如此,接下就是Redis的实际应用场景示例:
ssm项目中:利用spring自定义注解与AOP结合Redis的使用:首先在会议实体的state(会议状态)属性中使用了自定义注解,当我在controller层中调用了查询所有会议信息的方法时,通过切面结合state属性使用的自定义注解完成查询到会议信息的state字段的值时,则返回一个字符串形式的状态信息;
1、定义会议实体
首先,我们定义一个会议实体类Meeting
public class Meeting {
private String name;
@State(value = 1)
private int state;
...
// 构造方法、getter和setter方法省略
}
2、定义自定义注解
接下来,我们定义一个自定义注解@State
,用于标识会议状态字段。
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface State {
int value();
}
3、创建切面类
然后,我们创建一个切面类MeetingAspect
,用于在查询会议信息时,根据状态字段的值进行特殊处理。
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import java.util.List;
@Aspect
@Component
public class MeetingAspect {
@Autowired
private Jedis jedis;
@AfterReturning(pointcut = "execution(* com.example.controller.MeetingController.queryAllMeetings(..))", returning = "meetings")
public void handleQueryAllMeetings(JoinPoint joinPoint, List<Meeting> meetings) {
for (Meeting meeting : meetings) {
if (meeting.getState() == 1) {
jedis.set("待开会议", meeting.getName());
}
}
}
}
在上面的切面类中,我们使用@AfterReturning
切点拦截MeetingController
的getAllMeetings()
方法的返回结果。然后,我们遍历会议列表,如果会议状态字段的值为1,将会议状态名称设置为"待开会议",并将会议名称和状态名称存储到Redis中。
请确保你已经在Spring中配置了Redis相关的配置。
4、创建控制器类
现在,我们创建一个控制器类MeetingController
,用于获取所有会议信息。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
@RestController
public class MeetingController {
@Autowired
private MeetingService meetingService;
@GetMapping("/queryAllMeetings")
public List<Meeting> queryAllMeetings() {
return meetingService.findAll();
}
}
最后,确保在Spring配置文件中进行以下配置:这样,当调用MeetingController
的getAllMeetings()
方法时,切面会拦截返回结果,并根据会议状态字段的值进行特殊处理。如果会议状态字段的值为1,则将会议状态名称设置为"待开会议",并将会议名称和状态名称存储到Redis中。
请注意,以上示例仅供参考,你需要根据实际情况进行适当的修改和完善。特别是Redis相关的配置,需要根据你的实际环境和需求进行调整。
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:jacktools123@163.com进行投诉反馈,一经查实,立即删除!
标签:
上一篇:Java集合全解【完整版】
下一篇:【Java】阿里巴巴Java开发手册