1、需求,在一個服務內,消息發送和消息接收spring
2、根據網上或者書中處理以下:app
3、結果:報錯,this
Invalid bean definition with name 'input' defined in XXXX.SinkSender: bean definition with this name already existsinput
4、分析緣由it
上圖能夠看出,@EnableBinding的Sink.class和SinkSender.class中,@Input和@Output都定義了名稱相同的Sink.INPUT致使io
5、處理方式class
application.yml修改以下:stream
spring: cloud: stream: bindings: input: destination: raw-sensor-data output: destination: raw-sensor-data
SinkSender修改以下:im