最新回答 / 慕娘8336713
confirm是生产者将消息发送到交换机后的回调,ack是true,说明消息已经成功发送到交换机了; returnCallBack是交换机路由到队列的回调,所以路由失败跟ack没关系; 解决方案: 路由失败的时候,把当前消息保存下来(自己随意,不丢就行),然后再针对这部分消息做补偿;
最赞回答 / changfaaipiaorou
发送端有两种配置,confirm模式和非confirm模式。如果处于非confirm模式下,消息由于Productor到broker的网络波动导致失败,无法感知和重试。如果发送端处于confirm模式下,发送的每一条消息,broker会回复一个confirm消息,来确认消息的到达保证HA。confirm模式下发送端的性能会有所下降
最新回答 / 己悦丶
@Input(StreamClient.input)和@Output(StreamClient.input)通道名不能一样
已采纳回答 / Gintoki3172619
看一下第二张图的 #30 行,如果用 Map 接收的话应该用 @Headers 注解,而不是 @Header。另外有个小建议,你的类名里的 AreaRecieve 中的单词是不是拼写错了。
2018-12-21
最新回答 / 0_空想神话_0
可通过注入实现。
@Bean Jackson2JsonMessageConverter messageConverter() { return new Jackson2JsonMessageConverter(); }
2018-11-23