- 1. 需求分析及准备工作
- 1.1 需求分析
- 1.2 创建存储统计数据表
- 2. 写数据分析的接口
- 2.1 在service下创建一个名为service_statistic的模块
- 2.1 写properties文件
- 2.2 在service_ucenter中写查询某一天注册人数的接口
- 2.3 在service_static模块下用代码生成器生成相关的代码
- 2.4 写一个远程调用注册人数的接口
- 2.5 controller层
- 2.6 sevice层
- 3.后台管理系统的编写
- 3. 定时任务
- 3.1 启动定时器任务
- 3.2 每天凌晨一点执行定时任务
- 4. 前端统计数据的图表显示
- 4.1 后台统计数据接口的编写
- 4.2 简介
- 4.3 项目中整合Echarts
- 5. 网关
- 5.1 API网关介绍
- 5.2Spring Cloud Gateway核心概念
- 5.3 Getway的具体使用
- 统计在线项目的一系列数据，并用图表展示出来
CREATE TABLE `statistics_daily` ( `id` char(19) NOT NULL COMMENT '主键', `date_calculated` varchar(20) NOT NULL COMMENT '统计日期', `register_num` int(11) NOT NULL DEFAULT '0' COMMENT '注册人数', `login_num` int(11) NOT NULL DEFAULT '0' COMMENT '登录人数', `video_view_num` int(11) NOT NULL DEFAULT '0' COMMENT '每日播放视频数', `course_num` int(11) NOT NULL DEFAULT '0' COMMENT '每日新增课程数', `gmt_create` datetime NOT NULL COMMENT '创建时间', `gmt_modified` datetime NOT NULL COMMENT '更新时间', PRIMARY KEY (`id`), KEY `statistics_day` (`date_calculated`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='网站统计日数据';2. 写数据分析的接口 2.1 在service下创建一个名为service_statistic的模块 2.1 写properties文件
server.port=8008
spring.application.name=service-statistics
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/guli?serverTimezone=GMT%2B8
spring.datasource.username=root
spring.datasource.password=root
spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
spring.jackson.time-zone=GMT+8
mybatis-plus.mapper-locations=classpath:com/atguigu/edustatistic/mapper/xml
public class DateUtil {
private static final String dateFormat = "yyyy-MM-dd";
public static String formatDate(Date date) {
SimpleDateFormat sdf = new SimpleDateFormat(dateFormat);
return sdf.format(date);
}
public static Date addDays(Date date, int amount) {
Calendar now =Calendar.getInstance();
now.setTime(date);
now.set(Calendar.DATE,now.get(Calendar.DATE)+amount);
return now.getTime();
}
public static void main(String[] args) {
System.out.println(DateUtil.formatDate(new Date()));
System.out.println(DateUtil.formatDate(DateUtil.addDays(new Date(), -1)));
}
}
- 实现更新任务
@Component
public class ScheduleTask {
private StatisticsDailyService statisticsDailyService;
//每天凌晨一点，把前一天的数据进行查询和添加
@Scheduled(cron = "0 0 1 * * ?")
public void task2()
{
statisticsDailyService.registerCount(DateUtil.formatDate(DateUtil.addDays(new Date(),-1)));
}
}
4. 前端统计数据的图表显示
4.1 后台统计数据接口的编写
controller
//图标显示 返回两部分的数据 日期json数组 数量json数组
@GetMapping("/showData/{type}/{begin}/{end}")
public R showData(@PathVariable String type,@PathVariable String begin,@PathVariable String end)
{
Map map= dailyService.getShowData(type,begin,end);
return R.ok().data(map);
}
service
@Override
public Map getShowData(String type, String begin, String end) {
//根据条件查询对应的数据
QueryWrapper wrapper = new QueryWrapper<>();
wrapper.between("date_calculated",begin,end);
wrapper.select("date_calculated",type);
List selectList = baseMapper.selectList(wrapper);
//因为前端要返回两部分数据 日期和日期对应的数量
//前端要求返回数据的json格式，对应java后端的代码是list集合
//创建两个list集合 一个日期list 一个数量list
ArrayList date_calculatedList = new ArrayList<>();
ArrayList numDataList = new ArrayList<>();
//变量所有数据的list集合，进行封装
for(StatisticsDaily statisticsDaily:selectList)
{
//封装list集合
date_calculatedList.add(statisticsDaily.getDateCalculated());
//封装对应的数量
switch (type)
{
case "login_num":
numDataList.add(statisticsDaily.getLoginNum());
break;
case "register_num":
numDataList.add(statisticsDaily.getRegisterNum());
break;
case "video_view_num":
numDataList.add(statisticsDaily.getVideoViewNum());
break;
case "course_num":
numDataList.add(statisticsDaily.getCourseNum());
break;
default:
break;
}
}
//把封装之后的list集合放入map集合
HashMap map = new HashMap<>();
map.put("date_calculatedList",date_calculatedList);
map.put("numDataList",numDataList);
return map;
}
4.2 简介
ECharts是百度的一个项目，后来百度把Echart捐给apache，用于图表展示，提供了常规的折线图、柱状图、散点图、饼图、K线图，用于统计的盒形图，用于地理数据可视化的地图、热力图、线图，用于关系数据可视化的关系图、treemap、旭日图，多维数据可视化的平行坐标，还有用于 BI 的漏斗图，仪表盘，并且支持图与图之间的混搭。
官网：https://echarts.apache.org
- 下载echarts依赖npm install --save echarts@4.1.0
- 在statistic.js中添加路由信息
//2. 获取统计数据
getDataSta(searchObj){
return request({
url:`/edustatistic/sta/showData/${searchObj.type}/${searchObj.begin}/${searchObj.end}`,
method:'get'
})
}
- 在views/statistic/show.vue页面
5. 网关 5.1 API网关介绍查询
API 网关出现的原因是微服务架构的出现，不同的微服务一般会有不同的网络地址，而外部客户端可能需要调用多个服务的接口才能完成一个业务需求，如果让客户端直接与各个微服务通信，会有以下的问题：
- 客户端会多次请求不同的微服务，增加了客户端的复杂性。
- 存在跨域请求，在一定场景下处理相对复杂。
- 认证复杂，每个服务都需要独立认证。
- 难以重构，随着项目的迭代，可能需要重新划分微服务。例如，可能将多个服务合并成一个或者将一个服务拆分成多个。如果客户端直接与微服务通信，那么重构将会很难实施。
- 某些微服务可能使用了防火墙 / 浏览器不友好的协议，直接访问会有一定的困难。
以上这些问题可以借助 API 网关解决。API 网关是介于客户端和服务器端之间的中间层，所有的外部请求都会先经过 API 网关这一层。也就是说，API 的实现方面更多的考虑业务逻辑，而安全、性能、监控可以交由 API 网关来做，这样既提高业务灵活性又不缺安全性
网关是客户端和服务端之间的一面墙，可以起到很多作用：比如请求转发、负载均衡、权限控制
网关提供API全托管服务，丰富的API管理功能，辅助企业管理大规模的API，以降低管理成本和安全风险，包括协议适配、协议转发、安全策略、防刷、流量、监控日志等贡呢。一般来说网关对外暴露的URL或者接口信息，我们统称为路由信息。如果研发过网关中间件或者使用过Zuul的人，会知道网关的核心是Filter以及Filter Chain（Filter责任链）。Sprig Cloud Gateway也具有路由和Filter的概念。下面介绍一下Spring Cloud Gateway中几个重要的概念。
- 路由。路由是网关最基础的部分，路由信息有一个ID、一个目的URL、一组断言和一组Filter组成。如果断言路由为真，则说明请求的URL和配置匹配
- 断言。Java8中的断言函数。Spring Cloud Gateway中的断言函数输入类型是Spring5.0框架中的ServerWebExchange。Spring Cloud Gateway中的断言函数允许开发者去定义匹配来自于http request中的任何信息，比如请求头和参数等。
- 过滤器。一个标准的Spring webFilter。Spring cloud gateway中的filter分为两种类型的Filter，分别是Gateway Filter和Global Filter。过滤器Filter将会对请求和响应进行修改处理
- 创建一个名为api_getway的module
- 添加依赖
com.atguigu common_utils 0.0.1-SNAPSHOT org.springframework.cloud spring-cloud-starter-alibaba-nacos-discovery org.springframework.cloud spring-cloud-starter-gateway com.google.code.gson gson org.springframework.cloud spring-cloud-starter-openfeign
- properties配置
#端口号 server.port=8222 # 微服务名称 spring.application.name=service-getway # nacos spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848 #使用服务发现路由 spring.cloud.gateway.discovery.locator.enabled=true #设置路由id spring.cloud.gateway.routes[0].id=service-acl #设置路由的uri url lb://nacos微服务名称 spring.cloud.gateway.routes[0].uri=lb://service-acl #设置路由断言,代理servicerId为auth-service的/auth/路径 spring.cloud.gateway.routes[0].predicates= Path=/*/acl/** # 设置msm微服务 spring.cloud.gateway.routes[1].id=service-msm spring.cloud.gateway.routes[1].uri=lb://service-msm spring.cloud.gateway.routes[1].predicates= Path=/edumsm/** # 设置ucenter微服务 spring.cloud.gateway.routes[2].id=service-ucenter spring.cloud.gateway.routes[2].uri=lb://service-ucenter spring.cloud.gateway.routes[2].predicates= Path=/educenter/** # 设置cms微服务 spring.cloud.gateway.routes[3].id=service-cms spring.cloud.gateway.routes[3].uri=lb://service-cms spring.cloud.gateway.routes[3].predicates= Path=/educms/** # 设置edu微服务 spring.cloud.gateway.routes[4].id=service-edu spring.cloud.gateway.routes[4].uri=lb://service-edu spring.cloud.gateway.routes[4].predicates= Path=/eduservice/** # 设置order微服务 spring.cloud.gateway.routes[5].id=service-order spring.cloud.gateway.routes[5].uri=lb://service-order spring.cloud.gateway.routes[5].predicates= Path=/eduorder/** # 设置oss微服务 spring.cloud.gateway.routes[6].id=service-oss spring.cloud.gateway.routes[6].uri=lb://service-oss spring.cloud.gateway.routes[6].predicates= Path=/eduoss/** # 设置statistic微服务 spring.cloud.gateway.routes[7].id=service-statistics spring.cloud.gateway.routes[7].uri=lb://service-statistics spring.cloud.gateway.routes[7].predicates= Path=/edustatistic/** # 设置vod微服务 spring.cloud.gateway.routes[8].id=service-vod spring.cloud.gateway.routes[8].uri=lb://service-vod spring.cloud.gateway.routes[8].predicates= Path=/eduvod/**
- 主启动
@SpringBootApplication
@EnableDiscoveryClient
public class ApiGetwayApplication {
public static void main(String[] args) {
SpringApplication.run(ApiGetwayApplication.class, args);
}
}
