在java中使用redis

server/2024/10/9 15:20:02/

Redis Java使⽤

引入依赖

Java 操作redis的客⼾端有很多.其中最知名的是jedis.

创建maven项⽬,把jedis的依赖拷⻉到pom.xml中

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>4.3.2</version>
</dependency>

配置端⼝转发

Redis 服务器安装在云服务器上,⽽我们编写的代码则是在本地主机. 

可以使⽤端⼝转发的⽅式,直接把服务器的redis端⼝映射到本地.

此时,访问本地的8888,就相当于访问对应服务器的6379

可以在cmd里查看是否映射成功:

注意,xshell 和服务器必须处在连接状态,这样的映射才是有效的.

 

连接RedisServer

  • 使⽤JedisPool描述Redis服务器的位置.使⽤url来表⽰.
  • 使⽤ getResource 和服务器建⽴连接.
  • 连接使⽤完毕需要close关闭.也可以直接使⽤try⾃动关闭.
  • 通过ping⽅法可以检测连接是否正确建⽴.
java">public static void main(String[] args) {// 连接到 Redis 服务器上.JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");try (Jedis jedis = jedisPool.getResource()) {// redis 的各种命令, 就都对应到 jedis 对象的各种方法.String pong = jedis.ping();System.out.println(pong);}
}

看一些基础操作:

java">public class RedisDemoGeneric {public static void test1(Jedis jedis) {System.out.println("get 和 set 的使用");// 先清空数据库. 要避免上一组测试的残留数据影响到下一组测试的结果.jedis.flushAll();jedis.set("key", "111");jedis.set("key2", "222");SetParams params = new SetParams();params.ex(10);params.nx();jedis.set("key", "333", params);String value = jedis.get("key");System.out.println("value=" + value);}public static void test2(Jedis jedis) {System.out.println("exists 和 del");jedis.flushAll();jedis.set("key", "111");jedis.set("key2", "222");jedis.set("key3", "333");boolean result = jedis.exists("key");System.out.println("result: " + result);long result2 = jedis.del("key");System.out.println("result2: " + result2);result = jedis.exists("key");System.out.println("result: " + result);result2 = jedis.del("key", "key2", "key3");System.out.println("result2: " + result2);}public static void test3(Jedis jedis) {System.out.println("keys");jedis.flushAll();jedis.set("key", "111");jedis.set("key2", "111");jedis.set("key3", "111");jedis.set("key4", "111");// redis 中的 key 不能重复~ 而且也是不在意顺序的.Set<String> keys = jedis.keys("*");System.out.println(keys);}public static void test4(Jedis jedis) {System.out.println("expire 和 ttl");jedis.flushAll();jedis.set("key", "111");jedis.expire("key", 10);try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}long time = jedis.ttl("key");System.out.println("time: " + time);}public static void test5(Jedis jedis) {System.out.println("type");jedis.flushAll();jedis.set("key", "111");String type = jedis.type("key");System.out.println("type: " + type);jedis.lpush("key2", "111", "222", "333");type = jedis.type("key2");System.out.println("type: " + type);jedis.hset("key3", "f1", "111");type = jedis.type("key3");System.out.println("type: " + type);jedis.sadd("key4", "111", "222", "333");type = jedis.type("key4");System.out.println("type: " + type);jedis.zadd("key5", 10, "zhangsan");type = jedis.type("key5");System.out.println("type: " + type);}public static void main(String[] args) {// 连接到 Redis 服务器上.JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");try (Jedis jedis = jedisPool.getResource()) {// redis 的各种命令, 就都对应到 jedis 对象的各种方法.
//            String pong = jedis.ping();
//            System.out.println(pong);// test1(jedis);// test2(jedis);// test3(jedis);// test4(jedis);test5(jedis);}}
}

Redis Java 集成到SpringBoot

使⽤SpringBoot连接Redis单机

配置redis服务地址

application.yml:

spring:redis:host: 127.0.0.1port: 8888

创建Controller

此处需要使⽤StringRedisTemplate 实例

java">@RestController
public class MyController {@Autowiredprivate StringRedisTemplate redisTemplate;
}

前面使用jedis,是通过jedis对象里的各种方法来操作redis的

此处Spring则是通过StringRedisTemplate来操作redis

最原始提供的类是RedisTemplate,StringRedisTemplate是它的子类,专门处理文本数据

 

函数式接口,相当于一个回调函数,就在会调里,写要执行的redis命令

这里的RedisConnection就代表了redis连接,对标Jedis对象

此处RedisTemplate是把这些操作redis的方法,分成了几个类别,做了进一步封装

execute方法,让我们随时能够执行redis原生命令

java">// 后续 redis 测试的各种方法, 都通过这个 Controller 提供的 http 接口来触发.
@RestController
public class MyController {@Autowiredprivate StringRedisTemplate redisTemplate;@GetMapping("/testString")@ResponseBodypublic String testString() {redisTemplate.execute((RedisConnection connection) -> {// execute 要求回调方法中必须写 return 语句. 返回个东西.// 这个回调返回的对象, 就会作为 execute 本身的返回值.connection.flushAll();return null;});redisTemplate.opsForValue().set("key", "111");redisTemplate.opsForValue().set("key2", "222");redisTemplate.opsForValue().set("key3", "333");String value = redisTemplate.opsForValue().get("key");System.out.println("value: " + value);return "OK";}@GetMapping("/testList")@ResponseBodypublic String testList() {// 先清除之前的数据.redisTemplate.execute((RedisConnection connection) -> {// execute 要求回调方法中必须写 return 语句. 返回个东西.// 这个回调返回的对象, 就会作为 execute 本身的返回值.connection.flushAll();return null;});redisTemplate.opsForList().leftPush("key", "111");redisTemplate.opsForList().leftPush("key", "222");redisTemplate.opsForList().leftPush("key", "333");String value = redisTemplate.opsForList().rightPop("key");System.out.println("value: " + value);value = redisTemplate.opsForList().rightPop("key");System.out.println("value: " + value);value = redisTemplate.opsForList().rightPop("key");System.out.println("value: " + value);return "OK";}@GetMapping("/testSet")@ResponseBodypublic String testSet() {redisTemplate.execute((RedisConnection connection) -> {connection.flushAll();return null;});redisTemplate.opsForSet().add("key", "111", "222", "333");Set<String> result = redisTemplate.opsForSet().members("key");System.out.println("result: " + result);Boolean exists = redisTemplate.opsForSet().isMember("key", "111");System.out.println("exists: " + exists);Long count = redisTemplate.opsForSet().size("key");System.out.println("count: " + count);redisTemplate.opsForSet().remove("key", "111", "222");result = redisTemplate.opsForSet().members("key");System.out.println("result: " + result);return "OK";}@GetMapping("/testHash")@ResponseBodypublic String testHash() {redisTemplate.execute((RedisConnection connection) -> {connection.flushAll();return null;});redisTemplate.opsForHash().put("key", "f1", "111");redisTemplate.opsForHash().put("key", "f2", "222");redisTemplate.opsForHash().put("key", "f3", "333");String value = (String) redisTemplate.opsForHash().get("key", "f1");System.out.println("value: " + value);Boolean exists = redisTemplate.opsForHash().hasKey("key", "f1");System.out.println("exists: " + exists);redisTemplate.opsForHash().delete("key", "f1", "f2");Long size = redisTemplate.opsForHash().size("key");System.out.println("size: " + size);return "OK";}@GetMapping("/testZSet")@ResponseBodypublic String testZSet() {redisTemplate.execute((RedisConnection connection) -> {connection.flushAll();return null;});redisTemplate.opsForZSet().add("key", "zhangsan", 10);redisTemplate.opsForZSet().add("key", "lisi", 20);redisTemplate.opsForZSet().add("key", "wangwu", 30);Set<String> members = redisTemplate.opsForZSet().range("key", 0, -1);System.out.println("members: " + members);Set<ZSetOperations.TypedTuple<String>> membersWithScore = redisTemplate.opsForZSet().rangeWithScores("key", 0, -1);System.out.println("membersWithScore: " + membersWithScore);Double score = redisTemplate.opsForZSet().score("key", "zhangsan");System.out.println("score: " + score);redisTemplate.opsForZSet().remove("key", "zhangsan");Long size = redisTemplate.opsForZSet().size("key");System.out.println("size: " + size);Long rank = redisTemplate.opsForZSet().rank("key", "lisi");System.out.println("rank: " + rank);return "OK";}
}


http://www.ppmy.cn/server/128732.html

相关文章

FTP连接池与多线程FTP上传下载算法（Java）

FTP连接池与多线程FTP上传下载算法（Java）

设计一个能够处理FTP连接池在多线程环境下，尤其是涉及到故障重连时避免竞争条件的算法，需要综合考虑线程同步、连接状态管理和重试机制。以下是一个设计思路和实现方案： 设计思路 连接池管理： 维护一个连接池，其中包含多个FTP连接对象。每个FTP连接对象需有状态标记（如…
阅读更多...
【动态规划】完全背包问题

【动态规划】完全背包问题

完全背包问题 1. 完全背包 点赞&#x1f44d;&#x1f44d;收藏&#x1f31f;&#x1f31f;关注&#x1f496;&#x1f496; 你的支持是对我最大的鼓励&#xff0c;我们一起努力吧!&#x1f603;&#x1f603; 1. 完全背包 题目链接&#xff1a; DP42 【模板】完全背包 题目分…
阅读更多...
计算机网络：计算机网络概述 —— 描述计算机网络的参数

计算机网络：计算机网络概述 —— 描述计算机网络的参数

文章目录 数据量性能指标速率带宽数据传输速率 吞吐量时延分析时延问题 时延带宽积往返时间利用率丢包率丢包的情况 抖动可用性可靠性安全性 计算机网络是现代信息社会的基础设施&#xff0c;其性能和可靠性对各类应用至关重要。为了理解和优化计算机网络&#xff0c;我们需要深…
阅读更多...
如何用python抓取豆瓣电影TOP250

如何用python抓取豆瓣电影TOP250

1.如何获取网站信息&#xff1f; &#xff08;1&#xff09;调用requests库、bs4库 #检查库是否下载好的方法&#xff1a;打开终端界面&#xff08;terminal&#xff09;输入pip install bs4, 如果返回的信息里有Successfully installed bs4 说明安装成功&#xff08;request…
阅读更多...
一种格式化printf hex 数据的方法

一种格式化printf hex 数据的方法

格式化输出HEX数据 调试过程中通常需要个格式化输出16进制数据&#xff0c;为了方便美观可以参考如下方法。 #define __is_print(ch) ((unsigned int)((ch) - ) < 127u - )/*** dump_hex* * brief hex打印* * param buf: 需要打印的原始数据* param size: 原始数据类型*…
阅读更多...
【Spring】Spring MVC的项目准备和连接建立

【Spring】Spring MVC的项目准备和连接建立

文章目录 1. 什么是 Spring Web MVC1.1 MVC 定义1.2 什么是 Spring MVC 2. 学习 Spring MVC2.1 项目准备2.2 建立连接 1. 什么是 Spring Web MVC Spring Web MVC 是基于 Servlet API 构建的原始 Web 框架&#xff0c;从已开是就包含在 Spring 框架中。它的正式名称“Spring We…
阅读更多...
java语言基础案例-cnblog

java语言基础案例-cnblog

java语言基础案例 象棋口诀 输出 package nb;public class XiangQi {public static void main(String[] args) {char a 马;char b 象;char c 卒;System.out.println(a"走日"b"走田""小"c"一去不复还");} }输出汇款单 package nb…
阅读更多...
使用PL/SQL Deverloper过程遇见的问题

使用PL/SQL Deverloper过程遇见的问题

目录 背景: ORA-01031权限问题&#xff1a; PL/SQL Deverloper显示Oravle中存在的所有表&#xff1a; PL/SQL Deverloper优点: 背景: PL/SQL Developer是由Allround Automations公司开发的一款集成开发环境(IDE),它专门面向Oracle数据库存储的程序单元的开发。随着越来越多…
阅读更多...
最新文章

Copyright @ 2022~2023