如題，下面貼代碼了：public?interface?StreamClient?{
????String?queueNameIn?=?"OneMessageIn";
????String?queueNameOut?=?"OneMessageOut";
????@Input(queueNameIn)
????SubscribableChannel?input();
????@Output(queueNameOut)
????MessageChannel?output();
}@Component
@EnableBinding({StreamClient.class})
@Slf4j
public?class?StreamReceiver?{
????@StreamListener(StreamClient.queueNameIn)
????@SendTo(StreamClient.queueNameOut)
????public?SysUser?oneMessageIn(SysUser?sysUser)?{
????????log.info("{}",?sysUser);
????????return?sysUser;
????}
????@StreamListener(StreamClient.queueNameOut)
????public?void?oneMessageOut(SysUser?sysUser)?{
????????log.info("{}",?sysUser.getAvatar());
????}
}@RestController
@RequestMapping("/stream")
public?class?StreamMqController?{
????@Autowired
????private?StreamClient?streamClient;
????@GetMapping("")
????public?void?testQueue(){
????????SysUser?sysUser=new?SysUser();
????????sysUser.setAvatar("1.png");
????????sysUser.setName("gaojingsi");
????????streamClient.input().send(MessageBuilder.withPayload(sysUser).build());
????}
}啟動(dòng)了兩個(gè)實(shí)例，9090和9091端口，訪問(wèn)9090端口，就是9090收到，訪問(wèn)9091，就是9091收到，想兩個(gè)實(shí)例都收到怎么辦啊？
Finchley.SR4使用spring cloud stream, 開啟多個(gè)實(shí)例，不分組，為什么只有一個(gè)實(shí)例收到消息？
他門說(shuō)這就是人生
2020-03-07 11:26:38