Описание тега chronicle

Chronicle is a low latency data fabric for logging, IPC, sharing and processing data.
1 ответ

Может ли Chronicle Map использовать общий сетевой файл для данных только для чтения?

Я хотел бы использовать Chronicle Map для чтения сериализованной карты из общей сетевой папки и последующей ее локальной обработки. У нас было бы более 100 машин, считывающих подготовленные данные с карты - много итераций, но никогда не пишущих. Мог…
11 янв '16 в 20:36
1 ответ

Использование Map3 и Engine в одном проекте?

Поправьте меня, если я не прав, но, похоже, у меня будут проблемы, если я попытаюсь использовать Map3 и Engine в одном проекте из-за одинаковых имен пакетов? Есть ли способ сделать это? PS Примечание: похоже, что основная ветка Engine (по крайней ме…
19 апр '16 в 15:05
1 ответ

Шаблон наблюдателя для операций, выполняемых на карте хроники

Я с нетерпением жду возможности использовать Chronicle Map в качестве хранилища данных / кеша данных и собираюсь поделиться им с другими процессами JVM, работающими в том же блоке, чтобы уменьшить объем памяти каждого из других процессов JVM, иначе …
08 июн '16 в 14:20
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
2 ответа

Обновление хроники-карты сохранилось

Мне нужно обновить постоянное значение. Я имею в виду: ////// Класс InfoEquipoCache используется в качестве значения CM class InfoEquipoCache implements BytesMarshallable { private EquipoCache equipoCache; public void actualiza() { ..... equipoCache…
09 ноя '17 в 17:38
1 ответ

Очень медленная итерация на карте хроники

Я наблюдаю очень медленные итерации по карте хроники - в приведенном ниже примере 93 мс на итерацию по 1 млн записей на моем MacbookPro 2013 года. Мне интересно, есть ли лучший способ итерации или что-то я делаю не так или это ожидается? Я знаю, что…
14 май '17 в 17:37
1 ответ

Хроника Карта семантики атомарности

Меня интересует семантика атомарности в Chronicle Map. Если у меня есть хронологическая карта, совместно используемая двумя узлами (серверами), и я пытаюсь вставить один и тот же ключ в эту карту одновременно на обоих узлах, какова транзакционная се…
1 ответ

Может ли Chronicle Map работать на Java 1.6? или ниже этого?

Я использовал Chronicle Map в Java 1.7 на моей машине. Я хотел знать, могу ли я использовать то же самое на Java 1.6? как я должен построить и развернуть его на сервере, который работает на Java 1.6
19 янв '16 в 07:31
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
1 ответ

Выбираемый индекс хроники и файл данных

Мы пытаемся использовать Chronicle HFT в качестве доказательства концепции черно-белых компонентов обмена сообщениями с низкой задержкой. Мы используем хронику 1.7.2.jar У нас есть читатель и писатель, писатель продолжает писать выдержки в хронику, …
07 июн '16 в 14:44
1 ответ

Использование штучных / атомарных значений в Scala с Chronicle Map

Мы используем ChronicleMap для поддержки сохранности вне кучи в большом количестве разных магазинов, но немного пострадали от проблемы с самым простым вариантом использования. Прежде всего, вот помощник, который я написал, чтобы облегчить создание: …
05 апр '16 в 13:33
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 ответ

Сообщения хроники Java не удаляются после прочтения

Я пытаюсь использовать Java Chronicle 1.9.2 для записи / чтения сообщений. Я знаю, что доступны новые версии, но у меня есть несколько вопросов, прежде чем я потрачу на это больше времени. Мне нужно удалить сообщение, как только я прочитаю выдержку …
19 мар '16 в 14:36
1 ответ

SIGSEGV в хронике очереди 4.5.19

Что может привести к хронической очереди в Segfault? Я предполагаю, что где-то пропустил конфигурацию. У меня есть очередь ReadOnly Chronicle, созданная следующим образом: ChronicleQueue readQueue = SingleChronicleQueueBuilder.binary (readBasePath).…
03 янв '17 в 17:50
3 ответа

Генерирование меньшего количества мусора вызывает более длительные паузы GC

Недавно мы внесли изменения в механизм персистентности нашего приложения, заменив медленную сериализацию на рефлексию, чтобы создать строки операторов SQL, которые выполнялись для базы данных MySQL, с сериализацией через OpenHFT Chronicle, с жестко …
28 июл '16 в 21:41
2 ответа

Я создал единую очередь с ежедневной прокаткой

Я создал единую очередь с ежедневной прокаткой. На следующий день я не могу прочитать последнее добавленное сообщение. Я обнаружил, что индекс Tailer не перемещается к последнему циклу автоматически после прочтения всех сообщений в предыдущем цикле.…
26 июл '16 в 11:46
1 ответ

Как хроника очереди позволяет удаленному appender и tailer

Я только начинаю читать последнюю документацию V4. Рекомендуется для удаленного добавления и хвоста, рекомендуется использовать chronicle-engine, Требуется ли для предприятия поддержка этого набора функций? Я посмотрел вокруг тестовых пакетов chroni…
12 дек '17 в 16:21