ssm（Spring、Springmvc、Mybatis）实战之淘淘商…
2019-05-13 07:18:46来源：博客园 阅读 ()
文章大纲
一、课程介绍
二、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
原文链接:https://www.cnblogs.com/WUXIAOCHANG/p/10851733.html
如有疑问请与原作者联系
标签：
版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有
相关文章
- Spring系列.ApplicationContext接口 2020-06-11
- springboot2配置JavaMelody与springMVC配置JavaMelody 2020-06-11
- 给你一份超详细 Spring Boot 知识清单 2020-06-11
- SpringBoot 2.3 整合最新版 ShardingJdbc + Druid + MyBatis 2020-06-11
- 掌握SpringBoot-2.3的容器探针：实战篇 2020-06-11
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
热门词条
最新资讯
热门关注
热门标签