8.2. 대규모 메시지 처리를 위한 AMQP 수용자 구성
다음 절차에서는 AMQP 수락자를 구성하여 지정된 크기보다 큰 AMQP 메시지를 큰 메시지로 처리하는 방법을 보여줍니다.
절차
<
broker_instance_dir> /etc/broker.xml
구성 파일을 엽니다.브로커 구성 파일의 기본 AMQP 수락자는 다음과 같습니다.
<acceptors> ... <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor> ... </acceptors>
<acceptors> ... <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor> ... </acceptors>
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 기본 AMQP 수락자(또는 구성한 다른 AMQP 수락자)에서
amqpMinLargeMessageSize
속성을 추가하고 값을 지정합니다. 예를 들면 다음과 같습니다.<acceptors> ... <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpMinLargeMessageSize=204800</acceptor> ... </acceptors>
<acceptors> ... <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpMinLargeMessageSize=204800</acceptor> ... </acceptors>
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 이전 예에서 브로커는 포트 5672에서 AMQP 메시지를 허용하도록 구성되어 있습니다.
amqpMinLargeMessageSize
값에 따라 수락자가 204800바이트(즉, 200킬로바이트)보다 크거나 같은 본문이 있는 AMQP 메시지를 수신하는 경우 브로커는 메시지를 큰 메시지로 저장합니다. 이 속성의 값을 명시적으로 지정하지 않으면 브로커는 기본값 102400(즉, 100킬로바이트)을 사용합니다.
-
mq
pMinLargeMessageSize
를 -1로 설정하면 AMQP 메시지에 대한 대규모 메시지 처리가 비활성화됩니다. -
브로커가
amqpMinLargeMessageSize
값을 초과하지 않지만 메시징 저널 버퍼의 크기를 초과하는 영구 AMQP 메시지를 수신하는 경우 브로커는저널에
저장하기 전에 메시지를 큰 코어 프로토콜 메시지로 변환합니다.