最近2018中文字幕在日韩欧美国产成人片_国产日韩精品一区二区在线_在线观看成年美女黄网色视频_国产精品一区三区五区_国产精彩刺激乱对白_看黄色黄大色黄片免费_人人超碰自拍cao_国产高清av在线_亚洲精品电影av_日韩美女尤物视频网站

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
springboot+mybatis+redis二級緩存問題實例詳解

前言

創(chuàng)新互聯(lián)專注于睢縣網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供睢縣營銷型網(wǎng)站建設(shè)，睢縣網(wǎng)站制作、睢縣網(wǎng)頁設(shè)計、睢縣網(wǎng)站官網(wǎng)定制、重慶小程序開發(fā)服務(wù)，打造睢縣網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供睢縣網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

什么是mybatis二級緩存？

二級緩存是多個sqlsession共享的，其作用域是mapper的同一個namespace。

即，在不同的sqlsession中，相同的namespace下，相同的sql語句，并且sql模板中參數(shù)也相同的，會命中緩存。

第一次執(zhí)行完畢會將數(shù)據(jù)庫中查詢的數(shù)據(jù)寫到緩存，第二次會從緩存中獲取數(shù)據(jù)將不再從數(shù)據(jù)庫查詢，從而提高查詢效率。

Mybatis默認沒有開啟二級緩存，需要在全局配置(mybatis-config.xml)中開啟二級緩存。

本文講述的是使用redis作為緩存，與springboot、mybatis進行集成的方法。

1、pom依賴

使用springboot redis集成包，方便redis的訪問。redis客戶端選用Jedis。

另外讀寫kv緩存會進行序列化，所以引入了一個序列化包。      

 
   org.springframework.boot
   spring-boot-starter-redis
  
  
   redis.clients
   jedis
   2.8.0
  
  
   com.alibaba
   fastjson
   1.2.19

依賴搞定之后，下一步先調(diào)通Redis客戶端。

2、Redis訪問使用的Bean

增加Configuration，配置jedisConnectionFactory bean，留待后面使用。

一般來講，也會生成了redisTemplate bean，但是在接下來的場景沒有使用到。

@Configuration
public class RedisConfig {
 @Value("${spring.redis.host}")
 private String host;
 // 篇幅受限，省略了
 @Bean
 public JedisPoolConfig getRedisConfig(){
  JedisPoolConfig config = new JedisPoolConfig();
  config.setMaxIdle(maxIdle);
  config.setMaxTotal(maxTotal);
  config.setMaxWaitMillis(maxWaitMillis);
  config.setMinIdle(minIdle);
  return config;
 }
 @Bean(name = "jedisConnectionFactory")
 public JedisConnectionFactory getConnectionFactory(){
  JedisConnectionFactory factory = new JedisConnectionFactory();
  JedisPoolConfig config = getRedisConfig();
  factory.setPoolConfig(config);
  factory.setHostName(host);
  factory.setPort(port);
  factory.setDatabase(database);
  factory.setPassword(password);
  factory.setTimeout(timeout);
  return factory;
 }
 @Bean(name = "redisTemplate")
 public RedisTemplate<?, ?> getRedisTemplate(){
  RedisTemplate<?,?> template = new StringRedisTemplate(getConnectionFactory());
  return template;
 }
}

這里使用@Value讀入了redis相關(guān)配置，有更簡單的配置讀取方式(@ConfigurationProperties(prefix=...))，可以嘗試使用。

Redis相關(guān)配置如下

#redis
spring.redis.host=10.93.84.53
spring.redis.port=6379
spring.redis.password=bigdata123
spring.redis.database=15
spring.redis.timeout=0
spring.redis.pool.maxTotal=8
spring.redis.pool.maxWaitMillis=1000
spring.redis.pool.maxIdle=8
spring.redis.pool.minIdle=0

Redis客戶端的配置含義，這里不再講解了。pool相關(guān)的一般都和性能有關(guān)，需要根據(jù)并發(fā)量權(quán)衡句柄、內(nèi)存等資源進行設(shè)置。

Redis客戶端設(shè)置好了，我們開始配置Redis作為Mybatis的緩存。

3、Mybatis Cache

這一步是最為關(guān)鍵的一步。實現(xiàn)方式是實現(xiàn)Mybatis的一個接口org.apache.ibatis.cache.Cache。

這個接口設(shè)計了寫緩存，讀緩存，銷毀緩存的方式，和訪問控制讀寫鎖。

我們實現(xiàn)實現(xiàn)Cache接口的類是MybatisRedisCache。

MybatisRedisCache.java

public class MybatisRedisCache implements Cache {
 private static JedisConnectionFactory jedisConnectionFactory;
 private final String id;
 private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
 public MybatisRedisCache(final String id) {
  if (id == null) {
   throw new IllegalArgumentException("Cache instances require an ID");
  }
  this.id = id;
 }
 @Override
 public void clear() {
  RedisConnection connection = null;
  try {
   connection = jedisConnectionFactory.getConnection();
   connection.flushDb();
   connection.flushAll();
  } catch (JedisConnectionException e) {
   e.printStackTrace();
  } finally {
   if (connection != null) {
    connection.close();
   }
  }
 }
 @Override
 public String getId() {
  return this.id;
 }
 @Override
 public Object getObject(Object key) {
  Object result = null;
  RedisConnection connection = null;
  try {
   connection = jedisConnectionFactory.getConnection();
   RedisSerializer serializer = new JdkSerializationRedisSerializer();
   result = serializer.deserialize(connection.get(serializer.serialize(key)));
  } catch (JedisConnectionException e) {
   e.printStackTrace();
  } finally {
   if (connection != null) {
    connection.close();
   }
  }
  return result;
 }
 @Override
 public ReadWriteLock getReadWriteLock() {
  return this.readWriteLock;
 }
 @Override
 public int getSize() {
  int result = 0;
  RedisConnection connection = null;
  try {
   connection = jedisConnectionFactory.getConnection();
   result = Integer.valueOf(connection.dbSize().toString());
  } catch (JedisConnectionException e) {
   e.printStackTrace();
  } finally {
   if (connection != null) {
    connection.close();
   }
  }
  return result;
 }
 @Override
 public void putObject(Object key, Object value) {
  RedisConnection connection = null;
  try {
   connection = jedisConnectionFactory.getConnection();
   RedisSerializer serializer = new JdkSerializationRedisSerializer();
   connection.set(serializer.serialize(key), serializer.serialize(value));
  } catch (JedisConnectionException e) {
   e.printStackTrace();
  } finally {
   if (connection != null) {
    connection.close();
   }
  }
 }
 @Override
 public Object removeObject(Object key) {
  RedisConnection connection = null;
  Object result = null;
  try {
   connection = jedisConnectionFactory.getConnection();
   RedisSerializer serializer = new JdkSerializationRedisSerializer();
   result = connection.expire(serializer.serialize(key), 0);
  } catch (JedisConnectionException e) {
   e.printStackTrace();
  } finally {
   if (connection != null) {
    connection.close();
   }
  }
  return result;
 }
 public static void setJedisConnectionFactory(JedisConnectionFactory jedisConnectionFactory) {
  MybatisRedisCache.jedisConnectionFactory = jedisConnectionFactory;
 }
}
注意：
可以看到，這個類并不是由Spring虛擬機管理的類，但是，其中有一個靜態(tài)屬性jedisConnectionFactory需要注入一個Spring bean，也就是在RedisConfig中生成的bean。
在一個普通類中使用Spring虛擬機管理的Bean，一般使用Springboot自省的SpringContextAware。
這里使用了另一種方式，靜態(tài)注入的方式。這個方式是通過RedisCacheTransfer來實現(xiàn)的。
4、靜態(tài)注入
RedisCacheTransfer.java
@Component
public class RedisCacheTransfer {
 @Autowired
 public void setJedisConnectionFactory(JedisConnectionFactory jedisConnectionFactory) {
  MybatisRedisCache.setJedisConnectionFactory(jedisConnectionFactory);
 }
}
可以看到RedisCacheTransfer是一個springboot bean，在容器創(chuàng)建之初進行初始化的時候，會注入jedisConnectionFactory bean給setJedisConnectionFactory方法的傳參。
而setJedisConnectionFactory通過調(diào)用靜態(tài)方法設(shè)置了類MybatisRedisCache的靜態(tài)屬性jedisConnectionFactory。
這樣就把spring容器管理的jedisConnectionFactory注入到了靜態(tài)域。
到這里，代碼基本已經(jīng)搞定，下面是一些配置。主要有(1)全局開關(guān);(2)namespace作用域開關(guān);(3)Model實例序列化。
5、Mybatis二級緩存的全局開關(guān)
前面提到過，默認二級緩存沒有打開，需要設(shè)置為true。這是全局二級緩存的開關(guān)。
Mybatis的全局配置。
<?xml version="1.0" encoding="UTF-8"?>


 
 
  
  
 

全局配置的加載在dataSource中可以是這樣的。
bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis-mapper/*.xml"));
指定了mapper.xml的存放路徑，在mybatis-mapper路徑下，所有后綴是.xml的都會讀入。
bean.setConfigLocation(new ClassPathResource("mybatis-config.xml"));
指定了mybatis-config.xml的存放路徑，直接放在Resource目錄下即可。
@Bean(name = "moonlightSqlSessionFactory")
 @Primary
 public SqlSessionFactory moonlightSqlSessionFactory(@Qualifier("moonlightData") DataSource dataSource) throws Exception {
  SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
  bean.setDataSource(dataSource);
  bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis-mapper/*.xml"));
  bean.setConfigLocation(new ClassPathResource("mybatis-config.xml"));
  return bean.getObject();
 }
6、配置mapper作用域namespace
前面提到過，二級緩存的作用域是mapper的namespace，所以這個配置需要到mapper中去寫。

 
 
 
  
  
  
  
  
  
  
 
 



注意：
namespace下的cache標簽就是加載緩存的配置，緩存使用的正式我們剛才實現(xiàn)的MybatisRedisCache。
這里只實現(xiàn)了一個查詢queryGeoFence，你可以在select標簽中，開啟或者關(guān)閉這個sql的緩存。使用屬性值useCache=true/false。
7、Mapper和Model
讀寫緩存Model需要序列化：只需要類聲明的時候?qū)崿F(xiàn)Seriaziable接口就好了。
public class GeoFence implements Serializable {
 // setter和getter省略 
}
public class GeoFenceParam implements Serializable {
 // setter和getter省略 
}
mapper就還是以前的寫法，使用mapper.xml的方式這里只需要定義出抽象函數(shù)即可。
@Mapper
public interface MoonlightMapper {
 List queryGeoFence(GeoFenceQueryParam geoFenceQueryParam);
}
到這里，所有的代碼和配置都完成了，下面測試一下。
8、測試一下
Controller中實現(xiàn)一個這樣的接口POST。
@RequestMapping(value = "/fence/query", method = RequestMethod.POST)
 @ResponseBody
 public ResponseEntity queryFence(@RequestBody GeoFenceQueryParam geoFenceQueryParam) {
  try {
   Integer pageNum = geoFenceQueryParam.getPageNum()!=null?geoFenceQueryParam.getPageNum():1;
   Integer pageSize = geoFenceQueryParam.getPageSize()!=null?geoFenceQueryParam.getPageSize():10;
   PageHelper.startPage(pageNum, pageSize);
   List list = moonlightMapper.queryGeoFence(geoFenceQueryParam);
   return new ResponseEntity<>(
     new Response(ResultCode.SUCCESS, "查詢geoFence成功", list),
     HttpStatus.OK);
  } catch (Exception e) {
   logger.error("查詢geoFence失敗", e);
   return new ResponseEntity<>(
     new Response(ResultCode.EXCEPTION, "查詢geoFence失敗", null),
     HttpStatus.INTERNAL_SERVER_ERROR);
  }
 使用curl發(fā)送請求，注意
1）-H - Content-type:application/json方式
2）-d - 后面是json格式的參數(shù)包體
curl -H "Content-Type:application/json" -XPOST http://。。。/moonlight/fence/query -d '{
 "name" : "test",
 "group": "test",
 "type": 1,
 "startTime":"2017-12-06 00:00:00",
 "endTime":"2017-12-06 16:00:00",
 "pageNum": 1,
 "pageSize": 8
請求了三次，日志打印如下，
可以看到，只有第一次執(zhí)行了sql模板查詢，后面都是命中了緩存。
在我們的測試環(huán)境中由于數(shù)據(jù)量比較小，緩存對查詢速度的優(yōu)化并不明顯。這里就不過多說明了。
springboot+mybatis+redis 二級緩存問題實例詳解
            
            
                                                            

                                                網(wǎng)站名稱：springboot+mybatis+redis二級緩存問題實例詳解                                                

                                                當前路徑：http://fisionsoft.com.cn/article/gehgsi.html