springcloud-stream之消费者重复消费

标签：loading   class   消息服务   efault   通道   消费   inpu   des   spring   

　　首先本人还没有学习过rabbitmq，还不太知道其exchange和queue的存储和消费的机制。下面是个人的理解，日后要是学习了rabbitmq再来更正

　　springcloud-stream目前案例是使用rabbitmq作为支持，现在默认的destination是topic形式，不同的微服务实例会共享到同一个topic，这个也是因为不同的微服务实例默认是不同组的，不同组的微服务实例是全面消费(重复消费)，同组的微服务实例是竞争关系；如果要避免某些服务实例重复消费（这里的重复消费是：A消费完，B就消费不了，而不是A消费完还能再消费一次），就要进行分组。

 　　分组也比较简单，加上如下配置：

spring:
  application:
    name: cloud-stream-consumer
  cloud:
    stream:
      bindings: # 服务的整合处理
        input: # 名字是一个通道的名称
          destination: studyExchang # 表示要使用的Exchange名称定义
          content-type: application/json # 设置消息类型，本次为json
          binder: defaultRabbit #设置要绑定的消息服务的具体设置
          group: atguiguA # 消防组：ayguiguA

springcloud-stream之消费者重复消费

标签：loading   class   消息服务   efault   通道   消费   inpu   des   spring   

原文地址：https://www.cnblogs.com/ibcdwx/p/14454073.html