Описание тега chronicle-queue
1
ответ
Очередь хроники: использование с меньшим количеством или без лямбд
Документация показывает использование appender или tailer, как правило, с лямбдой, например: appender.writeDocument(wireOut -> wireOut.write("log").marshallable(m -> m.write("mkey").text(mkey) .write("timestamp").dateTime(now) .write("msg").te…
06 мар '17 в 16:07
1
ответ
Хроника Потребитель не правильно читает записи?
Я использую хроническую очередь (5.16.13) для записи и чтения значений json в файл хроники. Для записи объектов я использую следующее в цикле try (final DocumentContext dc = appender.writingDocument()) { dc.wire().write(() -> "msg").text("Hallo a…
11 сен '18 в 10:52
1
ответ
Сходство на основе JNA в Linux невозможно использовать, так как не удалось загрузить
У меня есть проект слушателя, реализованный на Java, который использует данные из kafka и помещает их в очередь Vanilla Chronicle. Я использую библиотеки Java jna, jna-platform версии 4.4.0 и хронической очереди версии 3.6.4. Когда я запускаю проект…
08 сен '17 в 11:28
1
ответ
Исключение NPE при чтении из очереди при удалении старых файлов данных очереди
Я открыл вопрос для этого: https://github.com/OpenHFT/Chronicle-Queue/issues/534 Я пытаюсь реализовать периодическую старую логику очистки файла очереди, используя StoreFileListener. Я использую последнюю версию net.openhft:хроника-очередь:5.16.13. …
17 сен '18 в 22:49
2
ответа
Создание очереди ванили
Раньше это работало с хронической очередью v3. Это не создает очередь в v4. Что я делаю неправильно? Благодарю. ChronicleronicleSignal = ChronicleQueueBuilder.vanilla("somePath"). Build (); ExcerptAppender appender =ronicleSignal.createAppender();
27 дек '16 в 16:37
0
ответов
Как заставить хроническую очередь ждать, пока событие не будет полностью записано на диск
Скажем, у меня есть требование, чтобы убедиться, что все записи на диск подтверждаются перед возвратом из вызова appender.writeText(). Возможно ли это, и если да, то как сделать так, чтобы все было записано на диск и сохранено? Я понимаю, что это вл…
12 дек '18 в 19:07
1
ответ
Очередь хроники - когда срабатывает StoreListener
CQ: 4.5.27. Я создал 2 хроники для одной для записи (один поток) и другой читатель (N потоков), читающий один и тот же файл с использованием одного хронического чтения. SingleChronicleQueue chronicleWriter = chronicleFactory.createChronicle("Writer"…
13 дек '17 в 17:56
1
ответ
Выбираемый индекс хроники и файл данных
Мы пытаемся использовать Chronicle HFT в качестве доказательства концепции черно-белых компонентов обмена сообщениями с низкой задержкой. Мы используем хронику 1.7.2.jar У нас есть читатель и писатель, писатель продолжает писать выдержки в хронику, …
07 июн '16 в 14:44
1
ответ
Как сериализовать простой объект для Chronicle Queue с помощью Chronicle Wire
В настоящее время я помещаю свои объекты в очередь хроники следующим образом ExcerptAppender appender = SingleChronicleQueueBuilder .binary("/path_to_chronicle/") .build() .acquireAppender(); // Write synchronized (appender) { appender.writeText(obj…
26 фев '19 в 11:03
1
ответ
Хроника очереди Tailer останавливается при перезапуске appender
В приведенном ниже коде, перезапуск процесса Tailer в порядке. Тем не менее, перезапуск процесса appender приводит к тому, что tailer не получает больше сообщений. Есть ли способ перезапустить приложение и оставить канал открытым? Отредактировано: н…
04 дек '18 в 05:44
1
ответ
SIGSEGV в хронике очереди 4.5.19
Что может привести к хронической очереди в Segfault? Я предполагаю, что где-то пропустил конфигурацию. У меня есть очередь ReadOnly Chronicle, созданная следующим образом: ChronicleQueue readQueue = SingleChronicleQueueBuilder.binary (readBasePath).…
03 янв '17 в 17:50
0
ответов
Сравнение производительности для хроники 3.2.5 и 4.6.61 с использованием JMH
Я провел базовое тестирование JMH с использованием фиктивных данных в последней версии хроники (4.6.61) и обнаружил, что производительность снижается по сравнению с предыдущей версией 3.2.5. Может ли HFT прокомментировать полученные данные? Результа…
26 янв '18 в 16:52
2
ответа
Я создал единую очередь с ежедневной прокаткой
Я создал единую очередь с ежедневной прокаткой. На следующий день я не могу прочитать последнее добавленное сообщение. Я обнаружил, что индекс Tailer не перемещается к последнему циклу автоматически после прочтения всех сообщений в предыдущем цикле.…
26 июл '16 в 11:46
1
ответ
Как хроника очереди позволяет удаленному appender и tailer
Я только начинаю читать последнюю документацию V4. Рекомендуется для удаленного добавления и хвоста, рекомендуется использовать chronicle-engine, Требуется ли для предприятия поддержка этого набора функций? Я посмотрел вокруг тестовых пакетов chroni…
12 дек '17 в 16:21
1
ответ
Относительно подтем в хронической очереди
Я ищу писать сообщения в одну очередь. Я хотел бы использовать функциональность подтем, чтобы тейлеры могли выбирать либо читать все подтемы в одной теме, либо выбирать конкретные подтемы для чтения. В документации упоминается, что подтемы поддержив…
05 дек '17 в 17:33
0
ответов
Очередь хроники - как считыватель методов может перехватывать все сообщения, не зная типа сообщения
Мне нужно создать простую программу (tailer), которая будет смотреть в хронологическую очередь и распечатывать статистику, т.е. количество сообщений каждого "типа". Очередь была написана с интерфейсом Method Writer. Несколько интерфейсов писателя бы…
26 ноя '18 в 09:52
0
ответов
Очередь хроники: StoreFileListener несколько onAcquired и onReleased
Я использую Chronicle 4.5.27. Ниже приведена простая реализация Writer и Reader с StoreFileListner. В Reader я получаю несколько событий onAcquired и onReleased. Почему это произойдет? Я ожидаю получить только один Acquire (когда файл получен для чт…
03 янв '18 в 13:50
1
ответ
Chronicle Queue замедляется и заканчивается память
Я оцениваю Chronicle Queue для использования в нашем программном обеспечении, и я, должно быть, делаю что-то не так.У меня есть приложение, которое очень быстро напишет около 650 тыс. Записей. После этого он останавливается, и в этот момент память р…
18 май '17 в 21:49
2
ответа
Хроника Очередь V3. Могут ли записи быть потеряны при переносе блока данных?
У меня есть приложение, которое записывает записи в Chronicle Queue (V3), которое также сохраняет значения индекса записей выдержки в других (Chronicle) картах путем предоставления индексированного доступа в очередь. Иногда нам не удается найти данн…
30 июн '17 в 15:24
0
ответов
Хроника очереди, сериализующие метки
Использование версии 4.5.27 Я использую этот код, чтобы записать Throwable в очередь, а затем прочитать его обратно. public static void writeThrowableToQueue(){ final Throwable throwable; try { throw new RuntimeException("serialise"); }catch(Throwab…
10 май '17 в 16:06