AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

06、SpringCloud之feign的工程化实例(分布式工程)（二）

2022-10-19 108
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 06、SpringCloud之feign的工程化实例(分布式工程)（二）

二、基于feign的工程化项目创建


2.1、案例目标及项目架构图


api模块依赖domain模块，然后其他服务依赖该api接口模块。


domain：实体类。

api：放置公共接口，例如feign接口。



2.2、实战—项目模块搭建


2.2.1、各个模块介绍及父模块pom.xml


项目模块展示：


注册中心：使用之前eureka案例中的即可



接着按照2.1中的项目架构图来进行搭建模块，分别是：api模块、doamin模块、order服务模块以及user服务模块


依赖关系如下：


api模块依赖domain模块。

domain：添加对应的实体类。

api：主要是编写对应的远程调用api接口以及断路器实现类。

order、user服务模块依赖api模块。

order服务主要是对外提供服务。

user服务中某个接口会进行调用order服务。



所有的包名统一前缀为com.changlu。


对于04-feign-project父模块的pom.xml配置如下：


<?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>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.12.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <!-- 创建好子模块之后，就会自动添加packaging以及modules管理   -->
    <groupId>com.changlu</groupId>
    <artifactId>04-feign-project</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>domain-project</module>
        <module>common-api</module>
        <module>user-center</module>
        <module>order-center</module>
    </modules>
    <!--全局版本控制-->
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
    </properties>
    <!--  全局依赖的模块  -->
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>
    <!--  全局管理的依赖版本（不会被直接引入）  -->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <!-- 打包编译   -->
<!--    <build>-->
<!--    </build>-->
</project>


2.2.2、domain-project模块


说明：该模块主要放置一些实体类。



pom.xml：


<?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>04-feign-project</artifactId>
        <groupId>com.changlu</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>domain-project</artifactId>
</project>


Order.java实体类：


package com.changlu.domain;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:30 PM
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class Order {
    private Integer orderId;
    private String orderName;
    private Double price;
}



2.2.3、common-api模块


说明：这个模块主要放一些公共的api接口，例如feign接口以及hystrix断路器接口。



pom.xml：


<?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>04-feign-project</artifactId>
        <groupId>com.changlu</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>common-api</artifactId>
    <dependencies>
        <!--    依赖domain    -->
        <dependency>
            <groupId>com.changlu</groupId>
            <artifactId>domain-project</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
    </dependencies>
</project>


com/changlu/feign/UserOrderFeign.java：feign接口规范


package com.changlu.feign;
import com.changlu.domain.Order;
import com.changlu.feign.hystrix.*;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:39 PM
 */
@FeignClient(value = "order-service", fallback = UserOrderFeignHystrix.class)
public interface UserOrderFeign {
    @GetMapping("/order/{id}")
    Order getOrderById(@PathVariable("id")Integer id);
}



com.changlu.feign.hystrix.UserOrderFeignHystrix：对应上面feign的断路器


package com.changlu.feign.hystrix;
import com.changlu.domain.Order;
import com.changlu.feign.UserOrderFeign;
import org.springframework.stereotype.Component;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:43 PM
 */
@Component
public class UserOrderFeignHystrix implements UserOrderFeign {
    @Override
    public Order getOrderById(Integer id) {
        return null;
    }
}


2.2.4、order-center服务模块


说明：该模块主要是对外提供订单服务。



pom.xml：


<?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>04-feign-project</artifactId>
        <groupId>com.changlu</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>order-center</artifactId>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>
        <!--    引入api依赖    -->
        <dependency>
            <groupId>com.changlu</groupId>
            <artifactId>common-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>
</project>


配置文件application.yaml：


server:
  port: 8081
spring:
  application:
    name: order-service
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka
  instance:
    hostname: localhost
    instance-id: ${eureka.instance.hostname}:${spring.application.name}:${server.port}


①添加启动器注解，开启服务注册


package com.changlu;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:36 PM
 */
@SpringBootApplication
@EnableEurekaClient
public class OrderServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderServiceApplication.class, args);
    }
}



②创建订单控制器：com.changlu.controller.OrderController


package com.changlu.controller;
import com.changlu.domain.Order;
import com.changlu.feign.UserOrderFeign;
import org.springframework.web.bind.annotation.RestController;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:38 PM
 */
@RestController
public class OrderController implements UserOrderFeign {
        @Override
        public Order getOrderById(Integer id) {
            Order order = Order.builder()
                    .orderId(id)
                    .price(100.0)
                    .orderName("牛奶布丁").build();
            return order;
        }
}



2.2.5、user-center服务模块


说明：该用户服务主要是对外提供用户服务，在提供用户服务过程中会进行调用订单服务，其中就涉及到了openfeign组件以及hystrix断路器组件（需要手动开启）。



pom.xml：


<?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>04-feign-project</artifactId>
        <groupId>com.changlu</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>user-center</artifactId>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>
        <!--    引入api依赖    -->
        <dependency>
            <groupId>com.changlu</groupId>
            <artifactId>common-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>
</project>


配置文件application.yaml：


server:
  port: 8082
spring:
  application:
    name: user-service
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka
  instance:
    hostname: localhost
    instance-id: ${eureka.instance.hostname}:${spring.application.name}:${server.port}
# 开启熔断
feign:
  hystrix:
    enabled: true



①创建启动器，添加服务注册以及feign包扫描


package com.changlu;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:52 PM
 */
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients(basePackages = "com.changlu.feign")
public class UserServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }
}


②创建用户控制器：com.changlu.controller.UserController


package com.changlu.controller;
import com.changlu.domain.Order;
import com.changlu.feign.UserOrderFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
/**
 * @Description:
 * @Author: changlu
 * @Date: 2:53 PM
 */
@RestController
public class UserController {
    @Autowired
    private UserOrderFeign feign;
    @GetMapping("/user/order/{userId}")
    public Order getOrderByUserId(@PathVariable("userId")Integer userId) {
        //根据用户id获取到订单id
        Integer id = 1111;
        Order order = feign.getOrderById(id);
        return order;
    }
}


至此，我们的项目模块搭建完成。


2.3、项目模块测试、


我们启动注册中心、订单服务以及用户服务：



接着我们来访问用户服务：http://localhost:8082/user/order/123



接着我们将订单服务关闭，再此访问查看下：



成功，当订单服务不可用时，即可返回对应断路器的内容。

文章标签：
API
关键词：
springcloud feign
springcloud分布式
分布式实例
分布式feign
springcloud实例
游客r35aptsdr4whc
目录
相关文章
互联网课堂
|
3月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要，常用于异步数据处理、自动化运维等场景。在单体应用中，利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而，进入微服务架构后，任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块，提供轻量级、高可用的分布式定时任务解决方案，支持防重复执行、分片运行等功能，并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案（如ShedLock）
互联网课堂
117 1
理想shi做条咸鱼
|
3月前
|
存储 Dubbo API
SpringCloud工程部署启动
本节笔者带领大家完成了SpringCloud工程从0->1的搭建，当然你不想搭建也可以直接采用方案一，二者等效，至此读者们完成了一个微服务工程的搭建、部署、访问。同时在本节最后一章，笔者基于RestTemplate发起的http请求实现远程调用，实现当A系统想要获取B系统数据时的跨系统数据交互。然而RESTful API访问并不是微服务的唯一解决方案，如Dubbo的交互一样可以实现，希望读者们能不限于此。
理想shi做条咸鱼
191 5
游客r43put2rqnbp4
|
25天前
|
人工智能 文字识别 Java
SpringCloud+Python 混合微服务，如何打造AI分布式业务应用的技术底层？
尼恩，一位拥有20年架构经验的老架构师，通过其深厚的架构功力，成功指导了一位9年经验的网易工程师转型为大模型架构师，薪资逆涨50%，年薪近80W。尼恩的指导不仅帮助这位工程师在一年内成为大模型架构师，还让他管理起了10人团队，产品成功应用于多家大中型企业。尼恩因此决定编写《LLM大模型学习圣经》系列，帮助更多人掌握大模型架构，实现职业跃迁。该系列包括《从0到1吃透Transformer技术底座》、《从0到1精通RAG架构》等，旨在系统化、体系化地讲解大模型技术，助力读者实现“offer直提”。此外，尼恩还分享了多个技术圣经，如《NIO圣经》、《Docker圣经》等，帮助读者深入理解核心技术。
游客r43put2rqnbp4
26 0
SpringCloud+Python 混合微服务，如何打造AI分布式业务应用的技术底层？
程序员小海绵
|
2月前
|
存储 NoSQL Redis
SpringCloud基础7——Redis分布式缓存，RDB,AOF持久化+主从+哨兵+分片集群
Redis持久化、RDB和AOF方案、Redis主从集群、哨兵、分片集群、散列插槽、自动手动故障转移
程序员小海绵
133 5
SpringCloud基础7——Redis分布式缓存，RDB,AOF持久化+主从+哨兵+分片集群
程序员小海绵
|
2月前
|
SQL NoSQL 数据库
SpringCloud基础6——分布式事务，Seata
分布式事务、ACID原则、CAP定理、Seata、Seata的四种分布式方案：XA、AT、TCC、SAGA模式
程序员小海绵
117 5
SpringCloud基础6——分布式事务，Seata
程序员小海绵
|
2月前
|
SpringCloudAlibaba JavaScript 前端开发
谷粒商城笔记+踩坑（2）——分布式组件、前端基础，nacos+feign+gateway+ES6+vue脚手架
分布式组件、nacos注册配置中心、openfegin远程调用、网关gateway、ES6脚本语言规范、vue、elementUI
程序员小海绵
165 1
谷粒商城笔记+踩坑（2）——分布式组件、前端基础，nacos+feign+gateway+ES6+vue脚手架
土木林森
|
2月前
|
消息中间件 Java 对象存储
数据一致性挑战：Spring Cloud与Netflix OSS下的分布式事务管理
数据一致性挑战：Spring Cloud与Netflix OSS下的分布式事务管理
土木林森
50 2
阿里云云原生
|
4月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
Spring Cloud Alibaba 发布了 Scheduling 任务调度模块 [#3732]提供了一套开源、轻量级、高可用的定时任务解决方案，帮助您快速开发微服务体系下的分布式定时任务。
阿里云云原生
14908 30
热爱技术的小郑
|
3月前
|
Java 微服务 Spring
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
文章介绍了如何利用Spring Cloud Alibaba快速构建大型电商系统的分布式微服务，包括服务限流降级等主要功能的实现，并通过注解和配置简化了Spring Cloud应用的接入和搭建过程。
热爱技术的小郑
205 0
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
codetrend
|
3月前
|
关系型数据库 MySQL 数据库
SpringCloud2023中使用Seata解决分布式事务
对于分布式系统而言，需要保证分布式系统中的数据一致性，保证数据在子系统中始终保持一致，避免业务出现问题。分布式系统中对数据的操作要么一起成功，要么一起失败，必须是一个整体性的事务。Seata简化了这个使用过程。
codetrend
85 2

热门文章

最新文章

  • 1
    AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(二)：配置WinClient分布式运行环境
  • 2
    分布式事务Seata【四】事务补偿（TCC）
  • 3
    分布式数据库架构：高可用、高性能的数据存储
  • 4
    阿里开源首款自研科学计算引擎 Mars ：基于张量的统一分布式计算框架
  • 5
    WCF分布式安全开发实践(8):消息安全模式之用户名身份验证:Message_UserName_WSHttpBinding
  • 6
    蚂蚁架构师郭援非：分布式数据库是金融机构数字化转型的最佳路径
  • 7
    Memcache分布式部署方案
  • 8
    WCF分布式安全开发实践(5):传输安全模式之Certificate身份验证:Transport_Certificate_WSHttpBinding
  • 9
    服务器内部分布式图片取得
  • 10
    .NET简谈事务、分布式事务处理
  • 1
    Spring Cloud 项目中实现推送消息到 RabbitMQ 消息中间件
    81
  • 2
    我把Spring Cloud的超详细资料介绍给你，面试官不会生气吧？geigei
    73
  • 3
    Spring cloud Hystrix 、Dashboard、API(zuul)相关报错
    61
  • 4
    Spring cloud原理详解
    64
  • 5
    在SpringCloud2023中快速集成SpringCloudGateway网关
    151
  • 6
    SpringCloud基础 Consul的引入
    50
  • 7
    SpringCloud 基础配置
    44
  • 8
    springboot和springcloud有哪些区别？
    95
  • 9
    spring cloud使用jar包部署和docker部署的区别
    644
  • 10
    Spring Cloud原理详解
    101

    • 相关课程

    更多
  • 开源PolarDB分布式版部署实操
  • Spring Boot+Vue.js+FastDFS实现分布式图片服务器
  • 微服务+全栈在线教育实战项目演练（SpringCloud Alibaba+SpringBoot）
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • 分布式文件存储系统技术及实现
  • 分布式协调系统 Zookeeper 快速入门

    • 相关电子书

    更多
  • 基于社区的分布式 风险感知模型
  • 如何利用Redisson分布式化传统Web项目
  • FLASH:大规模分布式图计算引擎及应用

    • 相关实验场景

    更多
  • 体验PolarDB-X透明分布式
  • 快速玩转Dubbo生态之一致性事务篇（Seata）
  • 快速上手使用Dubbo进行远程调用
  • Spring-cloud-bus-rocketmq入门与实践
  • Spring-cloud-stream-binder-rocketmq入门与实践
  • Rocketmq-spring入门与实践
    • 下一篇
    无影云桌面