We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
增加一个模块spring-cloud-huawei-rocketmq,支持RocketMq消息灰度
功能实现逻辑: 1、基于AOP切面对DefaultLitePullConsumer、DefaultPullConsumer与DefaultMQPushConsumer的构造方法进行切面,老项目不需要调整代码,切面中根据灰度规则设置灰度组名称。 2、基于AOP切面对消费者拉取消息的fetchxxx、subscribexxx方法进行切片,统计当前微服务每个消费组的serverAddr、topic、group信息,作为每个消费组的唯一标识。 3、基于AOP切面对RebalanceImpl的getSubscriptionInner方法、DefaultMQPullConsumerImpl的getSubscriptionData方法进行切片,重新构建subscriptionData的subString内容,改为SQL92方式过滤消息。
The text was updated successfully, but these errors were encountered:
chengyouling
No branches or pull requests
增加一个模块spring-cloud-huawei-rocketmq,支持RocketMq消息灰度
功能实现逻辑:
1、基于AOP切面对DefaultLitePullConsumer、DefaultPullConsumer与DefaultMQPushConsumer的构造方法进行切面,老项目不需要调整代码,切面中根据灰度规则设置灰度组名称。
2、基于AOP切面对消费者拉取消息的fetchxxx、subscribexxx方法进行切片,统计当前微服务每个消费组的serverAddr、topic、group信息,作为每个消费组的唯一标识。
3、基于AOP切面对RebalanceImpl的getSubscriptionInner方法、DefaultMQPullConsumerImpl的getSubscriptionData方法进行切片,重新构建subscriptionData的subString内容,改为SQL92方式过滤消息。
The text was updated successfully, but these errors were encountered: