java、spring、springboot中整合Redis的详细讲解

java整合Redis

1、引入依赖或者导入jar包

<dependency>
 <groupId>redis.clients</groupId>
 <artifactId>jedis</artifactId>
 <version>2.9.0</version>
</dependency>

2、代码实现

public class JedisTest {
 public static void main(String[] args) {
  //连接redis
  //Jedis jedis=new Jedis("192.168.65.128",6379);

  //使用Jedis连接池
  Jedis jedis=getJedis();
  //操作redis
  jedis.set("name","小白");
  jedis.set("age","19");
  System.out.println("操作成功!");
  jedis.close();
 }

 public static Jedis getJedis(){
  //创建连接池配置对象
  JedisPoolConfig config=new JedisPoolConfig();
  config.setMaxIdle(10);
  config.setMinIdle(5);
  config.setMaxTotal(100);
  //需要redis的服务密码时,使用第一种创建方式
  //JedisPool jedisPool=new JedisPool(config,"192.168.65.128",6379,10000,"root");
  JedisPool jedisPool=new JedisPool(config,"192.168.65.128",6379,10000);
  return jedisPool.getResource();
 }
}

Spring整合Redis

1、添加依赖

<dependency>
 <groupId>org.springframework.data</groupId>
 <artifactId>spring-data-redis</artifactId>
 <version>2.1.8.RELEASE</version>
</dependency>

<dependency>
 <groupId>redis.clients</groupId>
 <artifactId>jedis</artifactId>
 <version>2.9.0</version>
</dependency>

2、redis配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
 <!--1、配置redis连接池对象-->
 <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
  <!--最大空闲数-->
  <property name="maxIdle" value="50"/>
  <!--最大连接数-->
  <property name="maxTotal" value="100"/>
  <!--最大等待时间-->
  <property name="maxWaitMillis" value="60000"/>
 </bean>

 <!--2、配置redis连接工厂-->
 <bean id="factory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
  <!--连接池的配置-->
  <property name="poolConfig" ref="poolConfig"/>
  <!--连接主机-->
  <property name="hostName" value="192.168.65.128"/>
  <!--端口-->
  <property name="port" value="6379"/>
  <!--密码-->
  <!--
  当出现以下错误时,说明并不需要设置密码
  Caused by: redis.clients.jedis.exceptions.JedisDataException: ERR Client sent AUTH, but no password is set
  -->
  <!--<property name="password" value="root"/>-->
 </bean>

 <!--3、配置redis模板对象-->
 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
  <!--配置连接工厂-->
  <property name="connectionFactory" ref="factory"/>
 </bean>
</beans>

3、注入模板对象

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:application-redis.xml")
public class RedisTest {
 @Autowired
 private RedisTemplate redisTemplate;

 @Test
 public void test(){
  //redisTemplate.opsForValue().set("name","小黑");
  Object name = redisTemplate.opsForValue().get("name");
  System.out.println(name);
  System.out.println("操作完成");
 }
}

注意:使用Spring(SpringBoot)整合redis后,RedisTemplate对象会自带key和value的序列化功能。在redis的客户端操作时,获取的key是被序列化后的key.

思考:为什么Spring要提供一个序列化的功能? 为了开发者方便将对象存入redis中。可在xml中配置自定义的序列化类型。

 <!--3、配置redis模板对象-->
 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
  <!--配置连接工厂-->
  <property name="connectionFactory" ref="factory"/>
  <!--配置String类型的key value序列化方式 当存储的key是String类型时,则vlaue也是String类型,且key和value不被序列化-->
  <property name="keySerializer" ref="stringRedisSerializer"/>
  <property name="valueSerializer" ref="stringRedisSerializer"/>
 </bean>
 <!--自定义序列化类型-->
 <bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
 <!--默认的jdk序列化-->
 <bean id="jdkSerializationRedisSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>

springboot整合Redis

1、添加依赖

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

2、配置application.yml

3、注入模板对象

@RunWith(SpringRunner.class)
@SpringBootTest
class SpringbootRedisApplicationTests {

 @Autowired
 private RedisTemplate redisTemplate;

 @PostConstruct
 public void init(){
  //配置String类型的key value序列化方式
  redisTemplate.setStringSerializer(new StringRedisSerializer());
  redisTemplate.setValueSerializer(new StringRedisSerializer());
 }

 @Test
 void contextLoads() {
  redisTemplate.opsForValue().set("age",12);
  Object age = redisTemplate.opsForValue().get("age");
  System.out.println(age);
  System.out.println("操作成功");
 }

 //获取几种数据结构的对象
 @Test
 public void getRedisType(){
  //1、操作字符串数据类型
  redisTemplate.opsForValue();
  //2、操作hash的数据类型
  redisTemplate.opsForHash();
  //3、操作List的数据类型
  redisTemplate.opsForList();
  //4、操作Set的数据类型
  redisTemplate.opsForSet();
  //5、操作hSet的数据类型
  redisTemplate.opsForZSet();
  //6、操作基数的数据类型
  redisTemplate.opsForHyperLogLog();
 }
}

注意:不能在yml配置文件中配置自定义序列化,可以在springboot启动类或者测试类中,通过@PostConstruct注解来触发执行方法,从而达到配置自定义序列化的效果。

补充:

1.@PostConstruct说明
被@PostConstruct修饰的方法会在服务器加载Servlet的时候运行,并且只会被服务器调用一次,类似于Serclet的inti()方法。被@PostConstruct修饰的方法会在构造函数之后,init()方法之前运行。
2.@PreDestroy说明
被@PreDestroy修饰的方法会在服务器卸载Servlet的时候运行,并且只会被服务器调用一次,类似于Servlet的destroy()方法。被@PreDestroy修饰的方法会在destroy()方法之后运行,在Servlet被彻底卸载之前。

总结

1、当项目报以下错误:Caused by: redis.clients.jedis.exceptions.JedisDataException: ERR Client sent AUTH, but no password is set
报错的原因:是redis服务没设置密码,而项目配置文件中写了有redis密码
解决方案:
1)把项目配置文件中的密码password设置为空或者不设置。
2)设置redis服务密码
——可通过直接修改redis.conf配置文件中的requirepass属性方式,如果修改不生效,可通过命令方式修改,进入redis的客户端

redis 127.0.0.1:6379> CONFIG SET requirepass “root”
OK
redis 127.0.0.1:6379> AUTH root
Ok

然后重启项目就可以连接本机的redis服务了。

到此这篇关于java、spring、springboot中整合Redis的详细讲解的文章就介绍到这了,更多相关java springboot整合Redis内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • SpringBoot集成Redis实现消息队列的方法

    list 原理说明 Redis 的 list 是按照插入顺序排序的字符串链表. 如图所示,可以通过 lpush 和 rpop 或者 rpush 和 lpop 实现消息队列. 1 lpush 和 rpop 2 rpush 和 lpop 消息队列功能实现 引入 Redis 依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data

  • SpringBoot使用Redis的zset统计在线用户信息

    统计在线用户的数量,是应用很常见的需求了.如果需要精准的统计到用户是在线,离线状态,我想只有客户端和服务器通过保持一个TCP长连接来实现.如果应用本身并非一个IM应用的话,这种方式成本极高. 现在的应用都趋向于使用心跳包来标识用户是否在线.用户登录后,每隔一段时间,往服务器推送一个消息,表示当前用户在线.服务器则可以定义一个时间差,例如:5分钟内收到过客户端心跳消息,视为在线用户. 在线用户统计的实现 基于数据库实现 最简单的办法,就是在用户表,添加一个最后心跳包的日期时间字段 last_act

  • php使用redis的有序集合zset实现延迟队列应用示例

    本文实例讲述了php使用redis的有序集合zset实现延迟队列.分享给大家供大家参考,具体如下: 延迟队列就是个带延迟功能的消息队列,相对于普通队列,它可以在指定时间消费掉消息. 延迟队列的应用场景: 1.新用户注册,10分钟后发送邮件或站内信. 2.用户下单后,30分钟未支付,订单自动作废. 我们通过redis的有序集合zset来实现简单的延迟队列,将消息数据序列化,作为zset的value,把消息处理时间作为score,每次通过zRangeByScore获取一条消息进行处理. <?php

  • 如何自定义redis工具jar包供其他SpringBoot项目直接使用

    注:(最终redis数据库连接信息由使用者项目模块配置提供) 一.Redis常用存储操作实现(redis-util模块,该module最后会打包成jar供其他服务使用) 1.引用相关依赖 <!-- 如果有继承父级spring-boot-starter-parent,可不用添加版本号 --> <!-- Redis缓存 [start] --> <dependency> <groupId>org.springframework.boot</groupId&g

  • springboot2整合redis使用lettuce连接池的方法(解决lettuce连接池无效问题)

    lettuce客户端 Lettuce 和 Jedis 的都是连接Redis Server的客户端程序.Jedis在实现上是直连redis server,多线程环境下非线程安全(即多个线程对一个连接实例操作,是线程不安全的),除非使用连接池,为每个Jedis实例增加物理连接.Lettuce基于Netty的连接实例(StatefulRedisConnection),可以在多个线程间并发访问,且线程安全,满足多线程环境下的并发访问(即多个线程公用一个连接实例,线程安全),同时它是可伸缩的设计,一个连接

  • SpringBoot集成Redisson实现延迟队列的场景分析

    使用场景 1.下单成功,30分钟未支付.支付超时,自动取消订单 2.订单签收,签收后7天未进行评价.订单超时未评价,系统默认好评 3.下单成功,商家5分钟未接单,订单取消 4.配送超时,推送短信提醒 ...... 对于延时比较长的场景.实时性不高的场景,我们可以采用任务调度的方式定时轮询处理.如:xxl-job 今天我们采用一种比较简单.轻量级的方式,使用 Redis 的延迟队列来进行处理.当然有更好的解决方案,可根据公司的技术选型和业务体系选择最优方案.如:使用消息中间件Kafka.Rabbi

  • springboot+websocket+redis搭建的实现

    在多负载环境下使用websocket. 一.原因 在某些业务场景,我们需要页面对于后台的操作进行实时的刷新,这时候就需要使用websocket. 通常在后台单机的情况下没有任何的问题,如果后台经过nginx等进行负载的话,则会导致前台不能准备的接收到后台给与的响应.socket属于长连接,其session只会保存在一台服务器上,其他负载及其不会持有这个session,此时,我们需要使用redis的发布订阅来实现,session的共享. 二.环境准备 在https://mvnrepository.

  • springboot连接Redis的教程详解

    创建springboot项目 在NoSQL中选择Redis 项目目录 pom.xml中还需要加入下面的jar包 org.springframework.boot spring-boot-starter-json 在application.properties文件中添加Redis服务器信息 spring.redis.host=192.168.5.132 spring.redis.port=6379 剩下4个test类,我直接以源码的方式粘出来,里面有些代码是非必须的,我保留了测试的验证过程,所以里

  • 使用SpringBoot集成redis的方法

    今天,日月在这里教大家如何使用springBoot集成redis,说实话比较简单,网上也有大把的教程.先套用一下网上的简介. 定义 REmote DIctionary Server(Redis) 是一个由Salvatore Sanfilippo写的key-value存储系统. Redis是一个开源的使用ANSI C语言编写.遵守BSD协议.支持网络.可基于内存亦可持久化的日志型.Key-Value数据库,并提供多种语言的API. 它通常被称为数据结构服务器,因为值(value)可以是 字符串(S

  • springboot基于Redis发布订阅集群下WebSocket的解决方案

    一.背景 单机节点下,WebSocket连接成功后,可以直接发送消息.而多节点下,连接时通过nginx会代理到不同节点. 假设一开始用户连接了node1的socket服务.触发消息发送的条件的时候也通过nginx进行代理,假如代理转到了node2节点上,那么node2节点的socket服务就发送不了消息,因为一开始用户注册的是node1节点.这就导致了消息发送失败. 为了解决这一方案,消息发送时,就需要一个中间件来记录,这样,三个节点都可以获取消息,然后在根据条件进行消息推送. 二.解决方案(s

  • 关于Springboot2.x集成lettuce连接redis集群报超时异常Command timed out after 6 second(s)

    背景:最近在对一新开发Springboot系统做压测,发现刚开始压测时,可以正常对redis集群进行数据存取,但是暂停几分钟后,接着继续用jmeter进行压测时,发现redis就开始突然疯狂爆出异常提示:Command timed out after 6 second(s)...... Caused by: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 6 second(s) at io.lettuce

  • SpringBoot和Redis实现Token权限认证的实例讲解

    一.引言 登陆权限控制是每个系统都应必备的功能,实现方法也有好多种.下面使用Token认证来实现系统的权限访问. 功能描述: 用户登录成功后,后台返回一个token给调用者,同时自定义一个@AuthToken注解,被该注解标注的API请求都需要进行token效验,效验通过才可以正常访问,实现接口级的鉴权控制. 同时token具有生命周期,在用户持续一段时间不进行操作的话,token则会过期,用户一直操作的话,则不会过期. 二.环境 SpringBoot Redis(Docke中镜像) MySQL

  • 使用go操作redis的有序集合(zset)

    我就废话不多说了,大家还是直接看代码吧~ package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { // 连接redis数据库,指定数据库的IP和端口 conn, err := redis.Dial("tcp", "36.99.16.197:6379") if err != nil { fmt.Println("Con

随机推荐