大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章给大家介绍Spring boot中mybatis的二级缓存怎么使用redis集群进行替换,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、成都小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了台山免费建站欢迎大家使用!
1 . pom.xml添加相关依赖
org.springframework.boot spring-boot-starter-parent 1.5.1.RELEASE org.mybatis.spring.boot mybatis-spring-boot-starter 1.2.0 redis.clients jedis org.springframework.data spring-data-redis
2 . 配置Redis集群,参考spring-data-redis官方文档
@Component @ConfigurationProperties(prefix = "spring.redis.cluster") public class ClusterConfigurationProperties { /* * spring.redis.cluster.nodes[0] = 127.0.0.1:7379 * spring.redis.cluster.nodes[1] = 127.0.0.1:7380 * ... */ Listnodes; /** * Get initial collection of known cluster nodes in format {@code host:port}. * * @return */ public List getNodes() { return nodes; } public void setNodes(List nodes) { this.nodes = nodes; } } @Configuration public class AppConfig { /** * Type safe representation of application.properties */ @Autowired ClusterConfigurationProperties clusterProperties; public @Bean RedisConnectionFactory connectionFactory() { return new JedisConnectionFactory( new RedisClusterConfiguration(clusterProperties.getNodes())); } }
3 . 自定义二级缓存类
public class RedisCache implements Cache { private static final String PREFIX = "SYS_CONFIG:"; private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock(true); private String id; private JdkSerializationRedisSerializer jdkSerializer = new JdkSerializationRedisSerializer(); private static RedisConnectionFactory redisConnectionFactory; public RedisCache(final String id) { if (id == null) { throw new IllegalArgumentException("Cache instances require an ID"); } this.id = id; } @Override public String getId() { return this.id; } @Override public void putObject(Object key, Object value) { RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); if (key == null) return; String strKey = PREFIX + key.toString(); conn.set(strKey.getBytes(), jdkSerializer.serialize(value)); conn.close(); } @Override public Object getObject(Object key) { if (key != null) { String strKey = PREFIX + key.toString(); RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); byte[] bs = conn.get(strKey.getBytes()); conn.close(); return jdkSerializer.deserialize(bs); } return null; } @Override public Object removeObject(Object key) { if (key != null) { RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); conn.del(key.toString().getBytes()); conn.close(); } return null; } @Override public void clear() { // 关键代码,data更新时清理缓存 RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); Setkeys = conn.keys((PREFIX+"*").getBytes()); for (byte[] bs : keys) { conn.del(bs); } conn.close(); } @Override public int getSize() { // TODO Auto-generated method stub return 0; } @Override public ReadWriteLock getReadWriteLock() { return this.readWriteLock; } public static void setRedisConnectionFactory(RedisConnectionFactory redisConnectionFactory) { RedisCache.redisConnectionFactory = redisConnectionFactory; } }
使用一个Transfer类间接注入RedisConnectionFactory
@Component public class RedisCacheTransfer { @Autowired public void setJedisConnectionFactory( RedisConnectionFactory jedisConnectionFactory) { RedisCache.setRedisConnectionFactory(jedisConnectionFactory); } }
4 . 在application.propreties中开启二级缓存
开启mybatis的二级缓存
spring.datasource.cachePrepStmts=true
5 . 基于注解的使用
@CacheNamespace(implementation = RedisCache.class) public interface ConfigDaoMapper { ..... }
关于Spring boot中mybatis的二级缓存怎么使用Redis集群进行替换就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。