首页 > > 程序设计 > Java技术 >

SpringBoot使用redis缓存List<Object&…

2018-10-26 05:26:52来源：博客园 阅读 ()

新老客户大回馈,云服务器低至5折

一、概述

　　最近在做性能优化，之前有一个业务是这样实现的：

　　1.温度报警后第三方通讯管理机直接把报警信息保存到数据库

　　2.我们在数据库中添加触发器，（BEFORE INSERT）根据这条报警信息处理业务逻辑，在数据库中插入“其他业务数据”

　　3.前端setTimeout每隔5秒ajax去后端查询“其他业务数据”（查库）

　　优化后这样实现：

　　两个微服务，消息中间件专门一个服务，接收消息存入数据库，存入redis；业务服务直接从redis获取

　　1.MQTT订阅通讯管理机报警事件主题

　　2.发生报警后，java中根据报警信息保存“其他业务数据”到数据库并放入redis缓存

　　3.前端setTimeout每隔5秒ajax去后端查询“其他业务数据”（改为从redis中获取）

　　4.下一步计划使用WebSocekt，去掉前端setTimeout

二、SpringBoot配置redis

　　pom.xml、application.properties、@EnableCaching等等这些配置就不列出来了，大家可以百度，提一下RedisTemplate的配置

　　RedisTemplate<String, Object>可以直接存直接存List、Map等，使用jackson2JsonRedisSerializer序列化，

package ;

import java.lang.reflect.Method;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.CacheManager;
import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonInclude.Include;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;

@Configuration
public class RedisConfiguration {
	@Bean("jsonRedisCache")
	public CacheManager cacheManager(@Autowired RedisTemplate<String, Object> redisTemplate) {
		return new RedisCacheManager(redisTemplate);
	}
	
    @Bean
    public KeyGenerator keyGenerator() {
        return new KeyGenerator() {
			
			@Override
			public Object generate(Object target, Method method, Object... params) {
				  StringBuilder sb = new StringBuilder();
	                sb.append(target.getClass().getName());
	                sb.append(method.getName());
	                for (Object obj : params) {
	                    sb.append(obj.toString());
	                }
	                return sb.toString();
			}
		};
    }

	@Bean
	public RedisTemplate<String, Object> redisTemplate(@Autowired RedisConnectionFactory cf) {
		RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
		redisTemplate.setKeySerializer(new StringRedisSerializer());
		redisTemplate.setHashKeySerializer(jackson2JsonRedisSerializer());
		redisTemplate.setValueSerializer(jackson2JsonRedisSerializer());
		redisTemplate.setConnectionFactory(cf);
		redisTemplate.afterPropertiesSet();
		return redisTemplate;
	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Bean
	public Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer() {
		final Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(
				Object.class);
		final ObjectMapper objectMapper = Jackson2ObjectMapperBuilder.json().build();
		objectMapper.disable(DeserializationFeature.FAIL_ON_IGNORED_PROPERTIES);
		objectMapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
		objectMapper.setSerializationInclusion(Include.NON_NULL);
		objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
		objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
		jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
		return jackson2JsonRedisSerializer;
	}
}　　

 

三、List对象存入redis遇到的问题

　　1.@Cacheable不起作用问题

　　刚开始，计划在service层方法上使用注解@Cacheable进行缓存，但是redis没有保存，最后百度得到答案：一个类中@Cacheable标注的方法不能被本类中其他方法调用，否则缓存不起作用

　　修改类方法调用后此问题解决

　　错误的方法调用：

 

　　正确的调用：其他类调用该方法

　　这其中有个报错：No cache could be resolved for 'Builder[public java.util.List com.es.service.evralarm.EvrAlarmCacheService.getEvrAlarmByAccountId(java.lang.String)] caches=[] | key=''EvrAlarm-'+#accountId' | keyGenerator='' | cacheManager='' | cacheResolver='' | condition='' | unless='' | sync='false'' using resolver 'org.springframework.cache.interceptor.SimpleCacheResolver@7fbfc31a'. At least one cache should be provided per cache operation.

　　@Cacheable注解中添加cacheNames即可

package ;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import com.es.entity.evralarm.EvrAlarm;
import com.es.repository.evralarm.EvrAlarmDao;

@Service
public class EvrAlarmCacheService {

	@Autowired
	private EvrAlarmDao evrAlarmDao;
	
	@Cacheable(cacheNames="EvrAlarms",key="'EvrAlarm-'+#accountId")
	public List<EvrAlarm> getEvrAlarmByAccountId(String accountId){
		Map<String,Object> params = new HashMap<>();
		params.put("accountId", accountId);
		params.put("limit", 1);
		List<EvrAlarm> evrAlarms = evrAlarmDao.selectEvrAlarmByAccount(params);
		
		return evrAlarms;
	}
}

　　redis中存储的数据如下图：

 

　　2.Could not resolve type id 'com.es.xx.evralarm.EvrAlarm' into a subtype of [simple type, class java.lang.Object]: no such class found

at [Source: [B@29a6e242; line: 1, column: 60] (through reference chain: java.util.ArrayList[0])

　　业务服务中原代码：

@Cacheable(cacheNames="EvrAlarms",key="'EvrAlarm-'+#accountId")
		public List<EvrAlarm> selectEvrAlarmByAccount(String accountId){
			Map<String,Object> params = new HashMap<>();
			params.put("accountId", accountId);
			return evrAlarmDao.selectEvrAlarmByAccount(params);
		}

　　看到一遍文档后明白了，根本原因是：两个微服务，实体类内容虽然一样，但是类路径不一样

四、使用StringRedisTemplate、RedisTemplate<String, Object>

　　进一步分析发现使用@Cacheable有问题，消息中间件收到第二条报警消息，如果业务系统没有处理第一条报警消息（redis中未删除，同样的key redis中已有一条）则redis中的信息不会更新

　　正确的操作应该是：消息中间件每次接收消息,处理后都往redis中更新

1.使用RedisTemplate<String, Object>

　　使用RedisTemplate<String, Object>存储

package ;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.ListOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import com.es.entity.evralarm.EvrAlarm;
import com.es.repository.evralarm.EvrAlarmDao;

@Service
public class EvrAlarmCacheService {

	@Autowired
	private EvrAlarmDao evrAlarmDao;
	
	@Autowired
	private RedisTemplate<String, Object> redisTemplate;
	
	public List<EvrAlarm> getEvrAlarmByAccountId(String accountId){
		Map<String,Object> params = new HashMap<>();
		params.put("accountId", accountId);
		params.put("limit", 1);
		List<EvrAlarm> evrAlarms = evrAlarmDao.selectEvrAlarmByAccount(params);
		
		//redis缓存
		ListOperations<String, Object> lo = redisTemplate.opsForList();
		lo.rightPush("EvrAlarm-"+accountId, evrAlarms);
		return evrAlarms;
	}
}

　　

存储后redis中的数据结构入下图：

 

　　业务服务获取redis中的数据：

/**
		 * 根据账户ID查询最新告警信息
		 * */
		public List<EvrAlarm> selectEvrAlarmByAccount(String accountId){
			//redis缓存中获取
			ListOperations<String,Object> lo = redisTemplate.opsForList();
			Object obj = lo.index("EvrAlarm-"+accountId, 0);
			List<EvrAlarm> evrAlarms = (List<EvrAlarm>) obj;
			return evrAlarms == null ? new ArrayList<>() : evrAlarms;
		}

　　报错了：

　　报错信息很明了，“no such class found”，还是上面的问题，两个服务都有实体类“EvrAlarm”，内容相同，类路径不同

　　把消息服务中“EvrAlarm”实体类类路径修改后，redis存储结构如下：

　　

　　业务服务获取redis中的数据：

/**
		 * 根据账户ID查询最新告警信息
		 * */
		public List<EvrAlarm> selectEvrAlarmByAccount(String accountId){
			//redis缓存中获取
			ListOperations<String,Object> lo = redisTemplate.opsForList();
			List<EvrAlarm> evrAlarms = (List<EvrAlarm>) lo.index("EvrAlarm-"+accountId, 0);
			return evrAlarms == null ? new ArrayList<>() : evrAlarms;
		}

　　没有报错能够正常获取：

　　

2.使用StringRedisTemplate 

　　StringRedisTemplate不需要考虑存储对象的类路径问题，存储前直接把对象转成json字符串，获取的时候再把json转成对象

　　使用Gson直接把要保存的List<>对象转成json再保存到redis

　　中间件所在服务存入redis：

package com.xx.service.evralarm;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;

import com.es.entity.evralarm.EvrAlarm;
import com.es.repository.evralarm.EvrAlarmDao;
import com.google.gson.Gson;

@Service
public class EvrAlarmCacheService {

	@Autowired
	private EvrAlarmDao evrAlarmDao;
	
	@Autowired
	private StringRedisTemplate redisTemplate;
	
	public List<EvrAlarm> getEvrAlarmByAccountId(String accountId){
		Map<String,Object> params = new HashMap<>();
		params.put("accountId", accountId);
		params.put("limit", 1);
		List<EvrAlarm> evrAlarms = evrAlarmDao.selectEvrAlarmByAccount(params);
		
		//redis缓存
		ValueOperations<String,String> vo = redisTemplate.opsForValue();
		Gson gson = new Gson();
		vo.set("EvrAlarm-"+accountId, gson.toJson(evrAlarms));
		return evrAlarms;
	}
}

　　

　　业务服务从redis中取：

　　从redis中获取key对应的value，得到string类型的value，使用Gson转成List<>对象

查询：
/**
		 * 根据账户ID查询最新告警信息
		 * */
		public List<EvrAlarm> selectEvrAlarmByAccount(String accountId){
			//redis缓存中获取
			ValueOperations<String,String> vo = redisTemplate.opsForValue();
			String value = vo.get("EvrAlarm-"+accountId);
			Gson gson = new Gson();
			List<EvrAlarm> evrAlarms = gson.fromJson(value, List.class);
			return evrAlarms == null ? new ArrayList<>() : evrAlarms;
		}

 

   业务操作删除、同时删除redis：　　

public void deleteAccountEvralarm(String accountId, String evrAlarmId){
    	Map<String, Object> queryMap = new HashMap<>();
    	queryMap.put("accountId", accountId);
    	queryMap.put("evrAlarmId", evrAlarmId);
    	accountEvralarmDao.deleteByPrimaryKey(queryMap);
    	//redis删除缓存
    	redisTemplate.delete("EvrAlarm-"+accountId);
    }

　　

 

最后问题解决

参考文档：

http://www.mamicode.com/info-detail-2267905.html

https://blog.csdn.net/ranweizheng/article/details/42267803

https://yq.aliyun.com/ziliao/444278

https://blog.csdn.net/hanchao5272/article/details/79051364

 

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：JAVA 8 lambda 表达式实现按某个属性值查找集合中符合条件的所有

下一篇：框架：SpringBoot 数据库：MySql 前端：JS 后端读取数据

相关文章

IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设

网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源

网站联盟： 联盟新闻 联盟介绍 联盟点评 网赚技巧

行业资讯： 搜索引擎 网络游戏 电子商务 广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护

软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识： 网络协议 网络安全 网络管理 组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条
最新资讯
热门关注
热门标签