整合rocketmq/stream-rocketmq启动报错channel.AbstractMessageChannel问题

springboot整合rocketmq/stream-rocketmq启动报错

spring boot、springcloud、springcloud alibaba项目整合rocketmq时。一启动就报错：

Correct the classpath of your application so that it contains a single, compatible version of org.springframework.integration.channel.AbstractMessageChannel

项目pom依赖使用的是：

 <!--RocketMQ --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-stream-rocketmq</artifactId></dependency>

版本是：5.3.0.RELEASE

报错信息：

一启动项目就报错：

Description:An attempt was made to call a method that does not exist. The attempt was made from the following location:com.alibaba.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder.createProducerMessageHandler(RocketMQMessageChannelBinder.java:172)The following method did not exist:org.springframework.integration.channel.AbstractMessageChannel.getChannelInterceptors()Ljava/util/List;The method's class, org.springframework.integration.channel.AbstractMessageChannel, is available from the following locations:jar:file:/D:/zoutao_job/maven_repository/org/springframework/integration/spring-integration-core/5.3.0.RELEASE/spring-integration-core-5.3.0.RELEASE.jar!/org/springframework/integration/channel/AbstractMessageChannel.classIt was loaded from the following location:file:/D:/zoutao_job/maven_repository/org/springframework/integration/spring-integration-core/5.3.0.RELEASE/spring-integration-core-5.3.0.RELEASE.jarAction:Correct the classpath of your application so that it contains a single, compatible version of org.springframework.integration.channel.AbstractMessageChannel

图示：

问题排查：

由报错信息可知是spring-integration-core-5.3.0.RELEASE.jar 的问题

点进源码中，查看AbstractMessageChannel类发现没有getchannelInterceptors方法，且在RocketMQMessageChannelBinder.java:172行，出现报错：

官网查了半天：
https://github.com/alibaba/spring-cloud-alibaba/pull/1503

大概意思就是spring-cloud-starter-stream-rocketmq中自带的spring-integration-core版本过高改版，不适用。

解决方案：

因为一个spring-integration-core版本，就去更改MQ版本太容易出错，所以不采取。之前的版本中spring-integration-core版本为5.2.1是可以用的，所以我们剔除封装好的高版本，改为自定义版本搭配。

更改pom如下：

<!--RocketMQ -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-stream-rocketmq</artifactId><exclusions><exclusion><groupId>org.springframework.integration</groupId><artifactId>spring-integration-core</artifactId></exclusion></exclusions>
</dependency>
<dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-core</artifactId><version>5.2.1.RELEASE</version>
</dependency>

剔除原来自带的5.3.0以上版本，使用5.2.1版本。

启动项目正常：
查看RocketMQMessageChannelBinder 172行已经不报红了。