编年史与编年史队列包
chronicle vs chronicle-queue package
我刚刚开始使用编年史队列 - 但是我有点困惑 API 用于 reading/writing 队列。具体来说 chronicle-queue-5 vs chronicle-3.5.*
我已经完成了使用编年史的 link which basically uses chronicle-queue API , but there are others like this。
下面这两个有什么区别?
Chronicle chronicle = ChronicleQueueBuilder.indexed(_location).build();
ExcerptAppender appender = chronicle.createAppender();
appender.startExcerpt();
appender.writeUTF("Hello World");
对
ChronicleQueue queue = ChronicleQueue.singleBuilder(_location).build();
final net.openhft.chronicle.queue.ExcerptAppender appender = queue.acquireAppender();
try (DocumentContext dc = appender.writingDocument())
{
dc.wire().write("hello").text("world " );
}
ChronicleQueue 的 Javadoc 文档
和
Chronicle 看起来很像
他们都在向编年史队列写入消息。我相信这个
Chronicle chronicle = ChronicleQueueBuilder.indexed(_location).build();
ExcerptAppender appender = chronicle.createAppender();
appender.startExcerpt();
appender.writeUTF("Hello World");
现在可以像这样写入编年史队列 5
try (final ChronicleQueue queue = SingleChronicleQueueBuilder.binary("temp-dir").build()) {
final ExcerptAppender appender = queue.acquireAppender();
appender.writeText("Hello World");
}
或者如果你想存储 key
:value
数据,像这样
try (final ChronicleQueue queue = SingleChronicleQueueBuilder.binary("temp-dir-2").build()) {
final ExcerptAppender appender = queue.acquireAppender();
try (DocumentContext dc = appender.writingDocument()) {
dc.wire().write("hello").text("world");
}
DumpQueueMain.dump("temp-dir-2");
}
你可以使用
DumpQueueMain.dump("temp-dir-2");
查看数据是如何存储的,例如
# position: 131360, header: 2
--- !!data #binary
hello: world
我刚刚开始使用编年史队列 - 但是我有点困惑 API 用于 reading/writing 队列。具体来说 chronicle-queue-5 vs chronicle-3.5.*
我已经完成了使用编年史的 link which basically uses chronicle-queue API , but there are others like this。
下面这两个有什么区别?
Chronicle chronicle = ChronicleQueueBuilder.indexed(_location).build();
ExcerptAppender appender = chronicle.createAppender();
appender.startExcerpt();
appender.writeUTF("Hello World");
对
ChronicleQueue queue = ChronicleQueue.singleBuilder(_location).build();
final net.openhft.chronicle.queue.ExcerptAppender appender = queue.acquireAppender();
try (DocumentContext dc = appender.writingDocument())
{
dc.wire().write("hello").text("world " );
}
ChronicleQueue 的 Javadoc 文档 和 Chronicle 看起来很像
他们都在向编年史队列写入消息。我相信这个
Chronicle chronicle = ChronicleQueueBuilder.indexed(_location).build();
ExcerptAppender appender = chronicle.createAppender();
appender.startExcerpt();
appender.writeUTF("Hello World");
现在可以像这样写入编年史队列 5
try (final ChronicleQueue queue = SingleChronicleQueueBuilder.binary("temp-dir").build()) {
final ExcerptAppender appender = queue.acquireAppender();
appender.writeText("Hello World");
}
或者如果你想存储 key
:value
数据,像这样
try (final ChronicleQueue queue = SingleChronicleQueueBuilder.binary("temp-dir-2").build()) {
final ExcerptAppender appender = queue.acquireAppender();
try (DocumentContext dc = appender.writingDocument()) {
dc.wire().write("hello").text("world");
}
DumpQueueMain.dump("temp-dir-2");
}
你可以使用
DumpQueueMain.dump("temp-dir-2");
查看数据是如何存储的,例如
# position: 131360, header: 2
--- !!data #binary
hello: world