zoukankan      html  css  js  c++  java
  • spring cloud stream 局部异常和全局异常混乱

    缘由:保证消息不丢失(provider端)

    可能会因为mq不可用,或者某些情况,导致消息发送失败。

    spring cloud stream中,监听{destination}.errors,可以捕获消息发送异常信息,伪代码如下

    /**
     * 接收局部错误
     **/
    @ServiceActivator(inputChannel = "repeat-topic.errors")
    public void repeatError(ErrorMessage errorMessage) throws Exception {
        logger.error("[handleError][payload:{}]", ExceptionUtils.getRootCauseMessage(errorMessage.getPayload()));
        logger.error("[handleError][originalMessage:{}]", errorMessage.getOriginalMessage());
        logger.error("[handleError][headers:{}]", errorMessage.getHeaders());
        
        // 这里要记录下发送错误的消息
        // 比如,持久化到redis、mysql等等...
    }
    

    监听errorChannel可以捕获全局消息异常信息,伪代码如下

    /**
     * 接收全局错误
     **/
    @StreamListener(IntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME)
    public void handleError(ErrorMessage errorMessage) throws Exception {
        logger.error("[handleError][payload:{}]", ExceptionUtils.getRootCauseMessage(errorMessage.getPayload()));
        logger.error("[handleError][originalMessage:{}]", errorMessage.getOriginalMessage());
        logger.error("[handleError][headers:{}]", errorMessage.getHeaders());
        
        // 这里要记录下发送错误的消息
        // 比如,持久化到redis、mysql等等...
    }
    

    以上是理想状态下,emmmm,实际上

    在发生错误的时候,由于有默认的负载均衡策略,会将错误信息发送到n个错误处理中的某一个,通过debug源码,发现org.springframework.integration.dispatcher.UnicastingDispatcher.getHandlerIterator(Message<?> message)中,参与负载均衡的handler竟然是(全局+局部)都参与了,那还定义局部有啥用,不如全在全局处理异常得了,但是,我就是需要在处理局部异常啊...,然后疯狂找文档,真是全部的文章都是写着一样的内容,我都怀疑是不是没人在线上场景用spring cloud stream,全是写Demo?

    最终,用稀烂的英语在github上“网络问政”,

    得知,在spring cloud stream 3.1.0版本修复了这个问题(负载均衡策略是局部handler,但是所有错误都会桥接到全局handler上)

    解决办法:

    1. 升级spring cloud stream 版本(>=3.1.0)
    2. 用原生mq写
    3. 像spring cloud stream贡献者所说的,具体查看github issues里的操作

    完毕!

    有三个字送给你,
    一是“诚”,
    二是“勤”,
    三是“专”。
    当你无比地想做成一件事,
    愿意为它倾尽无数心血和努力时,
    结果总不会太差。
  • 相关阅读:
    Linux perf命令详解及常用参数解析
    pidstat 命令(Linux 进程使用资源情况采样)
    Katalon Studio入门学习之三种获取元素方式
    用Spring和c3p0工具简单的实现增删改查
    Spring AOP(面向切面示例)
    Spring属性注入、构造方法注入、工厂注入以及注入参数(转)
    PowerDesigner最基础的使用方法入门学习(转)
    Struts文件上传
    struts转换器
    Struts拦截器
  • 原文地址:https://www.cnblogs.com/jarjune/p/14354476.html
Copyright © 2011-2022 走看看