边缘消息
边缘消息包括消息端点和消息路由;它提供高性能和高可靠的分布式消息服务,支撑大数据采集、传输、汇聚、交换和存储,满足大数据实时处理和微服务处理架构。
消息端点
消息端点列表
菜单路径
边缘消息→ 消息端点
操作步骤
1 登录控制台。
2 进入智能边缘服务页面。
3 点击 “边缘消息” > “消息端点”,进入消息端点列表页面。
在当前页面查看已经创建的消息端点信息,还可以通过消息端点名称进行搜索。
创建消息端点
菜单路径
边缘消息→ 消息端点→ 创建消息端点
操作步骤
1 登录控制台。
2 进入智能边缘服务页面。
3 点击 “边缘消息” > “消息端点” > “创建消息端点”,进入创建消息端点页面,有三种可供创建的消息端点类型,见下图。
表1:Nats端点
属性名称 | 填写规则 |
---|---|
类型 | Nats |
位置 | 边缘节点 |
选择节点 | 已纳管且未创建端点的边缘节点 |
名称 | 1~50个字符,由小写字母、数字、“-”、“_”或“.”组成,并且必须以小写字母或数字开始和结束。 |
特别提示:这里在环境初始化时已创建好云端点
表2:FileService端点
属性名称 | 填写规则 |
---|---|
类型 | FileService |
位置 | 边缘节点 |
选择节点 | 已纳管的边缘节点 |
名称 | 1~50个字符,由小写字母、数字、“-”、“_”或“.”组成,并且必须以小写字母或数字开始和结束。 |
文件路径 | 2~50个字符,路径必须以‘/’开头,仅支持字母、数字、下划线。 |
表3:OSS端点
属性名称 | 填写规则 |
---|---|
类型 | OSS |
位置 | 云端 |
名称 | 1~50个字符,由小写字母、数字、“-”、“_”或“.”组成,并且必须以小写字母或数字开始和结束。 |
accessKey | 选择API密钥的AccessKeyID。 |
存储桶 | 选择对象存储中的存储桶。 |
访问域名 | 选择存储桶的访问域名。 |
secretKey | 输入API密钥AccessKeyID对应的AccessKeySecret。 |
特别提示:一个账号只允许创建一个OSS端点
5 点击确认按钮。
6 返回消息端点列表,查看消息端点,见下图。
消息路由
消息路由列表
菜单路径
边缘消息→ 消息路由
操作步骤
1 登录控制台。
2 进入智能边缘服务页面。
3 点击 “边缘消息” > “消息路由”,进入消息路由列表页面。
在当前页面查看已经创建的消息路由信息,还可以通过消息路由名称进行搜索。
创建消息路由
菜单路径
边缘消息→ 消息端点→ 创建消息路由
操作步骤
1 登录控制台。
2 进入智能边缘服务页面。
3 点击 “边缘消息” > “消息路由” > “创建消息路由”,进入创建消息路由页面,见下图。
4 (1) 源端点类型为Nats,目的端点为CloudNats,填写节点信息,需要填写的信息见表4。
表4
属性名称 | 填写规则 |
---|---|
消息路由名称 | 1~50个字符,由小写字母、数字、“-”、“_”或“.”组成,并且必须以小写字母或数字开始和结束 。 |
源端点 | 选择创建好的源端点 |
Topic | 选择源Topic,且1~50个字符,由小写字母、数字、“-”、“_”或“.”组成,并且必须以小写字母或数字开始和结束 。 |
目的端点 | 选择创建好的目的端点 |
特别提示:源端点为创建好的边缘Nats端点,目的端点为创建好的云端Nats端点
(2) 源端点类型为FileService,目的端点类型为OSS,填写节点信息,需要填写的信息见表5。
表5
属性名称 | 填写规则 |
---|---|
消息路由名称 | 1~50个字符,由小写字母、数字、“-”、“_”或“.”组成,并且必须以小写字母或数字开始和结束 。 |
源端点 | 选择创建好的源端点 |
目的端点 | 选择创建好的目的端点 |
特别提示:源端点为创建好的边缘FileService端点,目的端点为创建好的云端OSS端点
5 点击确认按钮。
6 返回消息端点列表,查看消息端点,见下图。
发送消息
从边缘端发送消息到云端,您首先需要获取Endpoint,然后你需要构造请求,将消息通过路由发送至云端。
1 获取Endpoint。
- 登录控制台。
- 进入智能边缘服务页面。
点击 “边缘消息” > “消息端点”,在列表属性列,且位置是edge、类型是Nats,endpoint的取值即为Endpoint,如下图。
2 构造请求,发送消息。
往云端发送消息,需构造HTTPS请求,具体信息如下。
- Method:POST
- URL:https://{endpoint}/iies/v1/message/node/{nodeId}/topic/{topic},endpoint即1中获取的endpoint,nodeId为边缘节点ID,topic为消息的主题,即创建消息路由中定义的源端点资源。
- Body:发送的消息内容,结构体里data字段是要传送的数据,data对应的值用户可自定义类型。
Header:Bearer Token,可通过消息端点列表 > 操作(查看密钥)获取。
- nodeId:为纳管的边缘节点ID
topic:创建消息路由中定义的源端点资源
获取token
获取nodeId
获取topic
接收消息
从云端接收消息,您首先需要获取Endpoint,然后你需要构造请求,通过路由接收消息。
1 获取Endpoint。
- 登录控制台。
- 进入智能边缘服务页面。
点击 “边缘消息” > “消息端点”,在列表属性列,且位置是cloud、类型是Nats,endpoint的取值即为Endpoint,如下图。
2 构造请求,接收消息。
云端接收消息,需构造HTTPS请求,具体信息如下。
- Method:GET
- URL:https://{endpoint}/iies/v1/message/node/{nodeId}/topic/{topic},endpoint即1中获取的endpoint,nodeId为边缘节点ID,topic为消息的主题,即创建消息路由中定义的源端点资源。
Header:Bearer Token,可通过消息端点列表 > 操作(查看密钥)获取。
- nodeId:为纳管的边缘节点ID
topic:创建消息路由中定义的源端点资源
获取token
获取nodeId
获取topic
发送文件
边缘端发送文件到云端,您需要将文件上传到FileService端点所属边缘端的对应路径下,将文件通过路由发送至云端。
接收文件
在对象存储服务中访问创建OSS端点时选择的存储桶即可下载上传至边缘端的文件。