机器网关服务.PDF

机器网关服务 机器网关服务 机器网关服务为在同一个OSGi 框架实例上运行的机器适配器提供了集 中的配置、监控监测和管理。 通过通用API 也展示了来自多个机器适配器的实时数据流，还可以用作服务多个客户端的 数据聚合器。 机器网关服务的架构灵活，可扩展，这样，开发者可以针对实时数据流自定义适配器。默认 提供MQTT、OPC-UA、Modbus 和健康状况监控监测器机器适配器。 启动开机时，机器网关查询所有已安装机器适配器的OSGi 服务注册表，并始终追踪其状态。 IMachineGateway 接口允许客户端服务获得机器适配器和数据节点列表，并读取和写入数 据。下图显示了机器网关服务的高级组件概览视图以及与其他服务的交互方式 依赖项 数据包com.ge.dspmicro.machinegateway.types 以及数据包中的类已经被转移移动 到新的 device-common bundle 中捆绑束。为这些类添加以下下列依赖项。 groupIdcom.ge.dspmicro/groupId artifactIddevice-common/artifactId version{Predix Machine version}/version 使用机器网关API 查看机器网关Javadoc API，了解如何实现机器网关服务。 找到并打开下列API ：SDK installation location/docs/apidocs/index.html/com.dspmicro.machinegateway.api。 使用机器网关示例应用程序 两个示例应用程序向你演示了如何构建自定义机器网关适配器。 1. 导航至SDK installation location/samples/sample-apps.zip 并提取文件。 2. 打开sample-basicmachineadapter 和sample-sample-subscriptionmachineadapter 应用程序。 注： 参见示例应用程序了解示例应用程序的构建和运行。 机器网关Ping 从机器网关、机器适配器、数据订阅、Hoover Spillway 和处理器到river 服务，机器网关Ping 服务都会发送PING 消息来确认连接。 机器网关Ping 服务实现 IValidateRoute 接口。在调用 ping (IPingMessage) 方法之 前， IPingMessage 实例应由 Machine Gateway Ping 服务通过调用 createPingMessage(MapString, Object params, IPongNotification pongNotification)方法创建。创建需要两个自变量：具有密钥的三个参数、适配器、订 阅和Spillway，这些在 E2EPingMessage 类中定义来识别网关，以及一个能够处理网关上 的pong 消息的pong 通知回调函数。 如果一个或多个参数无效或丢失，PONG 消息会包含有效的选项来更改参数并再次输入。 依赖项 消费此服务需要Maven 依赖项和OSGi 导入：  消费机器网关Ping 服务需要以下Maven 依赖项： dependency groupIdcom.ge.dspmicro/groupId artifactIdvalidater oute-api/artifactId version15.4.0/version /dependency  消费捆绑束需要下列OSGi 导入 Import Package: com.ge.dspmicro.validateroute.api;version=[1.0,2) 获取机器网关Ping 服务 使用声明式服务，注入机器网关Ping 服务。 如何注入机器网关Ping 服务的范例： @Reference(type = *) public void setMachineGatewayPing(IValidateRoute vali dateRoute) { if (E2EPingMessage.ROUTE_ADAPTER_TO_DATA_RIVER.equals(validate Route.getRouteName()) { //set service here this.machineGatewayPing = validat eRoute; } } 数据存储和转发 数据存储和转发服务会持续存储机器、传感器和设备