宜立方商城-使用redis缓存商城首页展示

ゝ一世哀愁。 2022-03-17 09:28 276阅读 0赞

首先jedis三个包

![70][]

public interface JedisClient {
    
    	String set(String key, String value);
    	String get(String key);
    	Boolean exists(String key);
    	Long expire(String key, int seconds);
    	Long ttl(String key);
    	Long incr(String key);
    	Long hset(String key, String field, String value);
    	String hget(String key, String field);
    	Long hdel(String key, String... field);
    }
    package cn.e3mall.common.jedis;
    
    
    
    import redis.clients.jedis.JedisCluster;
    
    public class JedisClientCluster implements JedisClient {
    	
    	private JedisCluster jedisCluster;
    	
    
    	public JedisCluster getJedisCluster() {
    		return jedisCluster;
    	}
    
    	public void setJedisCluster(JedisCluster jedisCluster) {
    		this.jedisCluster = jedisCluster;
    	}
    
    	@Override
    	public String set(String key, String value) {
    		return jedisCluster.set(key, value);
    	}
    
    	@Override
    	public String get(String key) {
    		return jedisCluster.get(key);
    	}
    
    	@Override
    	public Boolean exists(String key) {
    		return jedisCluster.exists(key);
    	}
    
    	@Override
    	public Long expire(String key, int seconds) {
    		return jedisCluster.expire(key, seconds);
    	}
    
    	@Override
    	public Long ttl(String key) {
    		return jedisCluster.ttl(key);
    	}
    
    	@Override
    	public Long incr(String key) {
    		return jedisCluster.incr(key);
    	}
    
    	@Override
    	public Long hset(String key, String field, String value) {
    		return jedisCluster.hset(key, field, value);
    	}
    
    	@Override
    	public String hget(String key, String field) {
    		return jedisCluster.hget(key, field);
    	}
    
    	@Override
    	public Long hdel(String key, String... field) {
    		return jedisCluster.hdel(key, field);
    	}
    
    }
    package cn.e3mall.common.jedis;
    
    
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    
    public class JedisClientPool implements JedisClient {
    	
    	private JedisPool jedisPool;
    
    	
    	public JedisPool getJedisPool() {
    		return jedisPool;
    	}
    
    	public void setJedisPool(JedisPool jedisPool) {
    		this.jedisPool = jedisPool;
    	}
    
    	@Override
    	public String set(String key, String value) {
    		Jedis jedis = jedisPool.getResource();
    		String result = jedis.set(key, value);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public String get(String key) {
    		Jedis jedis = jedisPool.getResource();
    		String result = jedis.get(key);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public Boolean exists(String key) {
    		Jedis jedis = jedisPool.getResource();
    		Boolean result = jedis.exists(key);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public Long expire(String key, int seconds) {
    		Jedis jedis = jedisPool.getResource();
    		Long result = jedis.expire(key, seconds);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public Long ttl(String key) {
    		Jedis jedis = jedisPool.getResource();
    		Long result = jedis.ttl(key);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public Long incr(String key) {
    		Jedis jedis = jedisPool.getResource();
    		Long result = jedis.incr(key);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public Long hset(String key, String field, String value) {
    		Jedis jedis = jedisPool.getResource();
    		Long result = jedis.hset(key, field, value);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public String hget(String key, String field) {
    		Jedis jedis = jedisPool.getResource();
    		String result = jedis.hget(key, field);
    		jedis.close();
    		return result;
    	}
    
    	@Override
    	public Long hdel(String key, String... field) {
    		Jedis jedis = jedisPool.getResource();
    		Long result = jedis.hdel(key, field);
    		jedis.close();
    		return result;
    	}
    
    }

配置文件：redis开发时候用单机版，实际上线用集群。

![70 1][]

<?xml version="1.0" encoding="UTF-8"?>
 <beans xmlns="http://www.springframework.org/schema/beans"
 	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
 	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
 	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
 	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
 	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
 	
 	
 	<bean id="jedisClientPool" class="cn.e3mall.common.jedis.JedisClientPool">
 		<property name="jedisPool" ref="jedisPool"></property>
 	</bean>
 	<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
 		<constructor-arg name="host" value="192.168.25.133"/>
 		<constructor-arg name="port" value="6379"/>
 	</bean>
 	
 	
 </beans>

//测试类供大家测试用,先试试是否运行成功在进行下面操作.（切换单机版和集群版的时候代码不用改）

package cn.e3mall.jedis;
    
    import org.junit.Test;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import cn.e3mall.common.jedis.JedisClient;
    
    public class JedisClientTest {
    
    	@Test
    	public void test() throws Exception{
    		ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-redis.xml");
    		JedisClient jedisClient = applicationContext.getBean(JedisClient.class);
    		jedisClient.set("myTest", "666");
    		String test = jedisClient.get("myTest");
    		System.out.println(test);
    	}
    }

package cn.e3mall.content.service.impl;
 
 import java.util.Date;
 import java.util.List;
 
 import org.apache.commons.lang3.StringEscapeUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.apache.commons.lang3.StringUtils;
 import cn.e3mall.commom.jedis.JedisClient;
 import cn.e3mall.common.utils.E3Result;
 import cn.e3mall.common.utils.JsonUtils;
 import cn.e3mall.content.service.ContentService;
 import cn.e3mall.mapper.TbContentMapper;
 import cn.e3mall.pojo.TbContent;
 import cn.e3mall.pojo.TbContentExample;
 import cn.e3mall.pojo.TbContentExample.Criteria;
 
 
 /**
 * 内容管理Service
 * Title: ContentServiceImpl
 * Description: 
 * Company: www.itcast.cn 
 * @version 1.0
 */
 @Service
 public class ContentServiceImpl implements ContentService {
 
 	@Autowired
 	private TbContentMapper contentMapper;
 	
 	@Autowired
 	private JedisClient jedisClient;
 	
 	@Value("${CONTENT_LIST}")
 	private String CONTENT_LIST;
 	
 	@Override
 	public E3Result addContent(TbContent content) {
 		//将内容数据插入到内容表
 		content.setCreated(new Date());
 		content.setUpdated(new Date());
 		//插入到数据库
 		contentMapper.insert(content);
 		// 缓存同步，删除缓存中对应的数据
 		jedisClient.hdel(CONTENT_LIST, content.getCategoryId().toString());
 		
 		return E3Result.ok();
 	}
 
 	/**
 	 * 根据内容分类id查询内容列表
 	 * @param cid
 	 * @return
 	 
 	 */
 	@Override
 	public List<TbContent> getContentListByCid(long cid) {
 		//查询缓存
 		try {
 		// 如果缓存中有直接相应结果
 		String json = jedisClient.hget(CONTENT_LIST, cid+"");
 		if(StringUtils.isNotBlank(json)){
 			List<TbContent> list = JsonUtils.jsonToList(json, TbContent.class);
 			return list;
 		}
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 		// 如果没有查询数据库
 		TbContentExample example = new TbContentExample();
 		Criteria criteria = example.createCriteria();
 		//设置查询条件
 		criteria.andCategoryIdEqualTo(cid);
 		//执行查询
 		List<TbContent> list = contentMapper.selectByExampleWithBLOBs(example);
 		// 把结果添加到缓存
 		try {
 			jedisClient.hset(CONTENT_LIST, cid+"", JsonUtils.objectToJson(list));
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 		return list;
 	}
 
 }

![70 2][]

启动服务器：

![70 3][]

[70]: /images/20220317/7f099432b007401d8f968b7179fc8435.png
[70 1]: /images/20220317/bcb7805ff331468d922572501115b86e.png
[70 2]: /images/20220317/fd7c8cb912cd4508bf63fa6fa048ec3d.png
[70 3]: /images/20220317/c9e37ddc5ea24ee091d481309f979c52.png