SpringCloud Feing 源码 (简单实用) (一)

news2024/11/18 9:28:44

文章目录

      • 1.远程调用
      • 2.代码解析
        • 2.1 Eureka微服务
        • 2.1 微服务结构以及配置类
        • 2.2 公共类
        • 2.3 provider微服务
        • 2.4 Feign-Order微服务
      • 3.结果展示

1.远程调用

  • 本地过程调用（Local Procedure Call，LPC），是指同一台机器上运行的不同进程之间的互相通信，即在多进程操作系统中，运行的不同进程之间可以通过 LPC 进行函数调用。
  • 远程过程调用（Remote Procedure Call，RPC），是指不同机器上运行的进程之间的相互通信，某一机器上运行的进程在不知道底层通信细节的情况下，就像访问本地服务一样，去调用远程机器上的服务。

被调用方（服务器）有一个开放的接口，然后调用方（用户）通过 Browser 使用这个接口，来间接调用被调用方相应的服务，从而实现远程调用。

  • SpringCloud对Feign进行了增强，使Feign支持了SpringMVC注解 (OpenFeign)

  • OpenFeign = RestTemplate+Ribbon (远程调用+负载均衡)

2.代码解析

在这里插入图片描述

这里通过Eureka注册中心注册Feign微服务和Payment微服务

开启3个微服务: Eureka + Feign-Order80 + Payment8001

Feign-Order80和Payment8001导入的依赖为openfeign和eureka client的

        <!--openfeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--eureka client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

Eureka微服务导入的依赖为Eureka server

       <!--eureka-server-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>

2.1 Eureka微服务

application.yml

server:
  port: 7001


eureka:
  instance:
    hostname: eureka7001.com #eureka服务端的实例名称
  client:
    register-with-eureka: false     #false表示不向注册中心注册自己。
    fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    service-url:
    #集群指向其它eureka
      #defaultZone: http://eureka7002.com:7002/eureka/
    #单机就是7001自己
      defaultZone: http://eureka7001.com:7001/eureka/

在这里插入图片描述

2.1 微服务结构以及配置类

  • Cloud-api-commons: 公共微服务
  • Cloud-provider-payment8001: 微服务提供者
  • Cloud-consumer-feign-order80: 微服务消费者, 调用feign接口远程调用提供者微服务

Provider8001微服务:

在这里插入图片描述
application.yml

server:
  port: 8001

spring:
  application:
    name: cloud-payment-service
#  zipkin:
#      base-url: http://localhost:9411
#  sleuth:
#    sampler:
#    #采样率值介于 0 到 1 之间，1 则表示全部采集
#    probability: 1
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
    driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
    url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root


eureka:
  client:
    #表示是否将自己注册进EurekaServer默认为true。
    register-with-eureka: true
    #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetchRegistry: true
    service-url:
      #单机版
      defaultZone: http://localhost:7001/eureka
      # 集群版
      #defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
  instance:
      instance-id: payment8001
      #访问路径可以显示IP地址
      prefer-ip-address: true
      #Eureka客户端向服务端发送心跳的时间间隔，单位为秒(默认是30秒)
      #lease-renewal-interval-in-seconds: 1
      #Eureka服务端在收到最后一次心跳后等待时间上限，单位为秒(默认是90秒)，超时将剔除服务
      #lease-expiration-duration-in-seconds: 2


mybatis:
  mapperLocations: classpath:mapper/*.xml
  type-aliases-package: com.atguigu.springcloud.entities    # 所有Entity别名类所在包

在这里插入图片描述

OpenFeign-Order80微服务:

在这里插入图片描述

application.yml

server:
  port: 80

eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/
#设置feign客户端超时时间(OpenFeign默认支持ribbon)
ribbon:
#指的是建立连接所用的时间，适用于网络状况正常的情况下,两端连接所用的时间
  ReadTimeout: 5000
#指的是建立连接后从服务器读取到可用资源所用的时间
  ConnectTimeout: 5000

logging:
  level:
    # feign日志以什么级别监控哪个接口
    com.atguigu.springcloud.service.PaymentFeignService: debug

在这里插入图片描述

2.2 公共类

cloud-api-commons 微服务

在这里插入图片描述

结果类

@Data
@AllArgsConstructor
@NoArgsConstructor
public class CommonResult<T> {
    private Integer code;
    private String message;
    private T data;

    public CommonResult(Integer code, String message){
        this(code, message, null);

    }
}

实体类

@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class Payment {
    private Long id;
    private String serial;

}

2.3 provider微服务

dao

@Mapper
public interface PaymentDao {
    public int create(Payment payment);

    public Payment getPaymentById(@Param("id") Long id);

}

service

public interface PaymentService {
    public int create(Payment payment);

    public Payment getPaymentById(@Param("id") Long id);
}

serviceImpl

@Service
public class PaymentServiceImpl implements PaymentService {
    @Resource
    private PaymentDao paymentDao;

    @Override
    public int create(Payment payment) {
        return paymentDao.create(payment);
    }

    @Override
    public Payment getPaymentById(Long id) {
        return paymentDao.getPaymentById(id);
    }
}

controller

@RestController
@Slf4j
public class PaymentController {
    @Value("${server.port}")
    public String serverPort;

    @Resource
    private PaymentService paymentService;

    @Resource
    private DiscoveryClient discoveryClient;

    @PostMapping("/payment/create")
    public CommonResult create(@RequestBody Payment payment){
        int i = paymentService.create(payment);
        log.info("result = {}", i);

        if (i > 0){
            return new CommonResult(200, "插入数据成功 + " + serverPort, i);
        }else {
            return new CommonResult(444, "插入数据失败", null);
        }
    }

    @GetMapping("/payment/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id")Long id){
        Payment result = paymentService.getPaymentById(id);
        log.info("result = {}", result);
        if (result != null){
            return new CommonResult(200, "查询成功数据, serverPort : " + serverPort, result);
        }else {
            return new CommonResult(444, "查询数据失败" + id, null);
        }
    }

    @GetMapping("/payment/discovery")
    public Object discovery(){
        List<String> services = discoveryClient.getServices();
        for (String service : services) {
            log.info("service : " + service);
        }
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance instance : instances) {
            log.info("instance : " + instance);
        }
        return discoveryClient;
    }
}

2.4 Feign-Order微服务

service

@Component
@FeignClient(name = "CLOUD-PAYMENT-SERVICE")
public interface PaymentFeignService {
    @GetMapping("/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id);
}

controller

@RestController
@Slf4j
public class OrderFeignController {
    @Autowired
    private PaymentFeignService paymentFeignService;

    @GetMapping("/consumer/payment/get/{id}")
    public CommonResult<Payment> get(@PathVariable("id") Long id){
        return paymentFeignService.getPaymentById(id);
    }
}

3.结果展示

http://localhost:7001/

在这里插入图片描述

Feign-Order80微服务调用Provider8001微服务得到结果

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/70260.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

从MES到MOM，抓住中国工业软件的机遇

从MES到MOM，抓住中国工业软件的机遇

从全球市场看&#xff0c;MES也是正进入MOM阶段&#xff0c;如图四所示。目前很多还是智能化第二代MES&#xff0c;主要是加强数据记录与处理和设备自动化管理&#xff0c;通过更精确的过程状态跟踪和更完整的数据记录&#xff0c;获取更多的数据来优化生产管理&#xff0c;并通…
阅读更多...
被微服务轰炸？莫怕！耗时35天整出的「微服务学习教程」送你

被微服务轰炸？莫怕！耗时35天整出的「微服务学习教程」送你

又被微服务轰炸&#xff1f;莫慌莫怕&#xff01;小编连续25天&#xff0c;整出这份最新最全「学习教程」送你&#xff01; 微服务架构学习教程&#xff1a;RPCDubboSpirngBootSpringCloud AlibabaDockerK8s 手绘了整个微服务架构的知识体系脑图&#xff0c;还有针对分部的Dub…
阅读更多...
LabelImg标注的YOLO格式txt标签中心坐标和物体边界框长宽的转换

LabelImg标注的YOLO格式txt标签中心坐标和物体边界框长宽的转换

目录 1.LabelImg标注的YOLO格式的TXT标签 OpencvYOLO-V3实现目标跟踪 YOLO-V3实时检测实现&#xff08;opencvpython实现&#xff09;——改进——&#xff1e;更加的易懂 YOLO-V3实时检测实现&#xff08;opencvpython实现&#xff09; 1.LabelImg标注的YOLO格式的TXT标签 …
阅读更多...
【Mysql】记录一些特殊的select语句

【Mysql】记录一些特殊的select语句

目录一.分页查询二.多表查询三.自连接四.子查询4.1单行子查询4.2多行子查询4.3临时表子查询4.4多行子查询4.5多列子查询一.分页查询 select...limit start,rows 表示从start1行开始取&#xff0c;取出rows行&#xff0c;start从0开始算 公式&#xff1a;limit 每页显示记录数*…
阅读更多...
R语言NLP案例：LDA主题文本挖掘优惠券推荐网站数据

R语言NLP案例：LDA主题文本挖掘优惠券推荐网站数据

介绍 Groupon是一个优惠券推荐服务&#xff0c;您可以免费注册Groupon&#xff0c;并且Groupon每天都会向您发送包含该地区当天交易的电子邮件。如果您喜欢这笔交易&#xff0c;那么您可以立即从Groupon购买&#xff0c;并在餐馆/商店兑换。 相关视频&#xff1a;文本挖掘&…
阅读更多...
微导纳米将于12月14日申购：前三季度收入约4亿元，同比增长67%

微导纳米将于12月14日申购：前三季度收入约4亿元，同比增长67%

12月5日&#xff0c;江苏微导纳米科技股份有限公司&#xff08;下称“微导纳米”&#xff0c;SH:688147&#xff09;披露招股意向书&#xff0c;启动发行招股&#xff0c;初步询价时间定于2022年12月9日&#xff0c;将于2022年12月14日申购。 据了解&#xff0c;微导纳米拟在上…
阅读更多...
电巢·新能源领域高速发展，驱动电解电容“老树又发新枝芽”

电巢·新能源领域高速发展，驱动电解电容“老树又发新枝芽”

据统计&#xff0c;新能源汽车销量2012年为1.3万台&#xff0c;2021年上升到352.1万台&#xff0c;截止2022年9月达到456.7万台。车载充电机(OBC)的主要功能是将交流电压输入&#xff0c;以适合电池组的电流和电压水平&#xff0c;转换为直流电压输出。 新能源汽车应用中&#…
阅读更多...
Apache Spark与 Apache Hadoop数据科学工具有哪些区别？

Apache Spark与 Apache Hadoop数据科学工具有哪些区别？

ApacheSpark与 Apache Hadoop数据科学工具有哪些区别&#xff1f;Apache Spark被设计为大规模处理的接口&#xff0c;而 Apache Hadoop 为大数据的分布式存储和处理提供了更广泛的软件框架。两者既可以一起使用也可以作为独立服务使用。Apache Spark 和 Apache Hadoop 都是 Apa…
阅读更多...
C51 - 微型步进电机15BY25驱动

C51 - 微型步进电机15BY25驱动

Contents1> 电机1.1> 旋转原理1.2> 拍数1.3> 步距角2> 驱动电路2.1> MS356562.2> L62192.3> TC15083> 工作时序1> 单相4拍2> 双相4拍3> 双相8拍1> 电机 1.1> 旋转原理 电生磁, 安培定则(右手螺旋定则); 步进电机转动的本质: 转子被定…
阅读更多...
【U8】T6升级U8后打开卡片管理报错

【U8】T6升级U8后打开卡片管理报错

T6升级U8&#xff0c;使用低版本升级U8工具&#xff0c;严格按照升级工具步骤操作&#xff08;以下三个步骤按顺序操作&#xff09; 升级成功后&#xff0c;在U8中&#xff0c;打开固定资产模块的卡片管理报错&#xff0c;如下图&#xff1a; 经过跟踪排查发现&#xff0c;后台…
阅读更多...
ChatGPT 加图数据库 NebulaGraph 预测 2022 世界杯冠军球队

ChatGPT 加图数据库 NebulaGraph 预测 2022 世界杯冠军球队

一次利用 ChatGPT 给出数据抓取代码&#xff0c;借助 NebulaGraph 图数据库与图算法预测体坛赛事的尝试。 作者&#xff1a;古思为 蹭 ChatGPT 热度 最近因为世界杯正在进行&#xff0c;我受到这篇 Cambridge Intelligence 的文章启发&#xff08;在这篇文章中&#xff0c;作…
阅读更多...
【机器学习实战】使用SGD-随机梯度下降、随机森林对MNIST数据进行二分类（Jupyterbook）

【机器学习实战】使用SGD-随机梯度下降、随机森林对MNIST数据进行二分类（Jupyterbook）

1. 数据集 由美国高中生和人口调查局员工手写的70000个数字的图片。数据集获取 # 获取MNIST数据集 from sklearn.datasets import fetch_openml mnist fetch_openml(mnist_784, version1, cacheTrue, as_frameFalse) mnist查看X和Y 找索引为36000的实例&#xff0c;并将其还…
阅读更多...
AXI4-Lite总线读写BRAM

AXI4-Lite总线读写BRAM

博主参考和学习的博客 AXI协议基础知识 。这篇博客比较详细地介绍了AXI总线&#xff0c;并且罗列了所有的通道和端口&#xff0c;写代码的时候可以方便地进行查表。AXI总线&#xff0c;AXI_BRAM读写仿真测试 。 这篇文章为代码的书写提供大致的思路&#xff0c;比如状态机和时…
阅读更多...
GDB调试

GDB调试

文章目录1.什么是GDB2. 准备工作3.GDB命令-启动、退出、查看代码4.设置断点5.GDB命令-调试命令1.什么是GDB 2. 准备工作 通常&#xff0c;在为调试而编译时&#xff0c;我们会关掉编译器的优化选项"-o",并打开调试选选项“-g”&#xff0c;另外&#xff0c;“-wall”…
阅读更多...
【第一章 Linux目录结构，网络连接模式，vi和vim，Linux关机重启命令，Linux用户管理】

【第一章 Linux目录结构，网络连接模式，vi和vim，Linux关机重启命令，Linux用户管理】

第一章 Linux目录结构&#xff0c;网络连接模式&#xff0c;vi和vim&#xff0c;Linux关机&重启命令&#xff0c;Linux用户管理 1.Linux和Unix&#xff1a; ①Unix针对于大型&#xff0c;高性能主机或服务器&#xff1b; ②Linux适用于个人计算机。 2.网络连接的三种模式…
阅读更多...
图解pytorch里面的torch.gather()

图解pytorch里面的torch.gather()

在 Dim1 的情况下应用 torch.gather() 上图显示了 torch gather() 函数在 dim1 的二维张量上的工作。 这里索引张量的行对应于输入张量的行&#xff08;用灰色阴影突出显示&#xff09;。现在对于索引张量中的每个索引值&#xff0c;从该行和输入张量的索引中选取相应的值。 让…
阅读更多...
LEADTOOLS 22-23 .Net/NetCore/JS/JAVA/Win/Linux

LEADTOOLS 22-23 .Net/NetCore/JS/JAVA/Win/Linux

破解版功能齐全&#xff1a;LEADTOOLS 是一系列综合工具包&#xff0c;旨在帮助程序员将光栅、文档、医学、多媒体和矢量图像集成到他们的桌面、服务器、平板电脑和移动应用程序中。LEADTOOLS 为开发人员提供最灵活、最强大的成像技术&#xff0c;为 OCR、条形码、表单识别、PD…
阅读更多...
推荐大家一些CTF的网站和工具

推荐大家一些CTF的网站和工具

一.网站 1.攻防世界 网址&#xff1a;攻防世界 这是一个有好多题目的网站 主要有Misc、Pwn、Web、Reverse、Crypto、Mobile几种题型 不会的问题还可以查题解 好用度 9星 2.BUUCTF 网址&#xff1a;BUUCTF在线评测 也有很多ctf的题目 逆向、网络等等...... 比攻防世界…
阅读更多...
最近火爆了的对话ChatGPT

最近火爆了的对话ChatGPT

前言 相信最近小伙伴们已经被ChatGPT的惊艳效果刷屏了&#xff0c;之前笔者也介绍过一些对话方向的工作&#xff0c;感兴趣的小伙伴可以穿梭&#xff1a; 对话系统最新综述II https://zhuanlan.zhihu.com/p/446760658 在对话系统中建模意图、情感: https://zhuanlan.zhihu.com/…
阅读更多...
Nacos是什么？

Nacos是什么？

摘要&#xff1a;Nacos是 Dynamic Naming and Configuration Service的首字母简称&#xff0c;相较之下&#xff0c;它更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。本文分享自华为云社区《Nacos入门指南 - Nacos是什么》&#xff0c;作者&#xff1a;华为云P…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023