0
春ウサギのバージョン：1.7.4.RELEASE春RabbitMQの待機確認タイムアウト
これは私のコードです：
@Configuration
public class RabbitmqConfiguration {
public RabbitmqConfiguration(RabbitTemplate rabbitTemplate,ConfirmCallback confirmCallback) throws Exception {
rabbitTemplate.setConfirmCallback(confirmCallback);
ObjectMapper mapper = new ObjectMapper();
mapper.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE);
rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter(mapper));
}
}
@Component
@Slf4j
public class OrderStatusChangeComponentImpl implements OrderStatusChangeComponent,ConfirmCallback{
@Autowired
private RabbitTemplate rabbitTemplate;
@Autowired
private OrderMessageLogComponent orderMessageLogComponent;
@Autowired
private Gson gson;
/*
* (non-Javadoc)
*
* @see org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback#
* confirm(org.springframework.amqp.rabbit.support.CorrelationData, boolean,
* java.lang.String)
*/
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
long nowTime = System.nanoTime();
String uuid = correlationData.getId();
if (ack) {
orderMessageLogComponent.deleteOrderMessageLogByUUID(uuid);
} else {
log.error(cause, nowTime);
}
}
私はJMeterのおよそ512スレッド1000個のループによってのRabbitMQ送信MSGをテストします。
ログを参照してくださいエラーが多すぎます。 チャネルシャットダウン：クリーンチャネルシャットダウン。プロトコル方法：#method<channel.close>(reply-code=406, reply-text=TIMEOUT WAITING FOR ACK, class-id=0, method-id=0)
最後に私のアプリケーションは接続できませんrabbitmq。 btw私のrabbitmqサーバはhealtyです。
「私のアプリケーションは、接続RabbitMQのできない最終的には」明確にしてください - エラーは何ですか？ –
org.springframework.amqp.AmqpIOException：java.net.SocketException：破損したパイプ – Maple