SpringBoot,Redis批量存取数据的操作,博智网带你了解详细信息 。
SpringBoot Redis批量存取数据springboot中的redisTemplate封装了redis批处理数据的接口，我们使用redisTemplate可以直接进行批量数据的get和set 。
package com.huateng.applacation.service; import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.stereotype.Component; import java.util.List; /** * @program: applacation * @description: * @author: daiwenlong * @create: 2019-01-24 13:26 **/@Componentpublic class RedisService {@Autowired@Qualifier("stringRedisTemplate")private StringRedisTemplate redisTemplate;public void insertKey(List<String> keys, String value){//批量get数据List<Object> list = redisTemplate.executePipelined(new RedisCallback<String>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {for (String key : keys) {connection.get(key.getBytes());}return null;}});//批量set数据redisTemplate.executePipelined(new RedisCallback<String>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {for (int i=0;i<keys.size();i++) {connection.set(keys.get(i).getBytes(),value.getBytes());}return null;}});}}
如果要设置 key 的过期时间，通过 setEx() 来做就可以了，过期时间单位是秒，相关代码如下：
/** * 合同批量导入redis * * @param contractBOList * @param expire * @return com.openailab.oascloud.common.model.ResponseResult * @author zxzhang * @date 2019/10/14 */@Overridepublic void contractBatchSetRedis(String contractBOList, long expire) {List<ContractBO> contracts = JSONObject.parseArray(contractBOList, ContractBO.class);if (contracts == null || contracts.size() == 0) {return;}//批量set数据redisUtil.getRedisTemplate().executePipelined((RedisCallback<String>) connection -> {for (ContractBO contract : contracts) {connection.setEx((RedisPrefixConst.CONTRACT_PREFIX + contract.getBusinessCode() + RedisPrefixConst.UNDERLINE_SEPARATOR + contract.getContractNo()).getBytes(), expire, JSONObject.toJSONString(contract).getBytes());}return null;});} /** * 合同批量获取redis * * @param contractBOList * @return java.lang.String * @author zxzhang * @date 2019/10/14 */@Overridepublic List<Object> contractBatchGetRedis(String contractBOList) {List<ContractBO> contracts = JSONObject.parseArray(contractBOList, ContractBO.class);if (contracts == null || contracts.size() == 0) {return null;}List<Object> list = redisUtil.getRedisTemplate().executePipelined((RedisCallback<String>) connection -> {for (ContractBO contract : contracts) {connection.get((RedisPrefixConst.CONTRACT_PREFIX + contract.getBusinessCode() + RedisPrefixConst.UNDERLINE_SEPARATOR + contract.getContractNo()).getBytes());}return null;});return list;}
SpringBoot对redis批量存取介绍到此结束 。
redisTemplate批量写入数据 /*** 批量写入数据* @param objectMap* @return*/public void saveMap(final Map<String,Object> objectMap) {//序列化成字节数组final Map<byte[],byte[]> byteMap=new HashMap<>();for(Map.Entry<String,Object> objectEntry:objectMap.entrySet()){String key=objectEntry.getKey();final byte[] keyBytes = redisTemplate.getStringSerializer().serialize(key);Object value=https://www.yf-zs.com/redian/objectEntry.getValue();final byte[] valueBytes =SerializeUtil.serialize(value);byteMap.put(keyBytes,valueBytes);}redisTemplate.execute(new RedisCallback