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

Вопросы с тегом
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 ответ

Как читать данные, сериализованные с помощью Chronicle Wire, из InputStream?

Некоторые данные сериализуются в выходной поток через Chronicle Wire. Object m = ... ; OutputStream out = ... ; WireType.RAW // .apply(Bytes.elasticByteBuffer()) // .getValueOut().object(m) // .bytes().copyTo(out) ; Я хочу вернуть их из Inputstream.…
29 ноя '18 в 16:28
1 ответ

Запись хроники с задержкой в ​​1-2 секунды при прокрутке файла с течением времени

У нас есть однопоточный java-процесс, который записывает сообщения в очередь хроник. Очередь (SingleChronicleQueue) настраивается с помощью RollCycle HOURLY. При почасовой отметке, когда происходит прокрутка файла, запись хроники занимает больше сек…
25 май '20 в 01:32
2 ответа

Chronicle Queue - readDocument(). IsPresent() возвращает false при наличии значений

Я изменил базовый код здесь [github]https://github.com/OpenHFT/Chronicle-Queue/blob/master/docs/How_it_works.adoc В основном я снимаю в хронологическом порядке одни и те же Маршаллируемые объекты. Я включил несколько операторов печати, чтобы показат…
22 окт '19 в 04:07
1 ответ

Поддерживает ли ChronicleWire необязательные поля в объектах?

Экспериментирую с ChronicleWire. Как описано в функциях, необязательные поля поддерживаются из коробки. Я только что создал простую самоописывающуюся сущность с одним необязательным (допускающим значение NULL) полем: public class Foo extends SelfDes…
21 окт '21 в 01:44
0 ответов

Безотходная серия прото-сообщений

Мы знаем буферы протокола Google как хорошо известный способ описания RPC / Event API сервисов. Но у него есть свои недостатки. Один из них - это дополнительный мусор (официальная реализация Java). Таким образом, это может повлиять на производительн…
21 ноя '21 в 19:53
1 ответ

Как сериализовать список SelfDescribingMarshallables в CSV

Мне нужно сериализовать список SelfDescribingMarshallables того же типа, что и вывод CSV, построчно, используя Chronicle Wire. Но net.openhft.chronicle.wire.WireType#CSVсоздает строку для каждого поля объекта, поэтому это не CSV. Есть примеры кода?
17 дек '20 в 11:11
2 ответа

Можно ли чередовать хвостовики ChronicleQueue для двух разных очередей?

У меня есть две отдельные ChronicleQueue, созданные независимыми потоками, которые отслеживают потоки веб-сокетов в приложении Java. Когда я читаю каждую очередь независимо в отдельной однопоточной программе, я могу пройти всю очередь, как и ожидало…
08 янв '22 в 16:18
1 ответ

Очередь хроники JSON

В настоящее время я пытаюсь маршалировать определенный POJO как JSON и записать его в очередь вывода. Это бег из того, что я пытаюсь сделать: object OrderExecutor { const val OUT_PATH = "${PATH}/order-executor/out" @JvmStatic fun main(args: Array&lt…
28 мар '22 в 08:42
1 ответ

Chronicle Queue: как читать исключения/документы с разными WireKey?

Предположим, что есть очередь хроники и производитель, который записывает в очередь сообщения двух типов. Каждый тип сообщения записывается с другим «WireKey». // Writes: {key1: TestMessage} appender.writeDocument(w -> w.write("key1").text("TestM…
18 апр '22 в 23:55
2 ответа

Могу ли я разобрать файл очереди хроники

Запись данных в очередь хроники. Это создает/обновляет файл очереди хроники и записывается в 20220525F.cq4. Запрос: Можно ли разобрать файл 20220525F.cq4, какой формат данных используется для записи файла?
25 май '22 в 13:01
1 ответ

Очередь хроник: записьHistory() больше недоступна?

Я хотел бы протестировать производительность очереди, используя метод, продемонстрированный в github README. Однако, когда я попробовал последнюю версию (очередь хроники: 5.23ea5, хроника-провод: 2.23ea5), она оказалась недоступной, я дважды провери…
27 апр '22 в 02:46
0 ответов

Хроника-Очередь: Почему занято-ожидающий хвостик при вращении генерирует мусор (нечего читать)?

У меня есть цикл ожидания, в котором хвостовик постоянно пытается прочитать из очереди: final Bytes<ByteBuffer> bbb = Bytes.elasticByteBuffer(MAX_SIZE, MAX_SIZE); // Busy wait loop. while (true) { tailer.readDocument(wire -> { wire.read().m…
05 май '22 в 14:50
0 ответов

Метод выпуска Chronicle Bytes устарел

Недавно я перешел на JDK 17 с JDK 11, что вызвало обновление библиотеки Chronicle Wire. Раньше мы использовали версию 2.17.50 с JDK 11, а теперь перешли на версию Chronicle-Wire 2.22.17 и Chronicle-bytes версии 2.22.21. Следующий код отлично работал…
06 апр '22 в 03:25
1 ответ

Как эффективно анализировать и сохранять данные в Chronicle Map

Я пытаюсь найти кратчайший и эффективный путь для анализа значений из json и сохранения некоторых из них на карте хроники. Мое текущее решение: String data = ...; ChronicleMap<CharSequence, Long> map = ...; JSONWire wire = new JSONWire(Bytes.a…
12 окт '22 в 14:21
1 ответ

Spring Boot и динамическая компиляция в Chronicle Wire

Ссылаясь на заголовок выше. Чтобы динамическая компиляция Chronicle wire работала с Springboot, вам необходимо распаковать jar-файлы Chronicle во временный каталог, чтобы компилятор платформы мог видеть классы из толстого JAR-файла. Ссылаясь на доку…
16 ноя '22 в 08:52
1 ответ

Обработка предупреждения очереди хроники: «Чтение управляющего кода в виде текста»

Я читаю предоставленный файл Chronicle Queue через tailer. При создании хвостовика я получаю предупреждающее сообщение: "чтение управляющего кода в виде текста" Кажется, есть определенный раздел(ы) файла, из-за которого регистрируется это предупрежд…
29 июл '22 в 01:57
0 ответов

Как разобрать сложный вложенный json, используя хроническую проводку в виде дерева?

У меня есть действительный json: { "arg": { "channel": "a", "sub": "b" }, "action": "update", "data": [{ "a": [ [ "0.35543", "199.194504", "0", "2" ], [ "0.3556", "0", "0", "0" ] ], "b": [], "ts": "122" }] } И я хочу разобрать его с помощью хроники,…
19 янв '23 в 17:17
0 ответов

Как реализовать асинхронную подписку с использованием сети хроник (tcp)

Я пытаюсь создать клиент-серверное приложение, используя сеть Chronicle (инфраструктура tcp с низкой задержкой). Сервер будет иметь несколько экземпляров, и ожидается, что клиенты будут размещены в разных центрах обработки данных в сети NAM. У меня …
10 фев '23 в 21:44