Skip to content
New issue

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

Support rocketmq message gray #1442

Open
chengyouling opened this issue Feb 11, 2025 · 0 comments
Open

Support rocketmq message gray #1442

chengyouling opened this issue Feb 11, 2025 · 0 comments
Assignees

Comments

@chengyouling
Copy link
Collaborator

增加一个模块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方式过滤消息。

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant