快捷導(dǎo)航

Go語言輕量級高性能嵌入式規(guī)則引擎RuleGo使用詳解

更新時間：2023年11月17日 09:34:58 作者：GitHub精選

這篇文章主要為大家介紹了Go語言輕量級高性能嵌入式規(guī)則引擎RuleGo使用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

背景介紹

在處理大量數(shù)據(jù)時，我們經(jīng)常需要對數(shù)據(jù)進行聚合、分發(fā)、過濾、轉(zhuǎn)換、豐富和執(zhí)行各種操作。而 RuleGo 是一個基于 Go 語言的輕量級、高性能、嵌入式規(guī)則引擎，可以幫助我們解決這些問題。它可以在低成本設(shè)備上高效地處理和鏈接數(shù)據(jù)，適用于物聯(lián)網(wǎng)邊緣計算。同時，RuleGo 還是一個靈活、高度可定制的事件處理框架，可以滿足高度個性化或頻繁變化的業(yè)務(wù)場景需求。

用一句話介紹 RuleGo 項目就是：“RuleGo is a lightweight, high-performance, embedded rule engine based on Go language. It can aggregate, distribute, filter, transform, enrich and execute various actions on input messages.”。

項目介紹

RuleGo 是一個基于編排的規(guī)則引擎，最擅長解耦系統(tǒng)。它采用協(xié)程池和對象池等技術(shù)，結(jié)合 Go 語言的高性能特性，可以在10W 數(shù)據(jù)處理 JS 腳本過濾-> JS 腳本數(shù)據(jù)處理-> HTTP 推送的情況下，平均處理時間為 9 秒。同時，RuleGo 支持將自己嵌入到現(xiàn)有項目中，非侵入式地利用其特性。所有業(yè)務(wù)邏輯都是組件化的，可以靈活配置和重用。你可以靈活地組合和重用不同的組件，以實現(xiàn)高度可定制和可擴展的業(yè)務(wù)流程。支持規(guī)則鏈的動態(tài)編排，你可以將你的業(yè)務(wù)封裝成 RuleGo 組件，通過構(gòu)建塊實現(xiàn)高度變化的業(yè)務(wù)需求。

同時，RuleGo 提供了豐富靈活的擴展接口和鉤子，如：自定義組件、組件注冊管理、規(guī)則鏈 DSL 解析器、協(xié)程池、規(guī)則節(jié)點消息流入/流出回調(diào)、規(guī)則鏈處理結(jié)束回調(diào)等。支持通過 Go 插件動態(tài)加載組件和擴展組件。內(nèi)置常用組件包括：消息類型切換、JavaScript 切換、JavaScript 過濾器、JavaScript 轉(zhuǎn)換器、HTTP 推送、MQTT 推送、發(fā)送電子郵件、日志記錄等組件。你也可以自己擴展其他組件。同時，RuleGo 還具有可靠的上下文隔離機制，無需擔(dān)心高并發(fā)情況下的數(shù)據(jù)流問題。

如何使用

你可以通過以下步驟安裝和使用 RuleGo：

1、安裝 Go 語言環(huán)境

2、執(zhí)行命令：go get github.com/rulego/rulego

3、在你的代碼中引入 RuleGo 包

4、編寫規(guī)則鏈，進行業(yè)務(wù)處理

對于以上鏈?zhǔn)秸{(diào)用關(guān)系，可以用如下 JSON DSL 進行描述。

{
  "ruleChain": {
    "name": "Test rule chain",
    "root": true,
    "debugMode": false
  },
  "metadata": {
    "nodes": [
      {
        "id": "s1",
        "type": "jsFilter",
        "name": "Filtering Data",
        "debugMode": true,
        "configuration": {
          "jsScript": "return msg!='bb';"
        }
      },
      {
        "id": "s2",
        "type": "jsTransform",
        "name": "Transform Data",
        "debugMode": true,
        "configuration": {
          "jsScript": "metadata['test']='test02';\n metadata['index']=50;\n msgType='TEST_MSG_TYPE2';\n var msg2=JSON.parse(msg);\n msg2['aa']=66;\n return {'msg':msg2,'metadata':metadata,'msgType':msgType};"
        }
      },
      {
        "id": "s3",
        "type": "restApiCall",
        "name": "Call Rest Api Push Data",
        "debugMode": true,
        "configuration": {
          "restEndpointUrlPattern": "http://192.168.216.21:9099/api/socket/msg",
          "requestMethod": "POST",
          "maxParallelRequestsCount": 200
        }
      }
    ],
    "connections": [
      {
        "fromId": "s1",
        "toId": "s2",
        "type": "True"
      },
      {
        "fromId": "s2",
        "toId": "s3",
        "type": "Success"
      }
    ],
    "ruleChainConnections": null
  }
}

如果你想了解更多使用方法，可以參考項目文檔中的示例代碼。