spring-rabbit

1열

2답변

rabbitmq에서 프리 펫 수와 ack 사이의 차이점을 알아야합니까? 또한 다음 문장의 차이점은 무엇입니까 : - 는 프리 페치 수는 10 (10) 소비자 스레드가 생성하지 말 내가 설정 한 경우? 또는 - 내가 10 명의 코스튬을 등록하면 10 개의 스레드가 생성됩니까? 더 효율적입니다 위의

1열

1답변

봄철 토끼가 거절 한 메시지를 전달하려고합니다. 괜찮습니까?

나는 다음과 같은 구성을 spring.rabbitmq.listener.prefetch=1 spring.rabbitmq.listener.concurrency=1 spring.rabbitmq.listener.retry.enabled=true spring.rabbitmq.listener.retry.max-attempts=3 spring.rabbitmq.l

1열

1답변

고부하에서의 RabbitMQ 소비자 이용률은 0입니다.

우리는 약 40 명의 소비자와 함께 spring amqp 기반 리스너 컨테이너를 사용하여 프리 페치 카운트 1을 사용합니다. 메시지 ttl은 데드 레터 큐에 도착하기 전에 약 60 초입니다. 각 소비자가 수행하는 작업은 데이터베이스 업데이트로, 메시지가 큐에 도착하는 속도보다 느립니다. 가끔 메시지가 대기열에 쌓이면 소비자 활용도가 0으로 떨어집니다. 나는

0열

1답변

Spring RabbitMQ 프로젝트에서 여러 가상 호스트를 사용하는 방법은 무엇입니까?

I했습니다 다음과 같은 두 가지 구성 클래스 : @Configuration @EnableRabbit @Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class }) public class RabbitConfigA { @Autowired @Qualifier("rabbitConnectio

0열

1답변

토끼 대기열에서 준비되지 않은 큐로 이동하는 토끼 mQ 메시지

게시자와 게시자가 시작됩니다. 이제는 소비자가 시작하고 문제는 메시지가 준비된 대기열에서 메시지가 다시 전달 된 채로 대기열로 이동한다는 것입니다 나는 내가 ACK가 아닌 소비자 재시작에 보낼 경우에만 재 전달 또는 시작으로 표시해야합니다입니다 원하는 avoid.So 할 구성 : @Bean public org.springframework.amqp.rabb

0열

2답변

Spring rabbit : AspectJ 사용없이 @RabbitListener로 주석 된 인터셉트 메소드 호출

AspectJ를 사용하지 않고 @RabbitListener로 주석 된 bean 메소드 호출을 인터셉트 할 수있는 방법이 있는가? 코드는 내가 방법은 @OtherAnnotation 주석이있는 경우, @RabbitListener 방법에 대한 모든 호출을 차단하기 위해 필요한이 @OtherAnnotation @RabbitListener public void

1열

1답변

RabbitMQ Spring에서 메시지를 수동으로 가져 오는 방법

레코드를 RabbitMQ 큐에서 수동으로 가져오고 자동으로 가져 오지 않아도됩니다. 아래는 내가 그렇게 창조 한 것입니다. 그러나, 더 나은 Spring/RabbitMQ 방법이 있는지 궁금합니다. channel.basicAck 및 channel.basicNack을 사용하게됩니다. 나는 소비자가 예외를 던지면 그 레코드가 대기 상태를 유지할 수 있도록 승인

0열

1답변

SimpleMessageListenerContainer : 소비자가 예외를 발생 시켰습니다. 처리가 지원되면 처리가 다시 시작될 수 있습니다.

스프링 부트 응용 프로그램과 시작을 잘 관리하는 rabbitmq 브로커가 연결되어 있지만 거기에 관계없이 메시지 소비자의 끊임없는 시작/종료가 발생합니다. 대기열에있는 메시지 2016년 10월 19일 11 : 40 : 25,909이 t 경고 : 다음은 내 응용 프로그램 로그 및 클라이언트 클래스의 사본은 [SimpleAsyncTaskExecutor-106]

0열

1답변

어디에 멀티 스레드 환경에서 수신 rabbitListener 구성 요소 내에 스레드 종속 데이터를 저장해야합니까?

다중 스레드 환경에서 스프링 amqp의 주석 기반 접근 방식을 사용하고 있습니다 (여러 소비자 => 여러 개의 토끼 수신기 컨테이너가 있음). @RabbitListener(queues = "tasks") public void receiveMessage(@Payload Task task) { // usage of httpClient here wit

1열

1답변

봄 토끼 봄 거래는

내가 좋아하는 봄 토끼 소비자 있습니다. 난 그것을 확인, 나는 3 테이블에 데이터를 저장 한 다음 예외를 던져 네 번째 테이블에 저장하십시오. 또한 3 개의 previos 테이블의 데이터가 롤백되지 않습니다. 봄에 제대로하는 법? onMessage 메서드의 모든 코드를 트랜잭션 내에 넣고 싶습니다. 감사합니다 UPDATE 내 토끼의 conf : 트랜잭션