服务间调用是微服务体系中必不可少的一部分,在springcloud alibaba的官网中,推荐使用是dubbo,但因为并发量比较小,同时dubbo相对比较复杂,所有楼主在服务间调用选型时,依然选择了openfeign。同时将服务间调用的接口封装为子工程,进行统一的api管理。避免小伙伴们造重复的轮子。
1.新建api子工程
1.搭建子工程
这里新建了一个子工程,文件结构如下。
2.添加pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
<version>2.2.6.RELEASE</version>
</dependency>
3.实现fallback熔断方法
当服务调用失败,会跳转到该类。后文会与Sentinel一起使用。
@Component
public class UserFallBack implements UserApi {
@Override
public Result<UserVO> getCurrentUser() {
Result<UserVO> result = new Result<>();
String error = "调用system获取当前用户信息失败!";
result.setCode(506);
result.setMessage(error);
return result;
}
@Override
public Result<UserVO> getUser(UserVO UserVO) {
Result<UserVO> result = new Result<>();
String error = "调用system获取输入用户信息失败!";
result.setCode(506);
result.setMessage(error);
return result;
}
}
4.feign接口实现
@FeignClient(name = "system", fallback = UserFallBack.class) //其中name为nacos中的服务名
public interface UserApi {
/**
* 获取当前用户信息
*
* @return
*/
@GetMapping("/getCurrentUser")
Result<UserVO> getCurrentUser();
/**
* 通过实体获取用户信息
*
* @return
*/
@GetMapping("/getUser")
Result<UserVO> getUser(@SpringQueryMap UserVO UserVO);
}
这里需要注意,如果在get请求时,同时boby中有值,feign会把get转换成post,所以这种情况需要使用@SpringQueryMap注解。
2.父工程调用
1.修改pom.xml
1.在pom文件中引入子工程 ,详细配置可以参考楼主文章:
<dependencies>
<dependency>
<groupId>com.vanpeng</groupId>
<artifactId>common-api</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
</dependencies>
2.修改启动类
@EnableDiscoveryClient
@SpringBootApplication
@EnableFeignClients("com.common.api")
public class DatacenterApplication {
public static void main(String[] args) {
SpringApplication.run(DatacenterApplication.class, args);
}
}
注意:@EnableFeignClients(“com.common.api”)一定要指定api子工程路径,否则不执行调用。
3.调用
public class DemoController {
@Autowired
UserApi userApi;
@GetMapping("/demo")
public void demo() {
Result<RestSysUserVO> xxx = userApi.getCurrentUser();
}
}
|