在 HSF 框架中开发 RESTful 应用,并实现服务注册与发现。由于 SAE 已经支持原生 Spring Cloud 框架的应用,新用户不推荐使用该开发方式。

背景信息

原生 Spring Cloud 框架下的服务开发请参考将 Spring Cloud 应用托管到 SAE

服务注册与发现

通过一个简单的示例详细介绍如何在本地开发 RESTful 应用并实现注册与发现。

Demo 源码下载: sc-vip-serversc-vip-client

  1. 创建服务提供者。
    此服务提供者提供了一个简单的 echo 服务,并将自身注册到服务发现中心。
    1. 创建命名为 sc-vip-server的 RESTful 应用工程,。
    2. pom.xml 中添加需要的依赖。
          <parent>
              <groupId>org.springframework.boot</groupId>
              <artifactId>spring-boot-starter-parent</artifactId>
              <version>1.5.8.RELEASE</version>
              <relativePath/>
          </parent>
      
          <dependencies>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-vipclient</artifactId>
                  <version>1.3</version>
              </dependency>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-pandora</artifactId>
                  <version>1.3</version>
              </dependency>
          </dependencies>
      
          <dependencyManagement>
              <dependencies>
                  <dependency>
                      <groupId>org.springframework.cloud</groupId>
                      <artifactId>spring-cloud-dependencies</artifactId>
                      <version>Dalston.SR4</version>
                      <type>pom</type>
                      <scope>import</scope>
                  </dependency>
              </dependencies>
          </dependencyManagement>

      如果您的工程不想将 parent 设置为 spring-boot-starter-parent,也可以通过添加 dependencyManagement 并设置 scope=import 来达到依赖管理的效果。

      <dependencyManagement>
                  <dependencies>
                      <dependency>
                          <groupId>org.springframework.boot</groupId>
                          <artifactId>spring-boot-dependencies</artifactId>
                          <version>1.5.8.RELEASE</version>
                          <type>pom</type>
                          <scope>import</scope>
                      </dependency>
                  </dependencies>
      </dependencyManagement>
    3. 创建服务提供者应用,其中 @EnableDiscoveryClient 注解表明此应用需开启服务注册与发现功能。
      @SpringBootApplication
          @EnableDiscoveryClient
          public class ServerApplication {
      
              public static void main(String[] args) {
                  PandoraBootstrap.run(args);
                  SpringApplication.run(ServerApplication.class, args);
                  PandoraBootstrap.markStartupAndWait();
              }
          }
    4. 创建 EchoController,提供简单的 echo 服务。
      @RestController
          public class EchoController {
              @RequestMapping(value = "/echo/{string}", method = RequestMethod.GET)
              public String echo(@PathVariable String string) {
                  return string;
              }
          }
    5. resources下的 application.properties 文件中配置应用名与监听端口号。
      spring.application.name=service-provider
      server.port=18081
  2. 创建服务消费者。
    本示例中将创建一个服务消费者,通过 RestTemplate、AsyncRestTemplate、FeignClient 这三个客户端去调用服务提供者。
    1. 创建名为 sc-vip-client 的 RESTful 应用工程。
    2. pom.xml 中引入需要的依赖。
      <parent>
              <groupId>org.springframework.boot</groupId>
              <artifactId>spring-boot-starter-parent</artifactId>
              <version>1.5.8.RELEASE</version>
              <relativePath/>
          </parent>
      
          <dependencies>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-vipclient</artifactId>
                  <version>1.3</version>
              </dependency>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-pandora</artifactId>
                  <version>1.3</version>
              </dependency>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-feign</artifactId>
              </dependency>
          </dependencies>
      
          <dependencyManagement>
              <dependencies>
                  <dependency>
                      <groupId>org.springframework.cloud</groupId>
                      <artifactId>spring-cloud-dependencies</artifactId>
                      <version>Dalston.SR4</version>
                      <type>pom</type>
                      <scope>import</scope>
                  </dependency>
              </dependencies>
          </dependencyManagement>

      本示例需要通过 FeignClient 进行演示,与 sc-vip-server(服务提供者)相比,pom.xml 文件中的依赖增加了 spring-cloud-starter-feign

    3. 与 sc-vip-server 相比,除了开启服务与注册外,还需要添加下面两项配置才能使用 RestTemplate、AsyncRestTemplate、FeignClient 这三个客户端。
      • 添加 @LoadBalanced 注解将 RestTemplate 和 AsyncRestTemplate 与服务发现结合。
      • 使用 @EnableFeignClients 注解激活 FeignClients。
        @SpringBootApplication
            @EnableDiscoveryClient
            @EnableFeignClients
            public class ConsumerApplication {
        
                @LoadBalanced
                @Bean
                public RestTemplate restTemplate() {
                    return new RestTemplate();
                }
        
                @LoadBalanced
                @Bean
                public AsyncRestTemplate asyncRestTemplate(){
                    return new AsyncRestTemplate();
                }
        
                public static void main(String[] args) {
                    PandoraBootstrap.run(args);
                    SpringApplication.run(ConsumerApplication.class, args);
                    PandoraBootstrap.markStartupAndWait();
                }
        
            }
    4. 在使用 EchoService 的 FeignClient 之前,还需要配置服务名以及方法对应的 HTTP 请求。在 sc-vip-server 工程中配置服务名 service-provider。
      @FeignClient(name = "service-provider")
          public interface EchoService {
              @RequestMapping(value = "/echo/{str}", method = RequestMethod.GET)
              String echo(@PathVariable("str") String str);
          }
    5. 创建一个 Controller 用于调用测试。
      @RestController
      public class Controller {
         @Autowired
         private RestTemplate restTemplate;
         @Autowired
         private AsyncRestTemplate asyncRestTemplate;
         @Autowired
         private  EchoService echoService;
         @RequestMapping(value = "/echo-rest/{str}", method = RequestMethod.GET)
         public String rest(@PathVariable String str) {
             return restTemplate.getForObject("http://service-provider/echo/" + str, String.class);
         }
         @RequestMapping(value = "/echo-async-rest/{str}", method = RequestMethod.GET)
         public String asyncRest(@PathVariable String str) throws Exception{
             ListenableFuture<ResponseEntity<String>> future = asyncRestTemplate.
                     getForEntity("http://service-provider/echo/"+str, String.class);
             return future.get().getBody();
         }
         @RequestMapping(value = "/echo-feign/{str}", method = RequestMethod.GET)
         public String feign(@PathVariable String str) {
             return echoService.echo(str);
         }
      }
      代码说明如下:
      • /echo-rest/ 验证通过 RestTemplate 去调用服务提供者。
      • /echo-async-rest/ 验证通过 AsyncRestTemplate 去调用服务提供者。
      • /echo-feign/ 验证通过 FeignClient 去调用服务提供者。
    6. 配置应用名以及监听端口号。
      spring.application.name=service-consumer
      server.port=18082
  3. 本地开发调试。
    1. 启动轻量级配置中心。
      本地开发调试时,需要使用轻量级配置中心,轻量级配置中心包含了 SAE 服务注册发现服务端的轻量版,详情请参见启动轻量级配置及注册中心
    2. 启动应用。
      • IDE 中启动

        在 IDE 中启动,通过 VM options 配置启动参数 -Dvipserver.server.port=8080(注意:该参数仅在本地开发且使用轻量级配置中心时需要添加,当应用部署到 SAE 时,须移除此参数,否则会使应用无法正常发布或订阅),通过 main 方法直接启动。

        轻量级配置中心与应用部署在不同的机器上,需要绑定 hosts,详情请参见启动轻量级配置及注册中心

      • FatJar 启动
        1. 添加 FatJar 打包插件。

          使用 Maven 将 pandora-boot 工程打包成 FatJar, 需要在 pom.xml 中添加如下插件。为避免与其他打包插件发生冲突,请勿在 build 的 plugin 中添加其他 FatJar 插件。

          <build>
              <plugin>
                  <groupId>com.taobao.pandora</groupId>
                      <artifactId>pandora-boot-maven-plugin</artifactId>
                      <version>2.1.9.1</version>
                      <executions>
                         <execution>
                            <phase>package</phase>
                            <goals>
                                <goal>repackage</goal>
                            </goals>
                         </execution>
                       </executions>
              </plugin>
          </build>
        2. 添加完插件后,在工程的主目录下,使用 maven 命令 mvn clean package 进行打包,即可在 target 目录下找到打包好的 FatJar 文件。
        3. 通过 Java 命令启动应用。
          java -Dvipserver.server.port=8080 -Dpandora.location=/Users/{$username}/.m2/repository/com/taobao/pandora/taobao-hsf.sar/dev-SNAPSHOT/taobao-hsf.sar-dev-SNAPSHOT.jar  -jar sc-vip-server-0.0.1-SNAPSHOT.jar
          说明 -Dpandora.location 指定的路径必须是全路径,且必须放在 sc-vip-server-0.0.1-SNAPSHOT.jar 之前。
      启动服务,分别进行调用,可以看到调用都成功了。EDAS应用开发HSF开发RESTful
  4. 常见问题处理。
    • AsyncRestTemplate 无法接入服务发现。

      AsyncRestTemplate 接入服务发现的时间比较晚,需要在 Dalston 之后的版本才能使用,具体详情参见此 pull request

    • FatJar 打包插件冲突。

      为避免与其他打包插件发生冲突,请勿在 build 的 plugin 中添加其他 FatJar 插件。

    • 打包时可不可以不排除 taobao-hsf.sar?

      可以,但是不建议这么做。

      通过修改 pandora-boot-maven-plugin 插件,把 excludeSar 设置为 false,打包时就会自动包含 taobao-hsf.sar。
      <plugin>
          <groupId>com.taobao.pandora</groupId>
          <artifactId>pandora-boot-maven-plugin</artifactId>
          <version>2.1.9.1</version>
          <configuration>
          <excludeSar>false</excludeSar>
          </configuration>
             <executions>
                 <execution>
                    <phase>package</phase>
                    <goals>
                        <goal>repackage</goal>
                    </goals>
                  </execution>
          </executions>
      </plugin>
      这样打包后可以在不配置 Pandora 地址的情况下启动。
      java -jar  -Dvipserver.server.port=8080 sc-vip-server-0.0.1-SNAPSHOT.jar

      请在将应用部署到 SAE 前恢复到默认排除 SAR 包的配置。