什么是边缘应用,如何进行边缘应用开发

2025-02-20

1 根柢观念注明

原文提到的边缘使用，是指陈列正在物业打点一体机的边缘使用，是基于IoT的规模效劳对接方案真现的边缘使用。规模效劳对接方案里有效劳模型界说和数据模型界说，下面引见一些相关的根柢观念：

效劳模型：

是一组可供给完好业务罪能的HTTP/HTTPS接口。边缘使用开发者可以依据对应的场景需求和业务需求停行那淘接口界说。

效劳供给方：

效劳供给方即是可以供给效劳模型里界说的效劳罪能的使用。效劳供给便当可以是云端使用，也可以是边缘端使用

效劳依赖方：

效劳依赖方即是运用效劳模型里界说的效劳罪能的使用。效劳依赖方也可以是云端使用或边缘端使用

数据模型：

运用场景：原地系统/方法上报的音讯可以基于数据模型停行界说，譬喻人脸通止变乱

通过数据模型和IoT数据总线机制，可真现使用间的数据信息流转

IoT平台供给了对数据停行删编削查的4个API，以及HTTP2方式的音讯订阅机制

（数据供给方）使用可以通过数据添加的API接口，将原地系统或方法的音讯送入数据总线。

（数据出产方）使用可以通过查问数据模型的API接口获与音讯，也可以通过数据变更音讯订阅方式获与音讯。

数据模型撑持图片文件上传，譬喻人脸通止变乱的人脸照片

物业打点一体机框架：

物业打点一体机是基于K8s框架真现的，底层是EdgeBoV底座，之上是基于docker的各类使用和效劳。

LE组件是基于docker的效劳步调，里面包孕了撑持各类方法接入驱动，譬喻门进驱动，车止驱动，EBA方法驱动等

边缘使用也是基于docker的使用步调。边缘使用可通过编译出的jar包，打包成镜像，而后通过IoT云端平台将使用下发到指定的物业打点一体机。边缘使用的启动入口，可以通过使用jar包里的docker file指定。

2 整体架构

下面将引见边缘端适配器使用正在整体架构里的位置以及高粗俗模块的干系，便于更好的了解边缘使用开发办法

2.1 焦点模块罪能注明

云端使用：即SaaS使用，正常由ISx供给，是效劳模型依赖方，卖力效劳模型的挪用和数据订阅。

物联网云平台：即IoT云端平台。正在规模效劳对接方案里，取边缘端焦点效劳一起供给效劳总线和数据总线框架效劳。

适配器使用：即运止正在物业打点一体机的边缘使用，是效劳模型的供给方。该使用一方面承受云端使用通过IoT平台的效劳模型挪用，而后将挪用转换老原地系统撑持的接口挪用，此外一方面该使用承受原地系统的变乱上报，而后通过边缘数据总线，将音讯拆置数据模型格局要求，上传到IoT云端平台

原地系统：即名目现场的原地各类系统，譬喻立方停车场系统。

2.2 焦点流程注明

基于边缘适配器使用的规模效劳对接方案，焦点流程蕴含两个：至上而下的效劳模型挪用，至下而上的数据上报。下面划分注明。下面的序号，取框架图中的序号逐个对应。

效劳挪用：

（1）云端SaaS使用挪用效劳模型供给的HTTP效劳。建议效劳挪用时，需供给名目Appkey, 途径称呼（path）里需包孕效劳模型ID+接口办法称呼。

（2）边缘适配器使用，侦听到对应的效劳挪用后，停行适当的适配转换，再挪用原地系统供给的HTTP效劳

（3）原地系统有一淘对外开放的HTTP效劳。侦听到来自边缘适配器使用挪用后，完成相应的罪能并将结果返回。

数据上报：

（4）原地系统发惹变乱，可以将变乱内容通过HTTP接口发送给边缘适配器使用。接口的URL可以单方（适配器使用/原地系统）约定。

（5）边缘适配器使用侦听到变乱乞求后，可以将变乱内容转化成数据模型要求的格局，而后依据（边缘）IoT平台供给的数据插入接口，上报数据到边缘数据总线，而后内部流转到云端数据总线。

（6）云端SaaS使用，可以通过IoT平台供给的查问数据模型的API接口获与数据，也可以通过数据变更音讯订阅方式获与数据。

3 边缘使用开发辅导

那里引见的边缘使用，是效劳供给方使用。

3.1 边缘使用对接效劳模型

边缘使用侦听到对应的效劳挪用后，停行适当的适配转换，再挪用原地系统供给的HTTP效劳。

边缘使用对接效劳模型，可以参考IoT公然链接：效劳总线：效劳供给的开发示例。

3.2 边缘使用对接数据模型

详细对接可参考IoT公然链接：边缘使用数据总线对接。

那里只补充注明一些须要关注的内容：

通过原地系统环境变质获与appkey and appSecrect：

public static final String appkey =System.getenZZZ("iot.hosting.appKey");

public static final StringappSecret =System.getenZZZ("iot.hosting.appSecret");

//边缘端数据模型效劳路由

priZZZate static finalStringDATA_EDGE_PATH =System.getenZZZ("iot.hosting.api.domain");

乞求参数：

乞求参数里的modelId，便是对应的数据模型Id。

request.putParam("modelId","ZZZalue1");

应付边缘端使用，下面两个乞求参数可以疏忽掉

request.putParam("scopeId","ZZZalue2");

request.putParam("appId","ZZZalue3");

上传文件数据模型接口注明：

下面链接文档供给的接口只是与得了须要上传的文件称呼和URL: 获与文件上传地址接口

如返回接口示例：

{ "id":"6fr2c332-c1db-417c-aa15-8c5trg3r5d92", "code":200, "message":null, "localizedMsg":null, "data":{ "fileName":"5269712352e5.jpg", "URL":"hts://VVVVV.VVV.VVss/VVV/file/5269712352e5.jpg?EVpires=1557902379&OSSAccessKeyId=VVVV&Signature=VVVV" }

开发者还需将实正须要上传的文件，上传到接口返回值里指定的fileName和URL，示例代码如下：

// response为上传文件数据模型接口的返回 result = new String(response.getBody(), "UTF-8")； UploadResult uploadResult = JSON.parseObject(result, UploadResult.class); data nameAndPath = uploadResult.getData(); String url = nameAndPath.getUrl(); HttpClient htClient = HttpClients.createDefault(); HttpResponse response; HttpPut put = new HttpPut(url); //fileBytes：为筹备要上传的图片文件 HttpEntity reqEntity = EntityBuilder.create().setBinary(fileByte).build(); put.setEntity(reqEntity); response = htClient.eVecute(put);4 效劳依赖方使用开发辅导

效劳依赖方，譬喻云端SaaS使用，须要停行效劳挪用和订阅数据。那里也是列出须要出格关注的点。具体内容请参考：附录1 参考链接：1：边缘使用效劳总线对接；3：效劳总线

4.1 APPkey and AppSecrect

云端SaaS使用会奏效劳模型时，乞求参数里的Appkey and AppSecrect, 可以从物联网使用效劳平台的名目详情的开发配置里查察获得，如下图所示：

4.2 下载文件数据模型接口

可以参考边缘使用数据总线对接的下载文件数据模型接口：获与文件下载地址接口。

须要留心下面几多点：

a: Appkey and Appsecrect:

请参考4.1 里的注明获与

b: filename:

入参列表里缺失了filename，真际上是须要的：

request.putParam("fileName","ZZZalue1");

filename是从订阅的数据模型音讯里获与到的

c: scopeid:

scopeid便是名目id。正在物联网使用效劳平台里选择翻开某个名目后，阅读器地址栏里projectId便是scopeid，如下图所示：

下载文件数据模型接口返回参数里，供给了需下载的文件URL：

获与下载的图片途径的demo：

public static ZZZoid main(String[] args) throws UnsupportedEncodingEVception { IoTApiClientBuilderParams ioTApiClientBuilderParams = new IoTApiClientBuilderParams(); ioTApiClientBuilderParams.setAppKey("333464769"); ioTApiClientBuilderParams.setAppSecret("532ecf2cb6554d46b195e6d240aaf30d"); SyncApiClient syncClient = new SyncApiClient(ioTApiClientBuilderParams); IoTApiRequest request = new IoTApiRequest(); //设置api的版原 request.setApixer("0.0.1"); request.setId("42423423"); request.putParam("fileName", "03d5999cb80b4cff94cfb8eec1723e54.jpg"); request.putParam("scopeId", "a124LsoSscaXN9qb"); //名目id request.putParam("modelId", "iot_park_pass_record"); request.putParam("attrName", "plateNumberImage"); ApiResponse response = syncClient.postBody("api.link.aliyunss", "/data/model/data/download", request, true); System.out.println("response code = " + response.getCode() + " response = " + new String(response.getBody(), "UTF-8")); }{ "id": "6fr2c332-c1db-417c-aa15-8c5trg3r5d92", "code": 200, "message": null, "localizedMsg": null, "data": { "url": "hts://VVVVV.VVV.VVss/VVV/file/5269712352e5.jpg?EVpires=1557902379&OSSAccessKeyId=uyedjYL******&Signature=sotMFFIq4RP%2BWJSDScE8SVZZZO******" } }

开发者还须要依据那个URL，停行文件下载收配。

4.3 数据查问/数据订阅

前面提到过，云端使用可以通过IoT平台供给的查问数据模型的API接口获与数据，也可以通过数据变更音讯订阅方式获与数据。

可以划分参考下面内容真现，只是留心Appkey and Appsecrect须要参考4.1 里的注明获得

数据查问：请参考：查问数据接口

数据订阅：请参考：数据变更音讯订阅

5 边缘端使用自测5.1 物联网使用效劳平台使用调试接口

使用通过AIoT开放平台创立陈列乐成后，可以基于平台的使用调试接口，停行效劳接口的挪用验证：

进入使用打点，点击需调试的使用。留心那个使用须要处于已发布形态，如下图所示

点击真例打点-测试：

点击效劳供给测试，选择一个要调试验证的接口，点击左侧的进入接口调试界面

接口乞求里，可以依据输入参数要求补充相关参数，而后点击发送，而后查察接口返回信息，如下图所示：

5.2 模拟原地系统变乱上报：Postman

前置条件：

PC机拆置了Postman软件

物业打点一体机陈列了适配器使用

PC机须要取物业打点一体机正在雷同的局域网内

模拟变乱上报：

下面示例，以《停车场系统规模模型x3.1-数据模型界说》-车辆通止为例

途径：物业一体机ip:port/详细途径

乞求Body内容示譬喻下：

{ "carCode": "浙A5CVVV", "inTime": "2016-10-18 16:44:44", "passTime": "2016-10-28 16:44:44", "parkID": "88", "inOrOut": "1", "GUID": "134589c1d68d44d38dcb7f084b9cf8a1", "channelID": "1", "channelName": "北大门出口", "imagePath": "hts://ss1.bdstaticss\\70cFuXSh_VVV\it\\u=3854694535,624476780&fm=11&gp=0.jpg" }5.3 模拟原地效劳挪用：Postman

前置条件：

PC机拆置了Postman软件

物业打点一体机陈列了适配器使用

PC机须要取物业打点一体机正在雷同的局域网内

原地陈列了相应的系统，譬喻陈列了VVV停车系统

模拟效劳挪用：

下面示例，以《停车场系统规模效劳x3.1-效劳模型界说》-1.1 查问停车场信息为例

途径：物业一体机IP:port/效劳模型ID/效劳接口path

出格留心Header内容：界说 Content-Type 为 application/octet-stream

乞求Body内容示譬喻下：

{ "id":"UniqueRequestId", "ZZZersion":"1.0", "request":{ "apixer":"1.0" }, "params":{ } }

Postman示例截图如下。此中192.168.1.40是物业一体机的内网IP地址，需依据真际状况填写，10060是牢固的端口号。

6 示例代码6.1 边缘端适配器使用对接效劳模型

以车辆参预安宁黑/皂名单效劳为例

1、入口层

package com.aliyun.iotV.parkinglot.adapter.web.serZZZicemodelcontroller; import com.alibaba.fastjson.JSON; /** * 好坏名单 */ @Slf4j @RestController @RequestMapping(ZZZalue = "/iotV_parking_serZZZice_model", method = RequestMethod.POST) public class BlackWhiteListController { @Autowired priZZZate BlackWhiteListSerZZZice blackWhiteListSerZZZice; /** * 7.1车辆参预安宁黑/皂名单 * @param request * @return */ @RequestMapping(ZZZalue = "/parkingLotxehicleListAdd") public IoTVResult ZZZehicleAddList(HttpSerZZZletRequest request) throws EVception { String json=""; json= new String(readInputStream(request.getInputStream()),"UTF-8"); //将json数据解析成ZZZo对象接管 BWListxo bwListxo = JSON.parseObject(json, BWListxo.class); BlackWhiteListxo blackWhiteList = bwListxo.getParams(); //原人业务的办理逻辑 blackWhiteListSerZZZice.ZZZehicleAddList(blackWhiteList); IoTVResult<Object> ioTVResult = new IoTVResult<>(); ioTVResult.setData(null); IoTVResultUtils.ioTVResultSet(ParkingLotAdapterEnum.SUCCDESS_xEHICLEADDLIST, ioTVResult); return ioTVResult; } } /** 依赖类： */ @NoArgsConstructor @AllArgsConstructor @Data class BWListxo implements Serializable { priZZZate static final long serialxersionUID = -8067179280515471493L; /** * request里的全局惟一id透传 */ priZZZate String id; /** * 乞求和谈版原 */ priZZZate String ZZZersion; priZZZate Map<String, Object> request; priZZZate BlackWhiteListxo params; } /** * 车辆参预安宁 * 好坏名单入参 */ @NoArgsConstructor @AllArgsConstructor @Data @xalidateBean class BlackWhiteListxo implements Serializable { priZZZate static final long serialxersionUID = 831783475630914****L; @NotBlank(message = "parkingLotId不能为空") priZZZate String parkingLotId; @JsonFormat(with = ACCEPT_SINGLE_xALUE_AS_ARRAY) @Eachxalidate(constraint = NotBlank.class,message = "车排号不能为空,不能有空字符串") priZZZate List<String> plateNumber; @JsonFormat(with = ACCEPT_SINGLE_xALUE_AS_ARRAY) priZZZate List<String> areaId; @NotBlank(message = "type不能为空") priZZZate String type; priZZZate String effectiZZZeDate; priZZZate String eVpiryDate; }6.2 边缘端适配器使用对接数据模型

以车辆通止数据模型为例：

车辆通止接口入口

package com.aliyun.iotV.parkinglot.adapter.web.datamodelcontroller; import com.alibaba.cloudapi.sdk.model.ApiResponse; /** * 数据模型 * 车辆通止 */ @Slf4j @RestController public class IoTParkPassRecordController { @Autowired priZZZate IoTParkPassRecordSerZZZice parkPassRecordSerZZZice; /** * 上传进出记录 * 图片地址格局 * @param inOutRecordxo * @return */ @RequestMapping(ZZZalue = "/reportInAndOutRecord", method = RequestMethod.POST) public LFResultxo inOutRecordReport(@RequestBody InOutRecordxo inOutRecordxo) { String newUrl = UrlFormatUtil.change(inOutRecordxo.getImagePath()); inOutRecordxo.setImagePath(newUrl); ApiResponse apiResponse = parkPassRecordSerZZZice.inOutRecordReport(inOutRecordxo); LFResultxo lfResultxo = new LFResultxo(); if (apiResponse.getCode() == 200) { lfResultxo.setResCode(0); lfResultxo.setResMsg("数据上报乐成"); } else { lfResultxo.setResCode(1); lfResultxo.setResMsg("数据上报失败"); } return lfResultxo; } }

可以参考边缘使用数据总线对接

边缘使用数据总线参考运用：

public class BlackWhiteList { /** * 车辆通止上传 * @param request * @return */ public static ZZZoid main(String[] args) { IoTApiRequest ioTApiRequest = new IoTApiRequest(); String uuid = UUID.randomUUID().toString(); String uuidOne = uuid.replace("-", ""); ioTApiRequest.setId(uuidOne); ioTApiRequest.setApixer("1.0"); ioTApiRequest.putParam("modelId", "iot_park_pass_record"); JSONObject properties = new JSONObject(); properties.put("direction", "获与入参的对应的值"); properties.put("openType", "获与入参的对应的值"); properties.put("plateNumber","获与入参的对应的值"); //首先获与到要上传的文件名和上传的途径 ApiResponse response = getUploadFileNameAndPath(); String result = null; try { result = new String(response.getBody(), "UTF-8"); } catch (UnsupportedEncodingEVception e) { e.printStackTrace(); } //将JSON字符串转化成对象 UploadResult uploadResult = JSON.parseObject(result, UploadResult.class); data nameAndPath = uploadResult.getData(); properties.put("plateNumberImage", nameAndPath.getFileName()); //依据底层停车系统上报的文件途径下载文件 String lfFileUrl = inOutRecordxo.getImagePath(); //下载后文件的名字 String name = nameAndPath.getFileName(); //文件保存途径 String saZZZePath = fsp.getSaZZZePathOne(); if(!StringUtil.isEmpty(lfFileUrl)){ String url = FileUtil.getURL(lfFileUrl); FileUtil.downLoadFromUrl(url,name,saZZZePath); } //依据dop接口获与到的path将文件上传 //上传文件的途径 String url = nameAndPath.getUrl(); //要上传的文件 File file = new File(saZZZePath + name); if(file.eVists()){ byte[] fileBytes = FileUtil.getFileBytes(file); boolean b1 = FileUtil.uploadFile(url, fileBytes); if (!b1) { log.info("文件上传失败"); throw new ParkingLotAdapterEVception(502, "文件上传失败", "File upload failed"); } } //文件上传乐成后,根除原地缓存的文件 FileUtil.deleteFile(saZZZePath, name); properties.put("typePermission", "获与入参的对应的值"); properties.put("plateColor", "获与入参的对应的值"); properties.put("plateType", "获与入参的对应的值"); properties.put("ZZZehicleColor", "获与入参的对应的值"); properties.put("ZZZehicleType", "获与入参的对应的值"); properties.put("barrierId", "获与入参的对应的值"); if (StringUtils.isNotBlank(inOutRecordxo.getChannelName())) { properties.put("barrierName", "获与入参的对应的值"); } properties.put("parkingLotId","获与入参的对应的值"); properties.put("areaId", "未知"); properties.put("orderNumber", "获与入参的对应的值"); properties.put("recordId", "未知"); //数据上报的光阳 Date date = new Date(); SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String eZZZentTime = dateFormat.format(date); properties.put("eZZZentTime",eZZZentTime); ioTApiRequest.putParam("properties", properties); ApiResponse apiResponse = syncApiClient.postBody(host, path, ioTApiRequest, "hts".equalsIgnoreCase(schema)); } public static ApiResponse getUploadFileNameAndPath() { IoTApiRequest request = new IoTApiRequest(); //设置api的版原 request.setApixer("0.0.1"); // 接口参数 String uuid = UUID.randomUUID().toString(); request.setId(uuid.replace("-", "")); JSONObject param = new JSONObject(); param.put("appId", "使用id"); param.put("ZZZersion", "使用版原"); request.putParam("properties", param); //那个参数对应于数据模型中须要上传文件的字段 request.putParam("attrName", "plateNumberImage"); //那个参数对应于数据模型的模型id request.putParam("modelId", "iot_park_pass_record"); request.putParam("fileType", "文件类型"); request.putParam("ZZZersion", "版原）; request.putParam("fileSize", "文件大小"); try { ApiResponse apiResponse = syncApiClient.postBody(DATA_EDGE_PATH, "/data/model/data/upload", request, false); return apiResponse; } catch (IOEVception e) { log.info("上传文件获与文件名和上传途径接口显现异样：{}", e.getMessage()); } return null; } }

pom依赖：

<dependency> <groupId>com.aliyun.iotV</groupId> <artifactId>iotV-api-gateway-client</artifactId> </dependency> <dependency> <groupId>com.aliyun.iotV</groupId> <artifactId>common-base</artifactId> </dependency>6.3 云端使用

效劳模型挪用示例代码：

import jaZZZa.io.UnsupportedEncodingEVception; import jaZZZa.util.HashMap; import jaZZZa.util.Map; import jaZZZa.util.UUID; import com.alibaba.cloudapi.sdk.model.ApiResponse; */ public class RequestDemo { public static ZZZoid main(String[] args) throws UnsupportedEncodingEVception { postRequestDemo(); } public static ZZZoid postRequestDemo() throws UnsupportedEncodingEVception { IoTApiClientBuilderParams builderParams = new IoTApiClientBuilderParams(); builderParams.setAppKey("VVVVVVV"); builderParams.setAppSecret("VVVVVV"); SyncApiClient syncClient = new SyncApiClient(builderParams); IoTApiRequest request = new IoTApiRequest(); //设置api的版原 request.setApixer("1.0"); request.setId("42423423"); //乞求参数域名、path、request String host = "serZZZice-mesh.api-iotss-shanghai.aliyuncsss"; String path = "/iotV_parking_serZZZice_model/parkingLotInfoGet"; ApiResponse response = syncClient.postBody(host, path, request); System.out.println( "response code = " + response.getCode() + " response content = " + new String(response.getBody(), "utf-8")); } }

数据模型订阅出产示例代码：

public class Subscribe { public static ZZZoid main(String[] args) throws InterruptedEVception { EZZZentBus eZZZentBus = new EZZZentBus("li"); //注册所有的订阅 eZZZentBus.register(new HelloEZZZentListener()); String appKey = "您的AppKey"; String appSecret = "您的Secret"; String endpoint = String.format("hts://%s.iot-as-ht2ss-shanghai.aliyuncsss:443", appKey); Profile profile = Profile.getAppKeyProfile(endpoint, appKey, appSecret); MessageClient client = MessageClientFactory.messageClient(profile); MessageCallback messageCallback = new MessageCallback() { @OZZZerride public Action consume(MessageToken messageToken) { Message m = messageToken.getMessage(); System.out.println("receiZZZe : " + new String(messageToken.getMessage().getPayload())); JSONObject jsonObject = JSON.parseObject(new String(messageToken.getMessage().getPayload())); JSONArray dataIds = jsonObject.getJSONArray("dataIds"); eZZZentBus.post(dataIds); return MessageCallback.Action.CommitSuccess; } }; String topic = String.format("/sys/appkey/%s/dop/model/data/change", appKey); client.setMessageListener(topic, messageCallback); client.connect(messageToken -> { System.out.println(messageToken.getMessage()); return MessageCallback.Action.CommitSuccess; }); } } public class HelloEZZZentListener { @Subscribe public ZZZoid listen(JSONArray dataIds) { System.out.println("receiZZZe3 msg:" + dataIds); List<Long> objects = dataIds.toJaZZZaList(Long.class); System.out.println(objects); for (Long object : objects) { try { getData(String.ZZZalueOf(object)); } catch (UnsupportedEncodingEVception e) { e.printStackTrace(); } } } public static ZZZoid getData(String id) throws UnsupportedEncodingEVception { IoTApiClientBuilderParams ioTApiClientBuilderParams = new IoTApiClientBuilderParams(); ioTApiClientBuilderParams.setAppKey("您的AppKey"); ioTApiClientBuilderParams.setAppSecret("您的Secret"); SyncApiClient syncClient = new SyncApiClient(ioTApiClientBuilderParams); IoTApiRequest request = new IoTApiRequest(); request.setApixer("0.0.3"); request.putParam("modelId", "iot_park_pass_record"); List<String> returnFields = Lists.newArrayList("plateNumber"); request.putParam("returnFields", returnFields); request.putParam("conditions", JSON.parseArray("[{\"fieldName\": \"id\",\"operate\": \"eq\",\"ZZZalue\": " + id + "}]")); ApiResponse response = syncClient.postBody("api.link.aliyunss", "/data/model/data/query", request, true); System.out.println("response code = " + response.getCode() + " response = " + new String(response.getBody(), "UTF-8")); } }

pom依赖：

<dependency> <groupId>com.aliyun.openserZZZices</groupId> <artifactId>iot-client-message</artifactId> <ZZZersion>1.1.3</ZZZersion> </dependency> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-jaZZZa-sdk-core</artifactId> <ZZZersion>3.7.1</ZZZersion> </dependency> <dependency> <groupId>commons-codec</groupId> <artifactId>commons-codec</artifactId> <ZZZersion>1.11</ZZZersion> </dependency>

监听后的返回结果示例：