分布式组件:Spring Cloud —— OpenFeign远程服务调用
1.引入依赖:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>
2.将服务注册到Nacos中:
参考我上一篇博客:分布式组件:Spring Cloud Alibaba——Nacos注册中心
3 在项目中创建一个feign包,用于声明远程调用的接口
package com.atguigu.gulimall.member.feign; import com.atguigu.common.utils.R; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.RequestMapping; /** * 这是一个声明式的远程调用 */ @FeignClient("gulimall-coupon") //Member服务要调用Coupon服务 @Component public interface CouponFeignService { @RequestMapping("/coupon/coupon/member/list") public R membercoupons(); }
当前我的服务是:gulimall-member,想要调用的服务为:gulimall-coupon
想要调用的远程服务接口为gulimall-coupon服务下的:/coupon/coupon/member/list
所以在@FeignClient(“gulimall-coupon”)注解的name属性中写上“gulimall-coupon“
在@RequestMapping("/coupon/coupon/member/list")注解的value属性中写上/coupon/coupon/member/list
4 在启动类中使用注解 @EnableFeignClients(basePackages = “com.atguigu.gulimall.member.feign”),basePackages 的值是CouponFeignService 接口所在的包名
package com.atguigu.gulimall.member; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients; /** * 1、想要远程调用别的服务 * 1)、引入open-feign * 2)、编写一个接口,告诉SpringCloud这个接口需要调用远程服务 * 1、声明接口的每一个方法都是调用哪个远程服务的那个请求 * 3)、开启远程调用功能 */ @EnableFeignClients(basePackages = "com.atguigu.gulimall.member.feign") @EnableDiscoveryClient @SpringBootApplication public class GulimallMemberApplication { public static void main(String[] args) { SpringApplication.run(GulimallMemberApplication.class, args); } }
5 以上就是使用OpenFeign远程调用的基本Demo,现在在gulimall-member服务下写个Controller来测试一下:
@RestController @RequestMapping("member/member") public class MemberController { @Autowired CouponFeignService couponFeignService; @RequestMapping("/coupons") //调用远程接口 public R test(){ MemberEntity memberEntity = new MemberEntity(); memberEntity.setNickname("张三"); R membercoupons = couponFeignService.membercoupons(); return R.ok().put("member",memberEntity).put("coupons",membercoupons.get("coupons")); } }
启动完两个微服务后:浏览器访问http://localhost:8000/member/member/coupons
出现以下信息:
证明远程调用gulimall-coupon服务接口成功~