java - 如何为外部存储序列化 JBoss Drools KieBase 集合？

Question

这实际上可能与 Drools 本身无关，但可能只是有一个 Java native 解决方案。我只是一个 Java 菜鸟，继承了一个项目，所以我试图了解最佳实践。

我们有一个基于规则的 Multi-Tenancy 系统，其中业务规则可以由我们的客户动态配置。我们将每个客户端的编译规则存储在 ConcurrentHashMap 中。看起来像这样


ConcurrentMap<String, KieBase> rules = new ConcurrentHashMap<>();


哪里string是代表每个唯一客户端的 UUID。然而，这个问题是水平扩展计算是一个问题，因为这只是一个内存中的 HashMap ，每次更改都会重新编译。如果我们将其扩展，每个客户端都需要监听新的规则更改并在每次发生时重新编译，这感觉很浪费，因为它们总是会产生相同的结果。

我的最终目标是将这些计算出的规则存储在 JVM 之外，以便多个实例可以共享编译后的规则，并且这些实例中的任何一个都可以安全地同时为特定客户端重新编译规则，而所有其他实例都可以可能需要为 那个客户端 等待的规则

所以我的想法是将 Redis 用作 k/v 锁/存储，其中键是 client_id，值是 Drools KieBase 对象的序列化版本。重新计算将使用 transaction 将 redis 存储锁定在该键上(或一些类似的锁定算法)以便其他需要该 client_id 的 KieBase 的实例将等到编译完成并写回数据库。

所以我有几个问题:

1. 此 KieBase 对象的序列化是 Drools 特有的事情还是 Java 中是否有针对任何对象的通用编码序列化机制(是否推荐这样做？)
2. 会像reddisson吗？做我正在寻找的东西吗？如果是这样，有没有人有一个片段可以指出我正确的方向？我基本上需要为每个客户端锁定一个 key ，以便在计算一个实例时多个实例会阻塞，但我最好不想锁定整个数据库，只锁定散列图中的一个条目。

Answer 1

一个简单的 ObjectOutputStream 就足以序列化一个 KieBase 对象。它下面用于写入文件，但您可以通过写入 ByteArrayOutputStream 并以任一形式获取结果来创建 String 或 byte[]。

KieBase kieBase = kieContainer.getKieBase();
FileOutputStream fos = new FileOutputStream( OUTPATH );
ObjectOutputStream oos = new ObjectOutputStream( fos );
oos.writeObject( kieBase );
oos.close();

FileInputStream fis = new FileInputStream( OUTPATH );
ObjectInputStream ois = new ObjectInputStream( fis );
KieBase kieBase1 = (KieBase)ois.readObject();
ois.close();

至于锁定，这取决于您是否需要针对并行运行的多个应用程序(在网络中)锁定外部表示，或者是否有一个(服务器)应用程序将所有内容保存在 HashMap 中。在后一种情况下，任何 Java 对象都有一个监视器:

synchronized( idString ) {
    idString.wait();    // or overloaded form with timeout
}

// different thread 
synchronized( idString ){
    idString.notify();
}

您可以引用 Brian Goetz 的书“Java Concurrency in Practice”。

编辑任何体面的数据库都有写锁定机制。此外，在您的情况下，您甚至可以使用简单的文件存储和文件锁定进行管理，这在 MS Windows 和所有 Unices 上都可用。