SpringCloud之異常報警通知(八)

在之前整合降級的基礎上，整合redis，達到報警的效果(redis的啟動還是之前boot里面整合的redis)

• order-service

  • pom.xml

     <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
      </dependency>

  • application.yml

    spring:
      application:
        name: order-service
      redis:
        port: 6379
        host: 192.168.180.113
        timeout: 2000

     

  • 修改web層，添加redis的邏輯

    @RestController
    @RequestMapping("/api/v1/order")
    public class OrderController {
    ​
    ​
        @Autowired(required = false)
        private ProductOrderServiceImpl productOrderService;
    ​
        @Autowired
        private StringRedisTemplate redisTemplate;
    ​
    ​
        @RequestMapping("/save")
        @HystrixCommand(fallbackMethod="saveOrderFail")
        public Object save(@RequestParam("user_id")int userId, @RequestParam("product_id") int productId, HttpServletRequest request){
    ​
            Map<String, Object> data = new HashMap<>();
            data.put("code", 0);
            data.put("data", productOrderService.save(userId, productId));
            return  data;
        }
    ​
    ​
        //注意，方法簽名一定要要和api方法一致
        private Object saveOrderFail(int userId, int productId, HttpServletRequest request){
    ​
    ​
            //監控報警
            String saveOrderKye = "save-order";
    ​
            String sendValue = redisTemplate.opsForValue().get(saveOrderKye);
            final String ip = request.getRemoteAddr();
            new Thread( ()->{
                if (StringUtils.isBlank(sendValue)) {
                    System.out.println("緊急短信，用戶下單失敗，請離開查找原因,ip地址是="+ip);
                    //發送一個http請求，調用短信服務 TODO
                   redisTemplate.opsForValue().set(saveOrderKye, "save-order-fail", 20, TimeUnit.SECONDS);
                }else{
                    System.out.println("已經發送過短信，20秒內不重復發送");
                }
    ​
            }).start();
    ​
    ​
            Map<String, Object> msg = new HashMap<>();
            msg.put("code", -1);
            msg.put("msg", "搶購人數太多，您被擠出來了，稍等重試");
            return msg;
        }
    ​
    ​
    }

  • 測試：

    

 

2019-10-19 20:56:11.880  INFO 20020 --- [erListUpdater-0] c.netflix.config.ChainedDynamicProperty  : Flipping property: product-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
feign 調用product-service findbyid 異常
2019-10-19 20:56:12.771  INFO 20020 --- [ HystrixTimer-1] io.lettuce.core.EpollProvider            : Starting without optional epoll library
2019-10-19 20:56:12.774  INFO 20020 --- [ HystrixTimer-1] io.lettuce.core.KqueueProvider           : Starting without optional kqueue library
已經發送過短信，20秒內不重復發送