메시지 큐는 요청을 즉시 처리할 작업자와 분리합니다. 생산자가 빠르게 메시지를 넣어도 소비자는 자신이 처리할 수 있는 속도로 가져옵니다.
데모에서 입력 속도가 높을 때 대기열이 자라고 소비 단계에서 하나씩 줄어듭니다. 큐 길이만큼 지연이 생기므로 적체와 실패 메시지 처리 방식을 관측해야 합니다.
언제 쓰나
이메일 발송이나 이미지 처리처럼 요청 밖에서 처리해도 되는 작업을 완충할 때 사용합니다.
메시지 큐
Message queue
생산자가 보낸 작업을 큐에 쌓고 소비자가 처리 가능한 속도로 꺼냅니다.
···
<div class="scene"><div class="title">BURST → BUFFER → WORKER</div><div class="row"><div class="tile">PRODUCER<br><b id="sent">0 sent</b></div><div class="queue" id="queue"></div><div class="tile">WORKER<br><b id="done">0 done</b></div></div><div class="muted" id="queueState">Queue absorbs a burst</div></div>.scene{width:min(94vw,760px);height:min(86vh,320px);padding:clamp(10px,2.5vmin,18px);border:1px solid var(--line);border-radius:14px;background:var(--surface);color:var(--fg);font:500 clamp(11px,1.3vw,16px)/1.25 "Pretendard Variable",Pretendard,-apple-system,sans-serif;display:flex;flex-direction:column;gap:clamp(7px,1.6vmin,12px);overflow:hidden}.scene *{box-sizing:border-box}.title{font-weight:750;color:var(--accent)}.muted{color:var(--muted)}.mono{font-family:ui-monospace,monospace}.row{display:flex;align-items:center;justify-content:center;gap:clamp(5px,1.4vmin,12px);flex:1;min-height:0}.tile{border:1px solid var(--line);border-radius:8px;background:var(--bg);padding:clamp(6px,1.6vmin,12px);text-align:center;min-width:0}.on{border-color:var(--accent)!important;background:color-mix(in srgb,var(--accent) 12%,var(--surface))!important}.pulse{animation:pulse 1.6s infinite alternate}@keyframes pulse{to{border-color:var(--accent);transform:translateY(-3px)}}.queue{flex:1;min-width:70px;height:52%;border:2px solid var(--accent);border-radius:8px;display:flex;align-items:center;justify-content:flex-end;gap:3px;padding:5px}.queue i{width:14%;height:70%;border-radius:4px;background:var(--accent);animation:pulse 1s infinite alternate}.tile b{color:var(--accent)}let sent=0,done=0,t=0;function tick(){if(t%8<5)sent+=2;else done=Math.min(sent,done+2);const count=Math.min(6,sent-done);document.getElementById('queue').innerHTML='<i></i>'.repeat(count);document.getElementById('sent').textContent=sent+' sent';document.getElementById('done').textContent=done+' done';document.getElementById('queueState').textContent=count>=5?'Backlog rises during burst':'Worker drains backlog';if(++t%16===0){sent=0;done=0}}tick();setInterval(tick,500)