Вопросы по теме 'chronicle'
Могу ли я писать разные типы сообщений в хронику-очередь?
Я хотел бы писать разные типы сообщений в хронику-очередь и обрабатывать сообщения в потребителях в зависимости от их типов.
Как я могу это сделать?
343 просмотров
schedule
22.06.2023
Что произойдет, если потребитель потерпит неудачу в Chronicle
Привет, глядя на Chronicle v3, что произойдет, если потребитель прочитает запись очереди, а затем попытается что-то сделать с этой записью ниже по течению, но потерпит неудачу.
Можно ли снова взять эту запись из очереди? Нужно ли все переигрывать?...
87 просмотров
schedule
25.11.2022
Шаблон наблюдателя для операций, выполняемых на карте хроники
Я с нетерпением жду возможности использовать Chronicle Map в качестве хранилища данных/кеша данных и намереваюсь поделиться им с другими процессами JVM, работающими в том же блоке, чтобы уменьшить объем памяти, занимаемой каждым из других процессов...
341 просмотров
schedule
05.07.2022
Повторное использование OutputStream Chronicle Bytes
Я использую сторонний двоичный кодировщик, который принимает OutputStream. Я получаю OutputStream из метода writeMarshallable Marshallable, подобного этому:
public void writeMarshallable(WireOut wire) {
OutputStream outputStream =...
140 просмотров
schedule
28.08.2022
Почему ChronicleMap не использует hashCode или equals для ключей поиска?
import net.openhft.chronicle.map.ChronicleMap;
import java.io.File;
import java.io.Serializable;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class App {
public static void main(String[] args) throws Exception...
446 просмотров
schedule
23.01.2023
Может ли Chronicle-Map обрабатывать данные больше, чем память?
Я немного смущен тем, как работает память из кучи. У меня есть сервер с 32 ГБ оперативной памяти и набором данных сопоставлений ключ-значение размером около 1 ТБ. Я ищу простую и быструю встроенную базу данных Java, которая позволила бы мне...
626 просмотров
schedule
30.07.2023
Объединение событий с 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
Использование ChronicleMap в качестве базы данных "ключ-значение"
Я хочу использовать ChronicleMap в качестве памяти база данных с сопоставлением пар "ключ-значение" (от String до byte[] ). Он должен быть в состоянии вместить порядка 100 миллионов записей. Чтение/получение будет происходить гораздо чаще,...
663 просмотров
schedule
14.04.2024
Медленный сборщик очереди в многопоточной очереди добавления
У меня есть сценарий, когда несколько потоков записываются в одну и ту же очередь.
Потоки Appender получают обновления с разных рынков (каждый поток — отдельный рынок) и помещают эти данные в одну и ту же очередь:
ChronicleQueue queue =...
327 просмотров
schedule
26.08.2023
Есть ли облегченная версия Chronicle Queue, в которой не используется зацикливание?
Я хочу использовать Chronicle Queuues в качестве входящих для пользовательских сообщений, чтобы каждый пользователь моего приложения имел своя очередь. Однако я столкнулся со следующими «проблемами»:
Поскольку количество сообщений на одного...
596 просмотров
schedule
24.12.2022
Сериализовать объект Java ByteBuffer с помощью Chronicle Wire
Я использовал "javolution", который помогает мне создавать объекты Java, которые можно сериализовать в nio.ByteBuffer, которые затем могут быть сопоставлены со структурами C.
Как я могу добиться того же с помощью Chronicle Wire?
252 просмотров
schedule
04.09.2022
Chronicle Consumer неправильно считывает записи?
Я использую хронику-очередь (5.16.13) для записи и чтения значений json в файл хроники. Для записи объектов я использую следующее в цикле
try (final DocumentContext dc = appender.writingDocument()) {
dc.wire().write(() ->...
420 просмотров
schedule
12.11.2022
хроника-байты, поднимающие segfault
следуя принятому решению в chronicle-bytes shared DirectBytesStores , теперь я настроил свой код в том же путь к принятому ответу.
Я создаю 1 000 000 объектов, которые я записываю в MappedFile, и я хотел бы, чтобы каждый объект мог управлять...
45 просмотров
schedule
26.05.2023
Как сериализовать простой объект для Chronicle Queue с помощью Chronicle Wire
В настоящее время я помещаю свои объекты в очередь хроник следующим образом
ExcerptAppender appender = SingleChronicleQueueBuilder
.binary("/path_to_chronicle/")
.build()
.acquireAppender();
//...
362 просмотров
schedule
14.01.2023
