Вопросы по теме 'chronicle-queue'
Могу ли я писать разные типы сообщений в хронику-очередь?
Я хотел бы писать разные типы сообщений в хронику-очередь и обрабатывать сообщения в потребителях в зависимости от их типов.
Как я могу это сделать?
343 просмотров
schedule
22.06.2023
Что произойдет, если потребитель потерпит неудачу в Chronicle
Привет, глядя на Chronicle v3, что произойдет, если потребитель прочитает запись очереди, а затем попытается что-то сделать с этой записью ниже по течению, но потерпит неудачу.
Можно ли снова взять эту запись из очереди? Нужно ли все переигрывать?...
87 просмотров
schedule
25.11.2022
Объединение событий с Chronicle Queue
Документ очереди хроники указывает, что приемники хроники могут быть установлены на разных устройствах, и события распределяются по сети из одной очереди хроники. ( http://chronicle.software/products/chronicle-queue/ )
У меня вопрос, можно ли...
205 просмотров
schedule
19.03.2023
Как создать очередь хроник с почасовыми файлами непрерывного хранилища (cq4)
Привет, я новичок в Chronicle Queue. У меня есть некоторые сомнения.
Я хочу создать очередь ChronicleQueue с почасовыми файлами хранилища. Как мне ее создать. Я создаю писателя следующим образом,
ChronicleQueue queue =...
467 просмотров
schedule
01.09.2022
Chronicle Queue замедляется и заканчивается память
Я оцениваю Chronicle Queue для использования в нашем программном обеспечении и, должно быть, делаю что-то не так. У меня есть приложение, которое очень быстро записывает около 650 тысяч записей. После этого он останавливается, и в этот момент память...
671 просмотров
schedule
21.02.2023
OpenHFT Chronicle Queue версии 4 — следующая синхронность?
В версии 3 OpenHFT Chronicle Queue есть API-вызов ExcerptAppender ( nextSynchronous(boolean )), чтобы запросить принудительную запись содержимого очереди на диск ( fsync'd ) после завершения следующего отрывка. Я не вижу подобного вызова в версии 4....
82 просмотров
schedule
02.12.2022
Очередь хроник V3. Могут ли записи быть потеряны при смене блока данных?
У меня есть приложение, которое записывает записи в очередь хроник (V3), которая также сохраняет значения индекса записи выдержки в других картах (хроники) путем предоставления индексированного доступа в очереди. Иногда нам не удается найти...
114 просмотров
schedule
22.07.2023
Chronicle V4 - одновременная запись в той же очереди Chronicle безопасна
Я планирую использовать хронику 4 (SingleChronicleQueue) для IPC.
Я использовал предыдущую хронику 3 (IndexedQueue), и она не была потокобезопасной, и я использовал для создания нескольких очередей для каждого потока, но кто-то сказал мне, что с...
818 просмотров
schedule
10.09.2022
Относительно подтем в очереди хроники
Я хочу писать сообщения в одну очередь. Я хотел бы использовать функциональность подтем, чтобы трейнеры могли выбирать: либо читать все подтемы в рамках одной темы, либо выбирать определенные подтемы для чтения.
В документации упоминается, что...
171 просмотров
schedule
14.12.2022
Очередь хроники: StoreFileListener несколько onAcquired и onReleased
Я использую Хронику 4.5.27.
Ниже представлена простая реализация Writer и Reader с помощью StoreFileListner. В Reader я получаю несколько событий onAcquired и onReleased.
Почему это произойдет? Я ожидаю получить только одно получение (когда...
284 просмотров
schedule
18.05.2023
Медленный сборщик очереди в многопоточной очереди добавления
У меня есть сценарий, когда несколько потоков записываются в одну и ту же очередь.
Потоки Appender получают обновления с разных рынков (каждый поток — отдельный рынок) и помещают эти данные в одну и ту же очередь:
ChronicleQueue queue =...
327 просмотров
schedule
26.08.2023
Есть ли облегченная версия Chronicle Queue, в которой не используется зацикливание?
Я хочу использовать Chronicle Queuues в качестве входящих для пользовательских сообщений, чтобы каждый пользователь моего приложения имел своя очередь. Однако я столкнулся со следующими «проблемами»:
Поскольку количество сообщений на одного...
596 просмотров
schedule
24.12.2022
Chronicle Consumer неправильно считывает записи?
Я использую хронику-очередь (5.16.13) для записи и чтения значений json в файл хроники. Для записи объектов я использую следующее в цикле
try (final DocumentContext dc = appender.writingDocument()) {
dc.wire().write(() ->...
420 просмотров
schedule
12.11.2022
Как сериализовать простой объект для Chronicle Queue с помощью Chronicle Wire
В настоящее время я помещаю свои объекты в очередь хроник следующим образом
ExcerptAppender appender = SingleChronicleQueueBuilder
.binary("/path_to_chronicle/")
.build()
.acquireAppender();
//...
362 просмотров
schedule
14.01.2023
Как обновить запись в очереди хроники?
Я хочу обновить запись по определенному индексу. Мой код не сработал. Спасибо вам всем
appender.writeBytes(Bytes.wrapForRead("1234".getBytes()));
long index = tailer.index();
DocumentContext dc = tailer.readingDocument();...
70 просмотров
schedule
26.05.2023
Восстановление очереди хроники после жесткого сбоя питания
При записи в Chronicle Queue запись по умолчанию не сбрасывается на диск, поэтому я считаю, что все, что находится в кеше грязных страниц ядра Linux, теряется. Каков наилучший подход к гарантированному восстановлению в случае сбоя питания? Будет ли...
98 просмотров
schedule
07.08.2022
Всегда затрагивается первый файл данных в очереди хроник.
Нам интересно, почему ChronicleQueue всегда касается первого файла данных. Есть ли для этого причина?
Похоже, что другой файлообменник не затрагивается, даже если данные считываются с них. Мы делаем что-то не так?
В настоящее время мы используем...
19 просмотров
schedule
14.09.2022
Chronicle Queue Чтение/запись из очереди с использованием нулевого распределения
Я новый пользователь очереди хроник и хочу использовать стратегию нулевого распределения для чтения и записи объектов из очереди хроник. Я хочу использовать очередь и маршалируемую реализацию байтов, например класс pojo, является ли это правильной...
297 просмотров
schedule
24.06.2022
Очередь хроник, читающая сообщения любого типа с помощью readDocument
В очереди хроник у меня написано два типа сообщений. Я хочу прочитать эти сообщения, используя тот же хвостовик, и, если это возможно, тем же методом, например, используя tailer.readDocument().
Кто-нибудь теперь, если это возможно, типы сообщений...
49 просмотров
schedule
08.07.2022
POC очереди хроники вернул непредвиденную задержку
Одна из наших систем имеет микросервисную архитектуру, использующую Apache Kafka в качестве служебной шины. Низкая задержка — очень важный фактор, но еще важнее надежность и согласованность (ровно один раз).
Когда мы проводили некоторые нагрузочные...
41 просмотров
schedule
07.03.2023
