stream 多个字段分组_SpringCloud 进阶：消息驱动之Spring Cloud Stream 消费者分组

  <dependency>
    <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

spring:
  cloud:
    stream:
      bindings:
         input:
            destination: mytopic
            binder: defaultRabbit
      binders:
         defaultRabbit:
             type: rabbit
             environment:
                spring:
                 rabbitmq:
                     host: localhost
                     port: 5672
server:
  port: 8081
 
 
eureka:
    instance:
      hostname: eureka7001.com  #eureka服务端的实例名称
      instance-id: receiver1
    client:
      service-url:
         # 与注册中心交互的url
        defaultZone: http://eureka7001.com:7001/eureka/
        enabled: true

spring:
  cloud:
    stream:
      bindings:
         input:
            destination: mytopic
            binder: defaultRabbit
      binders:
         defaultRabbit:
             type: rabbit
             environment:
                spring:
                 rabbitmq:
                     host: localhost
                     port: 5672
server:
  port: 8082
 
eureka:
    instance:
      hostname: eureka7001.com  #eureka服务端的实例名称
      instance-id: receiver2
    client:
      service-url:
         # 与注册中心交互的url
        defaultZone: http://eureka7001.com:7001/eureka/
        enabled: true

@RestController
public class SenderController {
 
    @Autowired
    SenderSource source;
 
    @RequestMapping("/send")
    public String sender(String msg) {
        source.output().send(MessageBuilder.withPayload(msg).build());
        return "ok";
    }

spring:
  cloud:
    stream:
      bindings:
         input:
           group: group1

spring:
  cloud:
    stream:
      bindings:
         input:
           group: group1