Skip to content

Latest commit

 

History

History
214 lines (165 loc) · 7.54 KB

README.md

File metadata and controls

214 lines (165 loc) · 7.54 KB

项目架构

本项目是基于SpringCloudAlibaba的微服务架构的demo，结合了Oauth2.0 + JWT单点登录，Openfeign远程调用和Seata分布式事务等组件的学习项目

服务启动时，添加环境变量到path.env文件，根据文件进行相关配置即可

系统组件

组件 版本 官网
SpringBoot 2.6.15 https://springdoc.cn/spring-boot/
SpringCloud 2021.0.5 https://spring.io/projects/spring-cloud
SpringCloudAlibaba 2021.0.6.0 https://spring.io/projects/spring-cloud-alibaba
SpringGateway 3.1.1 https://spring.io/projects/spring-cloud-gateway
Spring Security 2.6.15 https://spring.io/projects/spring-cloud-security
OAuth2.0 2.2.5.RELEASE https://docs.spring.io/spring-security/reference/servlet/oauth2/index.html
Nacos 2.2.0 https://nacos.io/zh-cn/docs/what-is-nacos.html
Seata 1.6.1 https://seata.apache.org/docs/v1.6/overview/what-is-seata
Sentinel 2021.0.6.0 https://sentinelguard.io/zh-cn/docs/introduction.html
OpenFeign 3.1.5 https://spring.io/projects/spring-cloud-openfeign
MySQL Connector 8.0.33 https://dev.mysql.com/doc/connector-j/en/
Mybatis 2.2.2 https://mybatis.org/mybatis-3/zh_CN/index.html
Lombok 1.18.28 https://projectlombok.org/features/

数据存储

数据库 版本 官网
MySQL 8.1.0 https://dev.mysql.com/doc/
Redis 7.0.12 https://developer.redis.com/howtos/quick-start

项目配置

Nacos配置

docker运行

docker run --name nacos3 -e MODE=standalone -p 8848:8848 -p 9848:9848 -p 9849:9849 -d nacos/nacos-server:latest

配置开启鉴权

1.使用 docker ps 命令查看正在运行的 Nacos 容器的 ID 或名称。

2.然后使用 docker exec -it 容器ID /bin/bash 命令进入容器的命令行界面。

3.进入容器后，可以使用 cd /home/nacos/conf 命令进入 Nacos 安装目录下的 conf 目录。

4.在 conf 目录下 ls 可以查看到 Nacos 运行的配置文件，包括 application.properties。

5.打开application.properties配置文件 vim application.properties 。

6.将下列配置信息输入文末

nacos.core.auth.system.type=nacos
nacos.core.auth.enabled=true
### JWT令
nacos.core.auth.plugin.nacos.token.secret.key=SecretKey012345678901234567890123456789012345678901234567890123456789
### Base64
nacos.core.auth.plugin.nacos.token.secret.key=VGhpc0lzTXlDdXN0b21TZWNyZXRLZXkwMTIzNDU2Nzg=
nacos.core.auth.server.identity.key=example
nacos.core.auth.server.identity.value=example

Oauth2.0配置

server:
  port: 8500
  servlet:
  	#为了防止一会在服务之间跳转导致Cookie打架（因为所有服务地址都是localhost，都会存JSESSIONID）
  	#这里修改一下context-path，这样保存的Cookie会使用指定的路径，就不会和其他服务打架了
  	#但是注意之后的请求都得在最前面加上这个路径
    context-path: /sso

OpenFeign配置

openfeign请求其他服务的服务启动类需要配置 @EnableFeignClients

sentinel配置

下载地址：https://github.com/alibaba/Sentinel/releases 导入jar包运行

  1. 添加依赖，在需要监控的服务添加即可

    <dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

  2. 配置文件中添加Sentinel相关信息

    spring:
  application:
    name: userservice
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
    sentinel:
      transport:
        dashboard: localhost:8858  # 添加监控页面地址即可

  3. 配置环境变量自定义端口 server.port=8858

  4. 启动jar包

访问地址：http://localhost:8858/#/login 账户密码默认都为 sentinel

Seata配置

源码地址：

https://github.com/seata/seata/archive/refs/heads/develop.zip

下载地址：

https://github.com/seata/seata/releases/download/v1.4.2/seata-server-1.4.2.zip

Docker安装：

docker run -d -p 8091:8091 -p 7091:7091  --name seata-server seataio/seata-server:1.7.1

添加依赖：

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

然后添加配置：

seata:
  service:
    vgroup-mapping:
    	# 这里需要对事务组做映射，默认的分组名为 应用名称-seata-service-group，将其映射到default集群
    	# 这个很关键，一定要配置对，不然会找不到服务
      bookservice-seata-service-group: default
    grouplist:
      default: localhost:8868

配置开启分布式事务:

@EnableAutoDataSourceProxy
@SpringBootApplication
public class BookApplication {
    public static void main(String[] args) {
        SpringApplication.run(BookApplication.class, args);
    }
}

在开启分布式事务的方法上添加@GlobalTransactional注解：

@GlobalTransactional
@Override
public boolean doBorrow(int uid, int bid) {
  	//这里打印一下XID看看，其他的服务业添加这样一个打印，如果一会都打印的是同一个XID，表示使用的就是同一个事务
    System.out.println(RootContext.getXID());
    if(bookClient.bookRemain(bid) < 1)
        throw new RuntimeException("图书数量不足");
    if(userClient.userRemain(uid) < 1)
        throw new RuntimeException("用户借阅量不足");
    if(!bookClient.bookBorrow(bid))
        throw new RuntimeException("在借阅图书时出现错误！");
    if(mapper.getBorrow(uid, bid) != null)
        throw new RuntimeException("此书籍已经被此用户借阅了！");
    if(mapper.addBorrow(uid, bid) <= 0)
        throw new RuntimeException("在录入借阅信息时出现错误！");
    if(!userClient.userBorrow(uid))
        throw new RuntimeException("在借阅时出现错误！");
    return true;
}

Seata会分析修改数据的sql，同时生成对应的反向回滚SQL，这个回滚记录会存放在undo_log 表中。所以要求每一个Client 都有一个对应的undo_log表（也就是说每个服务连接的数据库都需要创建这样一个表，这里由于我们三个服务都用的同一个数据库，所以说就只用在这个数据库中创建undo_log表即可）:

表SQL定义如下：

CREATE TABLE `undo_log`
(
  `id`            BIGINT(20)   NOT NULL AUTO_INCREMENT,
  `branch_id`     BIGINT(20)   NOT NULL,
  `xid`           VARCHAR(100) NOT NULL,
  `context`       VARCHAR(128) NOT NULL,
  `rollback_info` LONGBLOB     NOT NULL,
  `log_status`    INT(11)      NOT NULL,
  `log_created`   DATETIME     NOT NULL,
  `log_modified`  DATETIME     NOT NULL,
  `ext`           VARCHAR(100) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDB
  AUTO_INCREMENT = 1
  DEFAULT CHARSET = utf8;

Nacos 服务发现： https://blog.csdn.net/u013737132/article/details/133376131