# Frame **Repository Path**: Crabor/frame ## Basic Information - **Project Name**: Frame - **Description**: No description available - **Primary Language**: Java - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 2 - **Forks**: 1 - **Created**: 2022-02-27 - **Last Updated**: 2024-12-26 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # platform ## 我们能做什么 我们主要提供两种服务：上下文（context）服务以及不变式（invariant）服务。上下文服务用于过滤自身带噪点的数据，不变式服务用于在任务循环中记录变量trace生成不变式以及不变式相关服务。 ## 快速开始 按顺序执行下面步骤： ```txt 1. 编写wrapper 2. 编写app 3. 编写平台配置文件 4. 依次启动平台->resource->app ``` ### 1.编写wrapper wrapper是一个外部程序，用于与平台通信，包含Sensor或者Actor，用以和平台进行通信。下面是一个简单的Sensor wrapper示例： ```java public class WrapperDemo { public static void main(String[] args) throws IOException { String config = Util.readFileContent("Resources/config/resource/config.json"); WrapperRemoteConnector connector = WrapperRemoteConnector.getInstance(); if (connector.register("127.0.0.1", 9091, config)) { while (true) { CmdMessage msg = connector.recv(); switch (msg.cmd) { case "sensory_request": JSONObject value = new JSONObject(); value.put("speed", 10.0); value.put("longitude", 20.0); value.put("latitude", 30.0); CmdMessage response = new CmdMessage("sensory_back", value.toJSONString()); connector.send(response.toString()); break; } } // connector.close(); } } } ``` 由于平台启动时不知道任何wrapper信息，所以需要用户编写wrapper程序并向平台动态register。 ### 2.编写app 这里的app指用户程序，用户向平台动态注册自己的程序，获取平台的硬件资源和服务资源，用来服务自己的自适应程序。用户需要自己继承我们的抽象app类（AbstractSyncApp）来实现自己的应用，继承模板如下： ```java public class AppDemo extends AbstractApp { //注册sensor或者启动不变式服务、上下文服务时，平台会通过getMsg函数将数据传递给app @Override public void getMsg(String sensorName, SensorData value) { logger.info(String.format("[%s]: getMsg(channel, msg) -> %s, %s", appName, sensorName, value)); } //配置app的名称和描述 @Override public void configApp() { this.appName = "Demo"; this.appDescription = "This is Demo"; } //下面这个示例是一个简单的sensor订阅示例，订阅了YellowCar这个sensor，每隔1s平台就会通过getMsg函数将sensor数据传递给app public static void main(String[] args) throws InterruptedException { AppDemo app = new AppDemo(); AppRemoteConnector connector = AppRemoteConnector.getInstance(); connector.connectPlatform("127.0.0.1", 9090); connector.registerApp(app); connector.checkConnected(); Map supportedSensors = connector.getSupportedSensors(); if (supportedSensors.containsKey("YellowCar")) { connector.registerSensor("YellowCar", SensorMode.PASSIVE, 1); } connector.getMsgThread(CmdType.START); while (true); // connector.unregisterApp(app); // connector.disConnectPlatform(); } } ``` ### 3.编写平台配置文件 平台需要指定默认全局的上下文服务配置以及监听app和wrapper的端口。 ```json { //上下文服务全局配置 "CtxServerConfiguration": { "serverOn": true, "CtxValidator": "ECC+IMD", "baseRuleFile": "Resources/config/platform/ctx/platform/platformRules.xml", "baseBfuncFile": "Resources/config/platform/ctx/platform/platformBfunction.class", "basePatternFile": "Resources/config/platform/ctx/platform/platformPatterns.xml", "baseMfuncFile": "" }, //平台监听端口配置 "TCPConfig": { "appListenPort": 9090, "deviceListenPort": 9091 } } ``` ### 4.依次启动平台->resource->app 首先用户需要启动平台程序，位于“src/main/java/platform/Platform.java”；然后启动wrapper程序，向平台注册sensor或者actor资源；最后启动app程序，向平台注册app，订阅sensor或者启动不变式服务、上下文服务并获取数据。 ## context ## invariant ## log system ## resource manage 平台和外部程序（resource）通信采用TCP明文协议。明文协议格式为： ```txt 平台发送协议格式： {"cmd": "XXX", "message": "XXX"} ``` 其中平台接收的协议格式中**cmd**、**message**项需与发送协议格式中的保持一致。 ### 明文协议 | direction | cmd | message | |-----------|-----------------|----------------------------------------------------------------------| | W -> P | register | DeviceConf的json串 | | P -> W | register_back | true 或者 false | | P -> W | sensory_request | null | | W -> P | sensory_back | {"default":"100"}//单域传感器
或者{"speed":100,"longitude":22.3}//多域传感器 | | P -> W | action_request | {...}//用户自定义 | | W -> P | action_back | true 或者 false | | W -> P | shutdown | null | #### SensorConf ```json { "name": "YellowCar", "type": "Sensor", "fields": ["speed", "longitude", "latitude"] } ``` #### ActorConf ```json { "name": "YellowCar", "type": "Actor" } ``` ### java版本wrapper ```java import com.alibaba.fastjson.JSONObject; import common.socket.CmdMessage; import common.util.Util; import java.io.IOException; public class WrapperDemo { public static void main(String[] args) throws IOException { String config = Util.readFileContent("Resources/config/resource/config.json"); WrapperRemoteConnector connector = WrapperRemoteConnector.getInstance(); if (connector.register("127.0.0.1", 9091, config)) { while (true) { CmdMessage msg = connector.recv(); switch (msg.cmd) { case "sensory_request": JSONObject value = new JSONObject(); value.put("speed", 10.0); value.put("longitude", 20.0); value.put("latitude", 30.0); CmdMessage response = new CmdMessage("sensory_back", value.toJSONString()); connector.send(response.toString()); break; } } // connector.close(); } } } ``` ### c#版本wrapper ```c# using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Net.Sockets; using System.Net; using System.Threading; using System.IO; using Newtonsoft.Json; using Newtonsoft.Json.Linq; namespace WrapperDemo { class Program { string recv(Socket socket) { byte[] buffer = new byte[1024 * 1024 * 2]; int r = socket.Receive(buffer); if (r == 0) { return null; } string data = Encoding.UTF8.GetString(buffer, 0, r); return data; } void send(Socket socket, string data) { socket.Send(Encoding.UTF8.GetBytes(data)); } void task(string config) { //创建一个socket Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建一个ip地址对象 IPAddress ip = IPAddress.Parse("127.0.0.1"); //创建一个端口对象 IPEndPoint point = new IPEndPoint(ip, 9091); //连接服务器 socket.Connect(point); //发送数据 socket.Send(Encoding.UTF8.GetBytes(config)); //接收数据 string register_back = recv(socket); if (register_back == null) { return; } JObject obj = (JObject)JsonConvert.DeserializeObject(register_back); if (obj["cmd"].ToString() != "register_back" || obj["message"].ToString() != "true") { return; } while (true) { string request = recv(socket); if (request == null) { return; } obj = (JObject)JsonConvert.DeserializeObject(request); switch (obj["cmd"].ToString()) { case "sensory_request": JObject value = new JObject(); value.Add("speed", 10.0); value.Add("longitude", 20.0); value.Add("latitude", 30.0); JObject response = new JObject(); response.Add("cmd", "sensory_back"); response.Add("message", value.ToString()); send(socket, response.ToString()); break; case "action_request": JObject action_back = new JObject(); action_back.Add("cmd", "action_back"); action_back.Add("message", "true"); send(socket, action_back.ToString()); break; } } } static void Main(string[] args) { string config = File.ReadAllText("Resources/config/resource/config.json"); Program program = new Program(); Thread thread = new Thread(() => program.task(config)); thread.Start(); } } } ``` ### unity版本wrapper ```c# using System.Collections; using System.Collections.Generic; using UnityEngine; using System; using System.IO; using System.Net; using System.Net.Sockets; using System.Text; using UnityEngine.SceneManagement; using System.Threading; using Newtonsoft.Json; using Random = System.Random; using Newtonsoft.Json.Linq; public class cube_move : MonoBehaviour { private string[] paths = {"Assets/Scripts/sensor_car.json", "Assets/Scripts/actor_car.json"}; private string serverIP = "127.0.0.1"; private int serverPort = 9091; private List threads = new List(); private Mutex sensorMutex = new Mutex(); private Sensor sensor = new Sensor(); private Mutex actorMutex = new Mutex(); private Actor actor = new Actor(); private Color[] colors = new Color[4] { Color.yellow, Color.yellow, Color.yellow, Color.yellow }; private bool noiseFlag = false; private Random random = new Random(); private bool collisionFlag = false; public class Sensor { public Sensor() { front = 0; back = 0; left = 0; right = 0; } public float front; public float back; public float left; public float right; public float get(string name) { float ret = 0.0f; if (name == "front") { ret = front; } else if (name == "back") { ret = back; } else if (name == "left") { ret = left; } else if (name == "right") { ret = right; } return ret; } } public class Actor { public Actor() { xSpeed = 0; ySpeed = 0; zSpeed = 0; } public double xSpeed; public double ySpeed; public double zSpeed; public void set(string name, string value) { if (name == "xSpeed") { xSpeed = Double.Parse(value); } else if (name == "ySpeed") { ySpeed = Double.Parse(value); } else if (name == "zSpeed") { zSpeed = Double.Parse(value); } } } int ConvertToInt(double value) { int ret; if (value > 0) { ret = (int)Math.Ceiling(value); } else { ret = (int)Math.Floor(value); } return ret; } public class CmdMessage { public CmdMessage(string cmd, string message) { this.cmd = cmd; this.message = message == null ? null : message.Replace("\r\n", "").Replace("\n", "").Replace("\r", ""); } public String cmd; public String message; } CmdMessage recv(StreamReader reader) { string response = reader.ReadLine(); if (response == null) { return null; } CmdMessage ret = JsonConvert.DeserializeObject(response); if (ret.cmd != "alive_request") { Debug.Log("recv: " + response); } return ret; } void send(StreamWriter writer, CmdMessage data) { string str = JsonConvert.SerializeObject(data); Debug.Log("send: " + str); writer.WriteLine(str); writer.Flush(); } void task(object obj) { if (obj != null) { string path = (string)obj; string config = File.ReadAllText(path); TcpClient client = new TcpClient(serverIP, serverPort); StreamWriter writer = new StreamWriter(client.GetStream()); StreamReader reader = new StreamReader(client.GetStream()); //发送数据 CmdMessage register = new CmdMessage("register", config); //Debug.Log(register.ToString()); send(writer, register); //接收数据 CmdMessage register_back = recv(reader); if (register_back == null || register_back.cmd != "register_back" || register_back.message != "true") { return; } while (true) { CmdMessage request = recv(reader); if (request == null) { return; } switch (request.cmd) { case "sensory_request": JObject value = new JObject(); sensorMutex.WaitOne(); value.Add("left", sensor.get("left").ToString()); value.Add("right", sensor.get("right").ToString()); value.Add("front", sensor.get("front").ToString()); value.Add("back", sensor.get("back").ToString()); sensorMutex.ReleaseMutex(); CmdMessage sensory_back = new CmdMessage("sensory_back", value.ToString()); send(writer, sensory_back); break; case "action_request": string[] actions = request.message.Split(' '); actorMutex.WaitOne(); actor.set(actions[0], actions[1]); actorMutex.ReleaseMutex(); CmdMessage action_back = new CmdMessage("action_back", "true"); send(writer, action_back); break; } } } } // Start is called before the first frame update void Start() { // 建立多个子线程 for (int i = 0; i < paths.Length; i++) { Thread t = new Thread(new ParameterizedThreadStart(task)); t.Start(paths[i]); threads.Add(t); } } // Update is called once per frame void Update() { if (!collisionFlag) { actorMutex.WaitOne(); transform.Translate(Vector3.forward * ConvertToInt(actor.xSpeed) * Time.deltaTime); transform.Translate(Vector3.right * ConvertToInt(actor.ySpeed) * Time.deltaTime); transform.Rotate(Vector3.up * ConvertToInt(actor.zSpeed) * Time.deltaTime); actorMutex.ReleaseMutex(); RaycastHit[] hits = new RaycastHit[4]; Vector3[] directions = { transform.TransformDirection(Vector3.forward), transform.TransformDirection(Vector3.back), transform.TransformDirection(Vector3.left), transform.TransformDirection(Vector3.right) }; for (int i = 0;i < directions.Length; i++){ directions[i][1] = 0; } float[] distances = new float[4]; for (int i = 0;i < directions.Length; i++){ if (Physics.Raycast(transform.position, directions[i], out hits[i])){ Debug.DrawRay(transform.position, directions[i] * hits[i].distance, colors[i]); distances[i] = hits[i].distance; }else{ distances[i] = float.MaxValue; } } sensorMutex.WaitOne(); sensor.front = distances[0]; sensor.back = distances[1]; sensor.left = noiseFlag ? (random.Next(1, 100) < 10 ? 200 * (random.Next(0, 2) == 0 ? -1 : 1) : distances[2]) : distances[2]; sensor.right = noiseFlag ? (random.Next(1, 100) < 10 ? 200 * (random.Next(0, 2) == 0 ? -1 : 1) : distances[3]) : distances[3]; sensorMutex.ReleaseMutex(); } } void OnCollisionEnter(Collision collision) { collisionFlag = true; } void OnDestroy() { // 停止所有子线程 foreach (Thread t in threads) { t.Abort(); } } } ``` ### python版本wrapper ```python import socket import json import threading import time def recv(socket): buffer = bytearray(1024) r = socket.recv_into(buffer) if r == 0: return None data = buffer[:r].decode("utf-8") return data def send(socket, data): socket.send(data.encode("utf-8")) def task(config): #创建一个socket socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) #创建一个ip地址对象 ip = "127.0.0.1" #创建一个端口对象 point = 9091 #连接服务器 socket.connect((ip, point)) #发送数据 socket.send(config.encode("utf-8")) #接收数据 register_back = recv(socket) if register_back == None: return obj = json.loads(register_back) if obj["cmd"] != "register_back" or obj["message"] != "true": return while True: request = recv(socket) if request == None: return obj = json.loads(request) if obj["cmd"] == "sensory_request": value = {} value["speed"] = 10.0 value["longitude"] = 20.0 value["latitude"] = 30.0 response = {} response["cmd"] = "sensory_back" response["message"] = json.dumps(value) send(socket, json.dumps(response)) elif obj["cmd"] == "action_request": action_back = {} action_back["cmd"] = "action_back" action_back["message"] = "true" send(socket, json.dumps(action_back)) if __name__ == "__main__": config = open("config.json", "r").read() thread = threading.Thread(target=task, args=(config,)) thread.start() ``` ## app app与平台通信为tcp通信，具体支持的api及对应的明文协议如下： ### app与平台通信明文协议 | 类名 | 编程API | App -> Platform | Platform -> App | |-----------------|:------------------------------------------------------------------------------------------------------------------------------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------| | RemoteConnector | public boolean connectPlatform(String ip, int port); | {"api":"connect"} | {"state":true/false} | | RemoteConnector | public boolean disConnectPlatform(); | {"api":"disconnect"} | {"state":true/false} | | RemoteConnector | public boolean checkConnected(); | {"api":"is_connected"} | {"state":true/false} | | RemoteConnector | public boolean registerApp(AbstractApp app); | {"api":"register_app","app_name":"xxxx"} | {"state":true/false,"udp_port":xxxx} | | RemoteConnector | public boolean unregisterApp(AbstractApp app); | {"api":"unregister_app","app_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public Map getSupportedSensors(); | {"api":"get_supported_sensors"} | [{"sensor_name":"xxxx","value_type":"xxxx","fields":["xxxx",...],"state":"on/off","apps":["xxxx",...]},...] | | RemoteConnector | public Map getRegisteredSensors(); | {"api":"get_registered_sensors","app_name":"xxxx"} | [{"sensor_name":"xxxx","value_type":"xxxx","fields":["xxxx",...],"state":"on/off","apps":["xxxx",...]},...] | | RemoteConnector | public boolean getRegisteredSensorsStatus(); | {"api":"get_registered_sensors_status","app_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean registerSensor(String sensorName, SensorMode mode, int freq); | {"api":"register_sensor","app_name":"xxxx","sensor_name":"xxxx","mode":"xxxx","freq":xxxx} | {"state":true/false} | | RemoteConnector | public boolean cancelSensor(String sensorName); | {"api":"cancel_sensor","app_name":"xxxx","sensor_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean cancelAllSensors(); | {"api":"cancel_all_sensors","app_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public SensorData getSensorData(String sensorName); | {"api":"get_sensor_data","app_name":"xxxx","sensor_name":"xxxx"} | {"default":"value"} / {"field1":"value1",...} | | RemoteConnector | public Map getAllSensorData(); | {"api":"get_all_sensor_data","app_name":"xxxx"} | [{"sensor_name":"xxxx","value":{"default":"value"} / {"field1":"value1",...}},...] | | RemoteConnector | public boolean getMsgThread(CmdType cmd); | {"api":"get_msg_thread","app_name":"xxxx","cmd":"xxxx"} | {"state":true/false} | | RemoteConnector | public Map getSupportedActors(); | {"api":"get_supported_actors"} | [{"actor_name":"xxxx","value_type":"xxxx","state":"on/off","apps":["xxxx",...]},...] | | RemoteConnector | public Map getRegisteredActors(); | {"api":"get_registered_actors","app_name":"xxxx"} | [{"actor_name":"xxxx","value_type":"xxxx","state":"on/off","apps":["xxxx",...]},...] | | RemoteConnector | public boolean getRegisteredActorsStatus(); | {"api":"get_registered_actors_status","app_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean registerActor(String actorName); | {"api":"register_actor","app_name":"xxxx","actor_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean cancelActor(String actorName); | {"api":"cancel_actor","app_name":"xxxx","actor_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean cancelAllActors(); | {"api":"cancel_all_actors","app_name":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean setActorCmd(String actorName, String action) | {"api":"set_actor_cmd","app_name":"xxxx","actor_name":"xxxx","action":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean isServiceOn(ServiceType service); | {"api":"is_service_on","app_name":"xxxx","service_type":"xxxx"} | {"state":true/false} | | RemoteConnector | public boolean serviceStart(ServiceType service, ServiceConfig config); | {"api":"start_service","app_name":"xxxx","service_type":"xxxx","config":} | {"state":true/false} | | RemoteConnector | public boolean serviceStop(ServiceType service); | {"api":"stop_service","app_name":"xxxx","service_type":"xxxx"} | {"state":true/false} | | RemoteConnector | public String serviceCall(ServiceType service, CmdType cmd, ServiceConfig config); | {"api":"service_call","app_name":"xxxx","service_type":"xxxx","cmd_type":"xxxx","config":} | {"state":true/false} | | RemoteConnector | public SensorInfo getSensorInfo(String sensorName); | {"api":"get_sensor_info","sensor_name":"xxxx"} | {"sensor_name":"xxxx","value_type":"xxxx","fields":["xxxx",...],"state":"on/off","apps":["xxxx",...]} | | RemoteConnector | public String getSensorInfoAndData(String sensorName); | {"api":"get_sensor_info_and_data","sensor_name":"xxxx"} | {"sensor_name":"xxxx","value_type":"xxxx","fields":["xxxx",...],"state":"on/off","apps":["xxxx",...],value:"xxxx"} | | RemoteConnector | public Map getAllSensorInfo(); | {"api":"get_all_sensor_info"} | [{"sensor_name":"xxxx","value_type":"xxxx","fields":["xxxx",...],"state":"on/off","apps":["xxxx",...]},...] | | RemoteConnector | public Map getAllSensorInfoAndData(); | {"api":"get_all_sensor_info_and_data"} | [{"sensor_name":"xxxx","value_type":"xxxx","fields":["xxxx",...],"state":"on/off","apps":["xxxx",...],value:"xxxx"},...] | | RemoteConnector | public ActorInfo getActorInfo(String actorName); | {"api":"get_actor_info","actor_name":"xxxx"} | {"actor_name":"xxxx","value_type":"xxxx","state":"on/off","apps":["xxxx",...]} | | RemoteConnector | public Map getAllActorInfo(); | {"api":"get_all_actor_info"} | [{"actor_name":"xxxx","value_type":"xxxx","state":"on/off","apps":["xxxx",...]},...] | | RemoteConnector | public AppInfo getAppInfo(String appName); | {"api":"get_app_info","app_name":"xxxx"} | {"app_name":"xxxx","ctx":true/false,"inv":true/false,"state":"on/off","sensors":["xxxx",...],"actors":["xxxx",...]} | | RemoteConnector | public Map getAllAppInfo(); | {"api":"get_all_app_info"} | [{"app_name":"xxxx","ctx":true/false,"inv":true/false,"state":"on/off","sensors":["xxxx",...],"actors":["xxxx",...]},...] | | RemoteConnector | public ServiceInfo getServiceInfo(ServiceType service); | {"api":"get_service_info","app_name":"xxxx","service_type":"xxxx"} | | | RemoteConnector | public boolean dbSet(String key, String value); | {"api":"db_set","key":"xxxx","value":"xxxx"} | {"state":true/false} | | RemoteConnector | public String dbGet(String key); | {"api":"db_get","key":"xxxx"} | "xxxx" | | InvCheck | public boolean monitor(Object... objs); | {"api":"inv_monitor","objs":["XXXX",...]} | {"state":true/false} | | InvCheck | public boolean isMonitored(Object... objs); | {"api":"inv_is_monitored","objs":["XXXX",...]} | {"state":true/false} | | InvCheck | public boolean check(Object... objs); | {"api":"inv_check","objs":{"XXXX":XXXX,...},"line_number":XXXX,"check_time":XXXX,"iterId":XXXX} | {"state":true/false} | | DBController | public boolean createTable(String tableName, String primaryKey, List header) | {"api":"db_create","app_name":"xxxx","table_name":"xxxx","primary_key":"xxxx","header":["xxxx",...]} | {"state":true/false} | | DBController | public boolean deleteTable(String tableName) | {"api":"db_drop","app_name":"xxxx","table_name":"xxxx"} | {"state":true/false} | | DBController | public boolean insertRow(String tableName, Map row) | {"api":"db_insert","app_name":"xxxx","table_name":"xxxx","row":{"XXXX":XXXX,...}} | {"state":true/false} | | DBController | public boolean updateRow(String tableName, Map row) | {"api":"db_update","app_name":"xxxx","table_name":"xxxx","row":{"XXXX":XXXX,...}} | {"state":true/false} | | DBController | public boolean deleteRow(String tableName, int row, List conditions, List orders) | {"api":"db_delete","app_name":"xxxx","table_name":"xxxx","row":XXXX,"conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | {"state":true/false} | | DBController | public boolean deleteRowList(String tableName, int rows, List conditions, List orders) | {"api":"db_deletes","app_name":"xxxx","table_name":"xxxx","rows":XXXX,"conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | {"state":true/false} | | DBController | public Map getRow(String tableName, int row, List columns, List conditions, List orders) | {"api":"db_row","app_name":"xxxx","table_name":"xxxx","row":XXXX,"columns":["xxxx",...],"conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | {"XXXX":XXXX,...} | | DBController | public List> getRowList(String tableName, int rows, List columns, List conditions, List orders) | {"api":"db_rows","app_name":"xxxx","table_name":"xxxx","rows":XXXX,"columns":["xxxx",...],"conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | [{"XXXX":XXXX,...},...] | | DBController | public List getColumn(String tableName, int rows, String column, List conditions, List orders) | {"api":"db_column","app_name":"xxxx","table_name":"xxxx","rows":XXXX,"column":"xxxx","conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | [XXXX,...] | | DBController | public Map> getColumnMap(String tableName, int rows, List columns, List conditions, List orders) | {"api":"db_columns","app_name":"xxxx","table_name":"xxxx","rows":XXXX,"columns":["xxxx",...],"conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | {"XXXX":[XXXX,...],...} | | DBController | public Object getCell(String tableName, int row, String column, List conditions, List orders) | {"api":"db_cell","app_name":"xxxx","table_name":"xxxx","row":XXXX,"column":"xxxx","conditions":[{"column":"xxxx","compare":"xxxx","value":xxxx},...],"orders":[{"column":"xxxx","order":"xxxx"},...]} | XXXX | | DBController | public List getHeader(String tableName) | {"api":"db_header","app_name":"xxxx","table_name":"xxxx"} | ["xxxx",...] | | DBController | public int getCount(String tableName) | {"api":"db_count","app_name":"xxxx","table_name":"xxxx"} | XXXX | #### CtxServiceConfig ```json { "rule_file_content": "xxxx", "pattern_file_content": "xxxx", "bfunc_file_content": "xxxx", "mfunc_file_content": "xxxx", "rfunc_file_content": "xxxx", "ctx_validator": "xxxx" } ``` InvServiceConfig ```json { "init_thro": XXXX, "gen_thro": XXXX } ``` ## database database我们经过对项目的考量，决定采用H2数据库，理由如下： 1. H2数据库是一个嵌入式数据库，可以直接将其打包到项目中，不需要单独安装，使用方便。 2. H2数据库支持TCP连接及多线程访问，可以通过TCP连接进行远程访问，方便我们进行远程调试。 3. H2数据库支持内存模式，可以将数据库存储在内存中，提升访问速度，方便我们进行性能测试。 4. 当H2数据库同时开启TCP模式和内存模式时，数据库存在一个引用计数，当最后一个连接断开时，数据库会自动关闭，数据历史数据自动清除。方便平台断连时UI依旧能够访问数据库，而且不会造成数据库数据冗余。 ### 启动步骤 转到`Resources/config/database`目录下，执行`java -cp h2-2.1.214.jar org.h2.tools.Server -ifNotExists -tcp -tcpAllowOthers -tcpPort 9092`，启动数据库。 ### java连接数据库示例 ```java import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class H2DatabaseExample { public static void main(String[] args) { Connection conn = null; Statement stmt = null; ResultSet rs = null; try { // 加载H2数据库的驱动程序 Class.forName("org.h2.Driver"); // 连接到H2数据库，test如果不存在则自动创建 conn = DriverManager.getConnection("jdbc:h2:tcp://localhost:9092/mem:test", "sa", ""); // 创建一个Statement对象 stmt = conn.createStatement(); // 执行SQL查询语句 rs = stmt.executeQuery("SELECT * FROM customers"); // 处理查询结果 while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); String email = rs.getString("email"); System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email); } } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } finally { // 关闭ResultSet对象 if (rs != null) { try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } // 关闭Statement对象 if (stmt != null) { try { stmt.close(); } catch (SQLException e) { e.printStackTrace(); } } // 关闭Connection对象 if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } } } ```