[發明專利]一種高時效性的分布式服務集成調用系統

有效

• 申請號: 201010168618.0
• 申請日: 2010-05-11
• 公開（公告）號: CN101848239A
• 公開（公告）日: 2010-09-29
• 發明（設計）人: 徐慧;林劍檸;張煜;張萍
• 申請（專利權）人: 中國電子科技集團公司第二十八研究所
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 南京蘇高專利商標事務所(普通合伙) 32204
• 代理人: 肖明芳

1.一種高時效性的分布式服務集成調用系統，應用于具有多個服務請求者和多個服務的分布式服務集成調用環境中；包括服務請求者、服務、服務接口描述文件、服務消息編解碼子系統、服務消息傳輸子系統，其特征在于，服務請求者與服務之間的調用，采用二進制字節流格式的服務消息交換協議；

所述二進制字節流格式的服務消息交換協議包括二進制格式的服務消息頭和二進制格式的服務消息正文；

所述服務消息正文緊接在服務消息頭之后；所述的服務消息頭和服務消息正文按照網絡字節序進行排列；

所述服務消息頭包含類型標識、版本信息、消息頭長度、消息關聯標識、超時時間值、響應回送IP地址、響應回送實體標識、服務標識長度、服務接口標識長度、服務標識、服務接口標識以及保留位；

所述類型標識占4個比特位，用作判斷服務消息的類型，進行服務消息分類；其中，類型標識(0000)₂表示該消息是服務請求消息，服務請求消息正文中的內容包含編碼后的服務輸入參數值；類型標識(0001)₂表示該消息是服務響應消息，服務響應消息正文中的內容包含編碼后的服務輸出參數值；類型標識(0010)₂表示該消息是服務錯誤消息，服務錯誤消息正文中的內容是服務錯誤代碼值；

所述消息關聯標識用于在實現服務同步或異步調用時關聯服務請求消息與服務響應消息；

所述超時時間值表示本條服務消息過期失效的時間，是基于UTC的絕對時間值；

所述響應回送IP地址，是發起服務調用的服務請求者地址或者需要服務指定發送的一個目的地址；

所述服務消息在被發送前進行編碼，在被接收后、處理前進行解碼。

2.根據權利要求1所述的一種高時效性的分布式服務集成調用系統，其特征在于，服務消息編解碼子系統根據服務接口描述文件實現對各個服務消息的通用編碼和解碼處理，包括服務請求消息正文編碼接口、服務請求消息正文解碼接口、服務響應消息正文編碼接口以及服務響應消息正文解碼接口；

所述服務請求消息正文編碼接口在服務請求者調用服務時執行，在服務請求者端對服務輸入參數進行編碼，所述服務輸入參數包括服務接口的輸入參數、輸入輸出參數，編碼處理順序與服務接口描述文件中的服務輸入參數順序一致，編碼后的結果數據是服務請求消息正文；

所述服務請求消息正文解碼接口在服務接收到服務請求消息時執行，在服務端對服務請求消息正文中編碼過的服務輸入參數進行解碼，解碼處理順序與服務輸入參數編碼處理順序一致，解碼后的結果數據是服務輸入參數值；

所述服務響應消息正文編碼接口在服務返回調用結果時執行，在服務端對服務輸出參數進行編碼，所述服務輸出參數包括服務接口的輸出參數、輸入輸出參數和返回值，編碼處理順序與服務接口描述文件中的服務輸出參數順序一致，其中，返回值被最后編碼，編碼后的結果數據是服務響應消息正文；

所述服務響應消息正文解碼接口在服務請求者接收到服務響應消息時執行，在服務請求者端對服務響應消息正文中編碼過的服務輸出參數進行解碼，解碼處理順序與服務輸出參數編碼處理順序一致，解碼后的結果數據是服務輸出參數值；

所述服務輸入參數和服務輸出參數的類型包括基本類型、指針類型和復雜類型；其中，基本類型包括字符型、短整型、整型、長整型、單精度浮點型、雙精度浮點型、字符串型；復雜類型包括結構類型、數組類型。

3.根據權利要求1所述的一種高時效性的分布式服務集成調用系統，其特征在于，所述服務接口描述文件采用XML語言描述服務接口，一個服務接口描述文件用于描述一個服務的多個接口，描述文件的內容包括服務元素、服務名稱元素、服務接口元素、接口名稱元素、參數元素、參數元素屬性、參數類型元素、參數類型屬性；所述服務元素是服務接口描述的根元素；所述服務接口元素表示接口，作為服務元素的子元素；接口名稱元素描述服務的接口名稱；參數元素是接口參數的描述，接口的每個參數對應一個參數元素：參數元素屬性包括參數名、參數類型、參數序號、參數指針標志、參數模式標識、參數數組特性；參數類型元素是參數類型的描述；參數類型屬性包括類型名稱、類型長度以及類型分類標識。

4.根據權利要求1所述的一種高時效性的分布式服務集成調用系統，其特征在于，所述的服務消息傳輸子系統包括消息傳輸通道綁定模塊、基于socket套接字的消息傳輸通道、基于共享區的消息傳輸通道和基于直接地址調用的消息傳輸通道；

所述服務消息傳輸子系統定義了標識服務或服務請求者位置的地址表示方法；所述地址表示方法為網絡中的服務或服務請求者統一分配一個唯一的地址，所述地址由IP地址和實體標識兩部分組成，實體標識表示服務或服務請求者的軟件運行單元，各個服務或服務請求者采用相互區別的實體標識，所述IP地址用數值表示，占4個字節，所述實體標識用數值表示，占2個字節；

所述消息傳輸通道綁定模塊是被服務請求者或服務調用的接口函數庫，包括實體注冊接口、消息通用傳輸接口；服務請求者或服務在初始化時調用實體注冊接口將自己的實體標識注冊到消息傳輸通道綁定模塊中，服務消息通過消息通用傳輸接口收發；消息通用傳輸接口在收發服務消息時，根據服務請求者和服務的地址和已注冊的實體標識信息，判斷服務請求者與服務之間的軟件單元部署關系，實時綁定對應傳輸方式的消息通道；其中，服務和服務請求者之間的軟件單元部署關系的判斷方法為：服務請求者和服務的實體標識信息在消息傳輸通道綁定模塊中都已注冊，表示兩者在同一個進程空間；服務請求者和服務的實體標識信息在消息傳輸通道綁定模塊中未同時注冊，但兩者的IP地址相同，表示兩者在同一個主機節點，不在同一個進程空間；服務請求者和服務的IP地址不同，表示兩者不在同一個主機節點；

如果判斷服務和服務請求者在同一個進程空間則綁定基于直接地址調用的消息傳輸通道，是將服務消息作為函數參數在兩者的接口之間進行直接傳遞；

如果判斷服務和服務請求者在同一個主機節點，但不在一個進程空間則綁定基于共享區的消息傳輸通道，通過共享區交互和信號燈互斥的方式將服務消息在兩者之間進行進程間通信傳遞；

如果判斷服務和服務請求者不在同一個主機節點則綁定基于socket套接字的消息傳輸通道，采用TCP/IP協議的socket接口方式將服務消息在兩者之間進行網絡通信傳輸。