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秒内不重复发送