天天看点

五分钟带你玩转spring cloud alibaba(六)实战!组件化的服务间的调用

因为并发量比较小,同时dubbo相对比较复杂,所有楼主在服务间调用时,依然选择了openfeign,同时将服务间调用的接口封装为子工程,进行统一的api管理。

api子工程

这里新建了一个子工程

五分钟带你玩转spring cloud alibaba(六)实战!组件化的服务间的调用
五分钟带你玩转spring cloud alibaba(六)实战!组件化的服务间的调用

1.pom.xml

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

2.fallback:熔断

当服务调用失败,会跳转到该类

@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;
    }
}      

3.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注解

父工程调用

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>      

启动类

@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();
    }
 
}