使用Feign消费服务

Feign是一个声明式的服务调用组件，它整合了 Ribbon 和 Hystrix，使得服务调用更加简单。Feign提供了HTTP请求的模板，通过编写简单的接口和插入注解，就可以定义好HTTP请求的参数、格式、地址等信息。Feign会完全代理HTTP的请求，我们只需要像调用方法一样调用它就可以完成服务请求。

 

Feign具有如下特性：

        可插拔的注解支持，包括 Feign 注解和 JAX-RS 注解

        支持可插拔的 HTTP 编码器和解码器

        支持 Hystrix 和它的 Fallback

        支持 Ribbon 的负载均衡

        支持 HTTP 请求和响应的压缩

 

Feign对压缩的支持：在application.properties文件添加以下配置信息

#开启请求压缩功能
feign.compression.request.enabled=true
 
#开启响应压缩功能
feign.compression.response.enabled=true
 
#指定压缩请求数据类型
feign.compression.request.mime-types=text/xml;application/xml;application/json
 
#如果传输超过该字节，就对其进行压缩，默认是2048
feign.compression.request.min-request-size=2048

 

Feign的日志处理

        可为每个Feign客户端指定日志记录策略，每个Feign客户端都会创建一个logger。   

        默认情况下，logger的名称是Feign接口的完整类名。需要注意的是，Feign的日志打印只会对DEBUG级别作出响应。  

        Logger.Level的值有以下选择：                 

               NONE：不记录任何日志（默认值）

               BASIC：仅记录请求方法、URL、响应状态代码以及执行时间

               HEADERS：记录BASIC级别的基础上，记录请求和响应的header

               FULL：记录请求和响应的header，body和元数据

 

要使用Feign，需要在pom.xml文件中引入以下依赖：

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

 

 定义一个服务接口类，服务提供者的Controller类实现该接口类，Feign客户端接口类继承该接口类，这样可以实现接口共享。

public interface UserService {
	@GetMapping("/user/{id}")
	String addUser(@PathVariable(value="id") Long id);
	
	@GetMapping("/user/query")
	String query(@RequestParam(value="name") String name);
	
	@GetMapping("/user/getUser")
	User getUser(@RequestParam(value="id") Long id);
	
	@PostMapping("/user/add")
	User add(@RequestBody Address address);	
	
	@PostMapping("/user/update")
	String update(@RequestBody Address address);
	
	@GetMapping("/user/getAllAddress")
	List<Address> getAllAddress();
	
	@PostMapping("/user/put")
	void put(@RequestBody Address address);
}

 

 服务提供者的Controller类，实现上面定义的服务接口

@RestController
public class UserServiceController implements UserService {
	@Override
	public String addUser(@PathVariable(value="id") Long id){
		return "id=" + id;
	}

	@Override
	public String query(@RequestParam(value="name") String name){
		return "名字=" + name;
	}

	@Override
	public User getUser(@RequestParam(value="id") Long id){
		User user = new User();
		user.setId(id);
		user.setUsername("姓名1");
		user.setPassword("pwd1");
		return user;
	}

	@Override
	public User add(@RequestBody Address address){
		User user = new User();
		user.setId(100L);
		user.setUsername("姓名1");
		user.setPassword("pwd1");
		return user;
	}

	@Override
	public String update(@RequestBody Address address){
		return "update success";
	}

	@Override
	public List<Address> getAllAddress() {
		List<Address> list = new ArrayList<Address>();
		Address address1 = new Address("省1", "city1");
		Address address2 = new Address("province11", "市11");
		list.add(address1);
		list.add(address2);
		return list;
	}

	@Override
	public void put(@RequestBody Address address){
		System.out.println(address.getProvince() + ", " + address.getCity());
	}
}

 

创建Feign客户端接口类，该类继承于上面定义的服务接口，DefaultFeignConfiguration类是Feign的自定义配置类

/**
 * Feign客户端接口类：通过Feign的继承特性来实现接口共享
 * 
 * name=服务名
 * configuration  自定义Feign配置
 */
@FeignClient(name="service-provider-1", configuration=DefaultFeignConfiguration.class)
public interface UserFeignClient extends UserService{
	
}

 

创建Feign的自定义配置类

/**
 * 自定义Feign配置类
 * 
 * 该配置类不能被@ComponentScan扫描到，否则配置信息就会被所有 @FeignClient 共享
 * Feign的默认配置类是FeignClientsConfiguration，该类定义了Feign默认使用的编码器、解码器、所使用的契约等。
 */
@Configuration
@ExcludeComponent //用于标识该配置类不被@ComponentScan扫描
public class DefaultFeignConfiguration {
	/**
	 * 自定义日志输出
	 * 
	 * 需要在application.properties文件中添加以下信息才生效：
	 * 		logging.level.com.seasy.springcloud.serviceconsumer.feignclient.UserFeignClient=DEBUG
	 */
	@Bean
    Logger.Level feignLoggerLevel() {
        return Logger.Level.BASIC;
    }
}

 

application.properties文件的配置信息

spring.application.name=service-consumer-2
server.port=9002

eureka.instance.hostname=${spring.cloud.client.ip-address}
eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
eureka.instance.prefer-ip-address=true

#eureka.client.service-url.defaultZone=http://192.168.134.134:7001/eureka/
eureka.client.service-url.defaultZone=http://root:123456@192.168.134.134:7001/eureka/

logging.level.com.seasy.springcloud.serviceconsumer.feignclient.UserFeignClient=DEBUG

 

服务消费者的Controller类

@RestController
public class UserController {
	//引入FeignClient类
	@Autowired
    UserFeignClient userFeignClient;
	
	@GetMapping("/consumer2")
	public String test(){
		String result = userFeignClient.addUser(22L);

		result = userFeignClient.query("cjm");
		
		User user = userFeignClient.getUser(33L);
		
		Address address = new Address();
		address.setProvince("GuangDong");
		address.setCity("GuangZhou");
		
		user = userFeignClient.add(address);
		
		result = userFeignClient.update(address);
		
		List<Address> list = userFeignClient.getAllAddress();
		
		userFeignClient.put(address);
		
		return "ok";
	}
}

 

启动类：

@EnableEurekaClient
@EnableFeignClients //开启Feign功能
//使用自定义注解@ExcludeComponent和excludeFilters使RibbonConfiguration类不被@CompantScan扫描到
@ComponentScan(excludeFilters=@ComponentScan.Filter(type=FilterType.ANNOTATION, value={ExcludeComponent.class}))
@SpringBootApplication
public class Main {
	public static void main(String[] args) {
		SpringApplication.run(Main.class, args);
	}
}

 

修改Feign的负载均衡策略：

        Feign整合了Ribbon，Feign的负载均衡是通过Ribbon实现的。Ribbon默认的负载均衡策略是轮询，要改变这种默认行为，可以在启动类中定义负载均衡策略的Bean类。

@Bean
public IRule feignRule(){
	return new RandomRule(); //随机
}