spring-cloud-stream结合卡夫卡的使用方法是什么 - 行业资讯 - 肥雀云

　　介绍

这篇文章主要介绍了spring-cloud-stream结合卡夫卡的使用方法是什么,具有一定借鉴价值,需要的朋友可以参考下。希望大家阅读完这篇文章后大有收获。下面让小编带着大家一起了解一下。

1。pom文件导入依赖

& lt; !——卡夫卡——比; 　　& lt; dependency> 　　& lt; groupId> org.springframework.cloud 　　& lt; artifactId> spring-cloud-stream-binder-kafka 　　& lt;/dependency>

2.应用程序。yml文件配置

春: 　　云: 　　流: 　　卡夫卡: 　　粘结剂: 　　经纪人:xxx.xxx.xxx。xx: xxxx//卡夫卡的消息中间件服务器地址　　绑定: 　　xxx_output://通道名称　　目的地:xxx//消息发往的目的地,对应的话题在发送消息的配置里面,集团是不用配置的//如果我们需要传输json的信息,那么在发送消息端需要设置内容类型为json(其实可以不写,默认内容类型就是json) 　　xxx_input: 　　目的地:xxx//消息发往的目的地,对应的话题　　组:xxx//对应卡夫卡的组

3。创建消息发送者

@EnableBinding (Source.class)//@EnableBinding是绑定通道的,从古到今。类是春天提供的,表示这是一个可绑定的发布通道　　@ service 　　公开课MqService { 　　　　@ resource (name=KafkaConstants.OES_WORKBENCH_LIFE_DATA_OUTPUT) 　　私人MessageChannel oesWorkbenchChannel;/* * 　　*发送一条卡夫卡消息　　*/公共布尔sendLifeData(对象对象){ 　　MqUtils返回。发送(oesWorkbenchChannel,对象,KafkaConstants.OES_WORKBENCH_LIFE_DATA_OUTPUT); 　　} 　　}//发布通道　　公共接口源{ 　　@Output (KafkaConstants.OES_WORKBENCH_LIFE_DATA_OUTPUT) 　　MessageChannel oesWorkbenchLifeDataOutput ();//发布通道用MessageChannel 　　}

4。创建消息监听者

@Slf4j 　　@EnableBinding (Sink.class) 　　公开课WorkbenchStreamListener { 　　　　@ 　　私人FileService FileService; 　　　　@StreamListener (KafkaConstants.xxx_input)//监听接受通道　　公共空间receiveData (MoveMessage MoveMessage) { 　　} 　　}//接受通道　　公共接口水槽{ 　　@Input (KafkaConstants.OES_WORKBENCH_MOVE_INPUT) 　　SubscribableChannel oesWorkbenchMoveInput ();//接受通道用SubscribableChannel 　　}

接下来就可以愉快的发送监听消息了

感谢你能够认真阅读完这篇文章,希望小编分享spring-cloud-stream结合卡夫卡的使用方法是什么内容对大家有帮助,同时也希望大家多多支持,关注行业资讯频道,遇到问题就找,详细的解决方法等着你来学习!