摘要：
避免为每个服务使用者重复定义接口描述。1.添加服务器和客户端同时依赖的API项目，因为需要使用springMVC注释来描述接口。3.pom依赖˂！
前面使用ribbon拦截RestTemplate 实现服务的负载均衡 使用Hystrix进行熔断降级请求缓存 用原生的方式 将会有大量的模板代码，feigin就是rabbon和Histrix的整合 同
使用feign只需要通过接口对服务方的绑定 实现多处调用
使用例子1.引入Pom依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <!--开启端点 用于dashboard监控--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>
2.定义一个接口描述服务信息
@FeignClient("PROVIDER")
@RequestMapping("/user")
public interface UserService {
@RequestMapping(value = "/findById",method = RequestMethod.GET)
public User findById(@RequestParam("id") Integer id);
@RequestMapping(value = "/findAll",method = RequestMethod.GET)
public List<User> findAll();
@RequestMapping(value = "/deleteById",method = RequestMethod.GET)
public Boolean deleteById(@RequestParam("id")Integer id);
@RequestMapping(value = "/update",method = RequestMethod.POST)
public Boolean update(@RequestBody User user);
}@FeignClient 是用于服务发现 发现指定服务
@RequestMapping 为请求指定服务 指定方式
@RequestBody 表示参数是封装在报文体出传输 服务端 接收也需要打RequestBody
3.入口类开启Fegin以及服务发现
@SpringBootApplication @EnableFeignClients //开启feigin @EnableDiscoveryClient //开启服务发现 public class SpringCloudFeignConsumerApplication { public static void main(String[] args) { SpringApplication.run(SpringCloudFeignConsumerApplication.class, args); } }
4.通过注入实现调用
@RestController public class UserContorller { @Autowired UserService userService; @RequestMapping("/findById") @ResponseBody public User findById(Integer id) { return userService.findById(id); } @RequestMapping("/findAll") @ResponseBody public List<User> findAll() { return userService.findAll(); } @RequestMapping("/deleteById") @ResponseBody public Boolean deleteById(Integer id) { return userService.deleteById(1); } @RequestMapping("/update") @ResponseBody public Boolean update() { User user=new User(); user.setId(1); user.setName("测试修改"); User filterUser = userService.findById(user.getId()); filterUser.setName(user.getName()); userService.update(filterUser); return true; } }
将接口定义在服务端 服务消费者通过继承方式实现服务订阅。避免 每个服务消费者 都要重复定义接口描述
1.新增一个API项目并被服务端和客户端依赖 同时依赖web 因为需要使用springMVC注解对接口描述
3.pom依赖
<!--定义接口约束 需要用到springMVC的注解-->
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
</dependency>
</dependencies>
<!--用普通jar打包的方式-->
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId>
<executions>
<execution>
<id>attach-sources</id>
<goals>
<goal>jar</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>jar包打包方式 都改为传统的打包方式 否则 其他依赖会报错 找不到 符号 因为存在2个入口类
3.api项目添加一个接口描述
@RequestMapping("/user")
public interface UserService {
@RequestMapping(value = "/findById",method = RequestMethod.GET)
public User findById(@RequestParam("id") Integer id);
@RequestMapping(value = "/findAll",method = RequestMethod.GET)
public List<User> findAll();
@RequestMapping(value = "/deleteById",method = RequestMethod.GET)
public Boolean deleteById(@RequestParam("id")Integer id);
@RequestMapping(value = "/update",method = RequestMethod.POST)
public Boolean update(@RequestBody User user);
}4.更改provider
@Controller @RequestMapping("/user") public class UserContorller implements UserService { List<User> users; public UserContorller() { users = new ArrayList<>(); users.add(new User(1, "小明", 1)); users.add(new User(2, "小香", 0)); users.add(new User(3, "小方", 0)); users.add(new User(4, "小张", 0)); users.add(new User(6, "小李", 0)); } @RequestMapping("/findById") @ResponseBody public User findById(Integer id) { return users.stream().filter(c -> c.getId().intValue() == id.intValue()).findAny().get(); } @RequestMapping("/findAll") @ResponseBody public List<User> findAll() { return users; } @RequestMapping("/deleteById") @ResponseBody public Boolean deleteById(Integer id) { return users.removeIf(c -> c.getId().intValue() == id.intValue()); } @RequestMapping("/update") @ResponseBody public Boolean update(@RequestBody User user) { User filterUser = findById(user.getId()); filterUser.setName(user.getName()); return true; } }
5.更改consumer Service继承api的Service
@FeignClient("PROVIDER")
public interface UserService extends com.liqiang.api.UserService {
}6.consumer调用注入Service
@RestController public class UserContorller { @Autowired UserService userService; @RequestMapping("/findById") @ResponseBody public User findById(Integer id) { return userService.findById(id); } @RequestMapping("/findAll") @ResponseBody public List<User> findAll() { return userService.findAll(); } @RequestMapping("/deleteById") @ResponseBody public Boolean deleteById(Integer id) { return userService.deleteById(1); } @RequestMapping("/update") @ResponseBody public Boolean update() { User user=new User(); user.setId(1); user.setName("测试修改"); User filterUser = userService.findById(user.getId()); filterUser.setName(user.getName()); userService.update(filterUser); return true; } }
继承的缺点 接口修改 会导致调用端的构建失败 不同通过版本控制可以避免
Ribbon配置全局配置
通过ribbon.<属性>=..
ribbon: ConnectTimeout: 500 ReadTimeout=5000
指定服务配置及重试
<服务名>.ribbon.<属性>=... 服务名为@FeginClient配置
#对指定服务设置rabbion全局参数 Fegin接口@FeignClient("PROVIDER")
PROVIDER:
ribbon:
#配置首台服务器重试1次
MaxAutoRetries: 1
#配置其他服务器重试两次
MaxAutoRetriesNextServer: 2
#链接超时时间
ConnectTimeout: 500
#请求处理时间
ReadTimeout: 2000
#每个操作都开启重试机制
OkToRetryOnAllOperations: true全局配置
与hystrix配置一样
#配置断路器超时时间，默认是1000（1秒） hystrix: command: default: execution: isolation: thread: timeoutInMilliseconds: 12000
通过指令配置
hystrix.command.<commandKey> commandKey默认以方法名作为标识
禁用hystrix
全部禁用
feign: hystrix: enabled: true #启用hystrix false为禁用
指定服务禁用
@Configuration public class DisableHystrixConfiguration { @Bean @Scope("prototype") public Feign.Builder feignBuilder() { return Feign.builder(); } }
@FeignClient(value = "PROVIDER",configuration = DisableHystrixConfiguration.class) public interface UserService extends com.liqiang.api.UserService { }
1.增加一个Service的接口类
public class UserServiceFaillBack implements UserService { @Override public User findById(Integer id) { return null; } @Override public List<User> findAll() { return null; } @Override public Boolean deleteById(Integer id) { return false; } @Override public Boolean update(User user) { return false; } }
@FeignClient(value = "PROVIDER",configuration = DisableHystrixConfiguration.class,fallback = UserServiceFaillBack.class) public interface UserService extends com.liqiang.api.UserService { }
feign: compression: request: enabled: true #feign请求gizp压缩 减少网络损耗 response: enabled: true #feign响应gizp压缩 减少网络损耗 #启用压缩 压缩指定格式 超过对应大小的才开始压缩 #feign.compression.request.enabled=true #feign.compression.request.mime-types=text/xml,application/xml,application/json #指定格式 #feign.compression.request.min-request-size=2048 #指定大小
对服务开启日志输出
#还需要在application配置Logger.Level 详情区主类去看
logging:
level:
com:
liqiang:
feginService:
HelloExtendService: DEBUG还要在主类设置日志界别
class SpringcloudFeiginConsumerApplication { /*** * 日志可选级别 * • NONE: 不记录任何信息。 * • BASIC: 仅记录请求方法、URL以及响应状态码和执行时间。 * • HEADERS: 除了记录BASIC级别的信息之外， 还会记录请求和响应的头信息。 // * • FULL: 记录所有请求与响应的明细， 包括头信息、 请求体、 元数据等。 // * @return */ @Bean public Logger.Level feignLoggerLevel() { return Logger.Level.FULL; } public static void main(String[] args) { SpringApplication.run(SpringcloudFeiginConsumerApplication.class, args); } }
如果遇到feign注解无效，同时配置了scan 包扫描。 可以在@EnableFeignClients("你的feign包")或者application.properties 配置feign.client.package=com.crb.ocms.stock