2017-01-18 1 views
1

소비자 및 생산자가 서버에 2000 개의 메시지를 보내는 중 ACK가 활성화되었습니다. 내가 본 것은 약 1700 개의 메시지 만 소비자에게 전달된다는 것입니다. 누군가가 무엇이 잘못되었는지 말할 수 있습니까?rabbitmq-c 소비자가 모든 메시지를 수신하지 않음

내가 rabbitmq-C 라이브러리에서 제공하는 예제 코드를 실행하고

./amqp_producer 로컬 호스트 5672 1000

1000 MS : 1000 보낸 - 지난 보고서 (999 Hz에서) 이후 1000 생산자 - 메시지 수 : 2000 총 시간 (밀리 초) : 2001 전체 메시지 당 초 : 999.083

루트 @ CE-브래지어-MX240-E : /usr/sbin/rabbitmq_server-3.6.6 # sbin에/rabbitmqctl의 list_connections는 목록 연결을 send_cnt. .. 루트 @ 가전 - 브래지어-MX240-E : /usr/sbin/rabbitmq_server-3.6.6 # sbin 디렉토리/rabbitmqctl의 list_channels는 리스팅 채널 ... #의 ./amqp_consumer 로컬 호스트 5672 3275 밀리 messages_unacknowledged : 1 수상 - 지난 보고서 (0 Hz) 이후 1 개 3275 ms : 지난 보고서 (1919 Hz) 이후 2 - 1 수신 3277 ms : 지난 보고서 (656 Hz) 이후 3 - 1 수신 4001 ms : 지난 보고서 이후 727 - 724를 받았습니다. (999 Hz) 5000 ms : 마지막 보고서 (1001 Hz) 이후 1727 - 1000 수신

2000 년 중 1727 개가 소비자에게만 수신됩니다. 소비자가 no-ack 플래그를 0으로 설정했습니다.

답변

1

디스플레이 문제 일뿐입니다. amqp_consumer.cc의 요약 정보를 제공 한 자유 주의자가 다음 요약을 잘못 수집하는 타임 스탬프를 늘리는 버그를 표시했습니다.

+0

정답으로 표시해주세요. 고마워! – cantSleepNow

관련 문제