Lagom persistentEntityRegistry.register不起作用

我正在尝试用Cassandra和Lagom配置我的第一个实体 .

我问拉格姆如何在 Cassandra 拯救实体?

例如,这是我的UserServiceImpl类:

public class UserServiceImpl implements UserService {

    private final PersistentEntityRegistry persistentEntityRegistry;

    @Inject
    public UserServiceImpl(PersistentEntityRegistry persistentEntityRegistry) {
        this.persistentEntityRegistry = persistentEntityRegistry;
        persistentEntityRegistry.register(UserEntity.class);
    }

    @Override
    public ServiceCall<NotUsed, String> getUserInfo(String id) {
        return (request) -> {
            // Look up the user entity for the given ID.
            PersistentEntityRef<UserCommand> ref = persistentEntityRegistry.refFor(UserEntity.class, id);
            // Ask the entity the Hello command.
            return ref.ask(new UserCommand.Hello(id, Optional.empty()));
        };
    }
}

所以通过执行:

persistentEntityRegistry.register(UserEntity.class);

我应该有一张Cassandra用户表吗?因为我只有:

enter image description here

我不明白我应该在开始我的Lagom项目之前创建表用户还是只保存事件?

请帮忙

回答(1)

2 years ago

Lagom不需要实体表,因为它不是基于对象关系映射或任何类似的 . 其持久层基于事件采购原则 .

消息表将包含实体发出的事件,并且每次将其恢复到内存时都会恢复其状态 .

基本上,事件在消息表中以json格式保存 .

我们也有快照的概念 . 实体状态可以保存为快照(也使用json) . 这发生在每100个事件之后,这是一个小的优化,以避免每次从头开始重放事件 .

我将尽快解释整个机制 .

命令被发送到实体并且事件被持久化(在命令处理程序中发生) . 在持久化事件之后,将它们应用于实体以使其变异(在事件处理程序上发生) .

您重新启动该服务并向该同一实体发送新命令 . 此时实体不在内存中,因此Lagom会将其带入内存,但在处理该新命令之前,它将重放该实体的事件历史记录,以使其恢复到系统停机时的状态 .

之后,将应用该命令并保留新事件 .

在100个事件之后,将保存实体的快照,并且下次当需要重放该同一实体时,我们首先加载快照,然后我们应用在快照之后发生的事件 . 因此,在这种情况下,我们不需要重播整个事件历史记录 .