Paaiškinkite Prefetch koncepciją ir kaip ji taikoma RabbitMQ, norint valdyti pranešimų pristatymą

Prefetch RabbitMQ yra mechanizmas, kuris riboja kiekį žinučių, kurias vartotojas gali gauti iš brokerio vienu metu, prieš patvirtinant jų apdorojimą.

Tai padeda kontroliuoti apkrovą vartotojui ir išvengti situacijų, kai jis gauna per daug žinučių ir nesugeba jų laiku apdoroti, kas gali sukelti atminties perpildymą ar vėlavimus.

Pavyzdžiui, jei nustatysite prefetch skaičių kaip 1, vartotojas gaus tik vieną žinutę vienu metu ir negaus naujos, kol patvirtins esamos apdorojimą:

var channel = connection.CreateModel();
channel.BasicQos(0, 1, false); // prefetch skaičius = 1

var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) => {
    // žinutės apdorojimas
    channel.BasicAck(ea.DeliveryTag, false);
};

channel.BasicConsume(queue: "task_queue", autoAck: false, consumer: consumer);

Taip prefetch padeda subalansuoti apkrovą ir pagerinti žinučių apdorojimo patikimumą.