Spring-Cloud-stream-rabbit导致Netty无法启动

Question

他们不能一起工作吗？ 实际上，端口没有被占据。使用Netty TCP连接端口58888（或更改为任何其他端口）IT（Netty）不起作用。当我不使用SpringCloudstream时，Netty可以正常启动。

Netty启动错误： “ java.net.bindexception：已在使用中的地址：绑定”

-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.6.7</version>
  </dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    <version>3.2.2</version>
</dependency>

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.75.Final</version>
</dependency>

​----------------- config ---------------------------------------------------------------- - -

  rabbitmq:
    host: 192.168.31.248
    port: 5672
    username: rabbit
    password: 123456
    virtual-host: /
  cloud:
    stream:
      bindings:
        sms-out-0:
          destination: sms-exchange

- - - - - - - - - - - - - - - - - 消费者 - - - - - - --------------------------------------------------------------------------------

import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.util.function.Consumer;

@Component
public class SmsConsumer {
    
    @Bean
    public Consumer<String> sms() {
        return System.out::println;
    }
}

​ ---------------------------------------------------------------------------------------------------------------------------------------------------------------]

import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;

@Component
public class SmsProducer{
    
    @Resource
    private StreamBridge streamBridge;
    
    public void send(String message) {
        streamBridge.send("sms-out-0" , message);
    }
}

-生产者 为什么没有结果

...........

当我删除消费者时，Netty正常开始。看来这个问题与港口无关，我仍然不明白原因。

导入org.springframework.stereotype.component;

@Component
public class SmsConsumer {
    
//    @Bean
//    public Consumer<String> sms() {
//        return System.out::println;
//    }
}

当我注意到官方文档有避免混乱的技巧时，会进行以下更改

  rabbitmq:
    host: 192.168.31.248
    port: 5672
    username: rabbit
    password: 123456
    virtual-host: /
  cloud:
    function:
      definition: sms
    stream:
      function:
        autodetect: false
      bindings:
        sms-out-0:
          destination: sms-exchange

spring cloud cloud stream官方文档官方文档具有提示避免混淆

，但问题仍然存在，我无法解决

netty startup错误映像