父工程

pom文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  6.     <groupId>com.carve.springcloud</groupId>
  7.     <artifactId>cloud2020</artifactId>
  8.     <version>1.0-SNAPSHOT</version>
  9.     <packaging>pom</packaging>
  11.     <!--统一管理jar包版本-->
  12.     <properties>
  13.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  14.         <maven.compiler.source>1.8</maven.compiler.source>
  15.         <maven.compiler.target>1.8</maven.compiler.target>
  16.         <junit.version>4.12</junit.version>
  17.         <log4j.version>1.2.17</log4j.version>
  18.         <lombok.version>1.16.18</lombok.version>
  19.         <mysql.version>8.0.19</mysql.version>
  20.         <spring.boot.version>2.2.2.RELEASE</spring.boot.version>
  21.         <spring.cloud.version>Hoxton.SR1</spring.cloud.version>
  22.         <druid.spring.boot.starter.version>1.1.10</druid.spring.boot.starter.version>
  23.         <spring.cloud.alibaba.version>2.1.0.RELEASE</spring.cloud.alibaba.version>
  24.         <mybatis.spring.boot.starter.version>1.3.0</mybatis.spring.boot.starter.version>
  25.     </properties>
  27.     <!--子模块继承后,提供作用:锁定版本+子module不用groupId和version-->
  28.     <dependencyManagement>
  29.         <dependencies>
  30.             <!-- springboot 2.2.2 -->
  31.             <dependency>
  32.                 <groupId>org.springframework.boot</groupId>
  33.                 <artifactId>spring-boot-dependencies</artifactId>
  34.                 <version>${spring.boot.version}</version>
  35.                 <type>pom</type>
  36.                 <scope>import</scope>
  37.             </dependency>
  39.             <!-- Spring cloud Hoxton.SR1 -->
  40.             <dependency>
  41.                 <groupId>org.springframework.cloud</groupId>
  42.                 <artifactId>spring-cloud-dependencies</artifactId>
  43.                 <version>${spring.cloud.version}</version>
  44.                 <type>pom</type>
  45.                 <scope>import</scope>
  46.             </dependency>
  48.             <!-- Spring cloud alibaba 2.1.0.RELEASE -->
  49.             <dependency>
  50.                 <groupId>com.alibaba.cloud</groupId>
  51.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  52.                 <version>${spring.cloud.alibaba.version}</version>
  53.                 <type>pom</type>
  54.                 <scope>import</scope>
  55.             </dependency>
  57.             <dependency>
  58.                 <groupId>org.mybatis.spring.boot</groupId>
  59.                 <artifactId>mybatis-spring-boot-starter</artifactId>
  60.                 <version>${mybatis.spring.boot.starter.version}</version>
  61.             </dependency>
  63.             <dependency>
  64.                 <groupId>mysql</groupId>
  65.                 <artifactId>mysql-connector-java</artifactId>
  66.                 <version>${mysql.version}</version>
  67.             </dependency>
  69.             <dependency>
  70.                 <groupId>com.alibaba</groupId>
  71.                 <artifactId>druid-spring-boot-starter</artifactId>
  72.                 <version>${druid.spring.boot.starter.version}</version>
  73.             </dependency>
  75.             <dependency>
  76.                 <groupId>org.projectlombok</groupId>
  77.                 <artifactId>lombok</artifactId>
  78.                 <version>${lombok.version}</version>
  79.             </dependency>
  80.         </dependencies>
  81.     </dependencyManagement>
  83.     <build>
  84.         <plugins>
  85.             <plugin>
  86.                 <groupId>org.springframework.boot</groupId>
  87.                 <artifactId>spring-boot-maven-plugin</artifactId>
  88.                 <configuration>
  89.                     <fork>true</fork>
  90.                     <addResources>true</addResources>
  91.                 </configuration>
  92.             </plugin>
  93.         </plugins>
  94.     </build>
  96.     <!--第三方maven私服-->
  97.     <repositories>
  98.         <repository>
  99.             <id>nexus-aliyun</id>
  100.             <name>Nexus aliyun</name>
  101.             <url>http://maven.aliyun.com/nexus/content/groups/public</url>
  102.             <releases>
  103.                 <enabled>true</enabled>
  104.             </releases>
  105.             <snapshots>
  106.                 <enabled>false</enabled>
  107.             </snapshots>
  108.         </repository>
  109.     </repositories>
  110. </project>

子模块的pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>com.ali.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>

            <artifactId>cloud-provider-payment8001</artifactId>
            <dependencies>
            <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            </dependency>
            <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            </dependency>
            <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
            </dependency>
            <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
            </dependency>
            <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            </dependency>

            </dependencies>

</project>

通用模块 cloud-api-common

Payment,CommonResult

package com.carve.springcloud.entity;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Payment implements Serializable {
    private Long id;
    private String serial; // 流水号
}

package com.carve.springcloud.entity;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class CommonResult<T> {
    private Integer code;
    private String message;
    private T data;

    public CommonResult(Integer code, String message) {
        this(code, message, null);
    }
}

pom

<dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-devtools</artifactId>
      <scope>runtime</scope>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>cn.hutool</groupId>
      <artifactId>hutool-all</artifactId>
      <version>5.1.0</version>
    </dependency>
</dependencies>

支付生产者模块 cloud-provider-payment8001

pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>com.carve.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-provider-payment8001</artifactId>

    <description>支付模块</description>

    <dependencies>
        <dependency>
            <groupId>com.carve.springcloud</groupId>
            <artifactId>cloud-api-common</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
        </dependency>
        <!--mysql-connector-java-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!--jdbc-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!--热部署-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

yml

server:
  port: 8001

spring:
  application:
    name: cloud-payment-service

  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8
    username: root
    password: 123456

mybatis:
  mapper-locations: classpath*:mapper/*.xml
  type-aliases-package: com.carve.springcloud.entity

启动类

package com.carve.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

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

控制器

@RestController
@Slf4j
@RequestMapping("/payment")
public class PaymentController {
    @Autowired
    private PaymentService paymentService;

    @PostMapping("/create")
    public CommonResult create(@RequestBody Payment payment) {
        int result = paymentService.create(payment);
        if (result > 0) {
            return new CommonResult(200, "插件数据库成功", result);
        } else {
            return new CommonResult(444, "插入数据库失败", null);
        }
    }

    @GetMapping("/get/{id}")
    public CommonResult get(@PathVariable Long id) {
        Payment payment = paymentService.getById(id);
        if (null != payment) {
            return new CommonResult(200, "查询成功", payment);
        } else {
            return new CommonResult(404, "没有对应记录,查询ID:" + id, null);
        }
    }
}

订单消费者模块 cloud-consumer-order80

pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>com.carve.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-consumer-order80</artifactId>
    <description>消费者订单模块</description>

    <dependencies>
        <dependency>
            <groupId>com.carve.springcloud</groupId>
            <artifactId>cloud-api-common</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <!--热部署-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

yml

server:
  port: 80

启动类

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

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

控制器

@RestController
@Slf4j
public class OrderController {
    private static final String PAYMENT_URL = "http://localhost:8001";
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/consumer/payment/get/{id}")
    public CommonResult get(@PathVariable Long id) {
        return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
    }

    @PostMapping("/consumer/payment/create")
    public CommonResult create(@RequestBody Payment payment) {
        return restTemplate.postForObject(PAYMENT_URL + "/payment/create", payment, CommonResult.class);
    }
}

结构截图

父工程
image.png
通用模块
image.png
支付生产者模块
image.png

订单消费者模块
image.png

总结概要

1.cloud-consumer-order80 要远程调用 cloud-provider-payment8001 的接口
2.借助restTemple来实现http调用，存在很多弊端，如：接口链接写死在类里，做不到动态