ssm（Spring、Springmvc、Mybatis）实战之淘淘商城-第七天(非原创)
2024-08-25 04:29:02
文章大纲
一、课程介绍
二、Redis基础实战
三、Redis之高可用、集群、云平台搭建实战
四、淘淘商城Jedis整合spring
五、项目源码与资料下载
六、参考文章
一、课程介绍
一共14天课程
（1）第一天：电商行业的背景。淘淘商城的介绍。搭建项目工程。Svn的使用。
（2）第二天：框架的整合。后台管理商品列表的实现。分页插件。
（3）第三天：后台管理。商品添加。商品类目的选择、图片上传、富文本编辑器的使用。
（4）第四天：商品规格的实现。
（5）第五天：商城前台系统的搭建。首页商品分类的展示。Jsonp。
（6）第六天：cms系统的实现。前台大广告位的展示。
（7）第七天：cms系统添加缓存。Redis。缓存同步。
（8）第八天：搜索功能的实现。使用solr实现搜索。
（9）第九天：商品详情页面的展示。
（10）第十天：单点登录系统。Session共享。
（11）第十一天：购物车订单系统的实现。
（12）第十二天：nginx。反向代理工具。
（13）第十三天：redis集群的搭建、solr集群的搭建。系统的部署。
（14）项目总结。
二、Redis基础实战
Redis的基础包括以下内容，可参考文章https://www.cnblogs.com/WUXIAOCHANG/p/10832330.html进行学习
（1）安装并设置开机自动启动
（2）Redis文件结构
（3）Redis启动方式
（4）Redis持久化
（5）Redis配置文件详解
（7）Redis图形化工具
（8）Java之Jedis连接Redis单机
三、Redis之高可用、集群、云平台搭建实战
https://www.cnblogs.com/WUXIAOCHANG/p/10851334.html
四、淘淘商城Jedis整合spring
1. 添加Reids之后项目架构
2. Redis在淘淘商城解决方案
在taotao-rest工程中发布一个服务。当后台管理系统修改内容后，调用此服务，同步缓存。
3. Jedis整合spring
3.1 resources文件夹中添加配置文件
在resources文件夹中创建applicationContext-redis.xml配置文件
<?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.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">
<!-- 连接池配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!-- 最大连接数 -->
<property name="maxTotal" value="30" />
<!-- 最大空闲连接数 -->
<property name="maxIdle" value="10" />
<!-- 每次释放连接的最大数目 -->
<property name="numTestsPerEvictionRun" value="1024" />
<!-- 释放连接的扫描间隔（毫秒） -->
<property name="timeBetweenEvictionRunsMillis" value="30000" />
<!-- 连接最小空闲时间 -->
<property name="minEvictableIdleTimeMillis" value="1800000" />
<!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
<property name="softMinEvictableIdleTimeMillis" value="10000" />
<!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
<property name="maxWaitMillis" value="1500" />
<!-- 在获取连接的时候检查有效性, 默认false -->
<property name="testOnBorrow" value="true" />
<!-- 在空闲时检查有效性, 默认false -->
<property name="testWhileIdle" value="true" />
<!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
<property name="blockWhenExhausted" value="false" />
</bean>
<!-- 单机版的redis环境配置 -->
<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
<constructor-arg name="host" value="192.168.3.153"/>
<constructor-arg name="port" value="6379"/>
<constructor-arg name="poolConfig" ref="jedisPoolConfig"/>
</bean>
<!-- 集群redis环境的配置,任选其一 -->
<!-- bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
<constructor-arg name="nodes">
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7001"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7002"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7003"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7004"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7005"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7006"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7007"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.25.153"></constructor-arg>
<constructor-arg index="1" value="7008"></constructor-arg>
</bean>
</set>
</constructor-arg>
<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
</bean> -->
<!-- redis客户端实现类 -->
<!-- 单机版 -->
<bean id="jedisClient" class="com.taotao.rest.dao.impl.JedisClientPool"/>
<!-- 集群版 -->
<!--<bean id="jedisClient" class="com.taotao.rest.dao.impl.JedisClientCluster"/> -->
</beans>
温馨提示：
（1）jedisPoolConfig是连接池的配置信息，无论是单机还是集群都适用
（2）jedisClient为单机版的配置信息
（3）jedisCluster是集群版的配置信息
3.2 单机版整合测试
com.taotao.rest.dao包中创建连接池JedisClientPool.java
/**
* redis单机版客户端
*/
public class JedisClientPool implements JedisClient{
@Autowired
private JedisPool jedisPool;
@Override
public String get(String key) {
Jedis jedis = jedisPool.getResource();
String result = jedis.get(key);
jedis.close();
return result;
}
@Override
public String set(String key, String value) {
Jedis jedis = jedisPool.getResource();
String string = jedis.set(key, value);
jedis.close();
return string;
}
@Override
public long incr(String key) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.incr(key);
jedis.close();
return result;
}
@Override
public Long hset(String hkey, String key, String value) {
Jedis jedis = jedisPool.getResource();
Long hset = jedis.hset(hkey, key, value);
jedis.close();
return hset;
}
@Override
public String hget(String hkey, String key) {
Jedis jedis = jedisPool.getResource();
String result = jedis.hget(hkey, key);
jedis.close();
return result;
}
@Override
public Long del(String key) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.del(key);
jedis.close();
return result;
}
@Override
public Long hdel(String hkey, String key) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.hdel(hkey, key);
jedis.close();
return result;
}
@Override
public Long expire(String key, int second) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.expire(key, second);
return result;
}
}
com.taotao.rest.dao包中创建测试类JedisTest.java
public class JedisTest {
// 单机版测试Jedis，不使用连接池
public void testJedis() {
// 创建Jedis对象
Jedis jedis = new Jedis("127.0.0.1", 6379);
// 设置对象
jedis.set("key1", "jedis test");
String string = jedis.get("key1");
System.out.println(string);
// 关闭jedis
jedis.close();
}
// 单机版测试Jedis，这是使用连接池的方式来获取redis的资源
public void testJedispool() {
JedisPool pool = new JedisPool("127.0.0.1", 6379);
Jedis resource = pool.getResource();
String string = resource.get("key1");
System.out.println(string);
// 不要忘记关闭连接池了
pool.close();
resource.close();
}
创建后项目结构如下
3.3 集群版整合测试
com.taotao.rest.dao包中创建集群版客户端JedisClientCluster.java
/**
* redis集群版客户端
*/
public class JedisClientCluster implements JedisClient {
@Autowired
private JedisCluster jedisCluster;
@Override
public String get(String key) {
String string = jedisCluster.get(key);
return string;
}
@Override
public String set(String key, String value) {
String string = jedisCluster.set(key, value);
return string;
}
@Override
public long incr(String key) {
Long result = jedisCluster.incr(key);
return result;
}
@Override
public Long hset(String hkey, String key, String value) {
Long result = jedisCluster.hset(hkey, key, value);
return result;
}
@Override
public String hget(String hkey, String key) {
String string = jedisCluster.hget(hkey, key);
return string;
}
@Override
public Long del(String key) {
Long result = jedisCluster.del(key);
return result;
}
@Override
public Long hdel(String hkey, String key) {
Long result = jedisCluster.hdel(hkey, key);
return result;
}
@Override
public Long expire(String key, int second) {
Long result = jedisCluster.expire(key, second);
return result;
}
}
com.taotao.rest.dao包中使用测试类JedisTest.java
// 集群版，测试redis集群环境
public void testJiQun(){
HashSet<HostAndPort> nodes=new HashSet<HostAndPort>();
//这里的ip和后面的端口是，在linux系统的ip和配置的不同的redis的端口
nodes.add(new HostAndPort("127.0.0.1",6379));
nodes.add(new HostAndPort("127.0.0.1",6380));
nodes.add(new HostAndPort("127.0.0.1",6381));
nodes.add(new HostAndPort("127.0.0.1",6382));
nodes.add(new HostAndPort("127.0.0.1",6383));
nodes.add(new HostAndPort("127.0.0.1",6384));
JedisCluster cluster=new JedisCluster(nodes);
String string=cluster.get("key4");
System.out.println(string);
cluster.close();
}
4. 把缓存添加到业务逻辑
4.1 resources文件夹中添加配置
resources文件夹中新增resource.properties配置文件
#redis中内容缓存的key
REDIS_CONTENT_KEY=REDIS_CONTENT
#redis中商品信息缓存的key
REDIS_TAOTAO_ITEM_KEY=TAOTAO_ITEM
#过期时间60*60*24
REDIS_TAOTAO_ITME_EXPIRE=86400
4.2 创建缓存使用业务逻辑类
com.taotao.rest.service包下创建ContentServiceImpl.java进行缓存使用
package com.taotao.rest.service.impl;
import java.util.List;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import com.taotao.common.pojo.TaotaoResult;
import com.taotao.common.utils.ExceptionUtil;
import com.taotao.common.utils.JsonUtils;
import com.taotao.mapper.TbContentMapper;
import com.taotao.pojo.TbContent;
import com.taotao.pojo.TbContentExample;
import com.taotao.pojo.TbContentExample.Criteria;
import com.taotao.rest.dao.JedisClient;
import com.taotao.rest.service.ContentService;
/**
* 内容管理服务
*/
@Service
public class ContentServiceImpl implements ContentService {
@Autowired
private TbContentMapper contentMapper;
@Autowired
private JedisClient jedisClient;
@Value("${REDIS_CONTENT_KEY}")
private String REDIS_CONTENT_KEY;
@Override
public TaotaoResult getContentList(long categoryId) {
//添加取缓存的逻辑
//缓存不能影响正常逻辑
try {
String result = jedisClient.hget(REDIS_CONTENT_KEY, categoryId+"");
//判断结果是否为空
if (!StringUtils.isBlank(result)) {
List<TbContent> list = JsonUtils.jsonToList(result, TbContent.class);
return TaotaoResult.ok(list);
}
} catch (Exception e) {
e.printStackTrace();
}
//缓存逻辑结束
List<TbContent> list = null;
try {
TbContentExample example = new TbContentExample();
Criteria criteria = example.createCriteria();
// 设置查询条件
criteria.andCategoryIdEqualTo(categoryId);
// 执行查询
list = contentMapper.selectByExample(example);
} catch (Exception e) {
e.printStackTrace();
return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));
}
//把内容添加到缓存中
try {
jedisClient.hset(REDIS_CONTENT_KEY, categoryId + "",
JsonUtils.objectToJson(list));
} catch (Exception e) {
// TODO: handle exception
}
//end
return TaotaoResult.ok(list);
}
}
5. 同步缓存服务
当数据库中的内容信息发生改变后，例如首页大广告为的广告内容发生变化后，如何实现redis中的数据同步更新呢？可以在taotao-rest工程中发布一个服务，就是专门同步数据用的，其实只需要把缓存中的数据清空即可。当管理后台更新了内容信息后，需要调用此服务。
此服务不需要mapper内容。只需要JedisCluster对象。
5.1 创建缓存同步服务逻辑类
com.taotao.rest.service包中创建RedisSyncServiceImpl.java
@Service
public class RedisSyncServiceImpl implements RedisSyncService {
@Autowired
private JedisClient jedisClient;
@Value("${REDIS_CONTENT_KEY}")
private String REDIS_CONTENT_KEY;
@Override
public TaotaoResult syncContent(String key) {
jedisClient.hdel(REDIS_CONTENT_KEY, key);
return TaotaoResult.ok();
}
}
在com.taotao.rest.controller包中创建缓存同步的服务类RedisSyncController.java
@Controller
@RequestMapping("/sync")
public class RedisSyncController {
@Autowired
private RedisSyncService redisSyncService;
@RequestMapping("/content/{categoryId}")
@ResponseBody
public TaotaoResult syncContent(@PathVariable String categoryId) {
try {
redisSyncService.syncContent(categoryId);
} catch (Exception e) {
e.printStackTrace();
return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));
}
return TaotaoResult.ok();
}
}
五、项目源码与资料下载
链接：https://pan.baidu.com/s/1XsTBNB8RCT-c2SaFdOTyqA
提取码：t05n
六、参考文章
http://yun.itheima.com/course?hm
最新文章
- Java课程设计--山寨版QQ
- DOTA2参数收集
- TCP/IP协议详解 卷1—读书笔记（1）
- 对android录制的NV21视频数据进行旋转(90,180,270)与剪切
- CSS3+Js制作的一款响应式导航条
- 【35】考虑virtual方法以外的其他选择
- Android推送技术研究
- Powershell调用静态方法
- Activity切换动画(overridePendingTransition)-翻页效果
- 4.锁--Synchronizer Framework Base Class—AbstractQueuedSynchronizer介绍
- Linux - PCB之task_struct结构体
- git底层原理（一）
- ASP.NET Web API 2中的错误处理
- Safari不能连接到服务器
- 超简单的canvas绘制地图
- vue-router的简单实现原理
- 【打印】windows打印控件，Lodop.js介绍
- HDOJ 1023 Train Problem II
- PHP遍历数组常用方式（for,foreach,while,指针等等）
- ring3下的IAT HOOK