ReadSideProcessor 可以管理多个事件吗？

Question

我的应用程序需要管理 3 种类型的事件：创建、编辑和删除。我可以只用一个 ReadSideProcessor 来管理所有这些事件吗？在 prepare 方法中准备语句有什么特定的顺序吗？

Answer 1

是的，ReadSideProcessor.defineEventHandlers接受一个可以举办多个活动的建造者。

由于所有事件都是唯一的，因此定义它们的顺序并不重要。将其视为哈希图（事件，视图存储逻辑）

见下文，

@Override
public EventHandlers defineEventHandlers(EventHandlersBuilder builder) {
    // when Account created, insert account table;
    builder.setEventHandler(TransactionEvent.AccountCreatedEvent.class, (ev, offset) -> {
        System.out.println("offset ->" + offset);
        BoundStatement st = writeAccount.bind()
                                        .setString("account_id", ev.id)
                                        .setString("name", ev.name);


        BoundStatement stOffset = writeOffset.bind(offset);

        return completedStatements(Arrays.asList(st, stOffset));
    });
    // when Deposit, insert history and update balance
    builder.setEventHandler(TransactionEvent.MoneyDepositedEvent.class, (ev, offset) -> {
        System.out.println("offset ->" + offset);
        BoundStatement historyInsert = writeHistory.bind()
                                                   .setString("account_id", ev.id)
                                                   .setLong("amount", ev.amount)
                                                   .setString("type", "DEPOSIT")
                                                   .setTimestamp("at", toTimestamp(offset));

        BoundStatement accountUpdate = updateAccount.bind()
                                                    .setString("account_id", ev.id)
                                                    .setLong("balance", ev.balance + ev.amount);

        return completedStatements(Arrays.asList(historyInsert, accountUpdate, writeOffset.bind(offset)));
    });

    // when Withdrawal, insert history and update balance
    builder.setEventHandler(TransactionEvent.MoneyWithdrawnEvent.class, (ev, offset) -> {
        System.out.println("offset ->" + offset);
        BoundStatement historyInsert = writeHistory.bind()
                                                   .setString("account_id", ev.id)
                                                   .setLong("amount", ev.amount)
                                                   .setString("type", "WITHDRAWAL")
                                                   .setTimestamp("at", toTimestamp(offset));

        BoundStatement accountUpdate = updateAccount.bind()
                                                    .setString("account_id", ev.id)
                                                    .setLong("balance", ev.balance - ev.amount);

        return completedStatements(Arrays.asList(historyInsert, accountUpdate, writeOffset.bind(offset)));
    });
    return builder.build();
}

Answer 2

https://github.com/khazzz/lagomk

查看blog-impl项目 BlogEventProcessor class.

ReadSideProcessor 可以管理多个事件吗？

Can a ReadSideProcessor manage multiple events?

lagom