Finchley.SR4使用spring cloud stream, 开启多个实例，不分组，为什么只有
如题，下面贴代码了：
public interface StreamClient { String queueNameIn = "OneMessageIn"; String queueNameOut = "OneMessageOut"; @Input(queueNameIn) SubscribableChannel input(); @Output(queueNameOut) MessageChannel output();}@Component@EnableBinding({StreamClient.class})@Slf4jpublic 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()); }}启动了两个实例，9090和9091端口，访问9090端口，就是9090收到，访问9091，就是9091收到，想两个实例都收到怎么办啊？ |
免责声明：本内容仅代表回答会员见解不代表天盟观点，请谨慎对待。
版权声明：作者保留权利，不代表天盟立场。
|
|
|
|
|
|
|
|
天盟APP下载
