• 尚硅谷(SpringCloudAlibaba微服务分布式）学习代码Eureka部分

    1.项目结构

     

     

     2.cloud2024

    pom

    1. "1.0" encoding="UTF-8"?>
    2. "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.     4.0.0
    6.  
    7.     com.atguigu.springcloud
    8.     cloud2024
    9.     1.0-SNAPSHOT
    10.     pom
    11.  
    12.  
    13.     
    14.         <module>cloud-provider-payment8001module>
    15.         <module>cloud-consumer-order80module>
    16.         <module>cloud-api-commonsmodule>
    17.         <module>cloud-eureka-server7001module>
    18.         <module>cloud-eureka-server7002module>
    19.         <module>cloud-provider-payment8002module>
    20.     
    21.  
    22.  
    23.     
    24.     
    25.         UTF-8
    26.         1.8
    27.         1.8
    28.         4.12
    29.         1.2.17
    30.         1.18.30
    31.         8.0.18
    32.         1.1.16
    33.         1.3.0
    34.     
    35.  
    36.     
    37.         
    38.             
    39.             
    40.                 org.springframework.boot
    41.                 spring-boot-dependencies
    42.                 2.2.2.RELEASE
    43.                 pom
    44.                 import
    45.             
    46.             
    47.             
    48.                 org.springframework.cloud
    49.                 spring-cloud-dependencies
    50.                 Hoxton.SR1
    51.                 pom
    52.                 import
    53.             
    54.             
    55.             
    56.                 com.alibaba.cloud
    57.                 spring-cloud-alibaba-dependencies
    58.                 2.2.0.RELEASE
    59.                 pom
    60.                 import
    61.             
    62.             
    63.             
    64.                 mysql
    65.                 mysql-connector-java
    66.                 ${mysql.version}
    67.             
    68.             
    69.             
    70.                 com.alibaba
    71.                 druid-spring-boot-starter
    72.                 ${druid.verison}
    73.             
    74.             
    75.             
    76.                 org.mybatis.spring.boot
    77.                 mybatis-spring-boot-starter
    78.                 ${mybatis.spring.boot.verison}
    79.             
    80.             
    81.             
    82.                 org.projectlombok
    83.                 lombok
    84.                 ${lombok.version}
    85.             
    86.             
    87.             
    88.                 junit
    89.                 junit
    90.                 ${junit.version}
    91.             
    92.             
    93.             
    94.                 log4j
    95.                 log4j
    96.                 ${log4j.version}
    97.             
    98.         
    99.     
    100.  
    101.     
    102.         
    103.             
    104.                 org.apache.maven.plugins
    105.                 maven-compiler-plugin
    106.                 3.6.2
    107.                 
    108.                     8
    109.                     8
    110.                 
    111.             
    112.         
    113.     
    114.  
    115.

     2.cloud-api-commons

    2.1entities

    CommonResult

    1. package com.atguigu.springcloud.entities;
    2.  
    3. import lombok.AllArgsConstructor;
    4. import lombok.Data;
    5. import lombok.NoArgsConstructor;
    6.  
    7. @Data
    8. @NoArgsConstructor
    9. @AllArgsConstructor
    10. public class CommonResult {
    11.     private Integer code;
    12.     private String message;
    13.     private T        data;
    14.  
    15.     public CommonResult(Integer code,String message){
    16.         this(code,message,null);
    17.     }
    18. }

    Payment

    1. package com.atguigu.springcloud.entities;
    2.  
    3. import lombok.AllArgsConstructor;
    4. import lombok.Data;
    5. import lombok.NoArgsConstructor;
    6.  
    7. import java.io.Serializable;
    8.  
    9. @Data
    10. @NoArgsConstructor
    11. @AllArgsConstructor
    12. public class Payment implements Serializable {
    13.     private Long id;
    14.     private String serial;
    15. }

    pom

    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.     <parent>
    6.         <artifactId>cloud2024artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloud-api-commonsartifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8maven.compiler.source>
    16.         <maven.compiler.target>8maven.compiler.target>
    17.     properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.bootgroupId>
    21.             <artifactId>spring-boot-starter-webartifactId>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>org.springframework.bootgroupId>
    25.             <artifactId>spring-boot-starter-actuatorartifactId>
    26.         dependency>
    27.         <dependency>
    28.             <groupId>org.projectlombokgroupId>
    29.             <artifactId>lombokartifactId>
    30.             <optional>trueoptional>
    31.         dependency>
    32.         <dependency>
    33.             <groupId>cn.hutoolgroupId>
    34.             <artifactId>hutool-allartifactId>
    35.             <version>5.7.19version>
    36.         dependency>
    37.         
    38.         <dependency>
    39.             <groupId>org.springframework.bootgroupId>
    40.             <artifactId>spring-boot-devtoolsartifactId>
    41.             <scope>runtimescope>
    42.             <optional>trueoptional>
    43.         dependency>
    44.     dependencies>
    45.  
    46. project>

     3.cloud-consumer-order80

    config

    ApplicationContextConfig

    1. package com.atguigu.springcloud;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    6.  
    7. /**
    8.  * @Author: ASUS
    9.  * @Date: 2024/2/27 20:40
    10.  */
    11. @SpringBootApplication
    12. @EnableEurekaClient
    13. public class OrderMain80 {
    14.     public static void main(String[] args) {
    15.         SpringApplication.run(OrderMain80.class,args);
    16.     }
    17. }

    controller

    OrderController

    1. package com.atguigu.springcloud.controller;
    2.  
    3. import com.atguigu.springcloud.entities.CommonResult;
    4. import com.atguigu.springcloud.entities.Payment;
    5. import lombok.extern.slf4j.Slf4j;
    6. import org.springframework.beans.factory.annotation.Value;
    7. import org.springframework.web.bind.annotation.GetMapping;
    8. import org.springframework.web.bind.annotation.PathVariable;
    9. import org.springframework.web.bind.annotation.RestController;
    10. import org.springframework.web.client.RestTemplate;
    11.  
    12. import javax.annotation.Resource;
    13.  
    14. /**
    15.  * @Author: ASUS
    16.  * @Date: 2024/2/27 20:43
    17.  */
    18. @RestController
    19. @Slf4j
    20. public class OrderController {
    21.     //    public static final String PAYMENT_URL = "http://localhost:8001";
    22.     public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";
    23.     @Resource
    24.     private RestTemplate restTemplate;
    25.  
    26.     @GetMapping("/consumer/payment/create")
    27.     public CommonResult create(Payment payment) {
    28.         return restTemplate.postForObject(PAYMENT_URL + "/payment/create", payment, CommonResult.class);
    29.     }
    30.  
    31.     @GetMapping("/consumer/payment/get/{id}")
    32.     public CommonResult getPayment(@PathVariable("id") Long id) {
    33.         return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
    34.     }
    35. }

     yml

    1. server:
    2.   port: 80
    3. spring:
    4.   application:
    5.     name: cloud-order-service
    6. eureka:
    7.   client:
    8.     register-with-eureka: true
    9.     fetch-registry: true
    10.     service-url:
    11. #      defaultZone: http://localhost:7001/eureka
    12.        defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

    pom

    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.     <parent>
    6.         <artifactId>cloud2024artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloud-consumer-order80artifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8maven.compiler.source>
    16.         <maven.compiler.target>8maven.compiler.target>
    17.     properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    22.             <version>2.2.10.RELEASEversion>
    23.         dependency>
    25.         <dependency>
    26.             <groupId>com.atguigu.springcloudgroupId>
    27.             <artifactId>cloud-api-commonsartifactId>
    28.             <version>1.0-SNAPSHOTversion>
    29.         dependency>
    30.         <dependency>
    31.             <groupId>org.springframework.bootgroupId>
    32.             <artifactId>spring-boot-starter-webartifactId>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.springframework.bootgroupId>
    36.             <artifactId>spring-boot-starter-actuatorartifactId>
    37.         dependency>
    38.         <dependency>
    39.             <groupId>org.projectlombokgroupId>
    40.             <artifactId>lombokartifactId>
    41.             <optional>trueoptional>
    42.         dependency>
    43.         
    44.         <dependency>
    45.             <groupId>org.springframework.bootgroupId>
    46.             <artifactId>spring-boot-devtoolsartifactId>
    47.             <scope>runtimescope>
    48.             <optional>trueoptional>
    49.         dependency>
    50.     dependencies>
    51.  
    52. project>

     4.cloud-eureka-server7001

    yml

    1. server:
    2.   port: 7001
    3.  
    4. eureka:
    5.   instance:
    6.     hostname: eureka7001.com
    7.   client:
    8.     register-with-eureka: false
    9.     fetch-registry: false
    10.     service-url:
    11.       defaultZone: http://eureka7002.com:7002/eureka/

     pom

    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.     <parent>
    6.         <artifactId>cloud2024artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloud-eureka-server7001artifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8maven.compiler.source>
    16.         <maven.compiler.target>8maven.compiler.target>
    17.     properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-netflix-eureka-serverartifactId>
    22.             <version>2.2.10.RELEASEversion>
    23.         dependency>
    24.         
    25.         <dependency>
    26.             <groupId>com.atguigu.springcloudgroupId>
    27.             <artifactId>cloud-api-commonsartifactId>
    28.             <version>1.0-SNAPSHOTversion>
    29.         dependency>
    30.         <dependency>
    31.             <groupId>org.springframework.bootgroupId>
    32.             <artifactId>spring-boot-starter-webartifactId>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.springframework.bootgroupId>
    36.             <artifactId>spring-boot-starter-actuatorartifactId>
    37.         dependency>
    38.         <dependency>
    39.             <groupId>org.projectlombokgroupId>
    40.             <artifactId>lombokartifactId>
    41.             <optional>trueoptional>
    42.         dependency>
    43.         
    44.         <dependency>
    45.             <groupId>org.springframework.bootgroupId>
    46.             <artifactId>spring-boot-devtoolsartifactId>
    47.             <scope>runtimescope>
    48.             <optional>trueoptional>
    49.         dependency>
    50.     dependencies>
    51.  
    52. project>

    5.cloud-eureka-server7002

    yml

    1. server:
    2.   port: 7002
    3.  
    4. eureka:
    5.   instance:
    6.     hostname: eureka7002.com
    7.   client:
    8.     register-with-eureka: false
    9.     fetch-registry: false
    10.     service-url:
    11.       defaultZone: http://eureka7001.com:7001/eureka/

    pom

    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.     <parent>
    6.         <artifactId>cloud2024artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloud-eureka-server7002artifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8maven.compiler.source>
    16.         <maven.compiler.target>8maven.compiler.target>
    17.     properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-netflix-eureka-serverartifactId>
    22.             <version>2.2.10.RELEASEversion>
    23.         dependency>
    24.         
    25.         <dependency>
    26.             <groupId>com.atguigu.springcloudgroupId>
    27.             <artifactId>cloud-api-commonsartifactId>
    28.             <version>1.0-SNAPSHOTversion>
    29.         dependency>
    30.         <dependency>
    31.             <groupId>org.springframework.bootgroupId>
    32.             <artifactId>spring-boot-starter-webartifactId>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.springframework.bootgroupId>
    36.             <artifactId>spring-boot-starter-actuatorartifactId>
    37.         dependency>
    38.         <dependency>
    39.             <groupId>org.projectlombokgroupId>
    40.             <artifactId>lombokartifactId>
    41.             <optional>trueoptional>
    42.         dependency>
    43.         
    44.         <dependency>
    45.             <groupId>org.springframework.bootgroupId>
    46.             <artifactId>spring-boot-devtoolsartifactId>
    47.             <scope>runtimescope>
    48.             <optional>trueoptional>
    49.         dependency>
    50.     dependencies>
    51.  
    52.  
    53. project>

     6.cloud-provider-payment8001

    PayMain8001

    1. package com.atguigu.springcloud;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    6. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    7.  
    8.  
    9. @SpringBootApplication
    10. @EnableEurekaClient
    11. @EnableDiscoveryClient
    12. public class PayMain8001 {
    13.     public static void main(String[] args) {
    14.         SpringApplication.run(PayMain8001.class, args);
    15.     }
    16. }

    controller

    PaymentController

    1. package com.atguigu.springcloud.controller;
    2.  
    3. import com.atguigu.springcloud.entities.CommonResult;
    4. import com.atguigu.springcloud.entities.Payment;
    5. import com.atguigu.springcloud.service.PaymentService;
    6. import lombok.extern.slf4j.Slf4j;
    7. import org.springframework.beans.factory.annotation.Value;
    8. import org.springframework.cloud.client.ServiceInstance;
    9. import org.springframework.cloud.client.discovery.DiscoveryClient;
    10. import org.springframework.web.bind.annotation.*;
    11.  
    12. import javax.annotation.Resource;
    13. import java.util.List;
    14.  
    15. @RestController
    16. @Slf4j
    17. public class PaymentController {
    18.     @Resource
    19.     private PaymentService paymentService;
    20.  
    21.     @Value("${server.port}")
    22.     private String serverPort;
    23.  
    24.     @Resource
    25.     private DiscoveryClient discoveryClient;
    26.  
    27.     @PostMapping(value = "/payment/create")
    28.     public CommonResult create(@RequestBody Payment payment) {
    29.         int result = paymentService.create(payment);
    30.         log.info("******插入结果：" + result);
    31.         if (result > 0) {
    32.             return new CommonResult(200, "插入数据库成功,serverPort:" + serverPort, result);
    33.         } else {
    34.             return new CommonResult(444, "插入数据库失败", null);
    35.         }
    36.     }
    37.  
    38.     @GetMapping(value = "/payment/get/{id}")
    39.     public CommonResult getPaymentById(@PathVariable("id") Long id) {
    40.         Payment payment = paymentService.getPaymentById(id);
    41.         log.info("******查询结果：" + payment);
    42.         if (payment != null) {
    43.             return new CommonResult(200, "查询成功,serverPort:" + serverPort, payment);
    44.         } else {
    45.             return new CommonResult(444, "没有对应纪录，查询失败，查询的id:" + id, null);
    46.         }
    47.     }
    48.  
    49.     @GetMapping(value = "/payment/discovery")
    50.     public Object discovery() {
    51.         List services = discoveryClient.getServices();
    52.         for (String element : services) {
    53.             log.info("******element:"+element);
    54.         }
    55.         List instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
    56.         for (ServiceInstance instance : instances) {
    57.             log.info(instance.getInstanceId()+"\t"+instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());
    58.         }
    59.         return this.discoveryClient;
    60.     }
    61. }

    dao

    PaymentDao

    1. package com.atguigu.springcloud.dao;
    2.  
    3. import com.atguigu.springcloud.entities.Payment;
    4. import org.apache.ibatis.annotations.Mapper;
    5. import org.apache.ibatis.annotations.Param;
    6.  
    7. @Mapper
    8. public interface PaymentDao {
    9.     public int create(Payment payment);
    10.  
    11.     public Payment getPaymentById(@Param("id") Long id);
    12. }

    service

    PaymentService

    1. package com.atguigu.springcloud.service;
    2.  
    3. import com.atguigu.springcloud.entities.Payment;
    4. import org.apache.ibatis.annotations.Param;
    5.  
    6. public interface PaymentService {
    7.     public int create(Payment payment);
    8.  
    9.     public Payment getPaymentById(@Param("id") Long id);
    10. }

    PaymentServiceImpl

    1. package com.atguigu.springcloud.service.impl;
    2.  
    3. import com.atguigu.springcloud.dao.PaymentDao;
    4. import com.atguigu.springcloud.entities.Payment;
    5. import com.atguigu.springcloud.service.PaymentService;
    6. import org.apache.ibatis.annotations.Param;
    7. import org.springframework.stereotype.Service;
    8.  
    9. import javax.annotation.Resource;
    10.  
    11. @Service
    12. public class PaymentServiceImpl implements PaymentService {
    13.     @Resource
    14.     private PaymentDao paymentDao;
    15.  
    16.     public int create(Payment payment) {
    17.         return paymentDao.create(payment);
    18.     }
    19.  
    20.     public Payment getPaymentById(Long id) {
    21.         return  paymentDao.getPaymentById(id);
    22.     }
    23. }

    yml

    1. server:
    2.   port: 8001
    3.  
    4. spring:
    5.   application:
    6.     name: cloud-payment-service
    7.   datasource:
    8.     type: com.alibaba.druid.pool.DruidDataSource
    9.     driver-class-name: com.mysql.cj.jdbc.Driver
    10.     url: jdbc:mysql://localhost:3306/db2019?serverTimezone=UTC&allowMultiQueries=true
    11.     username: root
    12.     password: 123456
    13.  
    14. mybatis:
    15.   mapper-locations: classpath:mapper/*.xml
    16.   type-aliases-package: com.atguigu.springcloud.entities
    17.  
    18. eureka:
    19.   client:
    20.     register-with-eureka: true
    21.     fetch-registry: true
    22.     service-url:
    23. #      defaultZone: http://localhost:7001/eureka
    24.        defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
    25.   instance:
    26.     instance-id: payment8001
    27.     prefer-ip-address: true

    xml

    PaymentDao.xml

    1. "1.0" encoding="UTF-8"?>
    2. mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    3. <mapper namespace="com.atguigu.springcloud.dao.PaymentDao">
    4.  
    5.     <insert id="create" useGeneratedKeys="true" parameterType="Payment" keyProperty="id">
    6.             insert into payment(serial) values(#{serial});
    7.     insert>
    8.  
    9.     <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entities.Payment">
    10.         <id column="id" property="id" jdbcType="BIGINT"/>
    11.         <id column="serial" property="serial" jdbcType="VARCHAR"/>
    12.     resultMap>
    13.     <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap">
    14.         select * from payment where id = #{id};
    15.     select>
    16. mapper>

     pom

    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.     <parent>
    6.         <artifactId>cloud2024artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloud-provider-payment8001artifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8maven.compiler.source>
    16.         <maven.compiler.target>8maven.compiler.target>
    17.     properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    22.             <version>2.2.10.RELEASEversion>
    23.         dependency>
    24.         
    25.         <dependency>
    26.             <groupId>com.atguigu.springcloudgroupId>
    27.             <artifactId>cloud-api-commonsartifactId>
    28.             <version>1.0-SNAPSHOTversion>
    29.         dependency>
    30.         <dependency>
    31.             <groupId>org.springframework.bootgroupId>
    32.             <artifactId>spring-boot-starter-webartifactId>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.springframework.bootgroupId>
    36.             <artifactId>spring-boot-starter-actuatorartifactId>
    37.         dependency>
    38.         <dependency>
    39.             <groupId>org.mybatis.spring.bootgroupId>
    40.             <artifactId>mybatis-spring-boot-starterartifactId>
    41.         dependency>
    42.         <dependency>
    43.             <groupId>com.alibabagroupId>
    44.             <artifactId>druid-spring-boot-starterartifactId>
    45.             
    46.         dependency>
    47.         
    48.         <dependency>
    49.             <groupId>mysqlgroupId>
    50.             <artifactId>mysql-connector-javaartifactId>
    51.         dependency>
    52.         
    53.         <dependency>
    54.             <groupId>org.springframework.bootgroupId>
    55.             <artifactId>spring-boot-starter-jdbcartifactId>
    56.         dependency>
    57.         
    58.         <dependency>
    59.             <groupId>org.springframework.bootgroupId>
    60.             <artifactId>spring-boot-devtoolsartifactId>
    61.             <scope>runtimescope>
    62.             <optional>trueoptional>
    63.         dependency>
    64.         <dependency>
    65.             <groupId>org.projectlombokgroupId>
    66.             <artifactId>lombokartifactId>
    67.             <optional>trueoptional>
    68.         dependency>
    69.         <dependency>
    70.             <groupId>org.springframework.bootgroupId>
    71.             <artifactId>spring-boot-starter-testartifactId>
    72.             <scope>testscope>
    73.         dependency>
    74.     dependencies>
    75.  
    76. project>

     7.cloud-provider-payment8002

    PayMain8002

    1. package com.atguigu.springcloud;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    6.  
    7.  
    8. @SpringBootApplication
    9. @EnableEurekaClient
    10. public class PayMain8002 {
    11.     public static void main(String[] args) {
    12.         SpringApplication.run(PayMain8002.class, args);
    13.     }
    14. }

    controller

    PaymentController

    1. package com.atguigu.springcloud.controller;
    2.  
    3. import com.atguigu.springcloud.entities.CommonResult;
    4. import com.atguigu.springcloud.entities.Payment;
    5. import com.atguigu.springcloud.service.PaymentService;
    6. import lombok.extern.slf4j.Slf4j;
    7. import org.springframework.beans.factory.annotation.Value;
    8. import org.springframework.web.bind.annotation.*;
    9.  
    10. import javax.annotation.Resource;
    11.  
    12. @RestController
    13. @Slf4j
    14. public class PaymentController {
    15.     @Resource
    16.     private PaymentService paymentService;
    17.  
    18.     @Value("${server.port}")
    19.     private String serverPort;
    20.  
    21.     @PostMapping(value = "/payment/create")
    22.     public CommonResult create(@RequestBody Payment payment) {
    23.         int result = paymentService.create(payment);
    24.         log.info("******插入结果：" + result);
    25.         if (result > 0) {
    26.             return new CommonResult(200, "插入数据库成功,serverPort:"+serverPort, result);
    27.         } else {
    28.             return new CommonResult(444, "插入数据库失败", null);
    29.         }
    30.     }
    31.  
    32.     @GetMapping(value = "/payment/get/{id}")
    33.     public CommonResult getPaymentById(@PathVariable("id") Long id) {
    34.         Payment payment = paymentService.getPaymentById(id);
    35.         log.info("******查询结果：" + payment);
    36.         if (payment != null) {
    37.             return new CommonResult(200, "查询成功,serverPort:"+serverPort, payment);
    38.         } else {
    39.             return new CommonResult(444, "没有对应纪录，查询失败，查询的id:"+id, null);
    40.         }
    41.     }
    42. }

    dao

    PaymentDao

    1. package com.atguigu.springcloud.dao;
    2.  
    3. import com.atguigu.springcloud.entities.Payment;
    4. import org.apache.ibatis.annotations.Mapper;
    5. import org.apache.ibatis.annotations.Param;
    6.  
    7. @Mapper
    8. public interface PaymentDao {
    9.     public int create(Payment payment);
    10.  
    11.     public Payment getPaymentById(@Param("id") Long id);
    12. }

    service

    PaymentService

    1. package com.atguigu.springcloud.service;
    2.  
    3. import com.atguigu.springcloud.entities.Payment;
    4. import org.apache.ibatis.annotations.Param;
    5.  
    6. public interface PaymentService {
    7.     public int create(Payment payment);
    8.  
    9.     public Payment getPaymentById(@Param("id") Long id);
    10. }

    PaymentServiceImpl

    1. package com.atguigu.springcloud.service.impl;
    2.  
    3. import com.atguigu.springcloud.dao.PaymentDao;
    4. import com.atguigu.springcloud.entities.Payment;
    5. import com.atguigu.springcloud.service.PaymentService;
    6. import org.apache.ibatis.annotations.Param;
    7. import org.springframework.stereotype.Service;
    8.  
    9. import javax.annotation.Resource;
    10.  
    11. @Service
    12. public class PaymentServiceImpl implements PaymentService {
    13.     @Resource
    14.     private PaymentDao paymentDao;
    15.  
    16.     public int create(Payment payment) {
    17.         return paymentDao.create(payment);
    18.     }
    19.  
    20.     public Payment getPaymentById(Long id) {
    21.         return  paymentDao.getPaymentById(id);
    22.     }
    23. }

    yml

    1. server:
    2.   port: 8002
    3.  
    4. spring:
    5.   application:
    6.     name: cloud-payment-service
    7.   datasource:
    8.     type: com.alibaba.druid.pool.DruidDataSource
    9.     driver-class-name: com.mysql.cj.jdbc.Driver
    10.     url: jdbc:mysql://localhost:3306/db2019?serverTimezone=UTC&allowMultiQueries=true
    11.     username: root
    12.     password: 123456
    13.  
    14. mybatis:
    15.   mapper-locations: classpath:mapper/*.xml
    16.   type-aliases-package: com.atguigu.springcloud.entities
    17.  
    18. eureka:
    19.   client:
    20.     register-with-eureka: true
    21.     fetch-registry: true
    22.     service-url:
    23. #      defaultZone: http://localhost:7001/eureka
    24.        defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
    25.   instance:
    26.     instance-id: payment8002
    27.     prefer-ip-address: true

    xml

    PaymentDao.xml

    1. "1.0" encoding="UTF-8"?>
    2. mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    3. <mapper namespace="com.atguigu.springcloud.dao.PaymentDao">
    4.  
    5.     <insert id="create" useGeneratedKeys="true" parameterType="Payment" keyProperty="id">
    6.             insert into payment(serial) values(#{serial});
    7.     insert>
    8.  
    9.     <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entities.Payment">
    10.         <id column="id" property="id" jdbcType="BIGINT"/>
    11.         <id column="serial" property="serial" jdbcType="VARCHAR"/>
    12.     resultMap>
    13.     <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap">
    14.         select * from payment where id = #{id};
    15.     select>
    16. mapper>

     pom

    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.     <parent>
    6.         <artifactId>cloud2024artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloud-provider-payment8002artifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8maven.compiler.source>
    16.         <maven.compiler.target>8maven.compiler.target>
    17.     properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    22.             <version>2.2.10.RELEASEversion>
    23.         dependency>
    24.         
    25.         <dependency>
    26.             <groupId>com.atguigu.springcloudgroupId>
    27.             <artifactId>cloud-api-commonsartifactId>
    28.             <version>1.0-SNAPSHOTversion>
    29.         dependency>
    30.         <dependency>
    31.             <groupId>org.springframework.bootgroupId>
    32.             <artifactId>spring-boot-starter-webartifactId>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.springframework.bootgroupId>
    36.             <artifactId>spring-boot-starter-actuatorartifactId>
    37.         dependency>
    38.         <dependency>
    39.             <groupId>org.mybatis.spring.bootgroupId>
    40.             <artifactId>mybatis-spring-boot-starterartifactId>
    41.         dependency>
    42.         <dependency>
    43.             <groupId>com.alibabagroupId>
    44.             <artifactId>druid-spring-boot-starterartifactId>
    45.             
    46.         dependency>
    47.         
    48.         <dependency>
    49.             <groupId>mysqlgroupId>
    50.             <artifactId>mysql-connector-javaartifactId>
    51.         dependency>
    52.         
    53.         <dependency>
    54.             <groupId>org.springframework.bootgroupId>
    55.             <artifactId>spring-boot-starter-jdbcartifactId>
    56.         dependency>
    57.         
    58.         <dependency>
    59.             <groupId>org.springframework.bootgroupId>
    60.             <artifactId>spring-boot-devtoolsartifactId>
    61.             <scope>runtimescope>
    62.             <optional>trueoptional>
    63.         dependency>
    64.         <dependency>
    65.             <groupId>org.projectlombokgroupId>
    66.             <artifactId>lombokartifactId>
    67.             <optional>trueoptional>
    68.         dependency>
    69.         <dependency>
    70.             <groupId>org.springframework.bootgroupId>
    71.             <artifactId>spring-boot-starter-testartifactId>
    72.             <scope>testscope>
    73.         dependency>
    74.     dependencies>
    75. project>

  • 相关阅读:
    Python爬虫进阶：使用Scrapy库进行数据提取和处理
    vue 注册自定义指令，对输入框输入内容过滤（区分中英文）
    动手实现深度学习（5）：计算图的实现
    ABAP 报表中如何以二进制方式上传本地文件
    go 视频解码 -- 笔记
    最常用的 Linux 命令汇总
    论文精读Transformer: Attention is all you need
    共享WIFI项目新时代：代理商如何玩转下半场？
    Java中的常量管理：接口还是枚举，您如何选择？
    Vue3 使用动态组件 component
  • 原文地址：https://blog.csdn.net/weixin_52098748/article/details/136342734