草庐IT

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

coder 2023-11-07 原文

这实际上可能与 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 ，以便在计算一个实例时多个实例会阻塞，但我最好不想锁定整个数据库，只锁定散列图中的一个条目。

最佳答案

一个简单的 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 上都可用。

关于java - 如何为外部存储序列化 JBoss Drools KieBase 集合？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41645483/

何为KieBasesectioncodejavaconcurrencyredisdrools

有关java - 如何为外部存储序列化 JBoss Drools KieBase 集合？的更多相关文章

  1. ruby - 解析 RDFa、微数据等的最佳方式是什么，使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2

    我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i

  2. ruby - 如何为 emacs 安装 ruby​​-mode - 2

    我刚刚为fedora安装了emacs。我想用emacs编写ruby。为ruby​​提供代码提示、代码完成类型功能所需的工具、扩展是什么？ 最佳答案 ruby-mode已经包含在Emacs23之后的版本中。不过，它也可以通过ELPA获得。您可能感兴趣的其他一些事情是集成RVM、feature-mode(Cucumber)、rspec-mode、ruby-electric、inf-ruby、rinari(用于Rails)等。这是我当前用于Ruby开发的Emacs配置:https://github.com/citizen428/emacs

  3. java - 等价于 Java 中的 Ruby Hash - 2

    我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/

  4. java - 从 JRuby 调用 Java 类的问题 - 2

    我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www

  5. ruby - 是否有用于序列化和反序列化各种格式的对象层次结构的模式？ - 2

    给定一个复杂的对象层次结构，幸运的是它不包含循环引用，我如何实现支持各种格式的序列化？我不是来讨论实际实现的。相反，我正在寻找可能会派上用场的设计模式提示。更准确地说:我正在使用Ruby，我想解析XML和JSON数据以构建复杂的对象层次结构。此外，应该可以将该层次结构序列化为JSON、XML和可能的HTML。我可以为此使用Builder模式吗？在任何提到的情况下，我都有某种结构化数据-无论是在内存中还是文本中-我想用它来构建其他东西。我认为将序列化逻辑与实际业务逻辑分开会很好，这样我以后就可以轻松支持多种XML格式。 最佳答案 我最

  6. java - 我的模型类或其他类中应该有逻辑吗 - 2

    我只想对我一直在思考的这个问题有其他意见，例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我

  7. java - 什么相当于 ruby​​ 的 rack 或 python 的 Java wsgi？ - 2

    什么是ruby​​的rack或python的Java的wsgi？还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht

  8. ruby - Rack:如何将 URL 存储为变量？ - 2

    我正在编写一个简单的静态Rack应用程序。查看下面的config.ru代码:useRack::Static,:urls=>["/elements","/img","/pages","/users","/css","/js"],:root=>"archive"map'/'dorunProc.new{|env|[200,{'Content-Type'=>'text/html','Cache-Control'=>'public,max-age=6400'},File.open('archive/splash.html',File::RDONLY)]}endmap'/pages/search.

  9. Observability：从零开始创建 Java 微服务并监控它 （二） - 2

    这篇文章是继上一篇文章“Observability：从零开始创建Java微服务并监控它（一）”的续篇。在上一篇文章中，我们讲述了如何创建一个Javaweb应用，并使用Filebeat来收集应用所生成的日志。在今天的文章中，我来详述如何收集应用的指标，使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值，然后一切都回到一个请求。这也意味着这些指标可能不准确，你还想提取最小/

  10. 【Java 面试合集】HashMap中为什么引入红黑树，而不是AVL树呢 - 2

    HashMap中为什么引入红黑树，而不是AVL树呢1.概述开始学习这个知识点之前我们需要知道，在JDK1.8以及之前，针对HashMap有什么不同。JDK1.7的时候，HashMap的底层实现是数组+链表JDK1.8的时候，HashMap的底层实现是数组+链表+红黑树我们要思考一个问题，为什么要从链表转为红黑树呢。首先先让我们了解下链表有什么不好？？？2.链表上述的截图其实就是链表的结构，我们来看下链表的增删改查的时间复杂度增：因为链表不是线性结构，所以每次添加的时候，只需要移动一个节点，所以可以理解为复杂度是N(1)删：算法时间复杂度跟增保持一致查：既然是非线性结构，所以查询某一个节点的时候

随机推荐