1

我想使用Chronicle Queues作为用户消息的收件箱，我的应用程序的每个用户都有自己的队列。但是，我面临以下“问题”：

  1. 由于每个用户的消息数量并不多，因此单个用户的所有消息都可以存储在单个队列文件中而无需循环。如何禁用骑自行车？

  2. 如果可以禁用循环，是否可以将整个队列存储在单个文件中，而不是包含单个队列文件和 directory-listing.cq4t 的目录？

  3. 在我的带有 EXT4 文件系统的 Linux 操作系统上，一个空队列使用 83.9Mb 的磁盘空间。这可以减少到只占用内容的大致大小吗？

如果无法规避一个或多个给定问题，是否有另一种方法可以使用 Chronicle Queues 实现用户收件箱，例如子队列或其他？

4

1 回答 1

3

要减小文件的大小，可以减少blockSize队列的使用：

try (final SingleChronicleQueue queue = SingleChronicleQueueBuilder.binary(tmpDir.newFolder()).
    blockSize(4096).
    build()) {

您可以将邮箱名称存储为每个事件的一部分：

try (final DocumentContext documentContext = 
    queue.acquireAppender().writingDocument()) {
    documentContext.wire().getValueOut().
    text("user@mailbox").writeText(email);
}

最后，如果你真的想禁用循环行为，你可以为队列提供一个永不前进的时钟：

final AtomicLong fixedClock = new AtomicLong(System.currentTimeMillis());
try (final SingleChronicleQueue queue = SingleChronicleQueueBuilder.binary(tmpDir.newFolder()).
        timeProvider(fixedClock::get).
        blockSize(4096).
        build()) {

请注意，此操作模式不是受支持的用例。

队列的内部机制需要目录列表文件，因此没有它就无法使用队列。

确保在更改任何这些配置参数时执行测试。

于 2018-01-15T08:08:07.737 回答