java - KIE 执行服务器 - 引导规则插入事实 - 如何在 Java 中获取它？

Question

我正在使用 6.3.0 Drools Workbench 和 KIE 执行服务器，通过从 JAVA 应用到 KIE 执行服务器的 REST 通信。

我是使用 Drools 的新手。

下面是类似的问题，但没有解决问题(尤其是REST和6.3.0的结合):

• Access to Drools returned fact object in Java Code
• Drools: How to retrieve the fact in response from Kie Execution Server?

好吧，既然我们奠定了基础，这真的不可能吗？还是我们都理解错了？还有别的吗？ :)

事实是，这是应该经常遇到的事情，因为当您在 Drools Workbench 中使用引导规则时，它只在规则的 THEN 部分提供这种操作:“插入事实...”和“逻辑上插入事实 ...”(和调用方法)。

当添加事实(在我的例子中是“交易”)时，它会生成如下规则代码:

import java.lang.Number;

rule "BigAmount"
    dialect "mvel"
    when
        Transaction( amount > 10000.0 )
    then
        Transaction fact0 = new Transaction();
        fact0.setActivatedRule( "BigAmount" );
        insert( fact0 );
end

有人希望在 Java 中恢复这一事实。 Java 结果是这样的:

<fact-handle identifier="Transaction" external-form="0:9:338894407:338894407:9:DEFAULT:NON_TRAIT:hr.company.Transaction"/>

当尝试像这样检索它时，您得到 NULL:

    ... before is request sent ...
    KieServerCommand call = new CallContainerCommand(containerId, xStreamXml);

    List<KieServerCommand> cmds = Arrays.asList(call);
    CommandScript script = new CommandScript(cmds);

    for (int i=0; i<1; i++) {        
        ServiceResponsesList reply = client.executeScript(script);        

        for (ServiceResponse<? extends Object> r : reply.getResponses()) {
            System.out.println(r.getResult());

            ExecutionResultImpl result = (ExecutionResultImpl) BatchExecutionHelper.newXStreamMarshaller().fromXML( (String) r.getResult() );
            DefaultFactHandle obj = (DefaultFactHandle) result.getFactHandle("Transaction");
            Transaction t = (Transaction) obj.getObject();
            System.out.println("BU!");
        }
    };

或者这只是错误的方法？

谢谢!

Answer 1

玩了一段时间，这是我发现的...

我不确定上述问题和答案中的建议解决方案是否因 Drools/KIE 版本不同或这是与 KIE 服务器的 REST 通信而有所不同，但它们不适用于此处。

在规则中获取插入的对象(事实)

如果你有这样的规则:

rule "BigAmount"
    dialect "mvel"
    when
        Transaction( amount > 10000.0 )
    then
        Transaction fact0 = new Transaction();
        fact0.setActivatedRule( "BigAmount" );
        insert( fact0 );
end

如果您想通过 REST 在 JAVA 中检索它，您需要在 BatchExecutionCommand 中插入 GetObjects 命令:

    Transaction trans = new Transaction();      
    trans.setAmount(new Double(10001));

    // define commands
    InsertObjectCommand insertObjectCommand = new InsertObjectCommand(trans, "InputTransaction");

    GetObjectsCommand getObjectsCommand = new GetObjectsCommand();
    getObjectsCommand.setOutIdentifier("objects");

    FireAllRulesCommand fireAllRulesCommand = new FireAllRulesCommand("RunAllRules");

    // insert commands into Command object (BatchExecutionCommand)
    List<GenericCommand<?>> commands = new ArrayList<GenericCommand<?>>();
    commands.add(insertObjectCommand);
    commands.add(fireAllRulesCommand);
    commands.add(getObjectsCommand);
    BatchExecutionCommand command = new BatchExecutionCommandImpl(commands);

    String xStreamXml = BatchExecutionHelper.newXStreamMarshaller().toXML(command); // actual XML request

所以，这里重要的部分是:

    GetObjectsCommand getObjectsCommand = new GetbjectsCommand();
    getObjectsCommand.setOutIdentifier("objects");

这将告诉 KIE 服务器以 XML 格式返回给您单独的节点 - ，您将在其中找到 KIE session 中的所有对象:

<execution-results>
  <result identifier="InputTransaction">
    <com.company.fm.Transaction>
      <amount>10001.0</amount>
      <activatedRule>
        <string>BigAmount</string>
      </activatedRule>
    </com.company.fm.Transaction>
  </result>
  <result identifier="RunAllRules">
    <int>1</int>
  </result>
  <result identifier="objects">
    <list>
       ... all objects ...
    </list>
  </result>
  <fact-handle identifier="InputTransaction" external-form="0:1:226077856:226077856:1:DEFAULT:NON_TRAIT:com.company.fm.Transaction"/>
</execution-results>

之后，您可以从 session 中获取所有对象:

    // define kie client
    KieServicesConfiguration config = KieServicesFactory.newRestConfiguration(
            "http://docklin:8180/kie-server/services/rest/server",
            "ks-user",      //user must have role "kie-server" assigned
            "ks-user");
    config.setMarshallingFormat(MarshallingFormat.XSTREAM);     

    KieServicesClient client = KieServicesFactory.newKieServicesClient(config);     

    // set container for execution and prepare the call
    String containerId = "fm";
    KieServerCommand call = new CallContainerCommand(containerId, xStreamXml);        
    List<KieServerCommand> cmds = Arrays.asList(call);
    CommandScript script = new CommandScript(cmds);

    ServiceResponsesList reply = client.executeScript(script);        

    for (ServiceResponse<? extends Object> r : reply.getResponses()) {
            System.out.println(r.getResult());

            if (r.getResult() != null) {
                ExecutionResultImpl result = (ExecutionResultImpl) BatchExecutionHelper.newXStreamMarshaller().fromXML((String) r.getResult());
                // getting the same object that was sent but with filled in values
                trans = (Transaction) result.getResults().get("InputTransaction");
                // Objects From insert(fact0) in rule. The problem is that they are staying and multiplying there in Drools, don't know yet how to manage it. ToDo.
                ArrayList<Object> objects = (ArrayList<Object>) result.getResults().get("objects");                 
                System.out.println(objects); 
    }
    else
                System.out.println("Empty result...?");
    }

如评论中所述，这将返回 session 中的所有对象。如果多次调用该程序，它会将对象添加到 session 中而不删除旧对象。我没有更多的时间来玩弄它来弄清楚如何解决这个问题，只从这个单一的电话中获得那些。收回或可能的东西。

我实际上发现我根本不需要这个(并且 insert(fact) 可能不适合我的用例)但是我想要返回我发送的相同输入对象，并将填充值发送到它的属性中。

设置属性以发送输入对象并将此对象检索回 Java

我发现(告诉过你我是 Drools 的新手)我实际上可以在 Drools workbench->Guided Rule 中为对象分配一个变量。当您通过“向规则添加条件...”在规则的“WHEN”部分添加对象时，您只需设置变量名称(在弹出窗口的底部)，它将在“THEN”部分提供其他选项，像“修改”、“更改字段值”、...

如果您选择“更改字段...”，它将创建如下规则:

rule "BigAmount"
    dialect "mvel"
    when
        f : Transaction( amount >= 10000 )
    then
        f.addActivatedRule( "BigAmount" );
end

然后您实际上会在您发送的输入对象中获得此值(在我的例子中为“InputTransaction”)，这实际上是我的目标，并且不会在 session 中插入新对象(事实)。 这是代码中的这一部分:

// getting the same object that was sent but with filled in values
trans = (Transaction) result.getResults().get("InputTransaction");

我希望这对某人有帮助。

问候， 艾迪