openfeign在单体项目用法

admin10个月前实践出真知79

公司项目需要与其他系统对接,常规的httpClient写法,不符合我大道至简的理念,于是研究了一下openfeign,本文只是提供一个思路,具体还需要根据实际场景进行完善。

一、加入依赖

我使用的spring boot 为2.7.9 ,openfeign使用3.1.8,版本匹配不上会导致应用启动时候报错,错误大概意思是配置什么有问题

       <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>3.1.8</version>
        </dependency>



二、普通用法

注解上将url参数给上

package com.xx.module.memberinfo.openfeign;

import com.xx.module.memberinfo.openfeign.dto.UserInfoDTO;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@Service
//这里的url一定要给,不然会被当成微服务去请求名为test的服务
@FeignClient(name = "test", url = "http://xxx.com")
public interface MemberInfoApi {

    @GetMapping("/profile")
    UserInfoDTO getUser();

    @GetMapping("/list")
    List<UserInfoDTO> getUserList();
}



三、自定义用法

给定拦截器配置

1、创建请求拦截器

package com.xx.module.memberinfo.openfeign.interceptor;

import feign.RequestInterceptor;
import feign.RequestTemplate;

public class CommonFeignRequestInterceptor implements RequestInterceptor {

    @Override
    public void apply(RequestTemplate requestTemplate) {
        /*** 自定义request解析逻辑 ***/
        requestTemplate.target("http://a.b.com"); //修改请求地址,请求地址可以从配置,缓存,数据库啥的读取
        // 这里就是你请求前要进行的各种操作,比如设置一下header 添加点其他料
        /*** 自定义request解析逻辑 ***/
    }
}

2、创建响应拦截器

package com.xx.module.memberinfo.openfeign.interceptor;

import com.fasterxml.jackson.databind.ObjectMapper;
import feign.FeignException;
import feign.Response;
import feign.codec.Decoder;
import org.apache.commons.io.IOUtils;

import java.io.IOException;
import java.lang.reflect.Type;
import java.nio.charset.StandardCharsets;
import java.util.Collection;
import java.util.Map;

public class CommonFeignResponseInterceptor implements Decoder {

    private static final ObjectMapper objectMapper = new ObjectMapper();

    @Override
    public Object decode(final Response response, Type type) throws FeignException, IOException {
        /*** 自定义response解析逻辑 ***/
        Map<String, Collection<String>> headers = response.headers();
        Response.Body body = response.body();
        String bodyString = IOUtils.toString(body.asReader(StandardCharsets.UTF_8));
        Object result = objectMapper.readValue(bodyString, objectMapper.constructType(type));
        //解开之后这里继续处理逻辑
        /*** 自定义response解析逻辑 ***/
        return result;
    }
}

3、创建一个配置

package com.xx.module.memberinfo.openfeign.config;

import com.xx.module.memberinfo.openfeign.interceptor.CommonFeignResponseInterceptor;
import com.xx.module.memberinfo.openfeign.interceptor.CommonFeignRequestInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

//@Configuration //这一行如果加了 就对整个openfeign生效,可以根据实际情况添加
public class MemberFeignClientConfiguration {

    @Bean
    public CommonFeignRequestInterceptor commonFeignRequestInterceptor(){
        return new CommonFeignRequestInterceptor();
    }

    @Bean
    public CommonFeignResponseInterceptor commonFeignResponseInterceptor(){
        return new CommonFeignResponseInterceptor();
    }
}

4、注解使用

package com.xx.module.memberinfo.openfeign;

import com.xx.module.memberinfo.openfeign.dto.UserInfoDTO;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@Service
@FeignClient(name = "test", url = "http://xx.com", configuration = {MemberFeignClientConfiguration.class})
public interface MemberInfoApi {

    @GetMapping("/profile")
    UserInfoDTO getUser();

    @GetMapping("/list")
    List<UserInfoDTO> getUserList();
}




四、一把梭用法

1、前置步骤参考 【自定义用法】的 创建两个拦截器、创建配置文件

新增步骤

2、创建一个注解

package com.xx.module.memberinfo.openfeign.annotations;

import com.xx.module.memberinfo.openfeign.config.MemberFeignClientConfiguration;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.core.annotation.AliasFor;

import java.lang.annotation.*;

@FeignClient
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MemberFeignClient {

    @AliasFor(annotation = FeignClient.class)
    String name() default "MemberFeignClient";

    //todo 务必注意 这个url一定要填一个,后面通过request拦截器再修改
    // 不填写的话,openfeign会认为这是微服务模式,会通过name去请求,然后这个单体项目启动就提示没有引入负载均衡依赖
    @AliasFor(annotation = FeignClient.class)
    String url() default "http://localhost";

    @AliasFor(annotation = FeignClient.class)
    String path() default "";

    @AliasFor(annotation = FeignClient.class)
    Class<?>[] configuration() default {MemberFeignClientConfiguration.class};
}


3、注解使用

package com.xx.module.memberinfo.openfeign;

import com.xx.module.memberinfo.openfeign.dto.UserInfoDTO;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@Service
@MemberFeignClient
public interface MemberInfoApi {

    @GetMapping("/profile")
    UserInfoDTO getUser();

    @GetMapping("/list")
    List<UserInfoDTO> getUserList();
}


相关文章

关于时间的处理(时间范围生成,mysql按照天,周,月统计)

mysql的查询语句 #周  select FROM_UNIXTIME(create_time,'%Y%u') weeks,count(cas...

记录一次docker安装mysql8.3

配置文件 /data/mysql8-data/conf/my.cnf[mysql] # 设置mysql控制台默认字符集 default-character-set=utf8mb4 #&...

docker部署minio

docker部署minio

docker安装方式 移步 https://note.centos7.online/?id=27一、拉取镜像docker pull minio/minio二、启动容器do...

linux下利用nc监听端口的玩法

ubuntu/debian开机启动设置,移步这里家里有一些小服务器玩具,由于家里网络都是dhcp获取ip地址,ip地址可能会出现变动。那么如果在服务器上监听一个特殊端口,通过内网扫描指定的特殊端口,即...

记一次博客的迁移(Ubuntu安装docker部署博客)

一、docker的安装更新源#apt-get update安装依赖#apt-get install \     apt-tran...

安卓调用webview中iframe定义方法(适用于数据回调给webview)

首先在html中用js获取到当前页面的层级//递归获取当前嵌套在iframe页面的层级位置     function getSelfWindowPa...

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。