我正在使用 Cassandra 数据库开发一个简单的 Spring Boot 微服务。
我的服务器中的主要实体在下面的 Subscription
类中:
public final class Subscription {
private String id;
private String firstUser;
private String secondUser;
private String firstUserStatus;
private String secondUserStatus;
}
我的存储库使用订阅对象并将其持久化。
但在坚持之前,我应该检查一些约束,主要是不能有另一个订阅具有相同的 firstUser
和 secondUser
。
它可能失败的情况非常简单:
- 将保留一个订阅
- 正在验证表是否存在另一个订阅 相同的用户
- 现在可以保留具有相同用户的另一个订阅,并且 使之前的验证过时
- 持续订阅。
正确的解决方法是什么?
值得一提的是:用户的顺序并不重要。如果要保留用户“1”和“2”的订阅,则必须存在用户“1”和“2”或“2”和“1”的其他订阅。
UPD:考虑到@bhspencer 的回答,我可以提出另一种情况(我还需要强制状态保持一致):
- 将使用
firstUserStatus="ISSUED"
和secondUserStatus="WAITING_ACTION"
保留一个订阅
- 正在验证表是否存在具有相同用户的另一个订阅
- 具有相同 ID(用户)和
firstUserStatus="WAITING_ACTION"
和secondUserStatus="ISSUED"
的另一个订阅现在可以保留并使之前的验证过时< - 正在保留初始订阅并覆盖已存在的订阅 ->
secondUserStatus="ISSUED"
丢失
最佳答案
使对象的 id 成为 firstUser + secondUser 的串联。使 id 成为主键,以确保您的订阅是唯一的。
由于您的排序要求,您应该首先对 firstUser 和 secondUser 进行排序,然后按排序顺序将它们连接起来。这样做意味着 generateId("1", "2") 和 generateId("2". "1") 都会生成相同的 ID“1-2”。
public String generateId(String firstUser, String secondUser) {
List<String> ids = new ArrayList<>();
ids.add(firstUser);
ids.add(secondUser);
Collections.sort(ids);
String result = ids.get(0) + "-" + ids.get(1);
return result;
}
关于java - 如何处理 Cassandra 中的竞争条件?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54184281/