自定义BeanPostProcessor之Feign组件服务间优雅调用

本文主要是介绍自定义BeanPostProcessor之Feign组件服务间优雅调用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Feign是什么

feign是声明式的web service客户端，它让微服务之间的调用变得更简单了，类似controller调用service。Spring Cloud集成了Ribbon和Eureka，可在使用Feign时提供负载均衡的http客户端。

Feign怎么使用

@FeignClient(value = "service-name")
public interface CartFeignClient {@PostMapping("/cart/{productId}")Long addCart(@PathVariable("productId")Long productId);
}

上面是最简单的feign client的使用，声明完为feign client后，其他spring管理的类，如service就可以直接注入使用了，例如：

//这里直接注入feign client
@Autowired
private CartFeignClient cartFeignClient;@PostMapping("/toCart/{productId}")
public ResponseEntity addCart(@PathVariable("productId") Long productId){Long result = cartFeignClient.addCart(productId);return ResponseEntity.ok(result);
}

可以看到，使用feign之后，我们调用eureka 注册的其他服务，在代码中就像各个service之间相互调用那么简单。

常规Feign服务间调用

在本地研发环境开发时候可能需要调用其他服务，例如通过service-name的方式调用，但是如果经过注册中心，并且服务有多实例的情况下会出现超时的情况。可以通过指定服务ip的方式调用。

@FeignClient(value="service-name", url = "http://127.0.0.1:2607/")@FeignClient(value="service-name-1", url = "http://1.2.3.4:2607/")

Feign服务间调用更容易

如果引用的其他服务比较多，需要修改很多的url，这样比较浪费时间，通过重写@FeignClient的url，可进行统一处理，而不用一个一个的去修改。也可以配置研发环境，本地环境等多个环境的服务地址。
具体的实现方式是通过自定义BeanPostProcessor的方式，在bean初始化的时候动态替换。
BeanPostProcessor的原理可以看spring相关文章。

@Component
public class FeignClientsServiceNameAppendBeanPostProcessor implements BeanPostProcessor, ApplicationContextAware {private ApplicationContext applicationContext;private AtomicInteger atomicInteger = new AtomicInteger();// 需要替换的服务名称和ip集合public static final Map<String, String> SERVICE_MAP = new HashMap<>();private static String beanNameOfFeignClientFactoryBean = "org.springframework.cloud.netflix.feign.FeignClientFactoryBean";static {SERVICE_MAP.put("service-name", "http://127.0.0.1:2607");SERVICE_MAP.put("service-name-1", "http://1.2.3.4:8081");}@Overridepublic Object postProcessBeforeInitialization(Object bean, String s) throws BeansException {return bean;}@SneakyThrows@Overridepublic Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {if (atomicInteger.getAndIncrement() == 0) {Class beanNameClz = Class.forName(beanNameOfFeignClientFactoryBean);applicationContext.getBeansOfType(beanNameClz).forEach((feignBeanName, beanOfFeignClientFactoryBean) -> {try {setField(beanNameClz, "url", beanOfFeignClientFactoryBean);} catch (Exception e) {e.printStackTrace();}System.out.println(feignBeanName + "-->" + beanOfFeignClientFactoryBean);});}return bean;}private void setField(Class clazz,  Object obj) throws Exception {// 获取FeignClientFactoryBean的name属性，找到服务名称。例如：service-name-1Field name = ReflectionUtils.findField(clazz, "name");Object nameValue = null;if (Objects.nonNull(name)) {ReflectionUtils.makeAccessible(name);nameValue = name.get(obj);}// 获取FeignClientFactoryBean的url字段Field field = ReflectionUtils.findField(clazz, "url");if (Objects.nonNull(field) && Objects.nonNull(nameValue)) {ReflectionUtils.makeAccessible(field);Object value = field.get(obj);// 找到指定配置替换url的值if (Objects.nonNull(value) && SERVICE_MAP.containsKey(nameValue)) {value = SERVICE_MAP.get(nameValue);ReflectionUtils.setField(field, obj, value);}}}@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}