⭐⭐⭐ Spring Boot 项目实战 ⭐⭐⭐ Spring Cloud 项目实战
《Dubbo 实现原理与源码解析 —— 精品合集》 《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》 《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》 《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》 《Java 面试题 + Java 学习指南》

摘要: 原创出处 juejin.cn/post/7085661725881696293 「llsydn」欢迎转载,保留摘要,谢谢!


🙂🙂🙂关注**微信公众号:【芋道源码】**有福利:

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言将得到认真回复。甚至不知道如何读源码也可以请教噢
  4. 新的源码解析文章实时收到通知。每周更新一篇左右
  5. 认真的源码交流微信群。

Feign,在微服务框架中,是的服务直接的调用变得很简洁、简单,而不需要再编写Java Http调用其他微服务的接口。

动态feign

对于fegin调用,我们一般的用法都是为每个微服务都创建对应的feignclient接口,然后为每个微服务的controller接口,一一编写对应的方法,去调用对应微服务的接口。

例如下面这样:

//system
@FeignClient(name = "system")
public interface SystemClient {
@GetMapping("/system/test1")
JsonResult test1(String test1);

@GetMapping("/system/test2")
JsonResult test2(String test2);

....
}

//user
@FeignClient(name = "user")
public interface UserClient {
@GetMapping("/user/test1")
JsonResult test1(String test1);

@GetMapping("/user/test2")
JsonResult test2(String test2);

....
}

这样写的话,可能会有些累赘,那么我们能不能创建一个动态的feign;当调用sytem微服务的时候,传递一个feignclientnamesystem进去,然后定义一个通用的方法,指定调用的url,传递的参数,就可以了呢?

答案是可以的!!!^_^

装一下

  • 定义一个通用的接口,通用的get,post方法

public interface DynamicService {

@PostMapping("{url}")
Object executePostApi(@PathVariable("url") String url, @RequestBody Object params);

@GetMapping("{url}")
Object executeGetApi(@PathVariable("url") String url, @SpringQueryMap Object params);
}

executePostApi:(post方法)

url,表示你要调用微服务的接口url,一般来说是对应controller接口的url;

params,为调用该接口所传递的参数,这里加了@RequestBody,那对应的controller接口,接收参数也需要加上该注解。

  • 定义一个动态feignclient

@Component
public class DynamicClient {

@Autowired
private DynamicFeignClientFactory<DynamicService> dynamicFeignClientFactory;

public Object executePostApi(String feignName, String url, Object params) {
DynamicService dynamicService = dynamicFeignClientFactory.getFeignClient(DynamicService.class, feignName);
return dynamicService.executePostApi(url, params);
}

public Object executeGetApi(String feignName, String url, Object params) {
DynamicService dynamicService = dynamicFeignClientFactory.getFeignClient(DynamicService.class, feignName);
return dynamicService.executeGetApi(url, params);
}
}

executePostApi:(post方法)

feignName,表示需要调用的微服务的名称,一般对应application.name,例如:system

url,表示你要调用微服务的接口url,一般来说是对应controller接口的url;

params,为调用该接口所传递的参数,这里加了@RequestBody,那对应的controller接口,接收参数也需要加上该注解。

  • 定义一个动态feignclient工厂类

@Component
public class DynamicFeignClientFactory<T> {

private FeignClientBuilder feignClientBuilder;

public DynamicFeignClientFactory(ApplicationContext appContext) {
this.feignClientBuilder = new FeignClientBuilder(appContext);
}

public T getFeignClient(final Class<T> type, String serviceId) {
return this.feignClientBuilder.forType(type, serviceId).build();
}
}

主要的作用:是帮我们动态的创建一个feignclient对象

好了,具体的操作步骤,就是上面所说的了!!!是不是很通用了呢?^_^

通用是通用了,那怎么玩呢(如何使用)?

亮剑

使用的方式,也是十分的简单啦:^_^

DynamicClient dynamicClient = SpringUtil.getBean(DynamicClient.class);
Object result = dynamicClient.executePostApi("system", "/system/test", new HashMap<>());
System.out.println("==========>"+JSONObject.toJSONString(result));

先获取到DynamicClient对象,然后直接调用executePostApi方法

"system",表示调用微服务的名称,一般对应application.name

"/system/test",表示调用的url

new HashMap<>(),为需要传递的参数

好了,这样就实现了一个通用版的feignclient,那我们就可以愉快的编写代码了!!!^_^

溜了

文章目录
  1. 1. 动态feign