GB/T32419.4-2016
信息技术SOA技术实现规范第4部分：基于发布/订阅的数据服务接口
Informationtechnology—SOAtechnicalimplementationspecification—Part4:Publish/subscribebaseddataservicesinterface
- 中国标准分类号（CCS）L79
- 国际标准分类号（ICS）35.100.05
- 实施日期2017-05-01
- 文件格式PDF
- 文本页数25页
- 文件大小369.39KB
以图片形式预览信息技术SOA技术实现规范第4部分：基于发布/订阅的数据服务接口
信息技术SOA技术实现规范第4部分：基于发布/订阅的数据服务接口
国家标准 GB/T32419.4一2016 信息技术 SOA技术实现规范 第4部分:基于发布/订阅的数据服务接口 lInformationtechnology一SOAtechniealimplementationspeeifieation Part4:Publish/subsribebaseddataservicesinterface 2016-10-13发布 2017-05-01实施 国家质量监督检验检疫总局 发布 国家标准化管理委员会国家标准
GB/T32419.4一2016 前 言 GB/T32419信息技术sOA技术实现规范》分为6个部分 -第1部分:服务描述; 第2部分;服务注册与发现; 第3部分:服务管理; 第4部分;基于发布/订阅的数据服务接口 第5部分;服务集成开发; 第6部分:身份管理服务
本部分为GB/T32419的第4部分
本部分按照GB/T1.12009给出的规则起草
请注意本文件的某些内容可能涉及专利
本文件的发布机构不承担识别这些专利的责任 本部分由全国信息技术标准化技术委员会(SAC/TC28)提出并归口
本部分起草单位北京航空航天大学,北京大学、电子技术标准化研究院,国家信息中心,.北京 方位捷迅科技有限公司
本部分主要起草人;梅宏,赵永望,马殿富,王潮阳,袁媛、徐枫、宦茂盛
GB/T32419.4一2016 信息技术SOA技术实现规范 第4部分:基于发布/订阅的数据服务接口 范围 GB/T32419的本部分规定了基于发布/订阅的数据服务接口,包括相关约定、数据发布端点、数据 获取端点、数据接收端点和web服务接口的实现
本部分适用于sOA技术实现的开发、集成和应用
规范性引用文件 下列文件对于本文件的应用是必不可少的
凡是注日期的引用文件,仅注日期的版本适用于本文 凡是不注日期的引用文件,其最新版本(包括所有的修改单)适用于本文件 件
信息技术面向服务的体系结构(soA GB/T292622012 术语 GB/T292632012信息技术面向服务的体系结构(sOA应用的总体技术要求 术语和定义及缩略语 3.1 术语和定义 GB/T292622012界定的以及下列术语和定义适用于本文件
3.1.1 数据源 dataS0urce 数据的原始来源地
3.1.2 数据主题datatopie 数据源经发布后形成的一个数据类别
3.1.3 发布publish 将数据源与主题进行映射并在网络上以服务形式进行公开的过程
3.1.4 数据发布端点datapublishingendpoint 数据主题在网络上发布形成的服务访问点
3.1.5 数据获取端点 dataaccessendpoint 数据发布者上用于获取实际数据的服务访问点
3.1.6 订阅subscrihe 通过调用数据发布端点的服务,来表明对某种数据的兴趣,并通过注册的方式将数据使用者的数据 接收端点告知数据发布端点
GB/T32419.4一2016 3.1.7 数据接收端点datasubseribin ingendpoint 数据订阅者上用于接收通知的服务访问点
3.1.8 通知notifieation 在数据主题更新时,数据发布端点发送给数据接收端点的一个数据消息 3.2缩略语 下列缩略语适用于本文件
JsONJavaseript对象标记(javascriptobjeetnotation SOAP简单对象访问协议(simpleobjectaccessprotocol XML可扩展标记语言(extensiblemarkuplanguage 数据服务接口 4.1相关约定 4.1.1综述 本部分中数据服务的运行模式主要基于发布/订阅的网络服务模式
本条给出接口所涉及的发布 订阅,通知和数据获取这4个动作的相关约定
基于发布/订阅模式所进行的应用开发,除了应遵循 GB/T29263一2012中7.4的要求外,还应符合本条的要求
4.1.2发布 数据发布将数据源与主题进行映射,并将数据的可获取地址在网络上进行公布
发布过程会形成 个数据主题及相应的数据发布端 数据源、数据主题和数据发布端点之间有以下关系: 1同一个数据源可以被发布为多个数据主题,每个数据主题包含不同的名称,每个数据主题 是对数据源的一种封装,形成XMI可表示的数据; 2)多个数据主题可被发布在同一个数据发布端点
b)数据主题的构成可包括以下属性: 1 主题名称:每个主题唯一的,用于区分的标识名称; 2)数据类型:该主题发布的数据的类型,以XMLSchema表示 3)数据的有效期:该主题数据的有效时间,以年月日时分秒表示的截止时间; 4)数据更新的周期;该主题对应数据源中数据的更新周期,以秒为单位
数据发布端点的构成可包括以下属性 1 所对应的数据主题; 2)访问地址;通过该地址可访问发布端点中各种服务和数据 3)数据发布端点的服务接口;至少包含数据订阅服务、主题查询服务、数据获取服务
4.1.3订阅 订阅的具体要求如下 订阅者通过与数据发布端点的消息交互,进行一系列数据订阅的操作,具体有 1数据订阅:订阅者通过调用服务发布端点的订阅服务,并告知订阅的数据主题、数据订阅
GB/T32419.4一2016 类型和数据接收端的地址,从而在数据发布端点建立数据主题与数据接收端点的兴趣关 系
订阅成功后,数据主题的数据更新将按订阅类型通知给订阅者 数据退订;订阅者通过调用服务发布端点的退订服务,告知服务发布端点,该数据接收端 点与数据发布端点的订阅关系撤销
退订成功后,该数据主题的数据将不再通知给该订 阅者
暂停订阅订阅者通过调用服务发布端点的暂停订阅服务,告知服务发布端点,该数据接 收端点与数据发布端点的订阅关系暂停
暂停成功后,该数据主题的数据将不再通知给 该订阅者
直到订阅者重启该订阅后,数据通知恢复正常
重启订阅:订阅者在暂停订阅某个数据主题后,可调用数据发布端点的重启订阅服务,重 新恢复对该数据主题的订阅
更新订阅:订阅者在订阅某个数据主题后,可通过调用数据发布端点的更新订阅服务,更 新对该主题订阅的类型或参数
订阅者订阅某个数据主题时,可有多种不同的订阅类型,包插 b 订阅的时域类型;数据订阅的时域类型指订阅者在成功订阅某个数据主题后,数据发布端 1 点将按其订阅的时域条件进行数据通知,具体的时域条件有 起止时间;给定订阅的起止时间(以年月日时分秒为单位),在该时间范围内,数据发 布者有数据更新时会通知订阅者; 特定时间;给定订阅的一个时间点(以年月日时分秒为单位),当该时间到达时,数据 发布者将数据通知给订阅者 持续时间;给定从当前时间开始,订阅的一段持续时间(以秒为单位),从当前时间开 段持续时间内,数据发布者有数据更新时会通知订阅者 始的 滞后时间;给定从当前时刻开始的一个滞后时间(以秒为单位),从那个时间起,数据 发布者有数据更新时会通知订阅者 终止时间给定一个终止时间(以年月日时分秒为单位),从当前时间到该终止时间范 围内,数据发布者有数据更新时会通知订阅者 间隔时间;给定一个时间间隔周期(以秒为单位),每隔一个周期时间,数据发布者将 数据通知给订阅者
订阅的频域类型数据订阅的频域类型指订阅者在成功订阅某个数据主题后,数据发布端 点将按其订阅的频域条件进行数据通知
具体的频域条件有: -订阅次数;给定一个整数值n,当订阅者接收到n个该数据主题的数据更新后,不再 订阅该主题 e订阅消息的构成可包含以下属性: 1 订阅的主题; 2 订阅的类型; 3)订阅者的数据接收端点信息
4.1.4通知 数据源有新数据时,相关数据主题的数据发布端点通过调用该主题订阅者的数据接收端点服务,将 数据消息通知给订阅者
由于数据源的不同,本部分支持两种模式的通知类型;数据通知和引用通知
数据通知是数据发布 端点可将数据封装在通知消息的消息体中的一种方式,引用通知是数据发布端点将数据获取端点封装 在通知消息的消息体中的一种方式
数据接收端点得到数据获取端点后,通过调用数据获取端点的服 务接口,来获得具体的数据
GB/T32419.4一2016 通知的构成可包含以下属性 a)数据主题名称 b 数据更新的时间 数据内容或数据获取点地址
c 4.1.5数据获取 订阅者通过数据发布端点上的数据获取服务,可查询数据发布端点上的数据主题,并可获得某个主 题的最新数据
4.2数据发布端点 4.2.1 综述 数据发布端点的接口为包括订阅服务(订阅、退订、暂停订阅、重启订阅、更新订阅等),主题查询服 务等提供支持
4.2.2数据订阅服务消息格式 订阅者通过数据发布端点调用数据订阅服务时,应使用表1、表2、表3所描述的格式
表1调用订阅服务消息格式 字段名称 含义描述 字段类型 消息名称 字符串 Subscribe Topie 订阅的主题名称 字符串 订阅类型 Subscriptiontype 复杂类型(具体见表2 数据接收端地址 字符串 Datasubscriptionendpoiont 表2订阅内容消息格式 字段名称 订阅类型 含义描述 字段类型 日期时间 订阅的起始时间" from 起止时间 订阅的终止时间 日期时间 特定时间 when 订阅的一个时间点 日期时间 订阅从当前时间开始持续一段 持续时间 整数 keepon 时间(单位;s 滞后时间 从该时间开始订阅有效 日期时间 after 截止时间 until 订阅一直有效,直到该截止时间 日期时间 间隔时间 -个时间间隔周期(单位:s) 整数 foreach 整数 订阅次数 订阅的次数 times
GB/T32419.4一2016 表3订阅服务返回结果消息格式 字段名称 含义描述 字段类型 字符串 返回值 Response 其中,订阅成功时,Response字符串值为“OK”;失败时,Response字符串值为“ERROR”并跟上错 误类型信息 4.2.3数据退订服务 订阅者通过数据发布端点调用数据退订服务时,应使用表4,表5所描述的格式
表4退订消息格式 字段名称 含义描述 字段类型 Unsubscribe 消息名称 字符串 Topic 订阅的主题名称 字符串 表5退订返回结果消息格式 含义描述 字段名称 字段类型 返回值 字符串 Response 其中,订阅成功时,Response字符串值为“OK”;失败时,Response字符串值为“ERROR”并跟上错 误类型信息
4.2.4暂停订阅服务 订阅者通过数据发布端点调用暂停订阅服务时,应使用表6,表7所描述的格式
表6暂停订阅消息格式 字段名称 含义描述 字段类型 Suspendsubseribe 消息名称 字符串 Topie 订阅的主题名称 字符串 表7暂停订阅返回结果消息格式 字段名称 含义描述 字段类型 返回值 字符串 Response 其中,订阅成功时,Response字符串值为“OK”;失败时,Response字符串值为“ERROR”并跟上错 误类型信息 4.2.5重启订阅服务 订阅者通过数据发布端点调用重启订阅服务时,应使用表8,表9所描述的格式
GB/T32419.4一2016 表8重新订阅消息格式 含义描述 字段名称 字段类型 字符串 消息名称 Resumesubscribe 字符串 订阅的主题名称 Topic 表9重新订阅返回结果消息格式 含义描述 字段类型 字段名称 Response 返回值 字符串 其中,订阅成功时,Response字符串值为“OK”;失败时,Response字符串值为“ERROR”并跟上错 误类型信息
4.2.6更新订阅服务 订阅者通过数据发布端点调用更新订阅服务时,应使用表10,表11所描述的格式
表10更新订阅消息格式 字段名称 字段类型 含义描述 Updatesubscribe 消息名称 字符串 Topie 订阅的主题名称 字符串 Subscriptiontype 订阅类型 复杂类型 数据接收端地址 字符串 Datasubscriptionenpoiont 其中,订阅类型具体内容与4.2.2的类型一致
表11更新订阅返回结果消息格式 字段名称 含义描述 字段类型 Response 返回值 字符串 其中,订阅成功时,Res 字符申值为"OR",;失败时,Repone se字符串值为“ERROR”并跟上错 esponse 误类型信息
4.2.7数据主题查询服务 订阅者通过数据发布端点调用数据主题查询服务时,应使用表12,表13所描述的格式 表12数据主题查询消息格式 字段名称 义描述 字段类型 含 消息名称 字符串 Gettopic Topie 字符串 订阅的主题名称
GB/T32419.4一2016 表13数据主题查询返回结果消息格式 字段名称 含义描述 字段类型 返回值 字符串或复杂结构 Response 其中,成功时,Response值包含“OK”以及一个Topic的数据结构;失败时,Response字符串值为 “ERRoR”并跟上错误类型信息
4.3数据获取端点 4.3.1综述 数据获取端点的服务主要用于数据接收端点向数据发布者发送消息以获取实际的数据,主要为数 据获取服务
4.3.2数据获取服务 订阅者通过数据获取端点调用数据获取服务时,应使用表14、表15所描述的格式
表14获取数据消息格式 字段名称 含义描述 字段类型 字符串 消息名称 Getdata Topie 订阅的主题名称 字符串 表15获取数据返回结果消息格式 字段名称 含义描述 字段类型 返回值 字符串或复杂结构 Response 其中，成功时，Response值包含“OK”以及一个数据值结构;失败时,Response字符串值为 “ERROR”并跟上错误类型信息
4.4数据接收端点 4.4.1综述 数据接收端点的服务主要用于所订阅的时域、频域条件满足时,数据发布端点向接收端点发送通知 时所调用的服务接口,主要为通知服务
4.4.2通知服务 数据发布端点调用数据接收端点的通知服务时,可直接发送主题数据的值,也可发送获取主题数据 的获取点地址,应使用表16所描述的格式
GB/T32419.4一2016 表16调用通知服务消息格式 字段名称 含义描述 字段类型 字符串 消息名称 Notify 字符串 主题名称 Topic 主题的数据 字符串 Data Datapoint 数据访问点 字符串 4.5web服务接口的实现 第4章规定的面向数据的web服务接口可有多种不同的实现方法包括soOAP服务和JsoN服务 等
第4章规定的接口与sOAP和JsON的绑定,分别见附录A和附录B
GB/T32419.4一2016 附录 A 规范性附录 接口的SOAP绑定 A.1综述 在使用soAP作为web服务消息的编码规范时,应使用本附录定义的接口和消息类型
本附录使用sOAP1.2规范进行定义和描述
sOAP规范定义的XML元素命名空间为http:/ www,w3.org/2003/05/soapenvelope,前缀为soap
使用XMLschema进行数据定义时,sehema元素 的命名空间为http://www,w3.org/2001/XMl.Schema,前缀为xs
本部分定义的XMI元素的命名空 间为http://www.nits.org.cn/soa/dataservice,前缀为ds， A.2数据订阅服务 请求消息定义为 soap:Envelope》 soap;Header /soap:Header》 soap;Body ds:Subscribe》 ds:Topic》 xs:string /ds:Topic ds:Subscriptiontype fromtofrom=”xs:dateTime”to=”xs:dateTime”) whentime=”xs:dateTime xsnt (keepontime5 aftertime=”xs:int utiltime=”xs:dateTime 'xsint 《foreachtime 《timescou1nt=xsint” GB/T32419.4一2016 响应消息定义为 soap;Bnvelope) soap:Header /soaP:Header》 soap:Body ds:SubscribeRes esponse ok/八 errOr xs;string /error 《/ds:SubscribeResponse /soap;Body /soap:Bnvelope A.3数据退订服务 请求消息定义为 〈soap:Bnvelope soap;:Header》 /soap:Header》 soap:Body ds:Unsubscribe ds:Topic xs:string 《7ds:Topic 7ds:Unsubscribe /soap:Body /soap;Bnvelope 响应消息定义为 soap;Bnvelope soap:Header /soap;Header soap;Body dsUnsubscribeRe Response ok八 《error 1o
GB/T32419.4一2016 Xs;string /error /ds;UnsubscribeResponse /soap;Body /soap:Envelope》 A.4暂停订阅服务 请求消息定义为: soap;Envelope》 soap:Header》 /soap:Header》 soap:Body ds:Suspendsubscribe ds:Topic xs;string /ds:Topic /ds;Suspendsubscribe /soap:Body /soap:Envelope》 响应消息定义为 〈soap:Envelope soap;Header》 /soap;Header soap:Body ds;SuspendsubscribeResponse ok/) 《error xs:string /error 7ds:SuspendsubscribeResponse /soap:Body /soap;Bavelope)》 11
GB/T32419.4一2016 A.5重启订阅服务 请求消息定义为 ;Envelope》 soap:" Header》 soap: Header》 7/soap: :Body soaP: ds;Resumesubscribe ds:Topic xs;string /ds:Topic 《/ds:Resumesubscribe》 /soap;Body /soap:Bnvelope 响应消息定义为 soap:Envelope》 soap;Header /soap:Header soap:Body ds:ResumesubscribeResponse》 ok/ error xs:string /error 7ds;ResumesubscribeResponse /soap:Body /soap;Bnvelope A.6更新订阅服务 请求消息定义为 soap;Bnvelope soap;Header /soaP;Header eoap:Boady ds;Updatesubscribe' 12
GB/T32419.4一2016 ds;Topic) xs;string /ds;Topic》 ds:Subseriptiontype' fromtofrom=”xs;dateTime”to=”xs:dateTime”y whentime=”xs;date'Time”
GB/T32419.4一2016 /ds;Topic) /ds.Cettopic) /s0ap:Body /soap;Envelope 响应消息定义为: ;Envelope》 soaP: soap:Header》 /soap:Header》 soap;Body ds:GettopicResponse ok topic》 datatype>any(/datatype》 validtme)xs:dateTime(/validtime period)xs:int(/period》 /topic》 /ok》 error xs:string /error) /ds:GettopicResponse /soap:Body /soap:Envelope A.9通知服务 请求消息定义为 soap;Envelope soap:Header》 /soap;Header soap;Body ds;Notify) ds;topic Xs;string /ds;topic) 《dsdata>(any《/ds;data)》 15
GB/T32419.4?2016 )xs;anyURI/ds;datapoint) ds:datapoint /ds:Notify /soap;Body /soap:Bnvelope' 16
GB/T32419.4一2016 s 附 录 规范性附录 接口的JsoN绑定 B.1综述 在使用JsON作为web服务消息的编码规范时,应使用本附录定义的接口和消息类型
B.2数据订阅服务 请求消息定义为: message”;“subscribe" topie”;string “subscriptiontype” “fromto “from”:,“to”:} “whr hen'”;string keepon”number “after”;string “util”;string “foreach”;number “times”;number “datasubscriptionendpoint”string 响应消息定义为: se'" message”“subscribeRe “me esponse response “normal”;“ok” “eror";string B.3数据退订服务 请求消息定义为 17
GB/T32419.4一2016 “message”“Unsubscribe” “topic”;string， 响应消息定义为
” ;“nsubscribeResponse" message “response “normal”;“ok” “error”;string B,4暂停订阅服务 请求消息定义为 “message”“Suspendsubscribe” “topic”:string 响应消息定义为 "message",“Suspends subseribeResponse" “response” “normal”“ok” “error”;string B.5重启订阅服务 请求消息定义为 “message”;“Resumesubscribe" “topic”;string， 18
GB/T32419.4一2016 响应消息定义为 aage”“ResumesubscribeResponse'” “messal “response “normal”;“ok” “eror";string B.6更新订阅服务 请求消息定义为 message”;“Updatesubscribe" “topic”:string “subscriptiontype” fromto “from”:,“to”:} “when”;string keepOn;number “after”;string “util”:string “foreach”;number “times”;number “datasubscriptionendpoint”:string 响应消息定义为: “message”“UpdatesubscribeResponse” “response” “normal”;“ok” “error”;string B.7数据获取服务 请求消息定义为: 19
GB/T32419.4一2016 “message”;“Getdata" “topic”;string， 响应消息定义为 “message”:“GetdataResponse” response “normal”;object “error”:string B.8数据主题查询服务 请求消息定义为 “message”“Gettopic” “topic”;string， 响应消息定义为 “message”;“GettopicResponse” “response “normal” “datatype":object “validtime”:string， “period”;number “error”;string B.9通知服务 请求消息定义为: 20
GB/T32419.4?2016 message;Notify topic" :string data ":object|datapoint;string 21
GB/T32419.4?2016 www.w3. [1]SOAPVersion1.2Partl:MessagingFrameworkSecondEdition),http://w .org/ TR/s /op12/ 22
信息技术SOA技术实现规范第4部分：基于发布/订阅的数据服务接口GB/T32419.4-2016
随着信息技术的不断发展和应用，SOA技术作为一种面向服务的架构模式已经成为了众多企业中最为重要的IT架构之一。而在SOA技术中，数据服务接口则起到了非常重要的作用，它是实现不同服务间数据交互的关键环节之一。
为了规范SOA技术中数据服务接口的设计和实现，国家标准化管理委员会于2016年发布了GB/T32419.4-2016《信息技术 SOA技术实现规范 第4部分：基于发布/订阅的数据服务接口》标准。
该标准主要包括了基于发布/订阅模式的数据服务接口的设计和实现规范。其中，发布/订阅模式是指数据的生产者将数据发布到服务总线上，而数据的消费者则通过订阅相关的主题来获取数据。该模式具有异步通信、解耦合等优点，可以有效地提高系统的可扩展性和灵活性。
GB/T32419.4-2016标准规定了基于发布/订阅模式的数据服务接口的功能、性能、接口、安全保障等方面的要求。其中，数据服务接口要求能够支持多种不同的数据格式和协议，能够对数据进行访问控制和身份认证，同时还要保证数据传输的安全性和可靠性。
此外，GB/T32419.4-2016还重点关注了数据服务接口的设计和实现过程中需要注意的一些问题，例如如何处理故障和异常情况、如何进行性能优化等。这些问题都是影响数据服务接口质量和效率的重要因素，需要在设计和实现过程中予以考虑。
总之，GB/T32419.4-2016《信息技术 SOA技术实现规范 第4部分：基于发布/订阅的数据服务接口》标准的发布，对于规范SOA技术中数据服务接口的设计和实现具有非常重要的意义。只有遵循这些标准，才能够设计和实现出高质量、高性能的数据服务接口，从而更好地支撑企业信息化建设和发展。
