Java阶段五Day14

分布式事务

整合demo案例中

架构，代码关系

发送半消息

OrderServiceImpl

package cn.tedu.csmall.all.adapter.service.impl;import cn.tedu.csmall.all.adapter.mapper.OrderMapper;
import cn.tedu.csmall.all.service.ICartService;
import cn.tedu.csmall.all.service.IOrderService;
import cn.tedu.csmall.all.service.IStockService;
import cn.tedu.csmall.commons.exception.CoolSharkServiceException;
import cn.tedu.csmall.commons.pojo.order.dto.OrderAddDTO;
import cn.tedu.csmall.commons.pojo.order.entity.Order;
import cn.tedu.csmall.commons.pojo.stock.dto.StockReduceCountDTO;
import cn.tedu.csmall.commons.restful.JsonPage;
import cn.tedu.csmall.commons.restful.ResponseCode;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import java.util.List;
import java.util.Map;import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.annotation.DubboService;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;// order模块是具备生产者特征的,它会被business模块调用,所以也要加@DubboService注解
@DubboService(loadbalance = "random")
@Service
@Slf4j
public class OrderServiceImpl implements IOrderService {@Autowiredprivate OrderMapper orderMapper;/*** 防止消息异步消费逻辑中,重复消费的问题,业务方法* 设计成幂等的* @param orderAddDTO*/@Autowiredprivate RocketMQTemplate rocketMQTemplate;@Overridepublic void orderAdd(OrderAddDTO orderAddDTO) {int count=orderMapper.selectExists(orderAddDTO);if (count>0){log.debug("订单已经新增了");return;}//发送一个半消息,消息如果发送成功,是给购物车用的//只要包含当前订单用户,的订单商品是什么 消息特点精简准确//消息不仅只有消费者在使用,还有本地事务,和检查事务的方法都在使用//主要考虑check检查,如果消息本身携带的内容不足以支持检查逻辑//需要想办法携带更多信息String msgData=orderAddDTO.getUserId()+":"+orderAddDTO.getCommodityCode();Message message= MessageBuilder.withPayload(msgData).setHeader("name","王翠花").setHeader("orderId","1").build();//object参数表示业务数据,当前业务逻辑 减库存生单rocketMQTemplate.sendMessageInTransaction("order-add-topic",message,orderAddDTO);}// 分页查询所有订单的业务逻辑层方法// page是页码,pageSize是每页条数public JsonPage<Order> getAllOrdersByPage(Integer page, Integer pageSize){// PageHelper框架实现分页的核心操作:// 在要执行分页的查询运行之前,设置分页的条件// 设置的方式如下(固定的格式,PageHelper框架设计的)// PageHelper设置page为1就是查询第一页PageHelper.startPage(page,pageSize);// 下面开始持久层方法的调用// 此方法运行时因为上面设置了分页条件,sql语句中会自动出现limit关键字List<Order> list = orderMapper.findAllOrders();// 查询结果list中包含的就是分页查询范围的数据了// 但是这个数据不包含分页信息(总页数,总条数,是否是首页,是否是末页等)// 我们要利用PageHelper框架提供的PageInfo类型,来进行返回// PageInfo对象可以既包含分页数据,又包含分页信息// 这些信息会在PageInfo对象实例化时自动计算,并赋值到PageInfo对象中return JsonPage.restPage(new PageInfo<>(list));}
}

本地事务

本地事务方法调用顺序，在发送半消息之后执行

OrderAddTransactionListener

package cn.tedu.csmall.all.adapter.transaction;import cn.tedu.csmall.all.adapter.mapper.OrderMapper;
import cn.tedu.csmall.all.service.IStockService;
import cn.tedu.csmall.commons.exception.CoolSharkServiceException;
import cn.tedu.csmall.commons.pojo.order.dto.OrderAddDTO;
import cn.tedu.csmall.commons.pojo.order.entity.Order;
import cn.tedu.csmall.commons.pojo.stock.dto.StockReduceCountDTO;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionListener;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;/*** @author liner* @version 1.0*/
@Component
@RocketMQTransactionListener
public class OrderAddTransactionListener implements RocketMQLocalTransactionListener {@DubboReferenceprivate IStockService stockService;@Autowiredprivate OrderMapper orderMapper;/*** 1.减库存* 1.1 减成功 进入第二步生单* 1.2 减失败 rollback* 2.生单* 2.1 生单成功 commit* 2.2 生单失败 补偿库存 unkonwn* 其他异常问题 unknown* @param message userId":"commodityCode* @param o OrderAddDTO* @return*/@Overridepublic RocketMQLocalTransactionState executeLocalTransaction(Message message, Object o) {OrderAddDTO orderAddDTO=(OrderAddDTO)o;try{StockReduceCountDTO countDTO=new StockReduceCountDTO();countDTO.setCommodityCode(orderAddDTO.getCommodityCode());countDTO.setReduceCount(orderAddDTO.getCount());// 利用Dubbo调用stock模块减少库存的业务逻辑层方法实现功能stockService.reduceCommodityCount(countDTO);}catch (CoolSharkServiceException e){//返回rollbackreturn RocketMQLocalTransactionState.ROLLBACK;}catch (Throwable e){//返回unknownreturn RocketMQLocalTransactionState.UNKNOWN;}try{Order order=new Order();BeanUtils.copyProperties(orderAddDTO,order);orderMapper.insertOrder(order);}catch (Exception e){return RocketMQLocalTransactionState.UNKNOWN;}return RocketMQLocalTransactionState.COMMIT;}/*** 1. 检查订单是否成功.* 1.1 成功 commit* 1.2 没有成功 进入第2步* 2. 库存对当前订单是否已经减成功* 2.1 减成功,回退 第3步* 2.2 没减成功 rollback* 3.回退库存* 3.1 可能失败 unknown* 3.2 回退成功 rollback* @param message* @return*/@Overridepublic RocketMQLocalTransactionState checkLocalTransaction(Message message) {return null;}
}

完成检查补偿

利用检查补偿的方法，画的业务流程图

OrderAddTransactionListener

@Override
public RocketMQLocalTransactionState checkLocalTransaction(Message message) {//状态不明确,回调check方法,检查库存是否减少,检查订单是否生成String userIdAndCommodityCode = (String) message.getPayload();Object name = message.getHeaders().get("name");Object orderId = message.getHeaders().get("orderId");String userId=userIdAndCommodityCode.split(":")[0];String commodityCode=userIdAndCommodityCode.split(":")[1];OrderAddDTO orderAddDTO=new OrderAddDTO();orderAddDTO.setUserId(userId);orderAddDTO.setCommodityCode(commodityCode);int exist = orderMapper.selectExists(orderAddDTO);if (exist>0){//当前检查的这个订单已经生成,说明库存肯定减了return RocketMQLocalTransactionState.COMMIT;}//存在一个库存的日志表格,记录减库存的日志数据//通过传递订单信息,查询日志,如果减了就回退,如果没减,没有操作//返回给调用者检查结果是成功还是失败try{stockService.checkStockData();}catch (CoolSharkServiceException e){//没有库存减少的日志 没有任何减库存的操作return RocketMQLocalTransactionState.ROLLBACK;}//补偿回退 TODOtry{//补偿System.out.println("订单没有生成.库存减少了,开始补偿");}catch (Exception e){//补偿失败return RocketMQLocalTransactionState.UNKNOWN;}return RocketMQLocalTransactionState.ROLLBACK;
}

购物车消费

购物车整合rocketmq

购物车编写消费逻辑

package cn.tedu.csmall.all.adapter.consumer;import cn.tedu.csmall.all.service.ICartService;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.ScopeMetadata;
import org.springframework.stereotype.Component;/*** @author liner* @version 1.0*/
@Component
@RocketMQMessageListener(topic="order-add-topic",consumerGroup = "${rocketmq.consumer.group}",selectorExpression = "*")
public class CartDeleteConsumerListener implements RocketMQListener<String> {@Autowiredprivate ICartService cartService;@Overridepublic void onMessage(String msg) {String userId=msg.split(":")[0];String commodityCode=msg.split(":")[1];//删除购物车cartService.deleteUserCart(userId, commodityCode);}
}

鲁班周边环境调整

前端启动

介绍

• luban-front 前台

前台主要是给师傅用的

师傅抢单

签到 / 上传施工图片 / 完成订单

• luban-admin-front

后台是管理用的

需求单

厂商 / 供应商 入住

启动前端

node.js版本是 16 X 保证能运行

• luban-admin-front

启动顺序

1. npm install
2. npm run dev

• luban-front

启动顺序

1. npm install
2. npm run dev:h5

直接启动的项目

gateway（网关）

• 只需要nacos运行，默认连接localhost:8848 public DEFAULT_GROUP

login（登录注册）

• 导入登录的数据库表格

• 本地有redis（略）
• nacos localhost:8848（略）
• 运行bat文件 / sh文件

通过 idea 配置 bat / sh

attach（上传图片）

• 文件上传路径，和访问的关系

图片上传关系到鲁班中许多功能的业务流转

spring.resources.static-lcations：上传图片存放的路径，也是访问这个项目静态资源的路径

spring.mvc.static-path-pattern：访问attach服务时，匹配静态资源的规则

例如：

在

E:/home/images/dev/attach/haha.txt

E:/home/images/dev/attach/123456.png

attach 启动默认运行端口8092

http://localhost:8092/static/123456.png

http://localhost:8092/static/a/b/c/d/1.png

E:/home/images/dev/attach/a/b/c/d/1.png

• 导入数据库 sql 文件

分层开发和整洁架构

目标

• 了解分层开发的概念
• 理解分层开发实现结构的功能
• 落地整洁架构最终鲁班的项目

概念：纵向拆分（横向拆分）

分层开发（横向拆分）

分层开发的概念：

maven 多模块开发项目管理

可以利用这种管理功能，实现一个项目的多层次模块开发——分层开发

比如，当前项目HelloController依赖HelloService

这样做目的： 复杂开发过程，解耦（不调整依赖关系，无法解耦）

分层开发（横向拆分）和纵向拆分的区别在于，拆出多层，最终运行也是一个项目

整洁架构

《代码整洁之道》作者Bob大叔曾经说过

翻译过来：

程序架构总是一样的

让程序运行很简单

让程序"正确"很难

让程序维护简单，扩展简单就是正确

以 controller--service-mapper 为例，按照直觉分层开发，做依赖关系

问题1： 没有实现控制层，对持久层之间的隔离关系，可以随意的在controller中注入，依赖mapper

问题2：架构分层之间是纯粹强耦合

分层开发没有达到最终的目的，实现解耦，实现扩展维护方便

对应以上问题，在bob大叔的 《整洁架构之道》中，提到的解决的思想

整洁架构落地方案

核心点： 分层的众多模块中，有最核心的业务模块（service）

其他的模块，包括controller，redis，rocketmq，mysql，mybatis这些模块切分出来，都是容易被替换掉的

核心稳定的模块，如果依赖了容易变动不稳定模块，不满足整洁架构的思想

解决方案： 依赖倒置（开发原则）

是程序要依赖于抽象接口，不要依赖于具体实现*

• 分层数据封装
  • 入参（接收的参数）
    • query： 查询使用
    • param：写入使用（持久层写入转化成DO）
    • 远程调用：DTO
  • 出参（返回值）
    • service出参：BO
    • infrustructure出参： BO
    • dao出参：DO
    • adapter出参：VO
    • 远程调用： DTO

搭建worker项目架构

顶级夫工程继承操作

继承私服的父级项目tarena-mall-bom

创建项目架构

• worker-admin：后台后端
• worker-common（代码和依赖）：worker公用
• worker-po（代码和依赖）：包含的内容就是 worker 所有数据库 entity 对象
• worker-server：前台后端

根据分层架构依赖关系，搭建创建8个模块

worker-server

- adapter
- main
- client-api
- infrustructure
- dao-api
- dao-impl
- daomain
- protocol

附录

maven加载私服无法下载

现象： 拒绝连接远程私服，settings配置的

关键字： http://0.0.0.0 blocked

原因： idea默认的 maven 中settings.xml配置，禁止使用 http 协议访问私服

解决方法： 拦截删除

• 使用一个正常的 maven项目 执行mvn clean compile -X

• 进入文件夹，修改内容,将mirror（不是mirrors）注释或者删除

前端启动问题

现象： npm install 报错 npm run 报错

原因：

• 命令执行错了

• 网络不通畅

• node.js（16.X） npm（8.5）版本

mac运行passport

现象： 无法运行java -jar命令

原因： 代码内配置属性，不是针对mac设置的

解决方案：

master 提交了新版本

jar运行节省内存问题

可以在java -jar命令中添加选项，限制内存上限

128m 参数：

java -jar ***.jar -Xmx128M -Xms128M -XX:MaxMetaspaceSize=128M -XX:MetaspaceSize=128M

idea跑的 java 程序能加

连接mysql失败

现象： Access to "root@localhost:3306" denied

原因： 你的数据库 密码用户名 不是root root

解决方案： 运行passport.jar 默认使用root / root 需要覆盖 jar 内的springboot项目代码配置文件application.yaml

java -jar passport-provider-1.0-SNAPSHOT.jar -Xmx128M -Xms128M -XX:MaxMetaspaceSize=128M -XX:MetaspaceSize=128M --server.port=8099 --spring.profiles.active=local –spring.datasource.password=root

演示项目和本地项目

现象：

http://dev.front.luban.p.yufeiworld.com/

http://localhost:8989

访问演示页面测试本地代码功能

注册失败

现象： insert 语句中缺少 avator字段

关键字： unknown column 'avator'

原因： 导入的不是commont-passport.sql 而是common_passort.sql