开启你的第一行Spring Cloud代码

逃离我推掉我的手 2023-07-23 03:46 4阅读 0赞

本篇威哥打算分享如何搭建Spring Cloud框架。

好了，跟随威哥一起开启你的第一行Spring Cloud代码吧。

1、首先打开你的IDEA。创建一个Maven项目：william-spring-project。

按照威哥下面截图来操作。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 1

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 2

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 3

注意，上面Maven的配置请换成自己的Maven配置，下面是威哥的Maven配置。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 4

OK，Maven项目搭建成功，如图：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 5

2、创建服务注册中心

项目名称：register-server。威哥直接上图操作说明。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 6

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 7

如果上面点击下一步没有反应，这个可以使用国内阿里代理来操作，国内代理地址：https://start.aliyun.com。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 8

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 9

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 10

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 11

项目创建成功，这个之后需要来检查pom配置。pom.xml配置如下：

  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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.william</groupId>
  6.     <artifactId>spring</artifactId>
  7.     <version>0.0.1-SNAPSHOT</version>
  8.     <name>register-server</name>
  9.     <description>Demo project for Spring Boot</description>
  11.     <properties>
  12.         <java.version>1.8</java.version>
  13.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  14.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  15.         <spring-boot.version>2.2.6.RELEASE</spring-boot.version>
  16.         <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
  17.     </properties>
  19.     <dependencies>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  23.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-test</artifactId>
  28.             <scope>test</scope>
  29.             <exclusions>
  30.                 <exclusion>
  31.                     <groupId>org.junit.vintage</groupId>
  32.                     <artifactId>junit-vintage-engine</artifactId>
  33.                 </exclusion>
  34.             </exclusions>
  35.         </dependency>
  36.     </dependencies>
  38.     <dependencyManagement>
  39.         <dependencies>
  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>
  47.             <dependency>
  48.                 <groupId>org.springframework.boot</groupId>
  49.                 <artifactId>spring-boot-dependencies</artifactId>
  50.                 <version>${spring-boot.version}</version>
  51.                 <type>pom</type>
  52.                 <scope>import</scope>
  53.             </dependency>
  55.             <dependency>
  56.                 <groupId>org.springframework.cloud</groupId>
  57.                 <artifactId>spring-cloud-starter-eureka</artifactId>
  58.                 <version>1.4.7.RELEASE</version>
  59.             </dependency>
  60.             <dependency>
  61.                 <groupId>org.springframework.cloud</groupId>
  62.                 <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  63.             </dependency>
  65.             <dependency>
  66.                 <groupId>org.springframework.boot</groupId>
  67.                 <artifactId>spring-boot-starter-web</artifactId>
  68.             </dependency>
  69.             <dependency>
  70.                 <groupId>org.springframework.boot</groupId>
  71.                 <artifactId>spring-boot-starter-test</artifactId>
  72.                 <scope>test</scope>
  73.                 <exclusions>
  74.                     <exclusion>
  75.                         <groupId>org.junit.vintage</groupId>
  76.                         <artifactId>junit-vintage-engine</artifactId>
  77.                     </exclusion>
  78.                 </exclusions>
  79.             </dependency>
  80.         </dependencies>
  81.     </dependencyManagement>
  83.     <build>
  84.         <plugins>
  85.             <plugin>
  86.                 <groupId>org.apache.maven.plugins</groupId>
  87.                 <artifactId>maven-compiler-plugin</artifactId>
  88.                 <configuration>
  89.                     <source>1.8</source>
  90.                     <target>1.8</target>
  91.                     <encoding>UTF-8</encoding>
  92.                 </configuration>
  93.             </plugin>
  94.             <plugin>
  95.                 <groupId>org.springframework.boot</groupId>
  96.                 <artifactId>spring-boot-maven-plugin</artifactId>
  97.                 <version>2.2.6.RELEASE</version>
  98.             </plugin>
  99.         </plugins>
  100.     </build>
  102. </project>

配置application或者yml。这里威哥说明下，yml配置文件以树形结构组成，其优先级高于application，会在application之前先假装yml，如果同时存application和yml，那么application将会因为后加载而覆盖yml配置。下面威哥把2种配置都提供出来。

application.properties配置如下：

  1. server.port=9010
  2. eureka.instance.hostname=127.0.0.1
  4. #禁止自己当做服务注册
  5. eureka.client.register-with-eureka=false
  7. #屏蔽注册信息
  8. eureka.client.fetch-registry=false
  9. eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/

application.yml配置如下：

  1. server:
  2.   port: 9010
  3. eureka:
  4.   instance:
  5.     hostname: localhost
  6.   client:
  7.     register-with-eureka: false
  8.     fetch-registry: false
  9.     service-url:
  10.       defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

RegisterServerApplication启动项代码：

  1. @SpringBootApplication
  2. @EnableEurekaServer
  3. public class RegisterServerApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(RegisterServerApplication.class, args);
  7.     }
  9. }

上面@EnableEurekaServer的意思是：申明此处为服务注册中心。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 12

调试运行起来，之后在浏览器输入：http://localhost:9010/

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 13

出现上面效果图，证明Eureka注册中心发布成功。

3、创建服务生产者

项目名称：service-producer，创建步骤同时，只是勾选Eureka选项时区别下，如下：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 14

检查pom.xml：

  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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.2.6.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.william</groupId>
  12.     <artifactId>spring</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>service-producer</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.cloud</groupId>
  25.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-test</artifactId>
  35.             <scope>test</scope>
  36.             <exclusions>
  37.                 <exclusion>
  38.                     <groupId>org.junit.vintage</groupId>
  39.                     <artifactId>junit-vintage-engine</artifactId>
  40.                 </exclusion>
  41.             </exclusions>
  42.         </dependency>
  43.     </dependencies>
  45.     <dependencyManagement>
  46.         <dependencies>
  47.             <dependency>
  48.                 <groupId>org.springframework.cloud</groupId>
  49.                 <artifactId>spring-cloud-dependencies</artifactId>
  50.                 <version>${spring-cloud.version}</version>
  51.                 <type>pom</type>
  52.                 <scope>import</scope>
  53.             </dependency>
  54.         </dependencies>
  55.     </dependencyManagement>
  57.     <build>
  58.         <plugins>
  59.             <plugin>
  60.                 <groupId>org.springframework.boot</groupId>
  61.                 <artifactId>spring-boot-maven-plugin</artifactId>
  62.             </plugin>
  63.         </plugins>
  64.     </build>
  66. </project>

配置application.properties：

  1. eureka.client.service-url.defaultZone=http://localhost:9010/eureka/
  2. server.port=9011
  3. spring.application.name=service-producer
  4. test=Hellow,I am WeiGe,Welocme to Java World
  5. server.tomcat.uri-encoding=utf-8
  6. spring.http.encoding.charset=utf-8
  7. spring.http.encoding.enabled=true
  8. spring.http.encoding.force=true
  9. spring.cloud.loadbalancer.ribbon.enabled=false

启动项ServiceConsumerApplication：

  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. @RestController
  4. public class ServiceProducerApplication {
  6.     public static void main(String[] args) {
  7.         SpringApplication.run(ServiceProducerApplication.class, args);
  8.     }
  10. }

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 15

新建TestController：

  1. package com.william.producer;
  3. import org.springframework.beans.factory.annotation.Value;
  4. import org.springframework.web.bind.annotation.RequestMapping;
  5. import org.springframework.web.bind.annotation.RequestParam;
  6. import org.springframework.web.bind.annotation.RestController;
  8. @RestController
  9. @RequestMapping("service-producer-test")
  10. public class TestController {
  12.     @Value("${test}")
  13.     String test;
  15.     @Value("${spring.application.name}")
  16.     String appionName;
  18.     @Value("${server.port}")
  19.     String port;
  21.     @RequestMapping(value = "/mytest")
  22.     public String mytest(@RequestParam String name) {
  23.         return String.format("Hello %s，%s,该信息从服务：%s,端口：%s吐出。", name, test, appionName, port);
  24.     }
  25. }

ok，启动service-server和service-producer，可以看到生产者已经注册到了Eureka服务注册中心。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 16

现在跟随威哥来测试一把服务是不是通的，打开浏览器或者postMan输入：

http://localhost:9011/service-producer-test/mytest?name=威哥

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 17

OK，上面测试证明服务OK。接下来威哥要新建Facade层，用来做Request和Response层使用，因为上面做的服务都是最简单的url传参，但是实际使用中我们都是使用json对象来传参的。

4、创建Facade项目：service-facade

具体步骤都可以同时，也可以创建j2ee的项目，都行，威哥是这样创建的：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 18

注意：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 19

之后新建request和response：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 20

威哥贴一下pom.xml内容，可能有些同学需要，注意，需要安装下lombok插件。

  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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.2.6.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.william</groupId>
  12.     <artifactId>facade</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>service-facade</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.cloud</groupId>
  29.             <artifactId>spring-cloud-function-context</artifactId>
  30.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-test</artifactId>
  35.             <scope>test</scope>
  36.             <exclusions>
  37.                 <exclusion>
  38.                     <groupId>org.junit.vintage</groupId>
  39.                     <artifactId>junit-vintage-engine</artifactId>
  40.                 </exclusion>
  41.             </exclusions>
  42.         </dependency>
  43.         <dependency>
  44.             <groupId>org.projectlombok</groupId>
  45.             <artifactId>lombok</artifactId>
  46.             <version>1.18.12</version>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>javax.validation</groupId>
  50.             <artifactId>validation-api</artifactId>
  51.             <version>2.0.1.Final</version>
  52.         </dependency>
  53.     </dependencies>
  55.     <dependencyManagement>
  56.         <dependencies>
  57.             <dependency>
  58.                 <groupId>org.springframework.cloud</groupId>
  59.                 <artifactId>spring-cloud-dependencies</artifactId>
  60.                 <version>${spring-cloud.version}</version>
  61.                 <type>pom</type>
  62.                 <scope>import</scope>
  63.             </dependency>
  64.         </dependencies>
  65.     </dependencyManagement>
  67.     <build>
  68.         <plugins>
  69.             <plugin>
  70.                 <groupId>org.springframework.boot</groupId>
  71.                 <artifactId>spring-boot-maven-plugin</artifactId>
  72.             </plugin>
  73.         </plugins>
  74.     </build>
  76. </project>

GetCustomerRequest代码：

  1. package com.william.facade.request;
  3. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  4. import lombok.Data;
  6. import javax.validation.constraints.NotNull;
  8. @Data
  9. @JsonAutoDetect(fieldVisibility = JsonAutoDetect.Visibility.ANY, getterVisibility = JsonAutoDetect.Visibility.NONE)
  10. public class GetCustomerRequest {
  11.     @NotNull(message = "pkid不能为空。")
  12.     private Integer pkid;
  13. }

GetCustomerResponse代码：

  1. package com.william.facade.reponse;
  3. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  4. import lombok.Data;
  6. @Data
  7. @JsonAutoDetect(fieldVisibility = JsonAutoDetect.Visibility.ANY, getterVisibility = JsonAutoDetect.Visibility.NONE)
  8. public class GetCustomerResponse {
  9.     private Integer pkid;
  11.     private String customerName;
  13.     private String company;
  15.     private String sex;
  16. }

ok，facade项目完毕，后续威哥会使用到。

5、创建消费者：service-consumer

创建步骤通服务生产者

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 21

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 22

得到如下项目结构：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 23

pom.xml如下：

  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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.2.6.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.william</groupId>
  12.     <artifactId>consumer</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>service-consumer</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.cloud</groupId>
  25.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  26.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-test</artifactId>
  31.             <scope>test</scope>
  32.             <exclusions>
  33.                 <exclusion>
  34.                     <groupId>org.junit.vintage</groupId>
  35.                     <artifactId>junit-vintage-engine</artifactId>
  36.                 </exclusion>
  37.             </exclusions>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.springframework.boot</groupId>
  41.             <artifactId>spring-boot-starter-web</artifactId>
  42.         </dependency>
  43.     </dependencies>
  45.     <dependencyManagement>
  46.         <dependencies>
  47.             <dependency>
  48.                 <groupId>org.springframework.cloud</groupId>
  49.                 <artifactId>spring-cloud-dependencies</artifactId>
  50.                 <version>${spring-cloud.version}</version>
  51.                 <type>pom</type>
  52.                 <scope>import</scope>
  53.             </dependency>
  54.         </dependencies>
  55.     </dependencyManagement>
  57.     <build>
  58.         <plugins>
  59.             <plugin>
  60.                 <groupId>org.springframework.boot</groupId>
  61.                 <artifactId>spring-boot-maven-plugin</artifactId>
  62.             </plugin>
  63.         </plugins>
  64.     </build>
  66. </project>

application.properties配置如下：

  1. eureka.client.service-url.defaultZone=http://localhost:9010/eureka/
  2. server.port=9012
  3. spring.application.name=service-consumer
  5. server.tomcat.uri-encoding=utf-8
  6. spring.http.encoding.charset=utf-8
  7. spring.http.encoding.enabled=true
  8. spring.http.encoding.force=true
  9. spring.cloud.loadbalancer.ribbon.enabled=false

启动项ServiceConsumerApplication 内容：

  1. package com.william.consumer;
  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.client.loadbalancer.LoadBalanced;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import org.springframework.web.client.RestTemplate;
  11. @SpringBootApplication
  12. @EnableDiscoveryClient
  13. @RestController
  14. public class ServiceConsumerApplication {
  16.     public static void main(String[] args) {
  17.         SpringApplication.run(ServiceConsumerApplication.class, args);
  18.     }
  20.     @Bean
  21.     @LoadBalanced
  22.     RestTemplate restTemplate(){
  23.         return new RestTemplate();
  24.     }
  25. }

注意：上面重写了restTemplate，这个是为了演示基础的Ribbon消费RPC服务，但是威哥已经不使用它了，主要是为了完整的给同学们演示下。

调试起来service-consumer，再刷新下服务注册中心：会发现消费者也注入到了服务注册中心，这样是为了后面连接保持心跳，才能取到RPC调用所需的服务路由，Eureka是客户端负载均衡，会在消费者这一侧事先存储一份生产者的服务路由，这是需要保持心跳机制的，也是为后续威哥介绍Feign做的铺垫。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 24

6、service-consumer开始消费服务

新建一个TestController：

  1. package com.william.consumer;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.web.bind.annotation.RequestMapping;
  5. import org.springframework.web.bind.annotation.RequestParam;
  6. import org.springframework.web.bind.annotation.RestController;
  7. import org.springframework.web.client.RestTemplate;
  9. @RestController
  10. @RequestMapping("service-consumer")
  11. public class TestController {
  12.     @Autowired
  13.     RestTemplate restTemplate;
  15.     @RequestMapping("/sayHello")
  16.     public String sayHello(@RequestParam String info){
  17.         return restTemplate.getForObject(String.format("http://service-producer/service-producer-test/mytest?name=%s", info), String.class);
  18.     }
  20. }

运行起来，在浏览器输入：http://localhost:9012/service-consumer/sayHello?info=吴三桂

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 25

ok，到此我们已经使用Ribbon成功消费了服务。基本上同学们已经算是搭建成功了SpringCloud框架。如果不想继续跟着威哥深造，可以就此打住退出了，记得帮威哥点赞哈。

7、开启Feign的愉快模式

新建service-remote项目，同facade，步骤威哥就不再截图了，需要删除启动项和resources资源包（用不上）。

此时威哥就用上了service-facade。

但是除了删除启动类，还需要额外加入web引用，可以在pom中灌进去，也可以按照威哥下面操作把web项添加进去：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 26

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 27

最终得到的项目结构：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 28

pom.xml：

  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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.2.6.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.william</groupId>
  12.     <artifactId>remote</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>service-remote</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.cloud</groupId>
  29.             <artifactId>spring-cloud-function-context</artifactId>
  30.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-web</artifactId>
  35.         </dependency>
  37.         <dependency>
  38.             <groupId>org.springframework.cloud</groupId>
  39.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  40.         </dependency>
  43.         <dependency>
  44.             <groupId>org.springframework.cloud</groupId>
  45.             <artifactId>spring-cloud-starter-feign</artifactId>
  46.             <version>1.4.7.RELEASE</version>
  47.         </dependency>
  49.         <dependency>
  50.             <groupId>org.springframework.boot</groupId>
  51.             <artifactId>spring-boot-starter-test</artifactId>
  52.             <scope>test</scope>
  53.             <exclusions>
  54.                 <exclusion>
  55.                     <groupId>org.junit.vintage</groupId>
  56.                     <artifactId>junit-vintage-engine</artifactId>
  57.                 </exclusion>
  58.             </exclusions>
  59.         </dependency>
  60.         <dependency>
  61.             <groupId>com.william</groupId>
  62.             <artifactId>facade</artifactId>
  63.             <version>0.0.1-SNAPSHOT</version>
  64.             <scope>compile</scope>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>com.william</groupId>
  68.             <artifactId>facade</artifactId>
  69.             <version>0.0.1-SNAPSHOT</version>
  70.             <scope>compile</scope>
  71.         </dependency>
  72.     </dependencies>
  74.     <dependencyManagement>
  75.         <dependencies>
  76.             <dependency>
  77.                 <groupId>org.springframework.cloud</groupId>
  78.                 <artifactId>spring-cloud-dependencies</artifactId>
  79.                 <version>${spring-cloud.version}</version>
  80.                 <type>pom</type>
  81.                 <scope>import</scope>
  82.             </dependency>
  83.         </dependencies>
  84.     </dependencyManagement>
  86.     <build>
  87.         <plugins>
  88.             <plugin>
  89.                 <groupId>org.springframework.boot</groupId>
  90.                 <artifactId>spring-boot-maven-plugin</artifactId>
  91.             </plugin>
  92.         </plugins>
  93.     </build>
  95. </project>

新建CustomerRemote接口：

  1. package com.william.remote;
  3. import com.william.facade.reponse.GetCustomerResponse;
  4. import com.william.facade.request.GetCustomerRequest;
  5. import org.springframework.cloud.openfeign.FeignClient;
  6. import org.springframework.web.bind.annotation.PostMapping;
  7. import org.springframework.web.bind.annotation.RequestBody;
  9. import javax.validation.Valid;
  10. import java.util.List;
  12. @FeignClient(name = "service-producer")
  13. public interface CustomerRemote {
  15.     @PostMapping(value = "/service-producer/getCustomer")
  16.     List<GetCustomerResponse> getCustomer(@RequestBody(required = true) @Valid GetCustomerRequest request);
  17. }

8、消费者通过Feign以RPC形式调用生产者的服务

现在再回头到消费者service-consumer，其启动项需求添加注解：@EnableFeignClients(basePackages = { “com.william.remote” })

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 29

新建CustomerController：

  1. package com.william.consumer;
  3. import com.william.facade.reponse.GetCustomerResponse;
  4. import com.william.facade.request.GetCustomerRequest;
  5. import com.william.remote.CustomerRemote;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.PostMapping;
  8. import org.springframework.web.bind.annotation.RequestBody;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RestController;
  12. import javax.validation.Valid;
  13. import java.util.List;
  15. @RestController
  16. @RequestMapping("service-consumer")
  17. public class CustomerController {
  19.     @Autowired
  20.     private CustomerRemote customerRemote;
  22.     /**
  23.      * 获取客户信息
  24.      * @param request
  25.      * @return
  26.      * @author xuwei
  27.      * @since 2020-04-11
  28.      */
  29.     @PostMapping(value = "/getCustomer")
  30.     public List<GetCustomerResponse> getCustomer(@RequestBody(required = true) @Valid GetCustomerRequest request) {
  31.         List<GetCustomerResponse> response = customerRemote.getCustomer(request);
  32.         return response;
  33.     }
  34. }

ok，现在重新启动service-consumer，打开postman，本篇篇幅太长了，威哥就不介绍怎么引入swagger了。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1d2VpX25ldA_size_16_color_FFFFFF_t_70 30

到此本篇威哥分享完毕。大家记得帮威哥点赞啊。希望能够真正开启你的第一行Spring Cloud代码。

如果需要源码，请下载威哥上传的源码：https://download.csdn.net/download/xuwei_net/12324163。Maven依赖威哥没有上传哈，请自行更新依赖。

发表评论

表情：
评论列表 （有 0 条评论，4人围观）

还没有评论，来说两句吧...

相关阅读