Skip to content

liuhuiAndroid/cat-movie

BranchesTags

Repository files navigation

cat-movie

慕课网仿猫眼项目源码

1 微服务介绍

传统应用带来的问题：

  • 单一业务开发和迭代困难
  • 扩容困难
  • 部署和回滚困难

微服务概述：

  • 微服务是一种将业务系统进一步拆分的架构风格
  • 微服务强调每个业务都独立运行
  • 每个单一服务都应该使用更轻量的机制保持通信
  • 服务不强调环境，可以不同语言或数据源

2 演示环境构建

安装zookeeper

zookeeper 3.4.10 解压，修改conf/zoo_sample.cfg为zoo.cfg bin/zkServer.sh 启动

配置zookeeper

添加zkclient依赖，配置： spring: dubbo: registry: zookeeper://118.126.111.144:2181

3 业务基础环境构建

API网关的常见作用

  • 身份验证和安全
  • 审查和监测
  • 动态路由
  • 压力测试
  • 负载均衡
  • 静态相应处理

localhost:80/auth/userName=admin&password=admin 获取jwt guns-api项目，存放接口和公共类

4 用户模块开发

启动检查

dubbo可以不先启动服务提供者，避免强依赖

    @Reference(interfaceClass = UserAPI.class, check = false)
    private UserAPI userAPI;

负载均衡

负载均衡策略配置，一般配置在service上

loadbalance = "roundrobin"

多协议支持

protocol：服务之间的通信协议，一般用dubbo协议

5 影片模块开发

服务聚合

mybatis-plus自定义SQL实现

dubbo异步调用

影片详情查询接口存在多个服务调用 影片详情查询改造异步调用:Future特性 需要配置:@EnableAsync 和 async = true 异步调用 见文档

6 影院模块开发

影院模块业务开发

mybatis一对多查询：根据影院编号,获取所有电影的信息和对应的放映场次信息

修改全局异常返回

Tip

Dubbo特性：并发、连接控制，结果缓存

  • 结果缓存
@Reference(interfaceClass = CinemaServiceApi.class, cache = "lru", check = false)

dubbo缓存是本地缓存，不是分布式缓存，需要了解dubbo结果缓存与Redis等的区别，参考官网

结果缓存 见文档

  • 并发、连接控制
@Service(interfaceClass = CinemaServiceApi.class, executes = 10)

并发控制 见文档

连接控制 见文档

7 订单模块开发

订单模块业务开发

  • window ftp服务器
  1. 在计算机管理中创建用户 我的电脑 -> 管理 -> 计算机管理 -> 本地用户和组 -> 用户 -> 新用户
  2. 开启FTP服务器 控制面板 -> 程序和功能 -> 启用或关闭windows功能 -> Internet Infomation Services -> 勾选FTP服务器和Web管理工具
  3. 添加FTP站点 控制面板 -> 管理工具 -> IIS管理器 -> 网站 -> 添加FTP站点 -> 站点名称随便写，存放位置新建ftp文件夹 -> 端口2100，不需要SSL -> 身份验证匿名，所有用户可以读取写入
  4. 测试 ftp://192.168.10.109
  1. MoocOrderTMapper.xml#getOrderInfoById 对数据库时间的处理
  2. mysql函数：DATE_FORMAT、UNIX_TIMESTAMP

订单模块的横向和纵向拆表解决

问题：每年的订单量太大 横向拆分：同一个订单表拆成两个订单表 纵向拆分：订单表按年进行拆分 TODO mycat分库分表

暂时没有分组聚合的注解，只能手工合并
OrderServiceImpl2017 + OrderServiceImpl2018

@Service(interfaceClass = OrderServiceAPI.class, group = "default")
@Service(interfaceClass = OrderServiceAPI.class, group = "order2017")
@Service(interfaceClass = OrderServiceAPI.class, group = "order2018")

@Reference(interfaceClass = OrderServiceAPI.class, check = false, timeout = 8000, group = "order2018")
@Reference(interfaceClass = OrderServiceAPI.class, check = false, timeout = 8000, group = "order2017")

服务限流如何处理

问题：双十一订单太多 限流措施是系统高可用的一种手段

  1. 使用并发与连接控制进行限流，不常用
  2. 使用漏桶算法和令牌桶算法进行限流 漏桶算法流速固定，令牌桶对于业务峰值有一定承载能力
TokenBucket
下单增加令牌桶逻辑

服务的熔断和降级

问题：业务系统雪崩 hystrix具体使用见：Hystrix文档

如何保证多版本的蓝绿上线

group=lan version=1 version=2
group=lv version=1
gateway -> lan lv version=1
gateway -> lan version=1
gateway -> lan version=2

8 支付模块开发

支付模块业务开发

支付宝当面付流程：获取二维码 -> 等待支付宝回调 -> 修改订单状态 -> 定期对账 演示为了避免支付宝回调过程，在客户端查询支付状态的时候，Consumer修改订单状态 蚂蚁金服文档中心，下载当面付Demo 使用沙箱环境测试

dubbo特性学习：隐式参数、参数验证等

  • 本地存根 类似于dubbo的静态代理 dubbo会在客户端生成一个代理，处理部分业务 stub必须有可传入proxy的构造函数 本地存根 见文档
  • 本地伪装 常用 本地伪装是本地存根的一个子集 通常会使用本地伪装处理服务降级 hystrix对某个方法做降级，本地伪装可以对某个接口做降级 注意：本地伪装只能捕获Rpc异常 本地伪装 见文档
@Service(interfaceClass = AliPayServiceAPI.class, mock = "com.stylefeng.guns.api.alipay.AlipayServiceMock")
  • 隐式参数 dubbo提供了参数的隐式传递 dubbo的隐式参数仅单次调用可用 注意隐式参数的保留字段 分布式事务中经常用到 隐式参数 见文档

9 分布式事务

事务简介

事务是用来保证一组数据操作的完整性和一致性 事务必须满足ACID的四大特性：原子性（Atomicity）、一致性（Consistency）、隔离性（Isolation）、持久性（Durability）必背 事务具有四种隔离级别 事务具有七种传播行为

分布式事务的前世今生

分布式事务就是将多个节点的事务看成一个整体处理 分布式事务由事务参与者、资源服务器、事务管理器等组成 常见的分布式事务的例子：支付、下订单等

分布式事务解决方案

实现思路

两段式事务（2PC）和三段式事务（3PC）（很少用，但是原理需要知道） 基于XA的分布式事务：由两段式事务进化而来（了解） 基于消息（消息队列或Redis）的最终一致性方案（应用比较广泛） 案例：A系统转账前通过消息告诉B系统改状态成功再转钱否则回滚，一起成功失败 TCC（Try Confirm Cancel）编程式补偿性事务（应用最广）

两种事务比较

基于消息事务是强一致性事务，会存在资源浪费 TCC事务是柔性事务，在try阶段要对资源做预留 TCC事务在确认或取消阶段释放资源 与基于消息事务对比，TCC的时效性更好

主流分布式事务框架介绍

阿里全局事务服务（Global Transaction Service，简称GTS）收费 蚂蚁金服分布式事务（Distributed Transaction-eXtended，简称DTX）收费 开源TCC框架（TCC-Transaction） 暂时使用这个 开源TCC框架（ByteTCC） 具体源码见tcc-transaction-master-1.2.x项目

  • 重点内容 熟悉TCC-Transaction的分布式事务处理流程 TCC-Transaction不能保证幂等性，案例中已经有幂等性示范，添加了草稿状态 TCC分布式事务的核心是资源

10 集群监控与部署

了解dubbo监控相关内容

  • 了解Dubbo-monitor ：监控统计 dangdangdotcom/dubbox 支持restful，已经不维护了 apache/incubator-dubbo 下载源码编译得到 dubbo-monitor-simple-2.8.4-assembly.tar.gz

The function of monitor center will be merged to dubbo admin, based on metrics, coming soon monitor center功能即将合并到dubbo admin中

  • 部署Dubbo-monitor 解压dubbo-monitor-simple-2.8.4-assembly.tar.gz -》 dubbo-monitor-simple-2.8.4 修改conf中dubbo.properties,配置如下
dubbo.registry.address = zookeeper://118.126.111.144:2181
dubbo.jetty.port = 8090

dubbo.jetty.directory=E:/monitor
dubbo.charts.directory=E:/monitor/charts
dubbo.statistics.directory=E:/monitor/statistics
dubbo.log4j.file=E:/monitor/dubbo-monitor-simple.log
dubbo.log4j.level=WARN

bin/start.bat 启动 浏览器访问http://localhost:8090

Dubbo-admin 使用（常用）

Install admin console

git clone https://github.com/apache/incubator-dubbo-ops.git /var/tmp/dubbo-ops
cd /var/tmp/dubbo-ops
mvn clean package

修改配置 application.properties
mvn clean install -Dskiptest

dubbo 原生的admin工程使用的更多一点，可以使用当当的版本，dubbo-admin-2.6.0.war

dubbo-admin-2.6.0.war 重命名为admin
修改配置 dubbo.properties
启动tomcat
访问:localhost:8080/admin

链路监控

  • dubbo-filter Dubbo支持Filter机制 RpcContext就是通过Filter实现
MyFilter implements Filter
META-INF.dubbo 中 com.alibaba.dubbo.rpc.Filter 配置 MyFilterEXT=Myfilter全路径
application.properties 配置 spring.dubbo.provider.filter = MyFilterEXT

常见自定义Filter:日志记录、trace功能能

  • Zipkin 介绍 traceid spanid parentid java -jar zipkin.jar 或者 docker run -d -p 9411:9411 openzipkin/zipkin 访问 http://118.126.111.144:9411

  • 项目集成Zipkin

gateway、cinema、order、alipay项目增加zipkin依赖包，pom依赖见Zipkin文档
TraceConfig 以上项目都加入，配置各自的localServiceName
OrderController中OrderServiceAPI 注解上增加filter="tracing",很多地方都要加
启动项目
注意alipay中有common-lang冲突需要排除
postman测试登录、获取支付二维码
访问 http://118.126.111.144:9411 可以看到链路
zipkin数据可以存储到mysql上，三张表

业务系统部署

  1. 购买服务器：阿里云ECS购买服务器 https://www.aliyun.com
  2. 配置安全组：安全组相当于虚拟防火墙
  3. 连接服务器：可以用Xshell远程连接
  4. 域名备案：企业应用 域名注册 购买域名（申请一级域名需要备案，需要先备案服务号申请，然后进入备案系统）
  5. 安装mysql
#1. 创建用户
useradd lh
passwd qwer1234 
#2. 添加用户权限
chmod u+w /etc/sudoers
vi /etc/sudoers
lh  ALL=(ALL)   ALL
chmod u-w /etc/sudoers
#3. 关闭服务器防火墙，只依赖安全组，方便测试
service iptables stop // 关闭当前
chkconfig iptables off // 关闭以后
#4. 安装mysql 5.7
yum install -y lrzsz
mkdir /product
chown lh:lh /product
su - lh
mkdir software
上传mysql.rpm 镜像源
sudo yum install mysql.rpm
ls /etc/yum.repos.d/
sudo yum install mysql-community-server
#5. mysql 设置
sudo service mysqld status
sudo service mysqld start
#6. mysql 查看密码
grep "password" /var/log/mysqld.log
mysql -uroot -p
设置新密码
set password for 'root'@'localhost' = password('123zxc!#*');
#7.使mysql可以远程访问
select host,user from mysql.user
update mysql.user set host='%' where user='root';
select host,user from mysql.user;
exit
sudo service mysqld restart
  1. 访问远程服务器 可以用Xmanager远程连接,Xshell
  2. 安装vsftp 教程：https://help.aliyun.com/knowledge_detail/60152.html
  3. 安装jdk
  4. 安装zookeeper
  5. 数据初始化 数据库运行sql脚本
  6. 打包 注意 DefaultAliPayServiceImpl 中FTP保存路径需要修改为linux上的路径， 新增ftp上传路径 修改数据源，可以做多环境配置 注意端口冲突 日志文件路径需要修改 然后直接打包parent就可以 clean package 跳过测试 一般会依赖docker jenkins k8s TODO 自动化打包部署回退 sudo yum install -y unzip unzip product.zip # 里面是生成的jar包 nohup java -jar guns-user-0.0.1.jar & ps -ef | grep user 启动所有项目，使用postman测试
  7. 安装 OpenResty
sudo yum install pcre-devel openssl-devel gcc curl -y
tar -xzvf openresty-VERSION.tar.gz

./configure --prefix=/opt/openresty \
            --with-pcre-jit \
            --with-ipv6 \
            --without-http_redis2_module \
            --with-http_iconv_module \
            --with-http_postgres_module \
            -j2
            
make
make install
  1. 配置OpenResty 其实只是配置了nginx
cd nginx/conf
vi nginx.conf

server{
    listen 80;
    ...
    location / {
        proxy_pass http://127.0.0.1:8080
    }
}

11 微服务面试总结

备注

  • 常用命令
clean install -Dmaven.test.skip=true
#启动docker
sudo systemctl start docker
  • 测试接口
登录：http://localhost:81/auth?userName=admin&password=admin123
下单：http://localhost:81/order/buyTickets?fieldId=1&soldSeats=9&seatsName=1
订单列表：http://localhost:81/order/getOrderInfo
获取二维码：http://localhost:81/order/getPayInfo

About

慕课网仿猫眼项目源码

Resources

Readme

License

MIT license
Activity

Stars

26 stars

Watchers

3 watching

Forks

12 forks
Report repository

Releases

No releases published

Packages

No packages published

Languages