cloud stream分区分析

川长思鸟来 2022-03-31 12:30 181阅读 0赞

上一篇博客从使用的角度了解了spring cloud stream。现在得知道为什么其可以生效。  
我们针对分区做了下面的配置：

# cloud stream 相关
    spring.cloud.stream.bindings.input.destination=streamfenqu
    spring.cloud.stream.bindings.input.group=stream_receiver
    ## 消费组
    spring.profiles.active=
    ## 分区
    spring.cloud.stream.bindings.input.consumer.partitioned=true
    spring.cloud.stream.instance-count=3
    spring.cloud.stream.instance-index=

于是，在消息队列中，生成了三个队列和一个 exchange  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70]  
不言而喻，可以得出上面的关系图  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 1]  
所以，如果我们需要同时搞两个消费组，且具有各自的分区，那么应该修改exchange的名字，来看看是哪里定义的streamfenqu：

spring.cloud.stream.bindings.input.destination=streamfenqu

这是指的通道的目的地，修改exchange只能在此处进行修改，如果现在我有这样一个需求，对于发到exchange:streamfenqu中的消息，我需要分别给两个消费组进行分区消费，那么通道绑定的目的地应该都为 streamfenqu才行，按照道理，这里的路由键由cloud stream生成就重复了。下面我新建一个路由组，并对其进行分区，看有什么结果。(注意这里采用了相同的通道)  
使用下面的配置：

# cloud stream 相关
    spring.cloud.stream.bindings.input.destination=streamfenqu
    spring.cloud.stream.bindings.input.group=stream_receiver_2
    ## 消费组
    spring.profiles.active=
    ## 分区
    spring.cloud.stream.bindings.input.consumer.partitioned=true
    spring.cloud.stream.instance-count=3
    spring.cloud.stream.instance-index=
    # 应用本身相关
    spring.application.name=stream-receiver_2

打开实例  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 2]  
另外生成了几个队列  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 3]  
同时也添加了路由，来测试一下  
消费组stream\_receiver\_2的分区验证截图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 5]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 6]  
消费组stream\_receiver的分区验证截图  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 8]  
![在这里插入图片描述][20190103125536471.png]  
两个分区的消费组和分区功能都分别得到了有效验证

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70]: /images/20220331/9ffb3ac88ad4452d90e5320a6858fd32.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 1]: /images/20220331/647b843cecc04f29825a41a1459e39e0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 2]: /images/20220331/7d7f7a347663495da9ffe5e5e0d923c9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 3]: /images/20220331/fcc58c42236c495a9ac8c9ca59cad578.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 4]: /images/20220331/66cdeaaadf154cb6bfc9f773d156becc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 5]: /images/20220331/7f11bcc9367e40c7b6fd9a0162b51bb2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 6]: /images/20220331/0971853c5e4d4238a1a4ba0c137abfbd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 7]: /images/20220331/a162b2f9a01646c685590c240543cb88.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpZWxpbnJ1aTEyMw_size_16_color_FFFFFF_t_70 8]: /images/20220331/16aa05897cc94fbd9e5a0f74c44b1647.png
[20190103125536471.png]: /images/20220331/ff3c3b7f25a341a2b42369a3f4468064.png