SpringCloud-Hystrix断路器 @HystrixCommand 可监控报警

个人理解：此种方式只是针对某一个请求作处理，控制比较细
前提：注册中心，消费者可通过Feign调用生产者，都已经跑通
可参考：https://blog.csdn.net/qq_41712271/article/details/104757725

假如需求：订单服务 调用 产品服务，测试时，往产品服务项目中添加故意超时的代码即可
1 订单服务的项目，添加依赖

<!--hystrix依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<!--springboot整合redis-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2 订单服务的项目，启动类添加注解

//开启hystrix
@EnableCircuitBreaker

3 订单服务项目的配置文件application.yml

server:
port: 8781
#指定注册中心地址
eureka:
client:
serviceUrl:
defaultZone: http://192.168.0.12:8761/eureka/
#服务的名称
spring:
application:
name: order-service
redis:
database: 0
host: 127.0.0.
password: 123456
port: 6379
timeout: 2000
#自定义负载均衡策略
product-service:
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
#修改feign调用超时时间
feign:
#开启feign支持hystrix
(注意，一定要开启，旧版本默认支持，新版本默认关闭)
hystrix:
enabled: true
client:
config:
default:
connectTimeout: 2000
readTimeout: 2000
#execution.isolation.thread.timeoutInMilliseconds=2000
#设置hystrix超时时间
hystrix:
command:
default:
execution:
isolation:
thread:
timeoutInMilliseconds: 2000

4 订单服务的项目，Control层请求时，添加@HystrixCommand注解

@RestController
@RequestMapping("api/v1/order")
public class OrderController {
@Autowired
private ProductOrderService 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;
}
}

最后

以上就是单纯白云为你收集整理的SpringCloud-Hystrix断路器 @HystrixCommand 可监控报警的全部内容，希望文章能够帮你解决SpringCloud-Hystrix断路器 @HystrixCommand 可监控报警所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。