Свързани публикации 'message-queue'
Разпределени съобщения с ниска латентност с RocketMQ — Част 2
Това е втората и заключителна част от блога — разпределени съобщения с ниска латентност с RocketMQ. Ще хвърлим светлина върху трите ключа за гарантиране на капацитета, архитектурата на RocketMQ и бъдещето или системата за съобщения на Alibaba Cloud.
Три ключа за гарантиране на капацитет
Гаранцията за оптимизация с ниска латентност може да не доведе непременно до ситуация без латентност за машина за съобщения. За да осигури гладко изживяване за приложенията, системата за съобщения..
Bullmq — Опашка за съобщения в Node.js
Пакетът BullMQ е мощен инструмент за управление на опашки от съобщения в Node.js. Той е изграден върху популярната библиотека Bull и предоставя допълнителни функции и функционалност за управление на големи опашки от съобщения. Тук ще разгледаме основите на използването на пакета BullMQ и ще обсъдим някои най-добри практики за работа с опашки от съобщения в среда Node.js.
Първата стъпка в използването на пакета BullMQ е да го инсталирате във вашия проект Node.js. Това може да стане с..
Изкуството на отделяне от опашката на съобщенията
През последните няколко десетилетия една от най-важните цели в програмирането за системи може би е отделянето на зависимостите.
Следователно има интерфейси, абстракции, библиотеки и т.н. и т.н.
И открихме, че поканата на опашката от съобщения в система е истинската сделка за разбиване на компонентите и зависимостите.
Какво представлява опашката за съобщения?
Не давам урок за толкова страхотна технология, тъй като не сме истински експерти в тази област, нито тази статия всъщност за..
Свързани въпроси 'message-queue'
Как да разрешите msgget: Няма останало място при грешка на устройството?
Пиша IPC приложение, използвайки опашки от съобщения. Докато използвам функцията msgget() за получаване на опашка за съобщения, получавам тази грешка.
Заявените операции не изискват много място на устройството и също трябва да има място....
5286 изгледи
schedule
23.09.2022
Ниска латентност, голям мащаб на опашка от съобщения
Преминавам през известно преосмисляне на мащабните мултиплейър игри в ерата на Facebook приложенията и облачните изчисления.
Да предположим, че трябва да създам нещо върху съществуващи отворени протоколи и искам да обслужвам 1 000 000 играчи...
19912 изгледи
schedule
04.10.2022
Едновременни/паралелни Http повиквания в опашка с газ
Ако имате много URL адреси за извикване, има ли модели на опашка във F# с някакъв вид ограничение, като да кажем 5 или 10 извиквания наведнъж, преди да продължите към следващата група.
let urls = [
"http://example.com/1",...
125 изгледи
schedule
04.10.2022
NServicebus - Публикуване на съобщение, което съдържа HTML/XML
Използвам NServicebus с pubsub конфигурация. Досега беше наистина страхотно и съвсем просто. Забелязах обаче, че една от крайните точки на моите абонати не приема съобщения, които съдържат HTML/XML низове. Например добавям POCO обект, който...
324 изгледи
schedule
07.10.2022
проблем с postthreadmessage и peekmessage в delphi 2006
Създадох многодетно приложение. Всички прозорци на приложението (W[n]: TMyWindows) са еднакви и всички имат индивидуален обектен клас, свързан с тях (E: TMyObject). Дъщерните прозорци генерират чрез тези обекти някои съобщения. Създадох в основното...
3068 изгледи
schedule
30.11.2022
Услуга за имейл опашка за .NET
Създаваме приложение, което изпраща имейли, използвайки сървърите на нашите клиенти. Сървърите имат различни настройки по отношение на това колко имейли могат да бъдат изпратени на връзка/в секунда/и т.н.
Може ли някой да препоръча компонент за...
698 изгледи
schedule
27.10.2022
Прокси за опашка за съобщения в Python + Twisted
Искам да внедря олекотен прокси за опашка за съобщения. Работата му е да получава съобщения от уеб приложение (PHP) и да ги изпраща асинхронно до сървъра на опашката за съобщения. Причината за този прокси е, че MQ не винаги е наличен и понякога...
2248 изгледи
schedule
10.11.2022
Как да предавате сложни обекти ( std::string ) през boost::interprocess::message queue
Някой има ли примерен код, показващ тръбопровода за сериализиране на std::string, изпращайки го през boost::interprocess::message_queue и връщайки го отново?
2883 изгледи
schedule
10.12.2022
Добре, но не търся това. По същество поставям JavaScript кода на моята страница във функцията и искам тя да бъде извикана веднъж. По този начин не замърсявам глобалното пространство от имена с допълнителни променливи. Във вашия пример не бих се...
173 изгледи
schedule
15.11.2023
Как да изчистите/изчистите буфера на опашката за съобщения във VxWorks?
Бих искал да знам, има ли някакъв метод за изчистване на всички съобщения, които са конвейерно насочени към 1 msgQId?????
1439 изгледи
schedule
13.11.2022
JMS и AMQP - RabbitMQ
Опитвам се да разбера какво е JMS и как е свързано с терминологията на AMQP. Знам, че JMS е API, а AMQP е протокол.
Ето моите предположения (а също и въпроси)
RabbitMQ използва AMQP протокол (по-скоро прилага AMQP протокол)
Клиентите на...
59090 изгледи
schedule
04.11.2022
Трябва ли да използвам опашка за това?
Работя върху приложение, което се занимава с „чувствителни“ данни (известни още като номера на кредитни карти) и за да постигнем съответствие с PCI, трябва да гарантираме, че нашата база данни е отделна от нашите публични сървъри.
За да влязат...
173 изгледи
schedule
15.11.2023
ServiceStack: заменете уеб услуга с опашка от съобщения
Работя по проект, който предоставя API за получаване на информация за продуктите на нашите партньори.
Всяка заявка за търсене към нашия сайт трябва да направи n други заявки към партньорски сайтове, да събере и обобщи данни за продукти, така че...
411 изгледи
schedule
14.10.2022
Внедряване на опашка за съобщения
Търся най-бързия начин да регистрирам съобщение, без производителят да се свързва с който и да е сървър, когато изпраща журнала. Най-добрият сценарий би бил просто да регистрирате съобщението в нещо локално много бързо (памет, локална опашка за...
1013 изгледи
schedule
28.11.2023
Събитията на Socket поставят ли се на опашка във Flash?
Опитвам се да внедря двоичен протокол между флаш приложение и персонализиран Java сървър, използвайки TCP/IP сокети, съобщенията на протокола са с променлива дължина, така че идеята ми е да добавя поле, указващо броя байтове, които трябва да прочета...
246 изгледи
schedule
10.12.2023
Как да стартирате задача по график, когато имате съобщение за опашка на сървъра
На моя сървър ще има съобщение за опашка всеки път, когато някой изпрати формуляр на уебсайта. Съобщението на опашката се създава под:
Server Manager\ Features\ Message Queueing\ Private Queues\FolderName\Queue message.
Това, което се...
581 изгледи
schedule
10.12.2023
Заетото приложение води до фалшиво състояние Не отговаря в Windows 7 - WM_UPDATE
По време на дългосрочни операции нашето приложение C++ Win32 показва модален диалогов прозорец за състояние с лента на процеса, който се актуализира нередовно на всеки няколко секунди или така. Започвайки с Windows 7, разбрахме, че Windows много...
8592 изгледи
schedule
21.12.2023
Опашка за съобщения IPC Python към C
Използвах msgsend и получа от
#include <sys/ipc.h>
#include <sys/msg.h>
от доста време насам.
Току-що излязох с въпроса дали е възможно да се присъединя към комуникацията от програма на python.
Благодаря ти
2934 изгледи
schedule
21.12.2023
4.0/WCF: Най-добрият подход за двупосочна шина за съобщения?
Просто технологична актуализация, след като .NET 4.0 вече е на пазара.
Пиша приложение, което комуникира със сървъра чрез това, което всъщност е автобус за съобщения (вместо извиквания на метод). Това се основава на вътрешната архитектура на...
825 изгледи
schedule
26.12.2023
AMQP basic.get едновременни потребители, изтеглящи от опашката
Когато използвам RabbitMQ като брокер на съобщения, имам сценарий, при който множество едновременни потребители изтеглят съобщения от опашка с помощта на метода basic.get AMQP и използват изрично потвърждение за изтриване на съобщението от опашката....
7460 изгледи
schedule
14.10.2022
