Dispatcher没有频道'unknown.channel.name的订阅者

内容来源于 Stack Overflow,并遵循CC BY-SA 3.0许可协议进行翻译与使用

  • 回答 (1)
  • 关注 (0)
  • 查看 (556)

我正在尝试使用spring绑定来运行发布者和订阅者。

确保目的地(交换)是在本地创建的兔子mq。

出版商(app.yml)

spring:
  cloud:
    stream:
      bindings:
        output:
          destination: HelloDestination
  rabbitmq:
    addresses: xxx.xxx.xx.xxx

订阅者(app.yml)

spring:
  cloud:
    stream:
      bindings:
        input:
          destination: HelloDestination
  rabbitmq:
    addresses: xxx.xxx.xx.xxx
server:
  port: 8081

出版商(pom.yml)\ t

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
            <version>2.1.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-integration</artifactId>
        </dependency>

订阅者(pom.yml)

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
            <version>2.1.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-integration</artifactId>
        </dependency>

发布者(源java文件)

@SpringBootApplication
@EnableBinding(Source.class)
public class Demo1Application {

    //@Autowired
    //private static MessageChannel output;

    public static void main(String[] args) {
        SpringApplication.run(Demo1Application.class, args);

        String sampleMessage = "Hello";
        Message<String> message =
                MessageBuilder.withPayload("Hello World").build();

        MessageChannel output = new DirectChannel();

        output.send(message);   

    }

}

//消费者(源文件)

@SpringBootApplication
@EnableBinding(Sink.class)
public class Demo2Application {

    public static void main(String[] args) {
        SpringApplication.run(Demo2Application.class, args);
    }

    @StreamListener(Sink.INPUT)
    public void listenerMethod(Message<String> message)
    {
        System.out.println("The Message is :"+message);
    }
}

//----

完成所有操作后,我会看到创建的交换以及交换时的消息。消费者开始就好了。但是当尝试使用错误消息发送消息时,生产者会窒息

Exception in thread "main" org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'unknown.channel.name'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers, failedMessage=GenericMessage [payload=Hello World, headers={id=ccf86001-5dba-6c64-bc76-e1f58782de42, timestamp=1558883876384}], failedMessage=GenericMessage [payload=Hello World, headers={id=ccf86001-5dba-6c64-bc76-e1f58782de42, timestamp=1558883876384}]
    at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77)
    at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:461)
    at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:401)
    at com.example.demo.Demo1Application.main(Demo1Application.java:29)
Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers, failedMessage=GenericMessage [payload=Hello World, headers={id=ccf86001-5dba-6c64-bc76-e1f58782de42, timestamp=1558883876384}]
    at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:138)
    at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:105)
    at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscri

我希望阅读这条消息。

提问于
用户回答回答于

您需要从run()方法返回的应用程序上下文中获取通道“输出”,而不是创建自己的DirectChannel。

扫码关注云+社区

领取腾讯云代金券