ruansheng

**相关组件** RocketMQ ## 背景说明 Apache RocketMQ 5.0 版本发布后，客户端 SDK 提供了 `gRPC` 协议的支持，以前版本均采用 `Remoting` 协议。 - **Remoting 协议** RocketMQ 早期组件间默认的通信协议, 是 RocketMQ 官方仓库中自带的实现 - **gRPC 协议** 5.0 版本以后开始支持, 旨在以云原生主流技术演进更加轻量、标准、易扩展的客户端服务端通信协议. ## 组件适配...

### Describe what this PR does / why we need it ### Does this pull request fix one issue? ### Describe how you did it ### Describe how to verify...

spring-cloud-xds-adapter module function decoupling

4

### 相关组件 `spring-cloud-starter-xds-adapter` (2.2.x) ### 功能描述 从模块的命名来看, 希望这个模块具备通用的xDS协议适配能力。 ### 需求场景 例如用户扩展了`spring-cloud-starter-alibaba-governance-routing`模块中的路由配置或者有自己的相关实现，希望通过`spring-cloud-starter-xds-adapter`这个通用的协议适配器来转换自己的个性化配置。 ### 调整方案 #### 方案一： See `XdsAutoConfiguration.java`，增加相关Bean覆盖或生效策略来满足用户自定义配置转换的需求。 ```java @Bean public XdsResolveFilter authXdsResolveFilter() { return new AuthXdsResolveFilter(); } @Bean public XdsResolveFilter...

### Describe what this PR does / why we need it Fixed #3143

OpenSergoClient gRPC disconnection: DEADLINE_EXCEEDED

1

## 问题描述 部署`opensergo-control-plane`到K8S后 , 客户端连接成功，也成功加载了并生效了相关配置，超过`Deadline`限定时间(`OpenSergoClient`默认10S)后自动断开 Spring Boot 2.5.12，opensergo-java-sdk 0.1.0，Sentinel 2.0.0-alpha，opensergo-control-plane [基于main分支最新代码部署](https://github.com/opensergo/opensergo-control-plane) ## 问题验证 通过 [sentinel-demo-opensergo-datasource](https://github.com/alibaba/Sentinel/blob/master/sentinel-demo/sentinel-demo-opensergo-datasource) 进行验证 启动客户端后连接正常（`opensergo-control-plane`可以看到客户端的连接的日志），且可以正确的获取到`opensergo-control-plane`中相关CRD配置，通过请求接口验证限流规则也正确的被加载，但是gRPC连接会自动断开，本地启动客户端或者在集群中使用域名`opensergo-control-plane.opensergo-system.svc.cluster.local`连接都有一样的问题。 ```java 2023-03-16 14:30:46.714 ERROR 22976 --- [ault-executor-2] openSergoLogger : Fatal error occurred on...

### Describe what this PR does / why we need it Remove useless code

Update DefaultRocketMQListenerContainer#getMessageType to protected

1

## What is the purpose of the change ``` public interface IMessageConsumer extends RocketMQListener { } ```  Due to project needs, some personalized business operations need to extend the...