order service 调用商品库存服务和用户服务

刺骨的言语ヽ痛彻心扉 2022-11-25 13:04 68阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center]

### 文章目录 ###

*  一、修改04项目，完成远程调用
 *   *  1.1 环境配置
     *  1.2 Java源文件修改
 *  二、order-service 配置启动参数,启动两台服务器
 *  三、启动服务，访问测试
 *  四、hystrix dashboard 监控 order service 断路器

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 1]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70]

sp09-feign项目关闭，不再使用

# 一、修改04项目，完成远程调用 #

## 1.1 环境配置 ##

1.  添加依赖：feign，hystrix完整依赖，actuator ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 1]
2.  启用hystrix:
    
     *  yml： `feign.hystrix.enabled=true`  
        ![在这里插入图片描述][20200809102518807.png]
     *  主程序注解： `@EnableCircuitBreaker`  
        ![在这里插入图片描述][20200809102600595.png]
3.  主程序添加启用Feign：`@EnableFeignClients`  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 2]

## 1.2 Java源文件修改 ##

1.  声明式客户端：`ItemFeignClient`， `UserFeignClient`
2.  添加 Hystrix 降级代码
    
     *  声明式客户端接口上指定降级类  
        `@FeignClient(name="item-service", fallback=降级类.class)`
     *  实现降级类

**（1）ItemFeignClient**

package cn.tedu.sp04.order.feignclient;
    
    import java.util.List;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestBody;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.web.util.JsonResult;
    
    @FeignClient(name="item-service", fallback = ItemFeignServiceFB.class)
    public interface ItemFeignService { 
        @GetMapping("/{orderId}")
        JsonResult<List<Item>> getItems(@PathVariable String orderId);
    
        @PostMapping("/decreaseNumber")
        JsonResult decreaseNumber(@RequestBody List<Item> items);
    }

**（2）UserFeignClient**

package cn.tedu.sp04.order.feignclient;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestParam;
    
    import cn.tedu.sp01.pojo.User;
    import cn.tedu.web.util.JsonResult;
    
    @FeignClient(name="user-service", fallback = UserFeignServiceFB.class)
    public interface UserFeignService { 
        @GetMapping("/{userId}")
        JsonResult<User> getUser(@PathVariable Integer userId);
    
        @GetMapping("/{userId}/score")
        JsonResult addScore(@PathVariable Integer userId, @RequestParam Integer score);
    }

**（3）ItemFeignServiceFB**  
获取商品列表的降级方法，模拟使用缓存数据

package cn.tedu.sp04.order.feignFB;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.sp04.order.feign.ItemFeignClient;
    import cn.tedu.web.util.JsonResult;
    import org.springframework.stereotype.Component;
    
    import java.util.Arrays;
    import java.util.List;
    
    @Component
    public class ItemFeignServiceFB implements ItemFeignClient { 
    
        @Override
        public JsonResult<List<Item>> getItems(String orderId) { 
            if(Math.random()<0.5) { 
                return JsonResult.ok().data(
    
                        Arrays.asList(new Item[] { 
                                new Item(1,"缓存aaa",2),
                                new Item(2,"缓存bbb",1),
                                new Item(3,"缓存ccc",3),
                                new Item(4,"缓存ddd",1),
                                new Item(5,"缓存eee",5)
                        })
    
                );
            }
            return JsonResult.err("无法获取订单商品列表");
        }
    
        @Override
        public JsonResult decreaseNumber(List<Item> items) { 
            return JsonResult.err("无法修改商品库存");
        }
    
    }

**（4）UserFeignServiceFB**  
获取用户信息的降级方法，模拟使用缓存数据

package cn.tedu.sp04.order.feignFB;
    
    import cn.tedu.sp01.pojo.User;
    import cn.tedu.sp04.order.feign.UserFeignClient;
    import cn.tedu.web.util.JsonResult;
    import org.springframework.stereotype.Component;
    
    @Component
    public class UserFeignServiceFB implements UserFeignClient { 
    
        @Override
        public JsonResult<User> getUser(Integer userId) { 
            if (Math.random() < 0.4) { 
                return JsonResult.ok(new User(userId, "缓存name" + userId, "缓存pwd" + userId));
            }
            return JsonResult.err("无法获取用户信息");
        }
    
        @Override
        public JsonResult addScore(Integer userId, Integer score) { 
            return JsonResult.err("无法增加用户积分");
        }
    }

1.  修改 `OrderServiceImpl`，使用客户端接口调用远程服务

package cn.tedu.sp04.order.service;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.sp01.pojo.User;
    import cn.tedu.sp04.order.feign.ItemFeignClient;
    import cn.tedu.sp04.order.feign.UserFeignClient;
    import cn.tedu.web.util.JsonResult;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import cn.tedu.sp01.pojo.Order;
    import cn.tedu.sp01.service.OrderService;
    
    import lombok.extern.slf4j.Slf4j;
    
    import java.util.List;
    
    @Slf4j
    @Service
    public class OrderServiceImpl implements OrderService { 
        @Autowired
        private ItemFeignClient itemFeignClient;
        @Autowired
        private UserFeignClient userFeignClient;
    
        @Override
        public Order getOrder(String orderId) { 
            //调用用户，获取用户
            //真是项目中，要获取已经登录的ID
            JsonResult<User> user = userFeignClient.getUser(8);//此处是测试
    
            //调用商品，获取订单商品列表
            JsonResult<List<Item>> items = itemFeignClient.getItems(orderId);
            //TODO: 调用user-service获取用户信息
            //TODO: 调用item-service获取商品信息
            Order order = new Order();
            order.setId(orderId);
            order.setUser(user.getData());
            order.setItems(items.getData());
            return order;
        }
    
        @Override
        public void addOrder(Order order) { 
            //调用用户，增加积分
            userFeignClient.addScore(order.getUser().getId(),1000);
            //调用商品，减少库存
            itemFeignClient.decreaseNumber(order.getItems());
    
            //TODO: 调用item-service减少商品库存
            //TODO: 调用user-service增加用户积分
            log.info("保存订单："+order);
        }
    }

# 二、order-service 配置启动参数,启动两台服务器 #

*  `--server.port=8201`
 *  `--server.port=8202`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 4]

# 三、启动服务，访问测试 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 5]

*  根据orderid，获取订单  
    [http://localhost:8201/123abc][http_localhost_8201_123abc]  
    [http://localhost:8202/123abc][http_localhost_8202_123abc]
 *  保存订单  
    [http://localhost:8201/][http_localhost_8201]  
    [http://localhost:8202/][http_localhost_8202]

# 四、hystrix dashboard 监控 order service 断路器 #

访问 [http://localhost:4001/hystrix][http_localhost_4001_hystrix] ，填入 order service 的断路器监控路径，启动监控，在仪表盘监控上面的hystrix数据

hystrix监控

*  添加 actuator依赖
 *  暴露 hystrix.stream 监控端点  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 6]

*  [http://localhost:8201/actuator/hystrix.stream][http_localhost_8201_actuator_hystrix.stream]
 *  [http://localhost:8202/actuator/hystrix.stream][http_localhost_8202_actuator_hystrix.stream]

在仪表盘监控上面的hystrix数据  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 7]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/dc704efec7da46a2a785cfdf93563735.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/559dd393d5684ac5a36aad67d580fcae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70]: /images/20221124/0d516a9b405c4763819d161e6ea2b429.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 1]: /images/20221124/4302e3aadde948d0b9a5b3c4004ea9b8.png
[20200809102518807.png]: /images/20221124/3dacea6d844e4c6fae56393e44f0523d.png
[20200809102600595.png]: /images/20221124/cc7d94e27b60470dac74b8f41ca1151b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 2]: /images/20221124/7eb5a0915751402d8439e916c6ff063a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 3]: /images/20221124/ab009f9abd6c42adafcface4377ae7a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 4]: /images/20221124/e2ad5c2ded7340e4852e37190e39aa6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 5]: /images/20221124/4274beee73f04388a6534d30659d1132.png
[http_localhost_8201_123abc]: http://localhost:8201/123abc
[http_localhost_8202_123abc]: http://localhost:8202/123abc
[http_localhost_8201]: http://localhost:8201/
[http_localhost_8202]: http://localhost:8202/
[http_localhost_4001_hystrix]: http://localhost:4001/hystrix
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 6]: /images/20221124/75d230df15f7499a8912dc418a458d69.png
[http_localhost_8201_actuator_hystrix.stream]: http://localhost:8201/actuator/hystrix.stream
[http_localhost_8202_actuator_hystrix.stream]: http://localhost:8202/actuator/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 7]: /images/20221124/8ccc5bb19748406ebb6715794091dc2e.png