花癡流口水顏文字

可執(zhí)行模型是對引擎處理的Drools最低級別模型的重新設(shè)計。 在當前的系列（最多6.x）中，可執(zhí)行模型在過去的8年中有機地增長了，從未真正成為最終用戶的目標。 建議那些希望以編程方式編寫規(guī)則的人通過代碼生成和目標drl來完成； 這是不理想的。 從來沒有任何驅(qū)動程序可以使最終用戶更容易地使用它，因為在Java中廣泛使用匿名類非常麻煩。 借助Java 8和Lambda的這種變化，就有可能制造出最終用戶可以訪問的更具吸引力的模型。

這個新模型是在高級語言的編譯過程中生成的，但也可以單獨使用。 我們的目標是使該可執(zhí)行模型自成一體，并避免進行進一步的字節(jié)碼修改（分析，轉(zhuǎn)換或生成）； 從該模型的角度來看，所有內(nèi)容均由代碼或高級語言層提供。 例如，索引等必須由參數(shù)提供，高級語言在針對可執(zhí)行模型時會通過分析生成這些參數(shù)。

它旨在利用Java 8的lambda很好地映射到Fluent級別的構(gòu)建者。 這將使其對Java開發(fā)人員和語言開發(fā)人員更具吸引力。 而且，這將允許獨立于任何語言的低級引擎功能設(shè)計和測試。 這意味著我們可以在引擎級別進行創(chuàng)新，而不必擔心語言層。

可執(zhí)行模型應(yīng)該足夠通用以映射到多個域。 這將是一個低級數(shù)據(jù)流模型，您可以在其中處理功能性React式編程模型，但仍可用于從中構(gòu)建基于規(guī)則的系統(tǒng)。

以下示例提供了用于構(gòu)建可執(zhí)行模型的流利DSL的第一個視圖：

DataSource persons = sourceOf(new Person("Mark", 37),new Person("Edson", 35),new Person("Mario", 40));Variable<Person> markV = bind(typeOf(Person.class));Rule rule = rule("Print age of persons named Mark").view(input(markV, () -> persons),expr(markV, person -> person.getName().equals("Mark"))).then(on(markV).execute(mark -> System.out.println(mark.getAge())) );

前面的代碼定義了一個包含一些人員實例的數(shù)據(jù)源，并聲明了人員類型的變量markV。 規(guī)則本身包含通常的兩部分：LHS由傳遞給view（）方法的一組輸入和表達式定義，而RHS是由傳遞給then（）方法的lambda表達式定義的動作。

更詳細地分析LHS，語句如下：

input(markV, () -> persons)

將人員數(shù)據(jù)源中的對象綁定到markV變量，并通過對象類進行模式匹配。 從這個意義上講，DataSource可以被視為等同于Drools入口點。

相反的表達：

expr(markV, person -> person.getName().equals("Mark"))

使用謂詞定義綁定到markV變量的對象必須滿足的條件才能被引擎成功匹配。 請注意，正如預(yù)期的那樣，模式匹配的評估不是通過作為任何種類的分析或編譯過程的結(jié)果而生成的約束來執(zhí)行的，而是僅通過應(yīng)用實現(xiàn)謂詞的lambda表達式（在這種情況下，人員- > person.getName（）。equals（“ Mark”））匹配的對象。 換句話說，前一個DSL會產(chǎn)生一個規(guī)則的可執(zhí)行模型，該模型等效于后續(xù)drl的解析結(jié)果。

rule "Print age of persons named Mark" whenmarkV : Person( name == "Mark" ) from entry-point "persons" thenSystem.out.println(markV.getAge()); end

它還正在開發(fā)一個rete構(gòu)建器，可以使用此DSL定義的規(guī)則。 特別是，可以將這些規(guī)則添加到CanonicalKieBase中，然后像其他任何普通KieBase一樣從中創(chuàng)建KieSession。

CanonicalKieBase kieBase = new CanonicalKieBase(); kieBase.addRules(rule);KieSession ksession = kieBase.newKieSession(); ksession.fireAllRules();

當然，DSL還允許定義更復雜的條件，例如連接：

Variable<Person> markV = bind(typeOf(Person.class)); Variable<Person> olderV = bind(typeOf(Person.class));Rule rule = rule("Find persons older than Mark").view(input(markV, () -> persons),input(olderV, () -> persons),expr(markV, mark -> mark.getName().equals("Mark")),expr(olderV, markV, (older, mark) -> older.getAge() > mark.getAge())).then( on(olderV, markV).execute((p1, p2) -> System.out.println(p1.getName() + " is older than " + p2.getName())) );

或存在模式：

Variable<Person> oldestV = bind(typeOf(Person.class)); Variable<Person> otherV = bind(typeOf(Person.class));Rule rule = rule("Find oldest person").view(input(oldestV, () -> persons),input(otherV, () -> persons),not(otherV, oldestV, (p1, p2) -> p1.getAge() > p2.getAge())).then( on(oldestV).execute(p -> System.out.println("Oldest person is " + p.getName())) );

這里的not（）代表所有表達式的取反，因此上面使用的形式實際上只是以下內(nèi)容的快捷方式：

not( expr( otherV, oldestV, (p1, p2) -> p1.getAge() > p2.getAge() ) )

還已經(jīng)以以下形式支持累計：

Variable<Person> person = bind(typeOf(Person.class)); Variable<Integer> resultSum = bind(typeOf(Integer.class)); Variable<Double> resultAvg = bind(typeOf(Double.class));Rule rule = rule("Calculate sum and avg of all persons having a name starting with M").view(input(person, () -> persons),accumulate(expr(person, p -> p.getName().startsWith("M")),sum(Person::getAge).as(resultSum),avg(Person::getAge).as(resultAvg))).then(on(resultSum, resultAvg).execute((sum, avg) -> result.value = "total = " + sum + "; average = " + avg) );

為了提供最后一個更完整的用例，可以使用此DSL定義經(jīng)典火災(zāi)和警報示例的可執(zhí)行模型，如下所示。

Variable<Room> room = any(Room.class); Variable<Fire> fire = any(Fire.class); Variable<Sprinkler> sprinkler = any(Sprinkler.class); Variable<Alarm> alarm = any(Alarm.class);Rule r1 = rule("When there is a fire turn on the sprinkler").view(input(fire),input(sprinkler),expr(sprinkler, s -> !s.isOn()),expr(sprinkler, fire, (s, f) -> s.getRoom().equals(f.getRoom()))).then(on(sprinkler).execute(s -> {System.out.println("Turn on the sprinkler for room " + s.getRoom().getName());s.setOn(true);}).update(sprinkler, "on") );Rule r2 = rule("When the fire is gone turn off the sprinkler").view(input(sprinkler),expr(sprinkler, Sprinkler::isOn),input(fire),not(fire, sprinkler, (f, s) -> f.getRoom().equals(s.getRoom()))).then(on(sprinkler).execute(s -> {System.out.println("Turn off the sprinkler for room " + s.getRoom().getName());s.setOn(false);}).update(sprinkler, "on") );Rule r3 = rule("Raise the alarm when we have one or more fires").view(input(fire),exists(fire)).then(execute(() -> System.out.println("Raise the alarm")).insert(() -> new Alarm()) );Rule r4 = rule("Lower the alarm when all the fires have gone").view(input(fire),not(fire),input(alarm)).then(execute(() -> System.out.println("Lower the alarm")).delete(alarm) );Rule r5 = rule("Status output when things are ok").view(input(alarm),not(alarm),input(sprinkler),not(sprinkler, Sprinkler::isOn)).then(execute(() -> System.out.println("Everything is ok")) );CanonicalKieBase kieBase = new CanonicalKieBase(); kieBase.addRules(r1, r2, r3, r4, r5);KieSession ksession = kieBase.newKieSession();// phase 1 Room room1 = new Room("Room 1"); ksession.insert(room1); FactHandle fireFact1 = ksession.insert(new Fire(room1)); ksession.fireAllRules();// phase 2 Sprinkler sprinkler1 = new Sprinkler(room1); ksession.insert(sprinkler1); ksession.fireAllRules();assertTrue(sprinkler1.isOn());// phase 3 ksession.delete(fireFact1); ksession.fireAllRules();

在此示例中，可能還要注意幾件事：

• 必須執(zhí)行一些重復操作才能將表達式的參數(shù)綁定到評估它的lambda表達式的形式參數(shù)。 希望可以在解決此JDK錯誤時使用-parameters編譯參數(shù)來克服此問題。
• any（Room.class）是bind（typeOf（Room.class））的快捷方式
• 輸入未聲明數(shù)據(jù)源。 這是指出這些對象來自默認空DataSource的快捷方式（對應(yīng)于Drools默認入口點）。 實際上，在此示例中，事實以編程方式插入到KieSession中。
• 使用輸入而不為其提供任何表達式的輸入實際上是input（alarm），expr（alarm，a-> true）的快捷方式
• 以同樣的方式，沒有條件的存在模式，例如not（fire）是not（expr（fire，f-> true））的另一個快捷方式
• Java 8語法還允許將謂詞定義為訪問諸如expr（sprinkler，Sprinkler :: isOn）之類的事實的布爾屬性的方法引用。
• RHS與要執(zhí)行的代碼塊一起，還提供了一個流暢的接口來定義在觸發(fā)規(guī)則時必須執(zhí)行的工作內(nèi)存操作（插入/更新/刪除）。 特別是，更新還獲得了一個字符串變量，用于報告已更新事實中更改的屬性的名稱，例如update（sprinkler，“ on”）。 由于必須創(chuàng)建可執(zhí)行模型而無需任何代碼分析，因此必須再次明確提供此信息。

翻譯自: https://www.javacodegeeks.com/2014/07/drools-executable-model.html

花癡流口水顏文字

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的花痴流口水颜文字_流口水可执行模型的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。