在微服务项目中,进行在一个服务调用其他服务方法时,通常是采用feign去调用,因为调用起来比较简单直接,通过注解以及一些简单的操作就可以了,这里主要对通过RestTemplate调用服务做一个简单的记录。
目录
添加配置类
首先需要注入RestTemplate对象,需要在配置类进行配置。
@Configuration
public class Config {
@Bean
public RestTemplate restTemplate(){
return new RestTemplate();
}
}
具体操作
在实现类中注入RestTemplate和DiscoveryClient类,然后通过DiscoveryClient去获取服务的信息,比如服务地址、服务端口等,然后通过RestTemplate去实现调用操作。具体代码如下。
服务提供者
@RestController
@RequestMapping("/goods")
public class GoodsController {
@Autowired
private GoodsService goodsService;
@GetMapping ("/updateGoods/{id}")
public R updateGoods(@PathVariable Integer id){
return goodsService.updateGoods(id);
}
}
服务消费者
@Service
public class OrderServiceImpl implements OrderService {
@Autowired
private OrderMapper orderMapper;
@Autowired
private RestTemplate restTemplate;
@Autowired
private DiscoveryClient discoveryClient;
@Override
@Transactional(rollbackFor=Exception.class)
public R insertOrder(Order order){
//根据服务名去获取服务信息
ServiceInstance service = discoveryClient.getInstances("goods-service").get(0);
//根据服务名去获取服务信息
ServiceInstance service2 = discoveryClient.getInstances("coupon-service").get(0);
//获取服务地址
String url = service.getHost() + ":" + service.getPort();
String url2 = service2.getHost() + ":" + service2.getPort();
System.out.println("---------------调用商品服务进行库存更新--------------------");
//调用商品服务
Object forObject = restTemplate.getForObject("http://" + url + "/goods/updateGoods/" + order.getGoodsId() + "?id=" + order.getGoodsId(), Object.class);
Map map = (Map) forObject;
if (String.valueOf(map.get("code")).equals("201")){
System.out.println("---------------商品没有库存啦-----------------");
return R.fail(201,"商品没有库存啦");
}
System.out.println("---------------调用商品服务成功-----------------------");
System.out.println("---------------调用优惠券服务,修改优惠券信息--------------------");
//调用优惠券服务
Object forObject1 = restTemplate.getForObject("http://" + url2 + "/coupon/updateCoupon/" + order.getCouponId() + "?id=" + order.getGoodsId(), Object.class);
Map map2 = (Map)forObject1;
if (String.valueOf(map2.get("code")).equals("201")){
System.out.println("---------------优惠券已经使用过了----------------");
return R.fail(201,"优惠券已经使用过了");
}
System.out.println("---------------调用优惠券服务成功-----------------------");
order.setPrice(order.getGoodsPrice() * order.getCouponDiscount());
int i = orderMapper.insertOrder(order);
return i > 0 ? R.ok(order) : R.fail("失败");
}
}
如果调用其他服务方法需要返回结果时,会返回一个Object对象,如果需要获取里面的属性的值,可以把它转成Map,然后通过get(属性名)获取值。
在启动类添加注解
最后则是需要在启动类上添加@EnableDiscoveryClient注解
@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@EnableAspectJAutoProxy(exposeProxy = true)
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
}