本帖最后由 苦逼的BUG 于 2019-4-9 14:25 编辑
1.任务调度 SpringTask
1.1 什么是任务调度
在企业级应用中，经常会制定一些“计划任务”，即在某个时间点做某件事情，核心是以
时间为关注点，即在一个特定的时间点，系统执行指定的一个操作。常见的任务调度框架有
Quartz 和 SpringTask 等。
1.2 SpringTask 入门小 Demo
创建模块 pinyougou-task-service,引入 spring 相关依赖 dao 和 common 工程，tomcat7 端口
为 9108
添加 web.xml
添加配置文件 applicationContext-task.xml ,内容如下
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-4.2.xsd">
<context:component-scan base-package="com.pinyougou.task"/>
<task:annotation-driven/>
</beans>
创建包 com.pinyougou.task
编写类
@Component
public class SeckillTask {
/**
* 刷新秒杀商品
*/
@Scheduled(cron="* * * * * ?")
public void refreshSeckillGoods(){
System.out.println("执行了任务调度"+new Date());
}
}
执行后会看到控制台每秒都输出了当前时间，其中 cron 设置的为表达式，是执行的时间规
则。
1.3 Cron 表达式
1.3.1 Cron 表达式格式
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
Cron 表达式是一个字符串，字符串以 5 或 6 个空格隔开，分为 6 或 7 个域，每一个域代表
一个含义，Cron 有如下两种语法格式：
（1）Seconds Minutes Hours DayofMonth Month DayofWeek Year
（2）Seconds Minutes Hours DayofMonth Month DayofWeek
每一个域可出现的字符如下：
Seconds:可出现", - * /"四个字符，有效范围为 0-59 的整数
Minutes:可出现", - * /"四个字符，有效范围为 0-59 的整数
Hours:可出现", - * /"四个字符，有效范围为 0-23 的整数
DayofMonth:可出现", - * / ? L W C"八个字符，有效范围为 1-31 的整数
Month:可出现", - * /"四个字符，有效范围为 1-12 的整数或 JAN-DEc
DayofWeek:可出现", - * / ? L C #"四个字符，有效范围为 1-7 的整数或 SUN-SAT 两个范围。1
表示星期天，2 表示星期一， 依次类推
Year:可出现", - * /"四个字符，有效范围为 1970-2099 年
每一个域都使用数字，但还可以出现如下特殊字符，它们的含义是：
(1)*：表示匹配该域的任意值，假如在 Minutes 域使用*, 即表示每分钟都会触发事件。
(2)?:只能用在 DayofMonth 和 DayofWeek 两个域。它也匹配域的任意值，但实际不会。因为
DayofMonth 和 DayofWeek 会相互影响。例如想在每月的 20 日触发调度，不管 20 日到底是
星期几，则只能使用如下写法： 13 13 15 20 * ?, 其中最后一位只能用？，而不能使用*，如
果使用*表示不管星期几都会触发，实际上并不是这样。
(3)-:表示范围，例如在 Minutes 域使用 5-20，表示从 5 分到 20 分钟每分钟触发一次
(4)/：表示起始时间开始触发，然后每隔固定时间触发一次，例如在 Minutes 域使用 5/20,
则意味着 5 分钟触发一次，而 25，45 等分别触发一次.
(5),:表示列出枚举值值。例如：在 Minutes 域使用 5,20，则意味着在 5 和 20 分每分钟触发一
次。
(6)L:表示最后，只能出现在 DayofWeek 和 DayofMonth 域，如果在 DayofWeek 域使用 5L,意
味着在最后的一个星期四触发。
(7)W: 表示有效工作日(周一到周五),只能出现在 DayofMonth 域，系统将在离指定日期的最
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
近的有效工作日触发事件。例如：在 DayofMonth 使用 5W，如果 5 日是星期六，则将在最
近的工作日：星期五，即 4 日触发。如果 5 日是星期天，则在 6 日(周一)触发；如果 5 日在
星期一 到星期五中的一天，则就在 5 日触发。另外一点，W 的最近寻找不会跨过月份
(8)LW:这两个字符可以连用，表示在某个月最后一个工作日，即最后一个星期五。
(9)#:用于确定每个月第几个星期几，只能出现在 DayofMonth 域。例如在 4#2，表示某月的
第二个星期三。
1.3.2 Cron 表达式例子
0 0 10,14,16 * * ? 每天上午 10 点，下午 2 点，4 点
0 0/30 9-17 * * ? 朝九晚五工作时间内每半小时
0 0 12 ? * WED 表示每个星期三中午 12 点
"0 0 12 * * ?" 每天中午 12 点触发
"0 15 10 ? * *" 每天上午 10:15 触发
"0 15 10 * * ?" 每天上午 10:15 触发
"0 15 10 * * ? *" 每天上午 10:15 触发
"0 15 10 * * ? 2005" 2005 年的每天上午 10:15 触发
"0 * 14 * * ?" 在每天下午 2 点到下午 2:59 期间的每 1 分钟触发
"0 0/5 14 * * ?" 在每天下午 2 点到下午 2:55 期间的每 5 分钟触发
"0 0/5 14,18 * * ?" 在每天下午 2 点到 2:55 期间和下午 6 点到 6:55 期间的每 5 分钟触发
"0 0-5 14 * * ?" 在每天下午 2 点到下午 2:05 期间的每 1 分钟触发
"0 10,44 14 ? 3 WED" 每年三月的星期三的下午 2:10 和 2:44 触发
"0 15 10 ? * MON-FRI" 周一至周五的上午 10:15 触发
"0 15 10 15 * ?" 每月 15 日上午 10:15 触发
"0 15 10 L * ?" 每月最后一日的上午 10:15 触发
"0 15 10 ? * 6L" 每月的最后一个星期五上午 10:15 触发
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
"0 15 10 ? * 6L 2002-2005" 2002 年至 2005 年的每月的最后一个星期五上午 10:15 触发
"0 15 10 ? * 6#3" 每月的第三个星期五上午 10:15 触发
1.4 秒杀商品列表的增量更新
每分钟执行查询秒杀商品表，将符合条件的记录并且缓存中不存在的秒杀商品存入缓存
/**
* 刷新秒杀商品
*/
@Scheduled(cron="0 * * * * ?")
public void refreshSeckillGoods(){
System.out.println("执行了任务调度"+new Date());
//查询所有的秒杀商品键集合
List ids = new ArrayList( redisTemplate.boundHashOps("seckillGoods").keys());
//查询正在秒杀的商品列表
TbSeckillGoodsExample example=new TbSeckillGoodsExample();
Criteria criteria = example.createCriteria();
criteria.andStatusEqualTo("1");//审核通过
criteria.andStockCountGreaterThan(0);//剩余库存大于 0
criteria.andStartTimeLessThanOrEqualTo(new Date());//开始时间小于等于当前时间
criteria.andEndTimeGreaterThan(new Date());//结束时间大于当前时间
criteria.andIdNotIn(ids);//排除缓存中已经有的商品
List<TbSeckillGoods> seckillGoodsList=
seckillGoodsMapper.selectByExample(example);
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
//装入缓存
for( TbSeckillGoods seckill:seckillGoodsList ){
redisTemplate.boundHashOps("seckillGoods").put(seckill.getId(),
seckill);
}
System.out.println("将"+seckillGoodsList.size()+"条商品装入缓存");
}
1.5 过期秒杀商品的移除
每秒中在缓存的秒杀上皮列表中查询过期的商品，发现过期同步到数据库，并在缓存中移除
该秒杀商品
/**
* 移除秒杀商品
*/
@Scheduled(cron="* * * * * ?")
public void removeSeckillGoods(){
System.out.println("移除秒杀商品任务在执行");
//扫描缓存中秒杀商品列表，发现过期的移除
List<TbSeckillGoods> seckillGoodsList =
redisTemplate.boundHashOps("seckillGoods").values();
for( TbSeckillGoods seckill:seckillGoodsList ){
if(seckill.getEndTime().getTime()<new Date().getTime() ){//如果结束日期
小于当前日期，则表示过期
seckillGoodsMapper.updateByPrimaryKey(seckill);//向数据库保存记录
redisTemplate.boundHashOps("seckillGoods").delete(seckill.getId());//移除缓存数
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
据
System.out.println("移除秒杀商品"+seckill.getId());
}
}
System.out.println("移除秒杀商品任务结束");
}
2.Maven Profile
2.1 什么是 MavenProfile
在我们平常的 java 开发中，会经常使用到很多配制文件（xxx.properties，xxx.xml），而
当我们在本地开发（dev），测试环境测试（test），线上生产使用（product）时，需要不
停的去修改这些配制文件，次数一多，相当麻烦。现在，利用 maven 的 filter 和 profile 功能，
我们可实现在编译阶段简单的指定一个参数就能切换配制，提高效率，还不容易出错.
profile 可以让我们定义一系列的配置信息，然后指定其激活条件。这样我们就可以定义
多个 profile，然后每个 profile 对应不同的激活条件和配置信息，从而达到不同环境使用不同
配置信息的效果。
2.2 Maven Profile 入门
修改 pinyougou-page-web 的 pom.xml
<properties>
<port>9105</port>
</properties>
<build>
<plugins>
<plugin>
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.2</version>
<configuration>
<!-- 指定端口 -->
<port>${port}</port>
<!-- 请求路径 -->
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>
运行 tomcat7:run ,发现运行结果是一样的，因为 port 是变量，而变量值是定义为 9105。这
其实就是我们之前学习的 maven 的变量。
那我们现在思考一下，如果这个端口在开发时使用 9105，如果在生产环境（或其他环境）
为 9205 呢？如何解决值的动态切换呢？
这时我们修改 pom.xml，增加 profile 定义
<profiles>
<profile>
<id>dev</id>
<properties>
<port>9105</port>
</properties>
</profile>
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
<profile>
<id>pro</id>
<properties>
<port>9205</port>
</properties>
</profile>
</profiles>
执行命令 tomcat7:run -P pro 发现以 9205 端口启动
执行命令 tomcat7:run -P dev 发现以 9105 端口启动
-P 后边跟的是 profile 的 id
如果我们只执行命令 tomcat7:run ,也是以 9105 启动，因为我们一开始定义的变量值就是
9105，就是在不指定 profileID 时的默认值.
2.3 切换数据库连接配置
2.3.1 编写不同环境的配置文件
（1）我们在 pinyougou-dao 工程中 src/main/resources 下创建 filter 文件夹
（2）filter 文件夹下创建 db_dev.properties ，用于配置开发环境用到的数据库
env.jdbc.driver=com.mysql.jdbc.Driver
env.jdbc.url=jdbc:mysql://localhost:3306/pinyougoudb?characterEncoding=utf-8
env.jdbc.username=root
env.jdbc.password=123456
（3）filter 文件夹下创建 db_pro.properties
env.jdbc.driver=com.mysql.jdbc.Driver
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
env.jdbc.url=jdbc:mysql://localhost:3306/pinyougoudb_pro?characterEncoding=utf-8
env.jdbc.username=root
env.jdbc.password=123456
（4）修改 properties 下的 db.properties
jdbc.driver=${env.jdbc.driver}
jdbc.url=${env.jdbc.url}
jdbc.username=${env.jdbc.username}
jdbc.password=${env.jdbc.password}
2.3.2 定义 Profile
修改 pom.xml
<properties>
<env>dev</env>
</properties>
<profiles>
<profile>
<id>dev</id>
<properties>
<env>dev</env>
</properties>
</profile>
<profile>
<id>pro</id>
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
<properties>
<env>pro</env>
</properties>
</profile>
</profiles>
这里我们定义了 2 个 profile，分别是开发环境和生产环境
2.3.3 资源过滤与变量替换
修改 pom.xml ，在 build 节点中添加如下配置
<filters>
<filter>src/main/resources/filters/db_${env}.properties</filter>
</filters>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
</resource>
</resources>
这里我们利用 filter 实现对资源文件(resouces) 过滤
maven filter 可利用指定的xxx.properties 中对应的key=value 对资源文件中的${key}进行替
换，最终把你的资源文件中的 username=${key}替换成 username=value
2.3.4 打包
在 pinyougou-dao 工程 执行命令：package -P pro , 解压生成的 jar 包，观察
db.properties 配置文件内容，已经替换为生产环境的值。
在 pinyougou-sellergoods-service 工程 执行命令 pageage ，解压生成的 war 包里的
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
pinyougou-dao 的 jar 包，发现也是生成环境的值。
2.3.5 测试运行
【1】连接生产数据库
（1）在 pinyougou-dao 工程执行命令：install -P pro
（2）在 pinyougou-sellergoods-service：执行命令：tomcat7:run
（3）在 pinyougou-shop-web ： 执行命令：tomcat7:run
【2】连接开发数据库
（1）在 pinyougou-dao 工程执行命令：install -P dev (或 install )
（2）在 pinyougou-sellergoods-service：执行命令：tomcat7:run
（3）在 pinyougou-shop-web ： 执行命令：tomcat7:run
2.4 切换注册中心连接配置
2.4.1 集中配置注册中心地址
（1）在 pinyougou-common 工程中 properties 下创建 dubbox.properties
address=192.168.25.135:2181
（2）Spring 目录下创建 spring 配置文件 applicationContext-dubbox.xml 配置如下：
<dubbo:registry protocol="zookeeper" address="${address}"/>
（3）所有的服务工程与 web 工程都要依赖 pinyougou-common . 并删除每个工程中关于注
册中心地址的配置
（4）安装 pinyougou-common 到本地仓库，然后测试运行。
2.4.2 MavenProfile 配置
（1）在 pinyougou-common 工程中创建 filters 目录 ，目录下建立 dubbox_dev.properties
env.address=192.168.25.135:2181
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
（2）建立 dubbox_pro.properties
env.address=192.168.25.136:2181
（3）修改 dubbox.properties
address=${env.address}
（4）修改 pinyougou-common 的 pom.xml
<properties>
<env>dev</env>
</properties>
<profiles>
<profile>
<id>dev</id>
<properties>
<env>dev</env>
</properties>
</profile>
<profile>
<id>pro</id>
<properties>
<env>pro</env>
</properties>
</profile>
</profiles>
.............................
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
<build>
<filters>
<filter>src/main/resources/filters/dubbox_${env}.properties</filter>
</filters>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
</resource>
</resources>
</build>
3.MongoDB 简介
3.1 什么是 MongoDB
MongoDB 是一个跨平台的，面向文档的数据库，是当前 NoSQL 数据库产品中最热门
的一种。它介于关系数据库和非关系数据库之间，是非关系数据库当中功能最丰富，最像关
系数据库的产品。它支持的数据结构非常松散，是类似 JSON 的 BSON 格式，因此可以存
储比较复杂的数据类型。
MongoDB 的官方网站地址是：http://www.mongodb.org/
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
3.2 MongoDB 特点
MongoDB 最大的特点是他支持的查询语言非常强大，其语法有点类似于面向对象的查
询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索
引。它是一个面向集合的,模式自由的文档型数据库。
具体特点总结如下：
（1）面向集合存储，易于存储对象类型的数据
（2）模式自由
（3）支持动态查询
（4）支持完全索引，包含内部对象
（5）支持复制和故障恢复
（6）使用高效的二进制数据存储，包括大型对象（如视频等）
（7）自动处理碎片，以支持云计算层次的扩展性
（8）支持 Python，PHP，Ruby，Java，C，C#，Javascript，Perl 及 C++语言的驱动程序，
社区中也提供了对 Erlang 及.NET 等平台的驱动程序
（9） 文件存储格式为 BSON（一种 JSON 的扩展）
3.3 MongoDB 体系结构
MongoDB 的逻辑结构是一种层次结构。主要由：
文档(document)、集合(collection)、数据库(database)这三部分组成的。逻辑结构是面向用户
的，用户使用 MongoDB 开发应用程序使用的就是逻辑结构。
（1）MongoDB 的文档（document），相当于关系数据库中的一行记录。
（2）多个文档组成一个集合（collection），相当于关系数据库的表。
（3）多个集合（collection），逻辑上组织在一起，就是数据库（database）。
（4）一个 MongoDB 实例支持多个数据库（database）。
文档(document)、集合(collection)、数据库(database)的层次结构如下图:
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
下表是 MongoDB 与 MySQL 数据库逻辑结构概念的对比
3.4 MongoDB 在品优购系统中的应用
我们品优购的评价系统、收藏系统采用等信息存储在 MongoDB . MongoDB 安装及数
据库操作部分属于自学内容，，大家可以根据本课程提供的配套的自学资料学习此部分内容。
4.品优购-其它业务功能分析
4.1 用户中心（WEB）
用户在首页登陆系统后会进入到用户中心首页。
MongoDb 关系型数据库 Mysql
数据库(databases) 数据库(databases)
集合(collections) 表(table)
文档(document) 行(row)
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
4.1.1 订单中心
功能需求：
（1）实现对订单的查询功能
（2）未付款订单的付款功能
（3）未付款订单的取消功能
（4）已付款提醒订单发货功能
（5）确认收货
（6）退货
（7）用户评价
（8）物流信息跟踪
4.1.2 秒杀订单中心
同上。
4.1.3 我的收藏
购物车中有将我的购物车商品移到我的收藏功能，在用户中心中可以查看我收藏的商品
对于这样的用户收藏数据，我们可以使用 mongoDB 来实现。
（1）我的收藏列表
（2）删除收藏
4.1.4 我的足迹
（1）查看足迹列表
（2）删除我的足迹
4.1.5 个人信息设置
（1）个人信息
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
（2）地址信息
（3）密码重置
（4）绑定手机
4.2 商家后台-订单管理（WEB）
4.2.1 订单管理
（1）订单查询
（2）订单发货
（3）订单退货
4.2.2 秒杀订单管理
（1）秒杀中订单查询（查询 redis ）
（2）已完成秒杀订单查询（查询数据库）
（3）秒杀订单发货
（4）秒杀订单退货查询
4.3 运营商后台-订单管理（WEB）
4.3.1 订单管理
根据商家、订单号、用户 ID 等信息查询订单列表
4.3.2 秒杀订单管理
（1）查询秒杀中订单
（2）查询已付款订单
4.4 评价系统
针对评论这样数据量大并且价值不高的数据，我们通常采用 MongoDB 来实现存储。
北京市昌平区建材城西路金燕龙办公楼一层 电话：400-618-9090
4.4.1 评价系统-数据访问层
评价数据访问层-操作 mongoDB
4.4.2 评价系统-服务层
评价服务层
4.4.3 web 工程调用评价系统
（1）在商品详细页显示该商品的所有评论信息（CORS 跨域）
（2）用户中心 web 工程引用评价服务 可以对已收货的订单追加评价。
（3）商家后台 web 工程引用评价服务 可以查看订单的评价
（4）运营商后台 web 工程引用评价服务 可以查看订单的评价
（5）任务服务 pinyougou-task-service 引用评价服务和搜索服务，统计每个商品的评价更
新到 solr 索引库中。
4.5 商家首页
构建商家首页工程，引用搜索服务，显示该商家的商品列表
4.6 资金结算
用户购买商品是直接付款给平台的，而发货的是商家，那商家如何获得货款呢？这就需
要运营商定期将货款转账给商家。
4.6.1 佣金与佣金比例
说到平台与商家之间的资金结算，我们必须要提一下佣金。佣金就是运营商以销售额为
基础抽取的销售提成。 商品类型不同，设定相应的佣金比例也不同。例如食品类佣金比例
为 0.5% ，那么商家每产生 100 元的销售额就需要支付给运营商平台相应比例的佣金。
北京市昌平区建材城西路金燕龙办公楼一层 电话 |
|
收藏
淘帖
踩
