Spring Cloud Bus能否在启用EnableBinding（非函数式）时正常配置？

云上老周

2026-8-20

解决Spring Cloud Bus在@EnableBinding模式下的兼容问题

可以在不切换到函数式方案的前提下配置Spring Cloud Bus，具体操作如下：

排除函数式绑定依赖
Spring Cloud 2021.0.3版本的Bus starter默认引入了函数式绑定组件，和@EnableBinding注解冲突，需要在依赖中排除该组件。以Maven为例，修改Bus的依赖配置：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId> <!-- 若使用Kafka则替换为spring-cloud-starter-bus-kafka -->
    <exclusions>
        <exclusion>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-function</artifactId>
        </exclusion>
    </exclusions>
</dependency>

显式启用注解式Bus绑定
创建配置类，通过@EnableBinding指定Spring Cloud Bus内置的通道类，确保注解模式的绑定生效：

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.binding.BusChannels;

@EnableBinding(BusChannels.class)
public class CloudBusBindingConfig {
}

配置消息中间件与Bus参数
根据你使用的消息中间件（如RabbitMQ/Kafka）完成基础配置，并指定Bus的通道目标：

spring:
  rabbitmq:
    host: 你的RabbitMQ地址
    port: 5672
    username: 用户名
    password: 密码
  cloud:
    bus:
      enabled: true
    stream:
      bindings:
        springCloudBusInput:
          destination: springCloudBus
        springCloudBusOutput:
          destination: springCloudBus