• 对boot项目拆分成cloud项目的笔记

    引言：这里我用的是新版本的技术栈

    spring-boot-starter-parent                        ==>3.2.5

    mybatis-spring-boot-starter                      ==>3.0.3

    mybatis-plus-boot-starter                         ==>3.5.5

    spring-cloud-dependencies                     ==>2023.0.1

    spring-cloud-alibaba-dependencies        ==>2022.0.0.0

    nacos                                                       ==>v2.3.2-slim

    笔记也可以参考黑马的笔记：Docs

    下面这些是我自己拆分自己项目的过程及其笔记。

    一、引入项目中关键依赖

    1.     <parent>
    2.         <groupId>org.springframework.bootgroupId>
    3.         <artifactId>spring-boot-starter-parentartifactId>
    4.         <version>3.2.5version>
    5.     parent>
    6.  
    7.     <properties>
    8.         <spring-cloud.version>2023.0.1spring-cloud.version>
    9.         <spring-cloud-alibaba.version>2022.0.0.0spring-cloud-alibaba.version>
    10.         <mybatis.spring>3.0.3mybatis.spring>
    11.         <mybatisPlus>3.5.5mybatisPlus>
    12.     properties>
    13.  
    14.  
    15.     <dependencyManagement>
    16.         <dependencies>
    17.             
    18.             <dependency>
    19.                 <groupId>org.mybatis.spring.bootgroupId>
    20.                 <artifactId>mybatis-spring-boot-starterartifactId>
    21.                 <version>${mybatis.spring}version>
    22.             dependency>
    23.             
    24.             <dependency>
    25.                 <groupId>com.baomidougroupId>
    26.                 <artifactId>mybatis-plus-boot-starterartifactId>
    27.                 <version>${mybatisPlus}version>
    28.             dependency>
    29.             
    30.             <dependency>
    31.                 <groupId>org.springframework.cloudgroupId>
    32.                 <artifactId>spring-cloud-dependenciesartifactId>
    33.                 <version>${spring-cloud.version}version>
    34.                 <type>pomtype>
    35.                 <scope>importscope>
    36.             dependency>
    37.             
    38.             <dependency>
    39.                 <groupId>com.alibaba.cloudgroupId>
    40.                 <artifactId>spring-cloud-alibaba-dependenciesartifactId>
    41.                 <version>${spring-cloud-alibaba.version}version>
    42.                 <type>pomtype>
    43.                 <scope>importscope>
    44.             dependency>
    45.         dependencies>
    46.     dependencyManagement>

    二 、在docker中安装mysql和nacos

    1、创建通用网络

    这里hm-net是之前跟着黑马学习学习创建的 ，这里就也用这个网络

    docker network create hm-net
    2、安装mysql

    在虚拟机的root目录下建一个mysql目录用于存放信息，也可以在随便的目录创建

    在mysql目录里面创建三个包，conf，data和init，到时候创建mysql容器的时候自动挂载。init包主要放初始化的sql，让创建mysql的时候自动加载你需要的数据库信息，如果你是之后再创建也可以不在init包里面放信息，在conf包里面加载默认配置，文件名为xx.cnf,该文件的配置信息如下：

    1. [client]
    2. default_character_set=utf8mb4
    3. [mysql]
    4. default_character_set=utf8mb4
    5. [mysqld]
    6. character_set_server=utf8mb4
    7. collation_server=utf8mb4_unicode_ci
    8. init_connect='SET NAMES utf8mb4'

    运行下面指令创建mysql容器。下面所有-v ：左边都是你自己创建的包，：右边是系统中创建的位置，用自己创建的包进行挂载。

    1. docker run -d \
    2.   --name mysql \
    3.   -p 3306:3306 \
    4.   -e TZ=Asia/Shanghai \
    5.   -e MYSQL_ROOT_PASSWORD=123 \
    6.   -v /root/mysql/data:/var/lib/mysql \
    7.   -v /root/mysql/conf:/etc/mysql/conf.d \
    8.   -v /root/mysql/init:/docker-entrypoint-initdb.d \
    9.   --network hm-net\
    10.   mysql
    3、安装nacos

    可以参考我其他博客，里面也有介绍：学习springcloud中Nacos笔记-CSDN博客

    用database连上虚拟机里面的mysql，运行下面sql：

    1. /*
    2.  * Copyright 1999-2018 Alibaba Group Holding Ltd.
    3.  *
    4.  * Licensed under the Apache License, Version 2.0 (the "License");
    5.  * you may not use this file except in compliance with the License.
    6.  * You may obtain a copy of the License at
    7.  *
    8.  *      http://www.apache.org/licenses/LICENSE-2.0
    9.  *
    10.  * Unless required by applicable law or agreed to in writing, software
    11.  * distributed under the License is distributed on an "AS IS" BASIS,
    12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13.  * See the License for the specific language governing permissions and
    14.  * limitations under the License.
    15.  */
    16.  
    17. /******************************************/
    18. /*   表名称 = config_info                  */
    19. /******************************************/
    20. CREATE TABLE `config_info` (
    21.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    22.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    23.   `group_id` varchar(128) DEFAULT NULL COMMENT 'group_id',
    24.   `content` longtext NOT NULL COMMENT 'content',
    25.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    26.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    27.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    28.   `src_user` text COMMENT 'source user',
    29.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    30.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    31.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    32.   `c_desc` varchar(256) DEFAULT NULL COMMENT 'configuration description',
    33.   `c_use` varchar(64) DEFAULT NULL COMMENT 'configuration usage',
    34.   `effect` varchar(64) DEFAULT NULL COMMENT '配置生效的描述',
    35.   `type` varchar(64) DEFAULT NULL COMMENT '配置的类型',
    36.   `c_schema` text COMMENT '配置的模式',
    37.   `encrypted_data_key` text NOT NULL COMMENT '密钥',
    38.   PRIMARY KEY (`id`),
    39.   UNIQUE KEY `uk_configinfo_datagrouptenant` (`data_id`,`group_id`,`tenant_id`)
    40. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info';
    41.  
    42. /******************************************/
    43. /*   表名称 = config_info_aggr             */
    44. /******************************************/
    45. CREATE TABLE `config_info_aggr` (
    46.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    47.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    48.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    49.   `datum_id` varchar(255) NOT NULL COMMENT 'datum_id',
    50.   `content` longtext NOT NULL COMMENT '内容',
    51.   `gmt_modified` datetime NOT NULL COMMENT '修改时间',
    52.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    53.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    54.   PRIMARY KEY (`id`),
    55.   UNIQUE KEY `uk_configinfoaggr_datagrouptenantdatum` (`data_id`,`group_id`,`tenant_id`,`datum_id`)
    56. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='增加租户字段';
    57.  
    58.  
    59. /******************************************/
    60. /*   表名称 = config_info_beta             */
    61. /******************************************/
    62. CREATE TABLE `config_info_beta` (
    63.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    64.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    65.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    66.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    67.   `content` longtext NOT NULL COMMENT 'content',
    68.   `beta_ips` varchar(1024) DEFAULT NULL COMMENT 'betaIps',
    69.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    70.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    71.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    72.   `src_user` text COMMENT 'source user',
    73.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    74.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    75.   `encrypted_data_key` text NOT NULL COMMENT '密钥',
    76.   PRIMARY KEY (`id`),
    77.   UNIQUE KEY `uk_configinfobeta_datagrouptenant` (`data_id`,`group_id`,`tenant_id`)
    78. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_beta';
    79.  
    80. /******************************************/
    81. /*   表名称 = config_info_tag              */
    82. /******************************************/
    83. CREATE TABLE `config_info_tag` (
    84.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    85.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    86.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    87.   `tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id',
    88.   `tag_id` varchar(128) NOT NULL COMMENT 'tag_id',
    89.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    90.   `content` longtext NOT NULL COMMENT 'content',
    91.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    92.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    93.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    94.   `src_user` text COMMENT 'source user',
    95.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    96.   PRIMARY KEY (`id`),
    97.   UNIQUE KEY `uk_configinfotag_datagrouptenanttag` (`data_id`,`group_id`,`tenant_id`,`tag_id`)
    98. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_tag';
    99.  
    100. /******************************************/
    101. /*   表名称 = config_tags_relation         */
    102. /******************************************/
    103. CREATE TABLE `config_tags_relation` (
    104.   `id` bigint(20) NOT NULL COMMENT 'id',
    105.   `tag_name` varchar(128) NOT NULL COMMENT 'tag_name',
    106.   `tag_type` varchar(64) DEFAULT NULL COMMENT 'tag_type',
    107.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    108.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    109.   `tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id',
    110.   `nid` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'nid, 自增长标识',
    111.   PRIMARY KEY (`nid`),
    112.   UNIQUE KEY `uk_configtagrelation_configidtag` (`id`,`tag_name`,`tag_type`),
    113.   KEY `idx_tenant_id` (`tenant_id`)
    114. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_tag_relation';
    115.  
    116. /******************************************/
    117. /*   表名称 = group_capacity               */
    118. /******************************************/
    119. CREATE TABLE `group_capacity` (
    120.   `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
    121.   `group_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Group ID，空字符表示整个集群',
    122.   `quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额，0表示使用默认值',
    123.   `usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量',
    124.   `max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限，单位为字节，0表示使用默认值',
    125.   `max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数，，0表示使用默认值',
    126.   `max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限，单位为字节，0表示使用默认值',
    127.   `max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量',
    128.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    129.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    130.   PRIMARY KEY (`id`),
    131.   UNIQUE KEY `uk_group_id` (`group_id`)
    132. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='集群、各Group容量信息表';
    133.  
    134. /******************************************/
    135. /*   表名称 = his_config_info              */
    136. /******************************************/
    137. CREATE TABLE `his_config_info` (
    138.   `id` bigint(20) unsigned NOT NULL COMMENT 'id',
    139.   `nid` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'nid, 自增标识',
    140.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    141.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    142.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    143.   `content` longtext NOT NULL COMMENT 'content',
    144.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    145.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    146.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    147.   `src_user` text COMMENT 'source user',
    148.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    149.   `op_type` char(10) DEFAULT NULL COMMENT 'operation type',
    150.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    151.   `encrypted_data_key` text NOT NULL COMMENT '密钥',
    152.   PRIMARY KEY (`nid`),
    153.   KEY `idx_gmt_create` (`gmt_create`),
    154.   KEY `idx_gmt_modified` (`gmt_modified`),
    155.   KEY `idx_did` (`data_id`)
    156. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='多租户改造';
    157.  
    158.  
    159. /******************************************/
    160. /*   表名称 = tenant_capacity              */
    161. /******************************************/
    162. CREATE TABLE `tenant_capacity` (
    163.   `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
    164.   `tenant_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Tenant ID',
    165.   `quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额，0表示使用默认值',
    166.   `usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量',
    167.   `max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限，单位为字节，0表示使用默认值',
    168.   `max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数',
    169.   `max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限，单位为字节，0表示使用默认值',
    170.   `max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量',
    171.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    172.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    173.   PRIMARY KEY (`id`),
    174.   UNIQUE KEY `uk_tenant_id` (`tenant_id`)
    175. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='租户容量信息表';
    176.  
    177.  
    178. CREATE TABLE `tenant_info` (
    179.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    180.   `kp` varchar(128) NOT NULL COMMENT 'kp',
    181.   `tenant_id` varchar(128) default '' COMMENT 'tenant_id',
    182.   `tenant_name` varchar(128) default '' COMMENT 'tenant_name',
    183.   `tenant_desc` varchar(256) DEFAULT NULL COMMENT 'tenant_desc',
    184.   `create_source` varchar(32) DEFAULT NULL COMMENT 'create_source',
    185.   `gmt_create` bigint(20) NOT NULL COMMENT '创建时间',
    186.   `gmt_modified` bigint(20) NOT NULL COMMENT '修改时间',
    187.   PRIMARY KEY (`id`),
    188.   UNIQUE KEY `uk_tenant_info_kptenantid` (`kp`,`tenant_id`),
    189.   KEY `idx_tenant_id` (`tenant_id`)
    190. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='tenant_info';
    191.  
    192. CREATE TABLE `users` (
    193. 	`username` varchar(50) NOT NULL PRIMARY KEY COMMENT 'username',
    194. 	`password` varchar(500) NOT NULL COMMENT 'password',
    195. 	`enabled` boolean NOT NULL COMMENT 'enabled'
    196. );
    197.  
    198. CREATE TABLE `roles` (
    199. 	`username` varchar(50) NOT NULL COMMENT 'username',
    200. 	`role` varchar(50) NOT NULL COMMENT 'role',
    201. 	UNIQUE INDEX `idx_user_role` (`username` ASC, `role` ASC) USING BTREE
    202. );
    203.  
    204. CREATE TABLE `permissions` (
    205.     `role` varchar(50) NOT NULL COMMENT 'role',
    206.     `resource` varchar(255) NOT NULL COMMENT 'resource',
    207.     `action` varchar(8) NOT NULL COMMENT 'action',
    208.     UNIQUE INDEX `uk_role_permission` (`role`,`resource`,`action`) USING BTREE
    209. );
    210.  
    211. INSERT INTO users (username, password, enabled) VALUES ('nacos', '$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu', TRUE);
    212.  
    213. INSERT INTO roles (username, role) VALUES ('nacos', 'ROLE_ADMIN');

    配置nacos/custom.env文件，再将这个文件放在指定目录（root）下

    1. PREFER_HOST_MODE=hostname
    2. MODE=standalone
    3. SPRING_DATASOURCE_PLATFORM=mysql
    4. MYSQL_SERVICE_HOST=192.168.147.130
    5. MYSQL_SERVICE_DB_NAME=nacos
    6. MYSQL_SERVICE_PORT=3306
    7. MYSQL_SERVICE_USER=root
    8. MYSQL_SERVICE_PASSWORD=123
    9. MYSQL_SERVICE_DB_PARAM=characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai
    10. NACOS_AUTH_ENABLE=true
    11. NACOS_AUTH_IDENTITY_KEY=nacos
    12. NACOS_AUTH_IDENTITY_VALUE=nacos
    13. NACOS_AUTH_TOKEN=SecretKey012345678901234567890123456789012345678901234567890123456789
    14.

    拉取并安装nacos的镜像和容器

    在本项目中我用的是nacos6这个名字，用于区分其他容器，端口也不一样，还要加载的配置文件也不一样，上面的配置文件可以参考我之前的博客。

    1. docker run -d \
    2. --name nacos6 \
    3. --env-file ./nacos/quick-nacos.env \
    4. -p 8868:8848 \
    5. -p 9868:9848 \
    6. -p 9869:9849 \
    7. --restart=always \
    8. nacos/nacos-server:v2.3.2-slim

    用下面指令查看日志，最后面那个是容器名

    docker logs -f nacos6

    注意：这里需要注意，在新版本的nacos中，在java代码的配置里面需要加入nacos的用户名和密码，否则会报错。

    1. spring:
    2.   profiles:
    3.     active: dev
    4.   application:
    5.     name: user-service #微服务名称
    6.   cloud:
    7.     nacos:
    8.       server-addr: 192.168.147.130:8868
    9.       username: nacos #用户名
    10.       password: nacos #密码
    4、一些常用的dockers指令

    其中dps和dis可以去看看黑马的docker课，里面有自定义配置dps和dis，一般开机你都去停止那几个容器再去开启，因为有时候如果默认也是开启的，可能会存在一些bug，有时候你运行项目没事，有时候会出bug。所以你开虚拟机的时候顺便两个都停止再开启一边准没事。

    1. docker start mysql
    2. docker stop mysql
    3. docker start nacos6
    4. docker stop nacos6
    5. dis
    6. dps

    三、拆分项目

    1、原则

    这里直接套用黑马的笔记，我用的是纵向拆分

    明确了拆分目标，接下来就是拆分方式了。我们在做服务拆分时一般有两种方式：

    • 纵向拆分

    • 横向拆分

    所谓纵向拆分，就是按照项目的功能模块来拆分。例如黑马商城中，就有用户管理功能、订单管理功能、购物车功能、商品管理功能、支付功能等。那么按照功能模块将他们拆分为一个个服务，就属于纵向拆分。这种拆分模式可以尽可能提高服务的内聚性。

    而横向拆分，是看各个功能模块之间有没有公共的业务部分，如果有将其抽取出来作为通用服务。例如用户登录是需要发送消息通知，记录风控数据，下单时也要发送短信，记录风控数据。因此消息发送、风控数据记录就是通用的业务功能，因此可以将他们分别抽取为公共服务：消息中心服务、风控管理服务。这样可以提高业务的复用性，避免重复开发。同时通用业务一般接口稳定性较强，也不会使服务之间过分耦合。

    2、创建单一服务模块

    新建模块，按你业务来起名，下面有三个模块是我已经拆分好的了，就是新建模块选好maven和自己jdk版本，起好名，点击ok即可。

    给对应服务模块也要创建对应的数据库：

    3、给模块引入依赖

    这里注意一般业务模块的依赖都差不多，但是上面我抽取出来api模块和之前的common模块都是工具包，依赖会有所不同，下面我展示user-service和quick-api模块的依赖

     user-service：

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.     <parent>
    7.         <groupId>com.quickgroupId>
    8.         <artifactId>quick-pickupartifactId>
    9.         <version>0.0.1-SNAPSHOTversion>
    10.     parent>
    11.  
    12.     <artifactId>user-serviceartifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>17maven.compiler.source>
    16.         <maven.compiler.target>17maven.compiler.target>
    17.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    18.     properties>
    19.  
    20.     <dependencies>
    21.  
    22.         <dependency>
    23.             <groupId>com.quickgroupId>
    24.             <artifactId>quick-commenartifactId>
    25.             <version>0.0.1-SNAPSHOTversion>
    26.         dependency>
    27.  
    28.         
    29.         <dependency>
    30.             <groupId>cn.hutoolgroupId>
    31.             <artifactId>hutool-allartifactId>
    32.         dependency>
    33.  
    34.         
    35.         <dependency>
    36.             <groupId>com.github.xiaoymingroupId>
    37.             <artifactId>knife4j-openapi3-jakarta-spring-boot-starterartifactId>
    38.         dependency>
    39.  
    40.         
    41.         <dependency>
    42.             <groupId>com.github.xiaoymingroupId>
    43.             <artifactId>knife4j-openapi3-uiartifactId>
    44.         dependency>
    45.  
    46.         
    47.         <dependency>
    48.             <groupId>org.springframework.bootgroupId>
    49.             <artifactId>spring-boot-starter-webartifactId>
    50.         dependency>
    51.  
    52.         
    53.         <dependency>
    54.             <groupId>com.mysqlgroupId>
    55.             <artifactId>mysql-connector-jartifactId>
    56.         dependency>
    57.  
    58.         
    59.         <dependency>
    60.             <groupId>org.mybatis.spring.bootgroupId>
    61.             <artifactId>mybatis-spring-boot-starterartifactId>
    62.         dependency>
    63.  
    64.         <dependency>
    65.             <groupId>com.baomidougroupId>
    66.             <artifactId>mybatis-plus-boot-starterartifactId>
    67.         dependency>
    68.  
    69.         
    70.         <dependency>
    71.             <groupId>com.alibaba.cloudgroupId>
    72.             <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    73.         dependency>
    74.  
    75.         
    76.         <dependency>
    77.             <groupId>org.springframework.cloudgroupId>
    78.             <artifactId>spring-cloud-starter-openfeignartifactId>
    79.         dependency>
    80.         
    81.         <dependency>
    82.             <groupId>org.springframework.cloudgroupId>
    83.             <artifactId>spring-cloud-starter-loadbalancerartifactId>
    84.         dependency>
    85.  
    86.         
    87.         <dependency>
    88.             <groupId>io.github.openfeigngroupId>
    89.             <artifactId>feign-okhttpartifactId>
    90.         dependency>
    91.  
    92.         
    93.         <dependency>
    94.             <groupId>com.quickgroupId>
    95.             <artifactId>quick-apiartifactId>
    96.             <version>0.0.1-SNAPSHOTversion>
    97.         dependency>
    98.  
    99.  
    100.     dependencies>
    101.  
    102.  
    103.     <build>
    104.         <finalName>${project.artifactId}finalName>
    105.         <plugins>
    106.             <plugin>
    107.                 <groupId>org.springframework.bootgroupId>
    108.                 <artifactId>spring-boot-maven-pluginartifactId>
    109.             plugin>
    110.         plugins>
    111.     build>
    112.  
    113. project>

     quick-api：

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.     <parent>
    7.         <groupId>com.quickgroupId>
    8.         <artifactId>quick-pickupartifactId>
    9.         <version>0.0.1-SNAPSHOTversion>
    10.     parent>
    11.  
    12.     <artifactId>quick-apiartifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>17maven.compiler.source>
    16.         <maven.compiler.target>17maven.compiler.target>
    17.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    18.     properties>
    19.  
    20.     <dependencies>
    21.  
    22.         <dependency>
    23.             <groupId>com.quickgroupId>
    24.             <artifactId>quick-commenartifactId>
    25.             <version>0.0.1-SNAPSHOTversion>
    26.         dependency>
    27.  
    28.         
    29.         <dependency>
    30.             <groupId>org.springframework.cloudgroupId>
    31.             <artifactId>spring-cloud-starter-openfeignartifactId>
    32.         dependency>
    33.         
    34.         
    35.         <dependency>
    36.             <groupId>org.springframework.cloudgroupId>
    37.             <artifactId>spring-cloud-starter-loadbalancerartifactId>
    38.         dependency>
    39.  
    40.         
    41.         <dependency>
    42.             <groupId>com.github.xiaoymingroupId>
    43.             <artifactId>knife4j-openapi3-jakarta-spring-boot-starterartifactId>
    44.         dependency>
    45.  
    46.         
    47.         <dependency>
    48.             <groupId>com.github.xiaoymingroupId>
    49.             <artifactId>knife4j-openapi3-uiartifactId>
    50.         dependency>
    51.  
    52.     dependencies>
    53.  
    54.  
    55.  
    56. project>
    4、给每个服务做好配置文件

    这里我只展示user-service

    application.yml ：

    下面的一些配置需要看具体配置，其中的swagger我用的是swagger3，不同swagger配置不一样，swagger3可以参考我的一篇博客：SpringBoot3+支持Knife4j 4.0以上_knife4j-openapi3-jakarta-spring-boot-starter-CSDN博客

    还有服务端口，服务名称，扫描的包等等需要按自己项目修改。

    这里注意，新版本由于鉴权问题所以一定要加上nacos的用户名和密码

    1. server:
    2.   port: 8082 # 服务端口
    3. spring:
    4.   profiles:
    5.     active: dev # 环境配置，dev开发环境，test测试环境，prod生产环境
    6.   application:
    7.     name: user-service #微服务名称
    8.   cloud:
    9.     nacos:
    10.       server-addr: 192.168.147.130:8868 # nacos地址
    11.       username: nacos #用户名
    12.       password: nacos #密码
    13.       discovery:
    14.         group: QUICK_CLOUD # 配置服务注册分组
    15.     openfeign:
    16.       okhttp:
    17.         enabled: true # 开启okhttp
    18.   datasource:
    19.       driver-class-name: ${quick.datasource.driver-class-name}
    20.       url: jdbc:mysql://${quick.datasource.host}:${quick.datasource.port}/${quick.datasource.database}?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true
    21.       username: ${quick.datasource.username}
    22.       password: ${quick.datasource.password}
    23.  
    24. # springdoc-openapi项目配置
    25. springdoc:
    26.   swagger-ui:
    27.     path: /swagger-ui.html
    28.     tags-sorter: alpha
    29.     operations-sorter: alpha
    30.   api-docs:
    31.     path: /v3/api-docs
    32.   group-configs:
    33.     - group: 'C端用户接口'
    34.       paths-to-match: '/**'
    35.       packages-to-scan: com.quick.user.controller # 配置需要扫描的controller包路径
    36. knife4j:
    37.   enable: true
    38.   setting:
    39.     language: zh_cn
    40.  
    41. mybatis-plus:
    42.   type-aliases-package: com.quick.user.domain.po # 配置实体类存放的包路径
    43.   global-config:
    44.     db-config:
    45.       update-strategy: not_null
    46.       id-type: auto #配置实体类中id默认自增
    47.       logic-delete-field: deleted # 配置逻辑删除字段
    48.   configuration:
    49.     default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler
    50.     map-underscore-to-camel-case: true
    51.  
    52. logging:
    53.   level:
    54.     com:
    55.       quick:
    56.         user:
    57.           mapper: debug
    58.           service: info
    59.           controller: info
    60. quick:
    61.   jwt:
    62.     user-secret-key: quick
    63.     user-ttl: 72000000
    64.     user-token-name: authentication
    65.   wechat:
    66.     appid: ${quick.wechat.appid}
    67.     secret: ${quick.wechat.secret}

    下面是不同环境下的yml，如果你用的是dev就会用到application-dev.yml ，如果是local就是application-local.yml

    application-dev.yml ：

    1. quick:
    2.   datasource:
    3.     driver-class-name: com.mysql.cj.jdbc.Driver
    4.     host: 192.168.147.130 #虚拟机端口
    5.     port: 3306
    6.     database: quick-user #自己给自己对应服务建立的对应数据库
    7.     username: #自己数据库用户名
    8.     password: #自己数据库用户名
    9.  
    10.   wechat:
    11.  
    12.     #小程序:
    13.     appid: #自己小程序的appid
    14.     secret: #自己小程序的secret
    15.

    application-local.yml ：

    1. quick:
    2.   datasource:
    3.     driver-class-name: com.mysql.cj.jdbc.Driver
    4.     host: 192.168.147.130 #虚拟机端口
    5.     port: 3306
    6.     database: quick-user #自己给自己对应服务建立的对应数据库
    7.     username: #自己数据库用户名
    8.     password: #自己数据库用户名
    9.  
    10.   wechat:
    11.  
    12.     #小程序:
    13.     appid: #自己小程序的appid
    14.     secret: #自己小程序的secret
    15.
    5、给每个服务创建对应的包

    6、启动项目观察nacos

    输入访问nacos地址：http://192.168.147.130:8868/nacos/ （路径工具自己配置）

    可以看到成功注册上去。

    四、用OpenFeign实现服务调用

    1、引入依赖

    （操作对象：服务模块，user-service等等）

    在之前拆分项目的时候里面也有该依赖

    1.   
    2.   <dependency>
    3.       <groupId>org.springframework.cloudgroupId>
    4.       <artifactId>spring-cloud-starter-openfeignartifactId>
    5.   dependency>
    6.   
    7.   <dependency>
    8.       <groupId>org.springframework.cloudgroupId>
    9.       <artifactId>spring-cloud-starter-loadbalancerartifactId>
    10.   dependency>
    2、在服务启动类启用OpenFeign

    （操作对象：服务模块，user-service等等）

    添加注解@EnableFeignClients，这个注解后面那个属性在后面再解释

    1. @SpringBootApplication
    2. @EnableTransactionManagement //开启注解方式的事务管理
    3. @EnableCaching//开启缓存注解功能
    4. @EnableScheduling//开启任务调度
    5. @MapperScan("com.quick.user.mapper")
    6. //basePackages标记FeignClients扫描的包,defaultConfiguration标记日志级别配置类使得对该模块全局生效
    7. @EnableFeignClients(basePackages = "com.quick.api.client",defaultConfiguration = DefaultFeignConfig.class)
    8. public class UserApplication {
    9.  
    10.     public static void main(String[] args) {
    11.         SpringApplication.run(UserApplication.class, args);
    12.     }
    13.  
    14. }
    3、编写OpenFeign客户端

    （操作对象：api模块，sky-api）

    也可以在服务模块里面写，但是这样子多个服务都写有点臃肿，抽取出来更加方便各个服务调用，需要调用就引入api模块依赖即可

    客户端针对性的写，比如user-service模块的服务需要调用到store-service服务，就写对应操作store-service服务的客户端。下面给出user-service服务用到的客户端

    1. //调用同一个服务下的不同接口，用contextId区分
    2. @FeignClient(contextId = "store", name = "store-service")
    3. public interface StoreClient {
    4.  
    5.     //通过店铺id查询店铺所有信息
    6.     @GetMapping("/user/store/{storeId}")
    7.     @Operation(summary = "通过店铺id查询店铺所有信息")
    8.     Result getByStoreId (@PathVariable Long storeId);
    9.  
    10. }
    1. //调用同一个服务下的不同接口，用contextId区分
    2. @FeignClient(contextId = "mark",name = "store-service")
    3. public interface MarkClient {
    4.  
    5.     @GetMapping("/user/mark/getMarkListByUserId")
    6.     @Operation(summary = "通过用户id查看用户对所有店铺的评分")
    7.     Result> getMarkListByUserId(@RequestParam("userId") Long userId);
    8.  
    9. }

    由上面可见调用了两个客户端，在写客户端的时候需要在注解配置name，指定客户端调用的是哪个模块的接口，指定name为服务模块的服务名称，但是上面两个客户端都是store-service针对服务的客户端，如果写两个就会报错，所以需要区分两个客户端，所以得用contextId来区分。

     客户端里面的接口和对应模块的接口一致，下面给出对应一个的模块里面的controller接口和客户端比较

    MarkController:

    1. @RestController("userMarkController")
    2. @RequestMapping("/user/mark")
    3. @Tag(name = "C端-评分接口")
    4. @Slf4j
    5. @RequiredArgsConstructor
    6. public class MarkController {
    7.  
    8.     @Resource
    9.     private IMarkService markService;
    10.  
    11.     //通过用户id查看用户对所有店铺的评分
    12.     @GetMapping("/getMarkListByUserId")
    13.     @Operation(summary = "通过用户id查看用户对所有店铺的评分")
    14.     public Result> getMarkListByUserId(@RequestParam("userId") Long userId){
    15.  
    16.         QueryWrapperqueryWrapper=new QueryWrapper<>();
    17.         queryWrapper.lambda()
    18.                 .eq(Mark::getUserId,userId);
    19.         List markList = markService.list(queryWrapper);
    20.         return Result.success(markList);
    21.     }
    22.  
    23. }

    MarkClient:

    1. //调用同一个服务下的不同接口，用contextId区分
    2. @FeignClient(contextId = "mark",name = "store-service")
    3. public interface MarkClient {
    4.  
    5.     @GetMapping("/user/mark/getMarkListByUserId")
    6.     @Operation(summary = "通过用户id查看用户对所有店铺的评分")
    7.     Result> getMarkListByUserId(@RequestParam("userId") Long userId);
    8.  
    9. }

     上面可以看出，接口基本一致，但是在Client客户端里面要注意里面的路径信息必须完整，不能只复制异步的controller的一部分地址，要完整。

    4、编写客户端用到的实体类

    就是下面的dto。

    5、给api模块加上日志配置

    可能这个功能不算在OpenFeign里面，但是在api模块里面也顺便讲了

    1. public class DefaultFeignConfig {
    2.  
    3. //    NONE：不记录任何日志信息，这是默认值。
    4. //    BASIC：仅记录请求的方法，URL以及响应状态码和执行时间
    5. //    HEADERS：在BASIC的基础上，额外记录了请求和响应的头信息
    6. //    FULL：记录所有请求和响应的明细，包括头信息、请求体、元数据。
    7.  
    8.     //声明日志级别配置
    9.     @Bean
    10.     public Logger.Level feignLogLevel() {
    11.         return Logger.Level.FULL;
    12.     }
    13.  
    14. }

    加上这个配置类后，在之前谈过的在启动类加上@EnableFeignClients注解里面有个属性就是是这个配置在那个服务里面生效。就是里面的defaultConfiguration属性，加上这个配置类的信息。

    1. //basePackages标记FeignClients扫描的包,defaultConfiguration标记日志级别配置类使得对该模块全局生效
    2. @EnableFeignClients(basePackages = "com.quick.api.client",defaultConfiguration = DefaultFeignConfig.class)

    6、使用FeignClient

    在需要用到别的服务的时候，用FeignClient里面自定义写好的接口。

    用@RequiredArgsConstructor这个注解就能通过构造函数的方式对客户端接口的注入，导入也可以用@Resource或者@Autowired讲工厂里面的bean对象注入来使用

    1. @Service
    2. @Slf4j
    3. @RequiredArgsConstructor 
    4. public class UserServiceImpl extends ServiceImpl implements UserService {
    5.  
    6.     private final MarkClient markClient;
    7.     private final StoreClient storeClient;
    8.  
    9. }

    在接口实现里面调用

    1.         // 调用mark-service获取当前用户的所有评分
    2.         List markList = markClient.getMarkListByUserId(currentId).getData();
    3.         log.info("当前用户的所有评分:{}",markList);
    1.         // 同时查询相关的Store信息并设置到UserMarkVO中
    2.         Store store =storeClient.getByStoreId(mark.getStoreId()).getData();
    3.         log.info("store:{}",store);

    这里面的实体对象都是api包下的实体，实现不耦合。

    接口测试：

    之前用的log日志打印也出现了，成功用Feign实现跨服务调用。

    目前还没实现用网关去拦截等等操作，这些天在忙ddl，可能得过些天才继续更新，这也算自己做的笔记吧......

  • 相关阅读:
    Pandas中at、iat函数详解
    阿里云有奖体验：用PolarDB-X搭建一个高可用系统
    mysql远程连接 Communications link failure失败问题
    vue3学习笔记（异步组件，包含defineAsyncComponent、Suspense的使用）
    2022 开源之夏｜EMQ 三大开源项目开发圆满收官
    springboot- redis常见数据存取
    【卫朋】硬件创业：营销与开发同行
    Java创建Document对象有哪些方法呢？
    SpringMVC常用的三种获取请求参数的方式
    小型目标检测中的Transformer：一个基准和最先进技术的综述
  • 原文地址：https://blog.csdn.net/qq_73440769/article/details/139376179