spring cloud stream 3.1.2 源码搭配rocketmq绑定学习 (一)

新版建议用响应式函数编程 即Function/Supplier/Consumer方式, 后续简称为Function

文章中使用的外部消息中间件是rockermq, 所以后续外部消息中间件都称为rockermq.
如: (先从图简单看看stream和外部消息中间件之间的绑定关系)
-> (先从图简单看看stream和rocketmq之间的绑定关系)

先从图简单看看stream和rocketmq之间的绑定关系

先粗略梳理一下流程:

初始化

1. 根据配置文件或者扫描包把Function属性注册成Bean, 完成之后会创建对应的Input/Ouput的MessageChannel.
2. Function进行初始化, 找出上一步中注册的Bean中的functionDefinition进行相应的处理后注册进MessageDispatcher的Handlers中.
3. BindingLifecycle开始注册并调用start, 将MessageChannel和rocketmq进行绑定.

调用

1. rocketmq接收到消息.找到初始化第三步绑定的MessageChannel并把消息发送.
2. MessageChannel会调用子类中的方法找到对应的MessageDispatcher,调用初始化第二步中注册进Handlers的方法, 完成消息的消费.

以上就是一个简单版本的 spring cloud stream 和 rocketmq 的关联关系

Wish. Do.

原文转载：http://www.shaoqun.com/a/751787.html

跨境电商：https://www.ikjzd.com/

yiqu：https://www.ikjzd.com/w/210

myshow：https://www.ikjzd.com/w/2235

新版建议用响应式函数编程即Function/Supplier/Consumer方式,后续简称为Function文章中使用的外部消息中间件是rockermq,所以后续外部消息中间件都称为rockermq.如:(先从图简单看看stream和外部消息中间件之间的绑定关系)->(先从图简单看看stream和rocketmq之间的绑定关系)先从图简单看看stream和rocketmq之间的绑定关系先粗
跨境通网站：https://www.ikjzd.com/w/1329
taofenba：https://www.ikjzd.com/w/1725
ebay易趣：https://www.ikjzd.com/w/210
运营工具：你要的常用免费关键字搜索工具推荐！：https://www.ikjzd.com/home/136664
2018年亚马逊卖家们追过的黑科技大全！：https://www.ikjzd.com/home/10344
撞见女友和继父洗浴城缠绵：http://lady.shaoqun.com/m/a/270646.html