EDAS入门-springcloud+HSF开发实战

淩亂°似流年 2022-05-13 13:16 412阅读 0赞 
  1.     该系列博文旨在整理阿里云帮助文档中有关EDAS开发相关知识，自己在写学习了解时，个人在理解阿里帮助文档之后，整理代码使其更适合企业级应用，顺便做个备忘录。

前言

  1.   目前 EDAS 已经完全支持 Spring Cloud 应用了，您可以将 Spring Cloud 应用直接部署到 EDAS 中。
  • Spring Boot 提出的概念是 Build Anything，解决繁琐的 xml 配置的问题。
  • Spring Cloud 提出的概念是 Coordinate Anything，通过提供大量的、方便组件接入的 spring-cloud-starter 的支持，简化了分布式微服务的开发。

EDAS 也实现了自己的 Spring Cloud Starter HSF，您同样可以通过 Spring Cloud 来开发 HSF 应用。 本文档将介绍如何使用 Spring Cloud 来开发 HSF 应用。

该文档参考阿里帮助文档：https://help.aliyun.com/document_detail/63867.html?spm=a2c4g.11186623.6.667.1e40cab5VVvbG8

源码地址：https://github.com/feifuzeng/sc-edas-demo

创建POM工程

  1. 创建一个POM工程，取名sc-edas-demo,pom.xml文件如下

    1. <?xml version="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.0</modelVersion>
    7.     <groupId>com.feifz</groupId>
    8.     <artifactId>sc-edas</artifactId>
    9.     <version>0.0.1-SNAPSHOT</version>
    10.     <packaging>pom</packaging>
    12.     <name>sc-edas</name>
    13.     <description>EDAS 入门 springcloud+HSF</description>
    15.     <modules>
    16.         <module>sc-edas-api</module>
    17.         <module>sc-edas-provider</module>
    18.         <module>sc-edas-consumer</module>
    19.     </modules>
    20.     <parent>
    21.         <groupId>org.springframework.boot</groupId>
    22.         <artifactId>spring-boot-starter-parent</artifactId>
    23.         <version>1.5.8.RELEASE</version>
    24.         <relativePath/> <!-- lookup parent from repository -->
    25.     </parent>
    27.     <properties>
    28.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    29.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    30.         <java.version>1.8</java.version>
    31.     </properties>
  1.         <build>
  2.             <plugins>
  3.                 <plugin>
  4.                     <groupId>org.springframework.boot</groupId>
  5.                     <artifactId>spring-boot-maven-plugin</artifactId>
  6.                 </plugin>
  7.             </plugins>
  8.         </build>
  10.     </project>

创建服务提供者及API工程

  1. 创建一个 普通maven工程，命名为 sc-edas-api，在该工程内定义提供者暴露的所有HSF服务，单独发布成jar供调用方使用
  2. 创建创建一个 Spring Cloud 工程，命名为 sc-edas-provider，端口设置为18081

  3. pom.xml 内容如下：

    <?xml version=”1.0” encoding=”UTF-8”?>
    <project xmlns=”http://maven.apache.org/POM/4.0.0“

    1.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    2.         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    3.    <modelVersion>4.0.0</modelVersion>
    5.    <groupId>com.feifz</groupId>
    6.    <artifactId>sc-edas-provider</artifactId>
    7.    <version>0.0.1-SNAPSHOT</version>
    8.    <packaging>jar</packaging>
    10.    <name>sc-edas-provider</name>
    11.    <description>提供者</description>
    13.    <parent>
    14.        <groupId>com.feifz</groupId>
    15.        <artifactId>sc-edas</artifactId>
    16.        <version>0.0.1-SNAPSHOT</version>
    17.    </parent>
    19.    <dependencies>
    20.        <!--@Api-->
    21.        <dependency>
    22.            <groupId>com.feifz</groupId>
    23.            <artifactId>sc-edas-api</artifactId>
    24.            <version>0.0.1-SNAPSHOT</version>
    25.        </dependency>
    27.        <dependency>
    28.            <groupId>org.springframework.cloud</groupId>
    29.            <artifactId>spring-cloud-starter-hsf</artifactId>
    30.            <version>1.3</version>
    31.        </dependency>
    32.        <dependency>
    33.            <groupId>org.springframework.cloud</groupId>
    34.            <artifactId>spring-cloud-starter-pandora</artifactId>
    35.            <version>1.3</version>
    36.        </dependency>
    37.        <dependency>
    38.            <groupId>org.springframework.boot</groupId>
    39.            <artifactId>spring-boot-starter-web</artifactId>
    40.        </dependency>
    42.    </dependencies>
    43.    <dependencyManagement>
    44.        <dependencies>
    45.            <dependency>
    46.                <groupId>org.springframework.cloud</groupId>
    47.                <artifactId>spring-cloud-dependencies</artifactId>
    48.                <version>Dalston.SR4</version>
    49.                <type>pom</type>
    50.                <scope>import</scope>
    51.            </dependency>
    52.        </dependencies>
    53.    </dependencyManagement>
  1.     </project>
  3. 虽然 HSF 服务框架并不依赖于 Web 环境，但是 EDAS 管理应用的生命周期过程中需要使用到 Web 相关的特性，所以需要添加spring-boot-starter-web 的依赖。 如果您的工程不想将 parent 设置为 spring-boot-starter-parent，也可以通过如下方式添加 dependencyManagement ，设置 scope=import ，来达到依赖版本管理的效果。
  5.     <dependencyManagement>
  6.          <dependencies>
  7.              <dependency>          
  8.                  <groupId>org.springframework.boot</groupId>
  9.                  <artifactId>spring-boot-dependencies</artifactId>
  10.                  <version>1.5.8.RELEASE</version>
  11.                  <type>pom</type>
  12.                  <scope>import</scope>
  13.              </dependency>
  14.          </dependencies>
  15.      </dependencyManagement>
  17. 注意，其中提供者工程里引入了api工程jar包，目的为方便消费者消费时与提供者提供的包路径信息相同。对于api工程中定义的接口具体实现均在提供者工程里进行实现并添加注解进行暴露服务，具体可见提供者工程代码。

  1. 在api工程中定义接口

    1. package com.feifz.scedasapi.api;
    3. /**
    4.  * @author feifz
    5.  * @version 1.0.0
    6.  * @Description 示例接口
    7.  * @Date 2018/10/24 15:08
    8.  */
    9. public interface HelloService {
    11.     public String hello(String str);
    12. }

  1. 在provider工程编写api接口实现

    1. package com.feifz.scedasprovider.service;
    3. import com.alibaba.boot.hsf.annotation.HSFProvider;
    4. import com.feifz.scedasapi.api.HelloService;
    6. /**
    7.  * @author feifz
    8.  * @version 1.0.0
    9.  * @Description TOOD
    10.  * @Date 2018/10/24 15:09
    11.  */
    12. @HSFProvider(serviceGroup = "sc-edas-provider",serviceInterface = HelloService.class ,serviceVersion = "1.0.0")
    13. public class HelloServiceImpl implements HelloService {
  1.         @Override
  2.         public String hello(String str) {
  3.             return "sc-edas-provider-提供者返回->"+str;
  4.         }
  5.     }

  1. 在启动类main方法添加PandoraBootstrap启动

    1. package com.feifz.scedasprovider;
    3. import com.taobao.pandora.boot.PandoraBootstrap;
    5. import org.springframework.boot.SpringApplication;
    6. import org.springframework.boot.autoconfigure.SpringBootApplication;
    8. /**
    9.  * 提供者启动类
    10.  */
    11. @SpringBootApplication
    12. public class ScEdasProviderApplication {
    14.     public static void main(String[] args) {
    15.         // 启动 Pandora Boot 用于加载 Pandora 容器
    16.         PandoraBootstrap.run(args);
    17.         SpringApplication.run(ScEdasProviderApplication.class, args);
    18.         // 标记服务启动完成,并设置线程 wait。防止业务代码运行完毕退出后，导致容器退出。
    19.         PandoraBootstrap.markStartupAndWait();
    20.     }
    21. }

创建消费者工程

  1. 创建消费者springCloud,取名sc-edas-consumer，端口设置为18082

  2. POM.xml内容如下

    1. <?xml version="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.0</modelVersion>
    7.     <groupId>com.feifz</groupId>
    8.     <artifactId>sc-edas-consumer</artifactId>
    9.     <version>0.0.1-SNAPSHOT</version>
    10.     <packaging>jar</packaging>
    12.     <name>sc-edas-consumer</name>
    13.     <description>消费者</description>
    15.     <parent>
    16.         <groupId>com.feifz</groupId>
    17.         <artifactId>sc-edas</artifactId>
    18.         <version>0.0.1-SNAPSHOT</version>
    19.     </parent>
    20.     <dependencies>
    21.         <!--@Api-->
    22.         <dependency>
    23.             <groupId>com.feifz</groupId>
    24.             <artifactId>sc-edas-api</artifactId>
    25.             <version>0.0.1-SNAPSHOT</version>
    26.         </dependency>
    28.         <dependency>
    29.             <groupId>org.springframework.cloud</groupId>
    30.             <artifactId>spring-cloud-starter-hsf</artifactId>
    31.             <version>1.3</version>
    32.         </dependency>
    33.         <dependency>
    34.             <groupId>org.springframework.cloud</groupId>
    35.             <artifactId>spring-cloud-starter-pandora</artifactId>
    36.             <version>1.3</version>
    37.         </dependency>
    38.         <dependency>
    39.             <groupId>org.springframework.boot</groupId>
    40.             <artifactId>spring-boot-starter-web</artifactId>
    41.         </dependency>
    42.     </dependencies>
    43.     <dependencyManagement>
    44.         <dependencies>
    45.             <dependency>
    46.                 <groupId>org.springframework.cloud</groupId>
    47.                 <artifactId>spring-cloud-dependencies</artifactId>
    48.                 <version>Dalston.SR4</version>
    49.                 <type>pom</type>
    50.                 <scope>import</scope>
    51.             </dependency>
    52.         </dependencies>
    53.     </dependencyManagement>
    54. </project>

  1. 编写消费者配置类，通过注解的方式将服务消费者的实例注入到 Spring 的 Context 中。在 Config 类里配置一次 @HSFConsumer ，然后在多处通过 @Autowired 注入使用。通常一个 HSF Consumer 需要在多个地方使用，但并不需要在每次使用的地方都用 @HSFConsumer 来标记。只需要写一个统一的 Config 类，然后在其它需要使用的地方，直接通过 @Autowired 注入即可。

    1. package com.feifz.scedasconsumer;
    3. import com.alibaba.boot.hsf.annotation.HSFConsumer;
    4. import com.feifz.scedasapi.api.HelloService;
    6. import org.springframework.context.annotation.Configuration;
    8. /**
    9.  * @author feifz
    10.  * @version 1.0.0
    11.  * @Description 消费者 配置类
    12.  * @Date 2018/10/24 15:20
    13.  */
    14. @Configuration
    15. public class HsfConfig {
    17.     @HSFConsumer(serviceGroup = "sc-edas-provider",clientTimeout = 3000,serviceVersion = "1.0.0")
    18.     private HelloService helloService;
    19. }

  1. 编写control层demo代码

    1. package com.feifz.scedasconsumer.control;
  1.     import com.feifz.scedasapi.api.HelloService;
  3.     import org.springframework.beans.factory.annotation.Autowired;
  4.     import org.springframework.web.bind.annotation.PathVariable;
  5.     import org.springframework.web.bind.annotation.RequestMapping;
  6.     import org.springframework.web.bind.annotation.RequestMethod;
  7.     import org.springframework.web.bind.annotation.RestController;
  9.     /**
  10.      * @author feifz
  11.      * @version 1.0.0
  12.      * @Description 消费者 示例controller
  13.      * @Date 2018/10/24 15:29
  14.      */
  15.     @RestController
  16.     public class HelloController {
  18.         @Autowired
  19.         private HelloService helloService;
  21.         @RequestMapping(value = "/hello/{str}",method = RequestMethod.GET)
  22.         public String hello(@PathVariable String str){
  23.             return helloService.hello(str);
  24.         }
  25.     }
  27. **注：**在IDEA中编写该control时，IDEA可能会提示Could not autowire. No beans of 'HelloService' type found，可忽略，正常编译运行即可。

  1. 在启动类main方法添加PandoraBootstrap启动

    1. package com.feifz.scedasconsumer;
    3. import com.taobao.pandora.boot.PandoraBootstrap;
    5. import org.springframework.boot.SpringApplication;
    6. import org.springframework.boot.autoconfigure.SpringBootApplication;
    8. /**
    9.  * 消费者 启动类
    10.  */
    11. @SpringBootApplication
    12. public class ScEdasConsumerApplication {
    14.     public static void main(String[] args) {
    15.         // 启动 Pandora Boot 用于加载 Pandora 容器
    16.         PandoraBootstrap.run(args);
    17.         SpringApplication.run(ScEdasConsumerApplication.class, args);
    18.         // 标记服务启动完成,并设置线程 wait。防止业务代码运行完毕退出后，导致容器退出。
    19.         PandoraBootstrap.markStartupAndWait();
    20.     }
    21. }

启动运行

  1. 依次启动sc-edas-provider工程、sc-edas-consumer工程，访问 http://127.0.0.1:18082/hello/world
  2. 服务返回：sc-edas-provider-提供者返回->world

欢迎关注微信公众号：码仔zonE

2020081910375831.png

发表评论

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

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

相关阅读

    相关 什么是EDA？

    EDA是指数据探索分析(Exploratory Data Analysis)的缩写。它是一种统计分析方法，旨在了解数据的基本特征，并发现数据中的规律和模式。EDA通常是数据分析

    深藏阁楼爱情的钟深藏阁楼爱情的钟/ 0 赞/ 121 阅读

    相关 java从入门到实战开发

    　　手记文章 　　小伙伴们元宵节快乐，记得吃元宵哦～ 在日常开发中，小伙伴们多多少少都有用过 MyBatis 插件，松哥猜测大家用的最多的就是 MyBatis 的分页插件！不

    你的名字你的名字/ 0 赞/ 222 阅读