spring cloud 规则引擎 demo

这里提供一个使用Spring Cloud和Drools规则引擎的示例：

1. 首先，在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.kie</groupId>
    <artifactId>kie-ci</artifactId>
    <version>7.0.0.Final</version>
</dependency>
<dependency>
    <groupId>org.kie</groupId>
    <artifactId>kie-spring</artifactId>
    <version>7.0.0.Final</version>
</dependency>

2. 创建Drools规则文件，例如：

package com.example.rules

import com.example.dto.InputData;

rule "Rule1"
    when
        inputData : InputData(value == 1)
    then
        inputData.setResult("Rule1 fired");
end

rule "Rule2"
    when
        inputData : InputData(value == 2)
    then
        inputData.setResult("Rule2 fired");
end

3. 创建一个InputData类，例如：

public class InputData {
    private int value;
    private String result;

    // getters and setters
}

4. 创建一个Drools配置类，例如：

@Configuration
public class DroolsConfig {

    @Autowired
    private KieFileSystem kieFileSystem;

    @PostConstruct
    public void init() throws IOException {
        kieFileSystem.write(ResourceFactory.newClassPathResource("rules/rules.drl").getInputStream());
    }

    @Bean
    public KieContainer kieContainer() {
        KieServices kieServices = KieServices.Factory.get();
        KieRepository kieRepository = kieServices.getRepository();
        kieRepository.addKieModule(kieRepository::getDefaultReleaseId);
        KieBuilder kieBuilder = kieServices.newKieBuilder(kieFileSystem);
        kieBuilder.buildAll();
        KieModule kieModule = kieBuilder.getKieModule();
        return kieServices.newKieContainer(kieModule.getReleaseId());
    }
}

5. 创建一个StreamListener来接收和处理消息，例如：

@Component
public class StreamListener {

    @Autowired
    private KieContainer kieContainer;

    @StreamListener(Sink.INPUT)
    public void process(InputData inputData) {
        KieSession kieSession = kieContainer.newKieSession();
        kieSession.insert(inputData);
        kieSession.fireAllRules();
        kieSession.dispose();
        System.out.println(inputData.getResult());
    }
}

6. 创建一个消息发送器，例如：

@Component
public class MessageSender {

    @Autowired
    private Source source;

    public void send(InputData inputData) {
        source.output().send(MessageBuilder.withPayload(inputData).build());
    }
}

7. 最后，创建一个简单的测试类来发送消息，例如：

@SpringBootTest
public class StreamTest {

    @Autowired
    private MessageSender messageSender;

    @Test
    public void test() {
        messageSender.send(new InputData(1));
        messageSender.send(new InputData(2));
    }
}

这是一个示例，你可以根据自己的需要进行修改和扩展。