Redis的Java客户端

 目录

1.Jedis的使用

前置工作-ssh进行端口转发

JedisAPI的使用

Jedis连接池

2.SpringDataRedis的使用

1.创建项目

2.配置文件

3.注入RedisTemplate对象

4.编写代码

3.SpringRedisTemplate

哈希结构用法

​总结


1.Jedis的使用

Jedis:以Redis命令作为方法名称,学习成本低,简单实用。但是Jedis实例 是线程不安全的,多线程环境下需要基于连接池来使用

lettuce:基于Netty实现,支持同步异步,响应式编程方式,并且是线程安全的,支持redis哨兵模式,集群模式和管道模式

前置工作-ssh进行端口转发

从本机远程访问redis服务器是需要通过云服务器的外网ip来访问linux服务器的

只修改成外网ip还不够,6379端口是被云服务器的防火墙给保护起来的,如果将该端口的防火墙

关闭,就很可能会遭到黑客攻击。每次开放一个端口,被攻击的几率就更大。

保护了之后,不开启防火墙,我们也无法访问,关闭防火墙,会遭受攻击;换成其他端口也不行,只要redis的端口被公开到公网上,就特别容易被入侵!

可以通过ssh进行端口转发

端口转发(Port Forwarding),也称为端口映射,是通过 SSH 协议在本地和远程主机之间建立一个安全的通道,将流量从一个端口转发到另一个端口的过程。

通常情况下,网络中的设备通过端口号来识别和区分不同的服务或应用程序。端口转发可以实现以下两种方式:

  1. 本地端口转发(Local Port Forwarding):在本地主机上建立一个监听端口,并将该端口上接收到的请求转发到远程主机的目标端口。这使得本地主机能够访问远程主机上的服务,就像这些服务在本地运行一样。

  2. 远程端口转发(Remote Port Forwarding):在远程主机上建立一个监听端口,并将该端口上接收到的请求转发到本地主机的目标端口。这使得远程主机能够访问本地主机上的服务,就像这些服务在远程主机运行一样。

解决方案:通过ssh端口转发,把云服务器上的redis端口,映射表到本地主机

描述:

通过windows访问云服务器的6379,访问不了,通过ssh数据报,将访问redis的请求放到ssh数据包中。通过ssh数据报来访问,服务器的ssh程序解析出上述请求,然后将数据报交给6379端口程序;

ssh也需要给多个端口传递数据,因此为了区分不同的端口,会把服务器的端口在本地用一个端口来进行表示

通过端口转发,可以绕过网络防火墙的限制,访问被阻止或限制的服务。

ssh协议是通过22端口进行的,这个端口不容易被攻破

 此时用户端程序访问127.0.0.1:8888等价于访问linux的6379端口了。同时也保障了安全性

本机查看是否将8888端口绑定了 ,LISTEN状态就是绑定了

JedisAPI的使用

上述简单配置后,我们就能连接上redis了

1.创建Maven项目,导入jedis的依赖和单元测试依赖

    <dependencies>
        <!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.7.0</version>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter</artifactId>
            <version>5.7.2</version>
            <scope>test</scope>
        </dependency>
    </dependencies>

编写代码

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;

public class RedisTest {
    private Jedis jedis;
//前置工作,连接redis
    @BeforeEach
    void setUp(){
        jedis = new Jedis("127.0.0.1",8888);
        jedis.auth("123456");
        jedis.select(0);
    }
//使用
    @Test
    void testString1(){
        String res = jedis.set("hello3","hellohello");
        System.out.println(res);
    }
    @Test
    void testString(){
        String res = jedis.get("hello3");
        System.out.println(res);
    }
//后置工作,关闭资源
    @AfterEach
    void terDown(){
        if(jedis!=null){
            jedis.close();
        }
    }
}

 Jedis连接池

Jedis是线程不安全的,并发环境下需要创建独立的jedis对象。频繁的创建和销毁对象会有很大的开销

因此推荐使用jedis连接池代替直连方式

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisConnectionFactory {
    private static final JedisPool jedispoll;
    static {
        //配置连接池
       JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
       jedisPoolConfig.setMaxTotal(8);//最大连接数,最多常见
       jedisPoolConfig.setMaxIdle(8);//最大空闲连接,最多预备的
       jedisPoolConfig.setMinIdle(0);//最小连接,一直没人访问,就释放
       jedisPoolConfig.setMaxWaitMillis(1000);//等待时长,没有连接池需要等待空闲连接吗,没有等待1000ms
       //创建对象
        jedispoll = new JedisPool(jedisPoolConfig,
                "127.0.0.1",8888,1000,"123456");
    }
    public static Jedis getJedis(){
        return jedispoll.getResource();
    }
}

修改测试代码 

jedis = JedisConnectionFactory.getJedis();//不再new了,而是使用连接池中的jedis对象

public class RedisTest {
    private Jedis jedis;
    @BeforeEach
    void setUp(){
//        jedis = new Jedis("127.0.0.1",8888);
        jedis = JedisConnectionFactory.getJedis();
        jedis.auth("123456");
        jedis.select(0);
    }
    @Test
    void testString1(){
        String res = jedis.set("hello5","hellohello");
        System.out.println(res);
    }
    @Test
    void testString(){
        String res = jedis.get("hello5");
        System.out.println(res);
    }
    @AfterEach
    void terDown(){
        if(jedis!=null){
            jedis.close();
        }
    }
}

2.SpringDataRedis的使用

Spring提供了一组API,SpringDataRedis,底层做了很多兼容。包含对各种数据库的集成,对redis集成模块叫做SpringDataRedis

特点:提供了对不同Redis客户端的整合(lettuce和jedis)

提供了RedisTemplate统一API来操作Redis

支持Redis的发布订阅模型、支持哨兵和集群、支持基于letuuce的响应式编程

支持基于JDK,JSON,字符串,Spring对象的数据序列化与反序列化

支持基于Redis的JDKCOLLECTION实现 

使用 SpringDataRedis分三步:

1.创建项目,导入依赖

2.在配置文件中配置好信息

3.注入RedisTemplate对象

4.编写代码

1.创建项目

创建Maven项目,导入jedis的依赖和单元测试依赖

导入依赖,还要导入commons-pool2依赖

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-redis</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.apache.commons</groupId>
			<artifactId>commons-pool2</artifactId>
		</dependency>
	</dependencies>

2.配置文件

spring.redis.host=127.0.0.1
#Redis服务器连接端口
spring.redis.port=8888
#Redis服务器连接密码(默认为空)
spring.redis.password=123456
#连接池最大连接数(使用负值表示没有限制)
spring.redis.pool.max-active=8
#连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.pool.max-wait=-1
#连接池中的最大空闲连接
spring.redis.pool.max-idle=8
#连接池中的最小空闲连接
spring.redis.pool.min-idle=0
#连接超时时间(毫秒)
spring.redis.timeout=30000

3.注入RedisTemplate对象

	@Autowired
	private RedisTemplate redisTemplate;

4.编写代码

@SpringBootTest
class RedisDemo3ApplicationTests {

	@Autowired
	private RedisTemplate redisTemplate;
	@Test
	void contextLoads() {
		redisTemplate.opsForValue().set("name","zhangsan");
		Object name = redisTemplate.opsForValue().get("name");
		System.out.println(name);
	}

}

运行

redis中的还没有修改 ,查询后发现乱码了

 这与我们之前谈到的SpringDataRedis集成的redis支持序列化的特性

客户端传输数据时,将Object对象序列化为字节形式,默认采用的是jdk序列化,得到的结果自然不是正常字符串,可读性差并且占用内存

看一段RedisTemplate类的源码

public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperations<K, V>, BeanClassLoaderAware {
    private boolean enableTransactionSupport = false;
    private boolean exposeConnection = false;
    private boolean initialized = false;
    private boolean enableDefaultSerializer = true;
    @Nullable
    private RedisSerializer<?> defaultSerializer;
    @Nullable
    private ClassLoader classLoader;
    @Nullable
    private RedisSerializer keySerializer = null;
    @Nullable
    private RedisSerializer valueSerializer = null;
    @Nullable
    private RedisSerializer hashKeySerializer = null;
    @Nullable
    private RedisSerializer hashValueSerializer = null;
    private RedisSerializer<String> stringSerializer = RedisSerializer.string();
    /
        省略.......
    /
    public void afterPropertiesSet() {
        super.afterPropertiesSet();
        boolean defaultUsed = false;
        if (this.defaultSerializer == null) {
            this.defaultSerializer = new JdkSerializationRedisSerializer(this.classLoader != null ? this.classLoader : this.getClass().getClassLoader());
        }

提供了各种数据结构的序列化,并且最后一个方法,当默认序列化设置为空时,首先会创建一个新的JdkSerializationRedisSerializer。这个不太好用,还有其他的序列化方式

查看RedisSerializer的层级结构

我们可以自定义 RedisTemplate的序列化 方式

值处理需要使用json,需要引入依赖

		<dependency>
			<groupId>com.fasterxml.jackson.core</groupId>
			<artifactId>jackson-databind</artifactId>
		</dependency>

编写序列化配置代码

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> redisTemplate = new RedisTemplate<>();
        //设置连接工厂
        redisTemplate.setConnectionFactory(connectionFactory);
        //创建JSON序列化工具
        GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
        //设置key的序列化
        redisTemplate.setKeySerializer(RedisSerializer.string());
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        //设置value序列化
        redisTemplate.setValueSerializer(jsonRedisSerializer);
        redisTemplate.setHashValueSerializer(jsonRedisSerializer);
        //返回
        return redisTemplate;
    }
}
@SpringBootTest
class RedisDemo3ApplicationTests {
	@Autowired
	private RedisTemplate<String,Object> redisTemplate;
	@Test
	void contextLoads() {
		redisTemplate.opsForValue().set("name","慧怡");
		Object name = redisTemplate.opsForValue().get("name");
		System.out.println(name);
	}
}

我们使用Redis Desktop Manager查看

Redis Desktop Manager是一款简单快速、跨平台的Redis桌面管理工具,也被称作Redis可视化工具;支持命令控制台操作,以及常用,查询key,rename,delete等操作。

再看是否能传输对象

	@Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class User {
        private String name;
        private Integer age;
    }
    @Test
	void testSaveUser(){
		//写入数据
		redisTemplate.opsForValue().set("user:100",new User("慧怡",21));
		//获取数据
		User o = (User)redisTemplate.opsForValue().get("user:100");
		System.out.println("o = "+o);
	}

 

 

 可以看到:将对象序列化后,存入了json的对象,获取结果时,控制台打印的时反序列化了的对象

3.SpringRedisTemplate

写入json对象的同时,还写入了一个"@class": "com.example.demo.poji.User",所以在反序列化的时候,才根据这个读取到字节码,类的名称,将json反序列化为User对象

所以无论是字符串,还是java对象,都可以进行存储了,我们只需要在config中配置好 key的序列化工具和 value 的序列化工具就好

同时也带来一个问题

可以看到第一行数据比下面的数据都长了,会带来额外的内存开销,如果数据量巨大,将是一笔不小的开销,但是为了能反序列化又不能不传入该字段

为了节省内存空间,并不会使用JSON序列化器处理VALUE,而是统一使用String序列化器,要求只存储String类型的KEY和VALUE,当存储Java对象时,手动完成对象的序列化和反序列化

转换过程: 

那么是否要重新将配置文件的序列化改动呢?是不用的, SpringRedisTemplate类的KEY与VALUE默认就是String方式,省去了我们自定义的过程

@SpringBootTest
public class RedisDemo3StringTests {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Test
    void testString(){
        stringRedisTemplate.opsForValue().set("name","慧怡");
        Object name = stringRedisTemplate.opsForValue().get("name");
        System.out.println(name);
    }

 

 传对象时:

1.创建对象并手动序列化->写入数据

2.获取数据->手动反序列化

    @Autowired
    private static final ObjectMapper mapper = new ObjectMapper();
    @Test
    void testSaveUser() throws JsonProcessingException {
        //创建对象
        User user = new User("慧怡",21);
        //手动序列化
        String json = mapper.writeValueAsString(user);
        //写入数据
        stringRedisTemplate.opsForValue().set("user:200",json);

        //获取数据
        String jsonUser = stringRedisTemplate.opsForValue().get("user:200");
        //手动反序列化
        User user1 = mapper.readValue(jsonUser,User.class);
        System.out.println("user1 = "+user1);
    }

哈希结构用法

    @Test
    void hsahTest(){
        //存储
        stringRedisTemplate.opsForHash().put("user:300","name","慧怡");
        stringRedisTemplate.opsForHash().put("user:300","age","21");
        //取值
        Map<Object,Object> entires = stringRedisTemplate.opsForHash().entries("user:300");
        System.out.println(entires);
    }

 

总结

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/59419.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

mysql重置和修改密码 Ubuntu系统

忘记密码要重置密码 cat /etc/mysql/debian.cnf/etc/mysql/debian.cnf这个只有Debian或者Ubuntu服务器才有&#xff0c;里面有mysql安装后自带的用户&#xff0c;作用就是重启及运行mysql服务。我们用这个用户登录来达到重置密码的操作 使用上面的那个文件中的用户名和密码登…

强化学习分享(一) DQN算法原理及实现

摘要&#xff1a;主要讲解DQN算法的原理&#xff0c;伪代码解读&#xff0c;基于pytorch版本的DQN小游戏编程&#xff0c;同时对该代码进行详细标注&#xff0c;以及奉上原码。 &#xff08;一&#xff09;强化学习算法介绍 DQN&#xff0c;顾名思义&#xff0c;Deep Q Learni…

SpringCloud《Eureka、Ribbon、Feign、Hystrix、Zuul》作用简单介绍

概述 SpringCloud是一个全家桶&#xff0c;包含多个组件。 本文主要介绍几个重要组件&#xff0c;也就是Eureka、Ribbon、Feign、Hystrix、Zuul这几个组件。 一、业务场景介绍 业务流程&#xff0c;支付订单功能 订单服务改变为已支付订单服务调用库存服务&#xff0c;扣减…

中国农村程序员学习此【正则表达式进阶】发明cahtGPT,购买大平层,开上帕拉梅拉,迎娶白富美出任CEO走上人生巅峰

注&#xff1a;最后有面试挑战&#xff0c;看看自己掌握了吗 文章目录 限制可能的用户名匹配空白字符匹配非空白字符指定匹配的上限和下限只指定匹配的下限指定匹配的确切数量检查全部或无正向先行断言和负向先行断言检查混合字符组使用捕获组重用模式使用捕获组搜索和替换删除…

分类预测 | MATLAB实现WOA鲸鱼算法同步优化特征选择结合支持向量机分类预测

分类预测 | MATLAB实现WOA鲸鱼算法同步优化特征选择结合支持向量机分类预测 目录 分类预测 | MATLAB实现WOA鲸鱼算法同步优化特征选择结合支持向量机分类预测效果一览基本介绍程序设计参考资料 效果一览 基本介绍 MATLAB实现WOA鲸鱼算法同步优化特征选择结合支持向量机分类预测…

Windows 系统无法复制粘贴则么处理

Windows 系统无法复制粘贴如何恢复呢&#xff1f; 今天小编遇到一个问题&#xff0c;就是自己的电脑突然无法复制、粘贴&#xff0c;这样的问题我遇到很多次&#xff0c;重启电脑虽然能解决问题&#xff0c;但是不能一直通过重启来解决这样的问题&#xff0c;很浪费时间的。今…

Filebeat+ELK 部署

Node1节点&#xff08;2C/4G&#xff09;&#xff1a;node1/192.168.8.10 Elasticsearch Kibana Node2节点&#xff08;2C/4G&#xff09;&#xff1a;node2/192.168.8.11 Elasticsearch Apache节点&#xff1a;apache/192.168.8.13 …

2023年电赛---运动目标控制与自动追踪系统(E题)发挥题思路

前言 &#xff08;1&#xff09;因为博客编辑字数超过1W字会导致MD编辑器非常卡顿。所以我将发挥题和基础题的思路拆开了。 &#xff08;2&#xff09;更新日记&#xff1a; <1>2023年8月4日&#xff0c;9点20分。分离发挥题思路和基础题思路&#xff0c;增加了博主Huiye…

2020-2023中国高等级自动驾驶产业发展趋势研究

1.1 概念界定 2020-2023中国高等级自动驾驶产业发展趋势研究Trends in China High-level Autonomous Driving from 2020 to 2023自动驾驶发展过程中&#xff0c;中国出现了诸多专注于研发L3级以上自动驾驶的公司&#xff0c;其在业界地位也越来越重要。本报告围绕“高等级自动…

【雕爷学编程】MicroPython动手做(29)——物联网之SIoT 2

知识点&#xff1a;什么是掌控板&#xff1f; 掌控板是一块普及STEAM创客教育、人工智能教育、机器人编程教育的开源智能硬件。它集成ESP-32高性能双核芯片&#xff0c;支持WiFi和蓝牙双模通信&#xff0c;可作为物联网节点&#xff0c;实现物联网应用。同时掌控板上集成了OLED…

Java实现数据库表中的七种连接【Mysql】

Java实现数据库表中的七种连接【Mysql】 前言版权推荐Java实现数据库表中的七种连接左外连接右外连接其他连接 附录七种连接SQL测试Java测试转换方法类 Cla1类 Cla2类Cla3 最后 前言 2023-8-4 16:51:42 以下内容源自《【Mysql】》 仅供学习交流使用 版权 禁止其他平台发布时…

vue 混入(mixin)的使用

在 vue 组件内&#xff0c;如果想将一些公共功能&#xff0c;如组件、方法、钩子函数等复用&#xff0c;混入是一个很好的选择。 现在开始我们的混入使用吧 1、我们可以创建一个目录mixins&#xff0c;在创建一个comment.js文件如图&#xff1a; // 在 common.js 里写你想共享…

SQL 表别名 和 列别名

列表名 列表名之后 order by 可以用别名 也可以用原名&#xff0c; where 中不能用别名的 SQL语句执行顺序&#xff1a; from–>where–>group by -->having — >select --> order 第一步&#xff1a;from语句&#xff0c;选择要操作的表。 第二步&#xff1…

matlab编程实践18、19

浅水方程 浅水方程可以建立起海啸和浴缸中波浪的数学模型。浅水方程建立了水或者其它不可压缩液体受扰动时传播的模型。隐含的假设是&#xff0c;液体的深度和波浪的长度、扰动等相比是很小的。 在这样的记号下&#xff0c;浅水方程为双曲守恒定律的一个例子。 使用拉克斯-冯特…

ssm机动车维修站车辆维护管理系统java汽车报修备案jsp源代码mysql

本项目为前几天收费帮学妹做的一个项目&#xff0c;Java EE JSP项目&#xff0c;在工作环境中基本使用不到&#xff0c;但是很多学校把这个当作编程入门的项目来做&#xff0c;故分享出本项目供初学者参考。 一、项目描述 ssm机动车维修站车辆维护管理系统 系统有2权限&#…

iOS16.0:屏幕旋转

此文写于2022年08月03日&#xff0c;距离iOS16正式版推出还有一个多月的时间&#xff0c;iOS16 beta版本有很多API的修改&#xff0c;今天讨论的是屏幕旋转&#xff0c;基于Xcode 14.0 beta4。 之前的屏幕旋转会报错&#xff1a; [Orientation] BUG IN CLIENT OF UIKIT: Settin…

MinIO

MinIO 1.MinIO安装 Minio 是个基于 Golang 编写的开源对象存储服务&#xff0c;存储非结构化数据&#xff0c;如&#xff1a;图片&#xff0c;视频&#xff0c;音乐等 官网地址&#xff1a;https://min.io/ 中文地址&#xff1a;http://minio.org.cn 官网文档&#xff08; …

Istio 安全 mTLS认证 PeerAuthentication

这里定义了访问www.ck8s.com可以使用http也可以使用https访问&#xff0c;两种方式都可以访问。 那么是否可以强制使用mtls方式去访问&#xff1f; mTLS认证 PeerAuthentication PeerAuthentication的主要作用是别人在和网格里的pod进行通信的时候&#xff0c;是否要求mTLS mTL…

SpringBoot中事务失效的原因

SpringBoot中事务失效的原因 文章目录 SpringBoot中事务失效的原因一、事务方法非public修饰二、非事务方法调用事务方法三、事务方法的异常被捕获四、事务异常类型不对五、事务传播行为不对六、没有被Spring管理6.1、暴漏代理对象6.2、使用代理对象 常见的事务失效原因包括如下…

LeetCode-26-删除有序数组中的重复项

一&#xff1a;题目描述&#xff1a; 给你一个 升序排列 的数组 nums &#xff0c;请你 原地 删除重复出现的元素&#xff0c;使每个元素 只出现一次 &#xff0c;返回删除后数组的新长度。元素的 相对顺序 应该保持 一致 。然后返回 nums 中唯一元素的个数。 考虑 nums 的唯…