spring boot2.7集成OpenFeign 3.1.7

1.Feign

Feign是一个声明式web服务客户端。它使编写web服务客户端更容易。要使用Feign，请创建一个接口并对其进行注释。它具有可插入注释支持，包括Feign注释和JAX-RS注释。Feign还支持可插拔编码器和解码器。Spring Cloud增加了对Spring MVC注释的支持，并支持使用与Spring Web中默认使用的HttpMessageConverters相同的HttpMessageConverters。Spring Cloud集成了Eureka、Spring Cloud CircuitBreaker以及Spring Cloud LoadBalancer，在使用Feign时提供负载均衡的http客户端。

文档地址:https://docs.spring.io/spring-cloud-openfeign/docs/3.1.7/reference/html/#spring-cloud-feign-circuitbreaker

2.创建maven项目spring-cloud-feign-demo

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"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>spring-cloud-feign-demo</artifactId><version>1.0-SNAPSHOT</version><packaging>pom</packaging><modules><module>feign-app1</module><module>feign-app2</module></modules><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><!-- 统一依赖管理 --><spring.boot.version>2.7.8</spring.boot.version><!-- openfeign--><openfeign.version>3.1.7</openfeign.version>
<!--        <openfeign.version>4.0.6</openfeign.version>--><!-- loadbalancer--><loadbalancer.version>3.1.7</loadbalancer.version><!-- hutool工具类--><hutool.version>5.8.11</hutool.version><!-- feign-okhttp--><feign-okhttp.version>11.10</feign-okhttp.version></properties><dependencyManagement><dependencies><!-- 统一依赖管理 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>${spring.boot.version}</version><type>pom</type><scope>import</scope></dependency><!-- openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><version>${openfeign.version}</version></dependency><!-- loadbalancer--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId><version>${loadbalancer.version}</version></dependency><!-- hutool工具类--><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>${hutool.version}</version></dependency><!-- https://mvnrepository.com/artifact/io.github.openfeign/feign-okhttp --><dependency><groupId>io.github.openfeign</groupId><artifactId>feign-okhttp</artifactId><version>${feign-okhttp.version}</version></dependency></dependencies></dependencyManagement></project>

3.创建子项目客户端feign-app1

3.1 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"><modelVersion>4.0.0</modelVersion><parent><groupId>org.example</groupId><artifactId>spring-cloud-feign-demo</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>feign-app1</artifactId><packaging>jar</packaging><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><!-- Web 相关 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!-- feign-okhttp--><dependency><groupId>io.github.openfeign</groupId><artifactId>feign-okhttp</artifactId></dependency><!-- loadbalancer-->
<!--        <dependency>-->
<!--            <groupId>org.springframework.cloud</groupId>-->
<!--            <artifactId>spring-cloud-starter-loadbalancer</artifactId>-->
<!--        </dependency>--><!-- hutool工具类--><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId></dependency></dependencies></project>

创建org.example.app1.dto.Store

package org.example.app1.dto;/*** @Version Store v1.0.0 2024/11/25 14:50 $$*/
public class Store {private Long id;private String name;public String getName() {return name;}public void setName(String name) {this.name = name;}public Long getId() {return id;}public void setId(Long id) {this.id = id;}
}

3.2 创建 org.example.app1.client.StoreClient

package org.example.app1.client;import org.example.app1.dto.Store;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;import java.util.List;/*** contextId 如果我们想要创建多个具有相同名称或url的虚拟客户端，以便它们指向相同的服务器，但每个客户端都有不同的自定义配置，那么我们必须使用@FeignClient的contextId属性，以避免这些配置bean的名称冲突*/
@FeignClient(name = "storeClient", url = "${feign.client.config.storeClient.url}")
public interface StoreClient {@RequestMapping(method = RequestMethod.GET, value = "/stores")List<Store> getStores();@RequestMapping(method = RequestMethod.POST, value = "/stores/{storeId}", consumes = "application/json")Store update(@PathVariable("storeId") Long storeId, Store store);@RequestMapping(method = RequestMethod.DELETE, value = "/stores/{storeId:\\d+}")void delete(@PathVariable("storeId") Long storeId);}

3.3 创建配置文件:org.example.app1.config.StoreClientConfiguration

package org.example.app1.config;import feign.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;/*** @Author tanyong* @Version StoreClientConfig v1.0.0 2024/11/25 15:35 $$*/
@Configuration
public class StoreClientConfiguration {/*** 要在每个客户端基础上禁用Spring Cloud断路器支持，请创建一个vanilla Feign。具有“prototype”作用域的构建器** @return*/@Bean@Scope("prototype")public Feign.Builder feignBuilder() {return Feign.builder();}/*** 默认情况下创建类型为Retryer的NEVER_RETRY，它将禁用重试。* 请注意，这种重试行为与Feign默认的行为不同，后者会自动重试ioexception，* 将它们视为与网络相关的瞬态异常，以及从ErrorDecoder抛出的任何RetryableException。** @return*/// @Beanpublic Retryer feignRetryer() {return new Retryer.Default(100, java.util.concurrent.TimeUnit.SECONDS.toMillis(1), 3);}
}

3.4 创建org.example.app1.controller.StoreTestController

package org.example.app1.controller;import org.example.app1.client.StoreClient;
import org.example.app1.dto.Store;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;/*** @Author tanyong* @Version StoreController v1.0.0 2024/11/25 14:55 $$*/
@RestController
public class StoreTestController {@Resourceprivate StoreClient storeClient;@RequestMapping(method = RequestMethod.GET, value = "/stores")List<Store> getStores() {return storeClient.getStores();}@RequestMapping(method = RequestMethod.POST, value = "/stores/{storeId}", consumes = "application/json")Store update(@PathVariable("storeId") Long storeId, Store store) {return storeClient.update(storeId, store);}@RequestMapping(method = RequestMethod.DELETE, value = "/stores/{storeId:\\d+}")void delete(@PathVariable Long storeId) {storeClient.delete(storeId);}
}

3.5 创建 org.example.app1.interceptor.StoreInterceptor

package org.example.app1.interceptor;import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.springframework.stereotype.Component;/*** @Author tanyong* @Version RequestInterceptor v1.0.0 2024/11/26 17:00 $$*/
@Component
public class StoreInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate template) {template.header("Authorization", "Bearer your-token");}
}

3.7 创建org.example.app1.DemoApplication1

package org.example.app1;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;/*** @Author tanyong* @Version DemoApplication1 v1.0.0 2024/11/25 14:30 $$*/
@SpringBootApplication
@EnableFeignClients
public class DemoApplication1 {public static void main(String[] args) {SpringApplication.run(DemoApplication1.class, args);}
}

3.8 application.yaml 配置

spring:application:name: demo-server1main:allow-circular-references: true # 允许循环依赖，因为项目是三层架构，无法避免这个情况。
##############===load-balanced==######################
#    discovery: #服务配置
#      client:
#        simple:
#          instances:
#            stores:
#              - uri: http://localhost:8082##############===feign配置==######################
feign:compression: # GZIP 压缩 spring.cloud.openfeign.okhttp.enabled设置为true时，我们不启用压缩。request:enabled: truemime-types: text/xml,application/xml,application/jsonmin-request-size: 2048response:enabled: trueautoconfiguration:jackson: # 你可以考虑启用Jackson模块来支持org.springframework.data.domain.Page和org.springframework.data.domain.Sort解码enabled: truelazy-attributes-resolution: true #@FeignClient 延迟解析okhttp: #要使用OKHttpClient支持的伪客户端，请确保OKHttpClient在你的类路径中，并将spring.cloud.openfeign.okhttp.enabled设置为true。enabled: truereadTimeout: 5000hc5:enabled: false #确保HttpClient 5在类路径上httpclient:enabled: falsecircuitbreaker: #断路由enabled: trueclient:default-to-properties: falseconfig:default: #默认配置connectTimeout: 1000readTimeout: 1000loggerLevel: BASICstoreClient: #客户端配置,@FeignClient name名称 和 @FeignClient contextId，在负载均衡的场景中，它还对应于将用于检索实例的服务器应用程序的serviceIdurl: http://localhost:8082 #服务的url，该版本不支持此属性，@FeignClient(name = "storeClient", url = "${feign.client.config.storeClient.url}")connectTimeout: 5000readTimeout: 5000loggerLevel: FULL #NONE, No logging (DEFAULT).BASIC, 只记录请求方法和URL以及响应状态代码和执行时间。HEADERS, 标头，记录基本信息以及请求和响应标头。FULL, 记录请求和响应的标头、正文和元数据。#errorDecoder: com.example.SimpleErrorDecoder#retryer: com.example.SimpleRetryer 默认情况下，使用类型Retryer创建，它将禁用重试。请注意，这种重试行为与Feign默认的行为不同，后者会自动重试ioexception，将它们视为与网络相关的瞬态异常，以及从ErrorDecoder抛出的任何RetryableException
#            defaultQueryParameters: 指定查询参数，这些参数和头将随feignName客户端的每个请求一起发送。
#              query: queryValue
#            defaultRequestHeaders: 指定查询头，这些参数和头将随feignName客户端的每个请求一起发送。
#              header: headerValuerequestInterceptors: #自定义拦截器- org.example.app1.interceptor.StoreInterceptor
#          capabilities:
#            - com.example.FooCapability
#            - com.example.BarCapability
#            queryMapEncoder: com.example.SimpleQueryMapEncoder
#            metrics.enabled: falseserver:port: 8081# 日志文件配置
logging:level:org.example.app1.client: debug

3.9 logback-spring.xml 配置

<configuration><!-- 定义日志文件的存储路径 --><property name="LOG_PATH" value="logs" /><property name="LOG_FILE" value="${LOG_PATH}/app.log" /><!-- 控制台输出 --><appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender"><encoder><pattern>%d{yyyy-MM-dd HH:mm:ss} - %level - [%thread] - %logger{36} - %msg%n</pattern></encoder></appender><!-- 文件输出 --><appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"><file>${LOG_FILE}</file><rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><!-- 每天生成一个新的日志文件 --><fileNamePattern>${LOG_PATH}/app.%d{yyyy-MM-dd}.log</fileNamePattern><!-- 保留最近30天的日志文件 --><maxHistory>30</maxHistory></rollingPolicy><encoder><pattern>%d{yyyy-MM-dd HH:mm:ss} - %level - [%thread] - %logger{36} - %msg%n</pattern></encoder></appender><!-- 日志级别配置 --><root level="INFO"><appender-ref ref="CONSOLE" /><appender-ref ref="FILE" /></root>
</configuration>

4. 创建子项目服务端feign-app2

复制客户端代码，创建org.example.app2.controller.StoreController

package org.example.app2.controller;import cn.hutool.core.collection.CollUtil;
import org.example.app2.dto.Store;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** @Author tanyong* @Version StoreController v1.0.0 2024/11/25 14:55 $$*/
@RestController
public class StoreController {@RequestMapping(method = RequestMethod.GET, value = "/stores")List<Store> getStores() {Store s = new Store();s.setId(1L);s.setName("app2");return CollUtil.newArrayList(s);}@RequestMapping(method = RequestMethod.POST, value = "/stores/{storeId}", consumes = "application/json")Store update(@PathVariable("storeId") Long storeId, Store store) {return store;}@RequestMapping(method = RequestMethod.DELETE, value = "/stores/{storeId:\\d+}")void delete(@PathVariable Long storeId) {}
}

5.启动服务

postman调用成功响应：
在这里插入图片描述
客户端打印调用日志：
在这里插入图片描述

简单集成成功，完整配置查看：https://docs.spring.io/spring-cloud-openfeign/docs/3.1.7/reference/html/appendix.html

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Jmeter中的前置处理器

Jmeter中的前置处理器

5&#xff09;前置处理器 1--JSR223 PreProcessor 功能特点 自定义数据处理&#xff1a;使用脚本语言处理请求数据&#xff0c;实现高度定制化的数据处理和生成。动态数据生成&#xff1a;在请求发送前生成动态数据&#xff0c;如随机数、时间戳等。变量设置&#xff1a;设置…
阅读更多...
git（Linux）

git（Linux）

1.git 三板斧 基本准备工作&#xff1a; 把远端仓库拉拉取到本地了 .git --> 本地仓库 git在提交的时候&#xff0c;只会提交变化的部分 就可以在当前目录下新增代码了 test.c 并没有被仓库管理起来 怎么添加&#xff1f; 1.1 git add test.c 也不算完全添加到仓库里面&…
阅读更多...
学习Java的日子 Day56 数据库连接池，Druid连接池

学习Java的日子 Day56 数据库连接池，Druid连接池

Day56 1.数据库连接池 理解&#xff1a;池就是容器&#xff0c;容器中存放了多个连接对象 使用原因&#xff1a; 1.优化创建和销毁连接的时间&#xff08;在项目启动时创建连接池&#xff0c;项目销毁时关闭连接池&#xff09; 2.提高连接对象的复用率 3.有效控制项目中连接的…
阅读更多...
Jmeter测试工具的安装和使用，mac版本，jmeter版本5.2.1

Jmeter测试工具的安装和使用，mac版本，jmeter版本5.2.1

Jmeter测试工具的安装和使用JSON格式请求 一、安装1、安装jdk包和设置java环境2、去官网下载Jmeter3、解压后&#xff0c;打开mac终端&#xff0c;进入apache-jmeter的bin文件开启jmeter 二、使用jmeter1、添加线程2、添加HTTP请求3、配置请求的协议、IP地址、端口号、请求方法…
阅读更多...
Envoy 源码解析（一）：Envoy 整体架构、Envoy 的初始化

Envoy 源码解析（一）：Envoy 整体架构、Envoy 的初始化

本文基于 Envoy 1.31.0 版本进行源码学习 1、Envoy 整体架构 1&#xff09;、核心组件 Envoy 包含以下四个核心组件&#xff1a; Listener&#xff08;监听器&#xff09;&#xff1a;定义了 Envoy 如何处理入站请求。一旦连接建立&#xff0c;请求会被传递给一组过滤器进行处…
阅读更多...
【VUE3】VUE组合式（响应式）API常见语法

【VUE3】VUE组合式（响应式）API常见语法

pnpm常用命令 pnpm i //pnpm安装VUE3常见语法汇总 ref() //const count ref(0) //count.value&#xff08;访问值&#xff0c;包括对象要加.value&#xff09; //任何类型的值&#xff0c;包括深层嵌套的对象或则JS内置数据结构 await nextTick() //要等待 DOM 更新完成后…
阅读更多...
CGAL CGAL::Polygon_mesh_processing::self_intersections解析

CGAL CGAL::Polygon_mesh_processing::self_intersections解析

CGAL::Polygon_mesh_processing::self_intersections 是用于检测多边形网格&#xff08;Polygon Mesh&#xff09;中的自相交的函数。自相交是指网格中的某些面&#xff08;例如三角形&#xff09;与同一网格中的其他面交叉的情况。这种情况通常是不期望的&#xff0c;因为它会…
阅读更多...
⭐ Unity 资源管理解决方案：Addressable_ Demo演示

⭐ Unity 资源管理解决方案：Addressable_ Demo演示

一、使用Addressable插件的好处&#xff1a; 1.自动管理依赖关系 2.方便资源卸载 3.自带整合好的资源管理界面 4.支持远程资源加载和热更新 二、使用步骤 安装组件 1.创建资源分组 2.将资源加入资源组 3.打包资源 4.加载资源 三种方式可以加载 using System.Collections…
阅读更多...
Vue前端开发2.3.5 条件渲染指令

Vue前端开发2.3.5 条件渲染指令

本文介绍了Vue中两种条件渲染指令&#xff1a;v-if和v-show。v-if通过布尔值控制元素的DOM树存在&#xff0c;适用于不频繁切换显示状态的场景&#xff1b;v-show则通过CSS的display属性控制显示&#xff0c;适合频繁切换。通过创建单文件组件示例&#xff0c;演示了如何使用这…
阅读更多...
GitLab指定用户分配合并权限

GitLab指定用户分配合并权限

进入项目 -》 Project Settings Repository -》展开 Protected branches -》 添加要保护的分支&#xff0c;设置角色 管理用户角色权限 查看到不同用户的角色&#xff0c;一般设置Developer只有Merger Request权限&#xff0c;Maintainer还有Merge审批权限 GitLab 中的权限…
阅读更多...
计算机网络socket编程(5)_TCP网络编程实现echo_server

计算机网络socket编程(5)_TCP网络编程实现echo_server

个人主页&#xff1a;C忠实粉丝 欢迎 点赞&#x1f44d; 收藏✨ 留言✉ 加关注&#x1f493;本文由 C忠实粉丝 原创 计算机网络socket编程(5)_TCP网络编程实现echo_server 收录于专栏【计算机网络】 本专栏旨在分享学习计算机网络的一点学习笔记&#xff0c;欢迎大家在评论区交…
阅读更多...
C++ 二叉搜索树（Binary Search Tree, BST）深度解析与全面指南：从基础概念到高级应用、算法优化及实战案例

C++ 二叉搜索树（Binary Search Tree, BST）深度解析与全面指南：从基础概念到高级应用、算法优化及实战案例

&#x1f31f;个人主页&#xff1a;落叶 &#x1f31f;当前专栏: C专栏 目录 ⼆叉搜索树的概念 ⼆叉搜索树的性能分析 ⼆叉搜索树的插⼊ ⼆叉搜索树的查找 二叉搜索树中序遍历 ⼆叉搜索树的删除 cur的左节点为空的情况 cur的右节点为空的情况 左&#xff0c;右节点都不为…
阅读更多...
uniCloud云开发

uniCloud云开发

uniCloud 是 DCloud 联合阿里云、腾讯云、支付宝云&#xff0c;为开发者提供的基于 serverless 模式和 js 编程的云开发平台。 普通云函数 callFuction方式云函数&#xff0c;也称之为普通云函数 uni-app的前端代码&#xff0c;不再执行uni.request联网&#xff0c;而是通过…
阅读更多...
org.apache.log4j的日志记录级别和基础使用Demo

org.apache.log4j的日志记录级别和基础使用Demo

org.apache.log4j的日志记录级别和基础使用Demo&#xff0c;本次案例展示&#xff0c;使用是的maven项目&#xff0c;搭建的一个简单的爬虫案例。里面采用了大家熟悉的日志记录插件&#xff0c;log4j。来自apache公司的开源插件。 package com.qian.test;import org.apache.log…
阅读更多...
day05（单片机高级）PCB基础

day05（单片机高级）PCB基础

目录 PCB基础 什么是PCB&#xff1f;PCB的作用&#xff1f; PCB的制作过程 PCB板的层数 PCB设计软件 安装立创EDA PCB基础 什么是PCB&#xff1f;PCB的作用&#xff1f; PCB&#xff08;Printed Circuit Board&#xff09;&#xff0c;中文名称为印制电路板&#xff0c;又称印刷…
阅读更多...
fastjson不出网打法—BCEL链

fastjson不出网打法—BCEL链

前言 众所周知fastjson公开的就三条链&#xff0c;一个是TemplatesImpl链&#xff0c;但是要求太苛刻了&#xff0c;JNDI的话需要服务器出网才行&#xff0c;BCEL链就是专门应对不出网的情况。 实验环境 fastjson1.2.4 jdk8u91 dbcp 9.0.20 什么是BCEL BCEL的全名应该是…
阅读更多...
C#基础控制台程序

C#基础控制台程序

11.有一个54的矩阵&#xff0c;要求编程序求出其中值最大的那个元素的值&#xff0c;以及其所在的行号和列号。 12.从键盘输入一行字符&#xff0c;统计其中有多少个单词&#xff0c;单词之间用空格分隔开。 13.输入一个数&#xff0c;判断它是奇数还是偶数&#xff0c;如果…
阅读更多...
深度学习干货总结（持续更新）

深度学习干货总结（持续更新）

机器学习核心组件 可以用来学习的数据&#xff08;data&#xff09;&#xff1b; 如何转换数据的模型&#xff08;model&#xff09;&#xff1b; 一个目标函数&#xff08;objective function&#xff09;&#xff0c;用来量化模型的有效性&#xff1b; 调整模型参数以优化…
阅读更多...
腾讯云OCR车牌识别实践：从图片上传到车牌识别

腾讯云OCR车牌识别实践：从图片上传到车牌识别

在当今智能化和自动化的浪潮中&#xff0c;车牌识别&#xff08;LPR&#xff09;技术已经广泛应用于交通管理、智能停车、自动收费等多个场景。腾讯云OCR车牌识别服务凭借其高效、精准的识别能力&#xff0c;为开发者提供了强大的技术支持。本文将介绍如何利用腾讯云OCR车牌识别…
阅读更多...
如何制作项目网页

如何制作项目网页

一、背景 许多论文里经常会有这样一句话Supplementary material can be found at https://hri-eu.github.io/Lami/&#xff0c;这个就是将论文中的内容或者补充视频放到一个网页上&#xff0c;以更好的展示他们的工作。因此&#xff0c;这里介绍下如何使用前人提供的模板制作我…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023