Feign(远程调用)与注册中心


声明式远程调用

feign是一个声明式的HTTP客户端,他的目的就是让远程调用更加简单。给远程服务发的是HTTP请求。

1、引入依赖

<dependency>

   <groupId>org.springframework.cloud</groupId>

   <artifactId>spring-cloud-starter-openfeign</artifactId>

</dependency>

2、编写一个接口,接口告诉springcloud这个接口需要调用远程服务

@FeignClient("gulimall-coupon") //告诉spring cloud这个接口是一个远程客户端,要调用coupon服务(nacos中找到,所以"gulimall-coupon"对应的nacos上的注册名),具体是调用coupon服务的/coupon/coupon/member/list对应的方法
public interface CouponFeignService {
// 远程服务的url
@RequestMapping("/coupon/coupon/member/list")  //注意写全优惠券类上还有映射//注意我们这个地方不是控制层,所以这个请求映射请求的不是我们服务器上的东西,而是nacos注册中心的
public R membercoupons();//得到一个R对象
}

3、开启远程调用功能 @EnableFeignClients,要指定远程调用功能放的基础包

@EnableFeignClients(basePackages="com.atguigu.gulimall.member.feign")//扫描接口方法注解("com.atguigu.gulimall.member.feign"对应的是所有feign类所存在的文件路径,表示扫描该路径下所以含有@FeignClient注解的类)
@EnableDiscoveryClient
@SpringBootApplication
public class gulimallMemberApplication {

public static void main(String[] args) {
SpringApplication.run(gulimallMemberApplication.class, args);
}
}

进阶操作:

示例代码:

gulimall-product服务:

@Data
public class SpuBoundTo {

private Long spuId;
private BigDecimal buyBounds;
private BigDecimal growBounds;

}
//5、保存spu的积分信息  跨库gulimal_sms  -> sms_spu_bounds
Bounds bounds = vo.getBounds();
SpuBoundTo spuBoundTo = new SpuBoundTo();
BeanUtils.copyProperties(bounds,spuBoundTo);
spuBoundTo.setSpuId(infoEntity.getId());
couponFeignService.saveSpuBounds(spuBoundTo);
@FeignClient("gulimall-coupon")
public interface CouponFeignService {


/** 1、CouponFeignService.saveSpuBounds(spuBoundTo)
* 1)、@RequestBody将spuBoundTo对象转为json。
* 2)、找到gulimall-coupon服务,给/coupon/spubounds/save发送请求。
* 将上一步转的json放在请求体位置,发送请求
* 3)、对方服务收到请求。请求体里有json数据
* (@RequestBody SpuBoundsEntity spuBounds);将请求体的json转为SpuBoundsEntity;
* 只要json数据模型是兼容的。双方服务无需使用同一个to
*
* @param spuBoundTo
* @return
*/
@PostMapping("/coupon/spubounds/save")
R saveSpuBounds(@RequestBody SpuBoundTo spuBoundTo);
}

gulimall-coupon服务:

@Data
@TableName("sms_spu_bounds")
public class SpuBoundsEntity implements Serializable {
private static final long serialVersionUID = 1L;

/**
* id
*/
@TableId
private Long id;
/**
*
*/
private Long spuId;
/**
* 成长积分
*/
private BigDecimal growBounds;
/**
* 购物积分
*/
private BigDecimal buyBounds;
/**
* 优惠生效情况[1111(四个状态位,从右到左);0 - 无优惠,成长积分是否赠送;1 - 无优惠,购物积分是否赠送;2 - 有优惠,成长积分是否赠送;3 - 有优惠,购物积分是否赠送【状态位0:不赠送,1:赠送】]
*/
private Integer work;

}
  /**
* 保存
*/
@PostMapping("/coupon/spubounds/save")

public R save(@RequestBody SpuBoundsEntity spuBounds){
    spuBoundsService.save(spuBounds);

return R.ok();
}

总结:当两个服务之间通过Feign进行远程调用时,只需要保证以下几点:

  • @FeignClient("gulimall-coupon")中微服务名和该服务在注册中心中的名称一致
  • @PostMapping("/coupon/spubounds/save")访问url地址路径一致和@PostMapping发送方式一致
  • R 返回值一致
  • SpuBoundTo和SpuBoundsEntity中的属性一致
  • save(@RequestBody SpuBoundsEntity spuBounds)封装格式一致

至于方法名(如示例代码中的saveSpuBounds和save)和对象名(如示例代码中的SpuBoundTo和SpuBoundsEntity)不一致也可以进行数据之间的传递

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM