场景
在SpringBoot项目中需要连接两个Redis实例，并实现从A中获取数据并存取到B中。
另外A中redis的地址和密码不能外漏，则将A的地址和密码写在jar包中，B中redis参数可以在外置
配置文件application.yml中进行动态配置。
注：
博客：
BADAO_LIUMANG_QIZHI的博客_霸道流氓气质_CSDN博客
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。
实现
1、新建SpringBoot项目并添加依赖
?
??????? <dependency>
??????????? <groupId>redis.clients</groupId>
??????????? <artifactId>jedis</artifactId>
??????????? <version>3.3.0</version>
??????? </dependency>
??????? <dependency>
??????????? <groupId>org.springframework.data</groupId>
??????????? <artifactId>spring-data-redis</artifactId>
??????????? <version>2.3.6.RELEASE</version>
??????? </dependency>
??????? <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
??????? <dependency>
??????????? <groupId>com.alibaba</groupId>
??????????? <artifactId>fastjson</artifactId>
??????????? <version>1.2.75</version>
??????? </dependency>
?2、完整的pom文件代码
?
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
???????? xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
??? <modelVersion>4.0.0</modelVersion>
??? <parent>
??????? <groupId>org.springframework.boot</groupId>
??????? <artifactId>spring-boot-starter-parent</artifactId>
??????? <version>2.3.7.RELEASE</version>
??????? <relativePath/> <!-- lookup parent from repository -->
??? </parent>
??? <groupId>com.example</groupId>
??? <artifactId>demo</artifactId>
??? <version>0.0.1-SNAPSHOT</version>
??? <name>demo</name>
??? <description>Demo project for Spring Boot</description>
??? <properties>
??????? <java.version>1.8</java.version>
??? </properties>
??? <dependencies>
??????? <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>redis.clients</groupId>
??????????? <artifactId>jedis</artifactId>
??????????? <version>3.3.0</version>
??????? </dependency>
??????? <dependency>
??????????? <groupId>org.springframework.data</groupId>
??????????? <artifactId>spring-data-redis</artifactId>
??????????? <version>2.3.6.RELEASE</version>
??????? </dependency>
??????? <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
??????? <dependency>
??????????? <groupId>com.alibaba</groupId>
??????????? <artifactId>fastjson</artifactId>
??????????? <version>1.2.75</version>
??????? </dependency>
??? </dependencies>
??? <build>
??????? <plugins>
??????????? <plugin>
??????????????? <groupId>org.springframework.boot</groupId>
??????????????? <artifactId>spring-boot-maven-plugin</artifactId>
??????????? </plugin>
??????? </plugins>
??? </build>
</project>
?3、在配置文件application.properties中配置B的redis的参数
server.port=9090
spring.redis.user.host=另一个redis的地址
spring.redis.user.port=6379
spring.redis.user.password=1234564、新建Redis的配置类
package com.example.demo.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import redis.clients.jedis.JedisPoolConfig;
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
??? //order
??? @Value("127.0.0.1")
??? private String orderHost;
??? @Value("6379")
??? private String orderPort;
??? @Value("123456")
??? private String orderPassword;
??? //user
??? @Value("${spring.redis.user.host}")
??? private String userHost;
??? @Value("${spring.redis.user.port}")
??? private String userPort;
??? @Value("${spring.redis.user.password}")
??? private String userPassword;
??? private static final int MAX_IDLE = 200; //最大空闲连接数
??? private static final int MAX_TOTAL = 1024; //最大连接数
??? private static final long MAX_WAIT_MILLIS = 10000; //建立连接最长等待时间
??? //配置工厂
??? public RedisConnectionFactory connectionFactory(String host, int port, String password,int index) {
??????? RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
??????? redisStandaloneConfiguration.setHostName(host);
??????? redisStandaloneConfiguration.setPort(port);
??????? redisStandaloneConfiguration.setPassword(password);
??????? redisStandaloneConfiguration.setDatabase(index);
??????? return new JedisConnectionFactory(redisStandaloneConfiguration);
??? }
??? //连接池配置
??? public JedisPoolConfig poolConfig(int maxIdle, int maxTotal, long maxWaitMillis, boolean testOnBorrow) {
??????? JedisPoolConfig poolConfig = new JedisPoolConfig();
??????? poolConfig.setMaxIdle(maxIdle);
??????? poolConfig.setMaxTotal(maxTotal);
??????? poolConfig.setMaxWaitMillis(maxWaitMillis);
??????? poolConfig.setTestOnBorrow(testOnBorrow);
??????? return poolConfig;
??? }
??? @Bean("redisTemplateOrder")
??? public RedisTemplate<Object, Object> redisTemplateOrder(RedisConnectionFactory connectionFactory) {
??????? RedisTemplate<Object, Object> template = new RedisTemplate<>();
??????? template.setConnectionFactory(connectionFactory(orderHost, Integer.parseInt(orderPort),orderPassword,0));
??????? FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class);
??????? ObjectMapper mapper = new ObjectMapper();
??????? mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
??????? mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance ,
??????????????? ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
??????? serializer.setObjectMapper(mapper);
??????? template.setValueSerializer(serializer);
??????? // 使用StringRedisSerializer来序列化和反序列化redis的key值
??????? template.setKeySerializer(new StringRedisSerializer());
??????? template.afterPropertiesSet();
??????? return template;
??? }
??? @Bean("redisTemplateUser")
??? public RedisTemplate<Object, Object> redisTemplateUser(RedisConnectionFactory connectionFactory) {
??????? RedisTemplate<Object, Object> template = new RedisTemplate<>();
??????? template.setConnectionFactory(connectionFactory(userHost, Integer.parseInt(userPort),userPassword,0));
??????? FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class);
??????? ObjectMapper mapper = new ObjectMapper();
??????? mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
??????? mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance ,
??????????????? ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
??????? serializer.setObjectMapper(mapper);
??????? template.setValueSerializer(serializer);
??????? // 使用StringRedisSerializer来序列化和反序列化redis的key值
??????? template.setKeySerializer(new StringRedisSerializer());
??????? template.afterPropertiesSet();
??????? return template;
??? }
}注意：
这里连接的是两个Redis，其中A的Redis命名为order,其参数直接在注解中固定赋值。
B的Redis命名为user,参数从配置文件中获取。
这其中又用到了FastJson进行序列化的工具类FastJson2JsonRedisSerializer
package com.example.demo.config;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.parser.ParserConfig;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.type.TypeFactory;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.SerializationException;
import org.springframework.util.Assert;
import java.nio.charset.Charset;
public class FastJson2JsonRedisSerializer<T> implements RedisSerializer<T>
{
??? @SuppressWarnings("unused")
??? private ObjectMapper objectMapper = new ObjectMapper();
??? public static final Charset DEFAULT_CHARSET = Charset.forName("UTF-8");
??? private Class<T> clazz;
??? static
??? {
??????? ParserConfig.getGlobalInstance().setAutoTypeSupport(true);
??? }
??? public FastJson2JsonRedisSerializer(Class<T> clazz)
??? {
??????? super();
??????? this.clazz = clazz;
??? }
??? @Override
??? public byte[] serialize(T t) throws SerializationException
??? {
??????? if (t == null)
??????? {
??????????? return new byte[0];
??????? }
??????? return JSON.toJSONString(t, SerializerFeature.WriteClassName).getBytes(DEFAULT_CHARSET);
??? }
??? @Override
??? public T deserialize(byte[] bytes) throws SerializationException
??? {
??????? if (bytes == null || bytes.length <= 0)
??????? {
??????????? return null;
??????? }
??????? String str = new String(bytes, DEFAULT_CHARSET);
??????? return JSON.parseObject(str, clazz);
??? }
??? public void setObjectMapper(ObjectMapper objectMapper)
??? {
??????? Assert.notNull(objectMapper, "'objectMapper' must not be null");
??????? this.objectMapper = objectMapper;
??? }
??? protected JavaType getJavaType(Class<?> clazz)
??? {
??????? return TypeFactory.defaultInstance().constructType(clazz);
??? }
}5、分别新建两个Redis进行读取操作的service类
RedisServiceOrder:
package com.example.demo;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
@Component
public class RedisServiceOrder
{
??? @Resource(name = "redisTemplateOrder")
??? public RedisTemplate redisTemplate;
??? /**
???? * 缓存基本的对象，Integer、String、实体类等
???? *
???? * @param key 缓存的键值
???? * @param value 缓存的值
???? */
??? public <T> void setCacheObject(final String key, final T value)
??? {
??????? redisTemplate.opsForValue().set(key, value);
??? }
??? /**
???? * 缓存基本的对象，Integer、String、实体类等
???? *
???? * @param key 缓存的键值
???? * @param value 缓存的值
???? * @param timeout 时间
???? * @param timeUnit 时间颗粒度
???? */
??? public <T> void setCacheObject(final String key, final T value, final Long timeout, final TimeUnit timeUnit)
??? {
??????? redisTemplate.opsForValue().set(key, value, timeout, timeUnit);
??? }
??? /**
???? * 设置有效时间
???? *
???? * @param key Redis键
???? * @param timeout 超时时间
???? * @returntrue=设置成功；false=设置失败
???? */
??? public boolean expire(final String key, final long timeout)
??? {
??????? return expire(key, timeout, TimeUnit.SECONDS);
??? }
??? /**
???? * 设置有效时间
???? *
???? * @param key Redis键
???? * @param timeout 超时时间
???? * @param unit 时间单位
???? * @returntrue=设置成功；false=设置失败
???? */
??? public boolean expire(final String key, final long timeout, final TimeUnit unit)
??? {
??????? return redisTemplate.expire(key, timeout, unit);
??? }
??? /**
???? * 获得缓存的基本对象。
???? *
???? * @param key 缓存键值
???? * @return 缓存键值对应的数据
???? */
??? public <T> T getCacheObject(final String key)
??? {
??????? ValueOperations<String, T> operation = redisTemplate.opsForValue();
??????? return operation.get(key);
??? }
??? /**
???? * 删除单个对象
???? *
???? * @param key
???? */
??? public boolean deleteObject(final String key)
??? {
??????? return redisTemplate.delete(key);
??? }
??? /**
???? * 删除集合对象
???? *
???? * @param collection 多个对象
???? * @return
???? */
??? public long deleteObject(final Collection collection)
??? {
??????? return redisTemplate.delete(collection);
??? }
??? /**
???? * 缓存List数据
???? *
???? * @param key 缓存的键值
???? * @param dataList 待缓存的List数据
???? * @return 缓存的对象
???? */
??? public <T> long setCacheList(final String key, final List<T> dataList)
??? {
??????? Long count = redisTemplate.opsForList().rightPushAll(key, dataList);
??????? return count == null ? 0 : count;
??? }
??? /**
???? * 获得缓存的list对象
???? *
???? * @param key 缓存的键值
???? * @return 缓存键值对应的数据
???? */
??? public <T> List<T> getCacheList(final String key)
??? {
??????? return redisTemplate.opsForList().range(key, 0, -1);
??? }
??? /**
???? * 缓存Set
???? *
???? * @param key 缓存键值
???? * @param dataSet 缓存的数据
???? * @return 缓存数据的对象
???? */
??? public <T> long setCacheSet(final String key, final Set<T> dataSet)
??? {
??????? Long count = redisTemplate.opsForSet().add(key, dataSet);
??????? return count == null ? 0 : count;
??? }
??? /**
???? * 获得缓存的set
???? *
???? * @param key
???? * @return
???? */
??? public <T> Set<T> getCacheSet(final String key)
??? {
??????? return redisTemplate.opsForSet().members(key);
??? }
??? /**
???? * 缓存Map
???? *
???? * @param key
???? * @param dataMap
???? */
??? public <T> void setCacheMap(final String key, final Map<String, T> dataMap)
??? {
??????? if (dataMap != null) {
??????????? redisTemplate.opsForHash().putAll(key, dataMap);
??????? }
??? }
??? /**
???? * 获得缓存的Map
???? *
???? * @param key
???? * @return
???? */
??? public <T> Map<String, T> getCacheMap(final String key)
??? {
??????? return redisTemplate.opsForHash().entries(key);
??? }
??? /**
???? * 往Hash中存入数据
???? *
???? * @param key Redis键
???? * @param hKey Hash键
???? * @param value 值
???? */
??? public <T> void setCacheMapValue(final String key, final String hKey, final T value)
??? {
??????? redisTemplate.opsForHash().put(key, hKey, value);
??? }
??? /**
???? * 获取Hash中的数据
???? *
???? * @param key Redis键
???? * @param hKey Hash键
???? * @return Hash中的对象
???? */
??? public <T> T getCacheMapValue(final String key, final String hKey)
??? {
??????? HashOperations<String, String, T> opsForHash = redisTemplate.opsForHash();
??????? return opsForHash.get(key, hKey);
??? }
??? /**
???? * 获取多个Hash中的数据
???? *
???? * @param key Redis键
???? * @param hKeys Hash键集合
???? * @return Hash对象集合
???? */
??? public <T> List<T> getMultiCacheMapValue(final String key, final Collection<Object> hKeys)
??? {
??????? return redisTemplate.opsForHash().multiGet(key, hKeys);
??? }
??? /**
???? * 获得缓存的基本对象列表
???? *
???? * @param pattern 字符串前缀
???? * @return 对象列表
???? */
??? public Collection<String> keys(String pattern)
??? {
??????? return redisTemplate.keys(pattern);
??? }
??? /**
???? * 获得缓存的集合(模糊查询)
???? *
???? * @param keys
???? * @return
???? */
??? public <T> List<T> getCacheList(Set keys) {
??????? return redisTemplate.opsForValue().multiGet(keys);
??? }
}RedisServiceUser:
package com.example.demo;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
@Component
public class RedisServiceUser
{
??? @Resource(name = "redisTemplateUser")
??? public RedisTemplate redisTemplate;
??? /*
???? * 缓存基本的对象，Integer、String、实体类等
???? *
???? * @param key 缓存的键值
???? * @param value 缓存的值
???? */
??? public <T> void setCacheObject(final String key, final T value)
??? {
??????? redisTemplate.opsForValue().set(key, value);
??? }
??? /**
???? * 缓存基本的对象，Integer、String、实体类等
???? *
???? * @param key 缓存的键值
???? * @param value 缓存的值
???? * @param timeout 时间
???? * @param timeUnit 时间颗粒度
???? */
??? public <T> void setCacheObject(final String key, final T value, final Long timeout, final TimeUnit timeUnit)
??? {
??????? redisTemplate.opsForValue().set(key, value, timeout, timeUnit);
??? }
??? /**
???? * 设置有效时间
???? *
???? * @param key Redis键
???? * @param timeout 超时时间
???? * @returntrue=设置成功；false=设置失败
???? */
??? public boolean expire(final String key, final long timeout)
??? {
??????? return expire(key, timeout, TimeUnit.SECONDS);
??? }
??? /**
???? * 设置有效时间
???? *
???? * @param key Redis键
???? * @param timeout 超时时间
???? * @param unit 时间单位
???? * @returntrue=设置成功；false=设置失败
???? */
??? public boolean expire(final String key, final long timeout, final TimeUnit unit)
??? {
??????? return redisTemplate.expire(key, timeout, unit);
??? }
??? /**
???? * 获得缓存的基本对象。
???? *
???? * @param key 缓存键值
???? * @return 缓存键值对应的数据
???? */
??? public <T> T getCacheObject(final String key)
??? {
??????? ValueOperations<String, T> operation = redisTemplate.opsForValue();
??????? return operation.get(key);
??? }
??? /**
???? * 删除单个对象
???? *
???? * @param key
???? */
??? public boolean deleteObject(final String key)
??? {
??????? return redisTemplate.delete(key);
??? }
??? /**
???? * 删除集合对象
???? *
???? * @param collection 多个对象
???? * @return
???? */
??? public long deleteObject(final Collection collection)
??? {
??????? return redisTemplate.delete(collection);
??? }
??? /**
???? * 缓存List数据
???? *
???? * @param key 缓存的键值
???? * @param dataList 待缓存的List数据
???? * @return 缓存的对象
???? */
??? public <T> long setCacheList(final String key, final List<T> dataList)
??? {
??????? Long count = redisTemplate.opsForList().rightPushAll(key, dataList);
??????? return count == null ? 0 : count;
??? }
??? /**
???? * 获得缓存的list对象
???? *
???? * @param key 缓存的键值
???? * @return 缓存键值对应的数据
???? */
??? public <T> List<T> getCacheList(final String key)
??? {
??????? return redisTemplate.opsForList().range(key, 0, -1);
??? }
??? /**
???? * 缓存Set
???? *
???? * @param key 缓存键值
???? * @param dataSet 缓存的数据
???? * @return 缓存数据的对象
???? */
??? public <T> long setCacheSet(final String key, final Set<T> dataSet)
??? {
??????? Long count = redisTemplate.opsForSet().add(key, dataSet);
??????? return count == null ? 0 : count;
??? }
??? /**
???? * 获得缓存的set
???? *
???? * @param key
???? * @return
???? */
??? public <T> Set<T> getCacheSet(final String key)
??? {
??????? return redisTemplate.opsForSet().members(key);
??? }
??? /**
???? * 缓存Map
???? *
???? * @param key
???? * @param dataMap
???? */
??? public <T> void setCacheMap(final String key, final Map<String, T> dataMap)
??? {
??????? if (dataMap != null) {
??????????? redisTemplate.opsForHash().putAll(key, dataMap);
??????? }
??? }
??? /**
???? * 获得缓存的Map
???? *
???? * @param key
???? * @return
???? */
??? public <T> Map<String, T> getCacheMap(final String key)
??? {
??????? return redisTemplate.opsForHash().entries(key);
??? }
??? /**
???? * 往Hash中存入数据
???? *
???? * @param key Redis键
???? * @param hKey Hash键
???? * @param value 值
???? */
??? public <T> void setCacheMapValue(final String key, final String hKey, final T value)
??? {
??????? redisTemplate.opsForHash().put(key, hKey, value);
??? }
??? /**
???? * 获取Hash中的数据
???? *
???? * @param key Redis键
???? * @param hKey Hash键
???? * @return Hash中的对象
???? */
??? public <T> T getCacheMapValue(final String key, final String hKey)
??? {
??????? HashOperations<String, String, T> opsForHash = redisTemplate.opsForHash();
??????? return opsForHash.get(key, hKey);
??? }
??? /**
???? * 获取多个Hash中的数据
???? *
???? * @param key Redis键
???? * @param hKeys Hash键集合
???? * @return Hash对象集合
???? */
??? public <T> List<T> getMultiCacheMapValue(final String key, final Collection<Object> hKeys)
??? {
??????? return redisTemplate.opsForHash().multiGet(key, hKeys);
??? }
??? /**
???? * 获得缓存的基本对象列表
???? *
???? * @param pattern 字符串前缀
???? * @return 对象列表
???? */
??? public Collection<String> keys(String pattern)
??? {
??????? return redisTemplate.keys(pattern);
??? }
??? /**
???? * 获得缓存的集合(模糊查询)
???? *
???? * @param keys
???? * @return
???? */
??? public <T> List<T> getCacheList(Set keys) {
??????? return redisTemplate.opsForValue().multiGet(keys);
??? }
}6、编写测试Controller进行测试
package com.example.demo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/badao")
public class TestController {
??? @Autowired
??? private RedisServiceOrder redisServiceOrder;
??? @Autowired
??? private RedisServiceUser redisServiceUser;
??? @GetMapping("/test")
??? public String list()
??? {
??????? redisServiceOrder.setCacheObject("badao","公众号:霸道的程序猿");
??????? String badao = redisServiceOrder.getCacheObject("badao");
??????? redisServiceUser.setCacheObject("copyBadao",badao);
??????? return "公众号:霸道的程序猿";
??? }
}7、启动项目并调用测试接口
?