融合多通信方式的企業一體化信息處理方法與流程

2023-07-04 17:08:41 1

本發明涉及一種融合多通信方式的企業一體化信息處理方法，主要應用於企業內部人員之間的通信和消息處理。

背景技術：

現代化的企業內部通信存在著多種通信選擇，常用的消息處理方式藉助於電話、簡訊、微信和QQ等軟體和工具實施。同時，每個企業針對不同的業務場景也會建立各種獨立應用，這些應用在使用過程中需要通過傳遞消息給消息處理人，或將消息傳遞給第三方應用再通過第三方應用傳遞給消息處理人。採用上述方法進行消息處理各種類型的消息都是獨立存在的，並且消息處理易受網絡延時的影響，消息的傳遞安全性差，消息洩露的風險大，容易給企業造成不可估量的損失。

技術實現要素：

為了克服現有技術下的上述缺陷，本發明的目的在於提供一種消息中心，克服了現有的技術中各種類型消息不能同步、消息傳遞效率低下和各種業務間消息傳遞障礙多、時效性差的問題，本發明通過整合和集成各種業務和服務系統中的用戶數據消息，為用戶提供一體化的消息服務。

本發明的技術方案是：

一種融合多通信方式的企業一體化信息處理方法，包括以下步驟：

步驟1，通知人（發起方）通過其客戶端向發起方服務端發送消息，發起方服務端據此更新消息註冊文件，消息中心獲取發起方服務端的消息註冊文件更新信息；

步驟2，所述消息中心向接收方服務端發出消息提醒，接收方服務端將消息提醒發送至被通知人的客戶端；

步驟3，被通知人通過其客戶端向接收方服務端發出查看消息請求，所述接收方服務端將所述查看消息請求轉發至所述消息中心，所述消息中心向發起方服務端發出相應的查看消息請求；

步驟4，發起方服務端依據消息中心的查看消息請求，將相關消息發送至消息中心，消息中心將該消息發送至接收方服務端。

優選的，所述服務端包括微信服務端、語音服務端、CRM（Customer Relationship Management，客戶關係管理或客戶關係管理系統）服務端、OA（Office Automation，辦公自動化或辦公自動化系統）服務端和簡訊服務端，還可以包括其他適於企業和/或企業人員信息交流的服務端。

優選的，所述消息中心獲取發起方服務端的消息註冊文件更新信息的方式為：發起方服務端更新消息註冊文件後，開啟埠監聽接口以接收來自所述消息中心的消息檢測請求，所述消息中心定時發送消息檢測請求，檢測各相關服務端是否有消息註冊文件更新，當相關服務端上存在消息註冊文件更新時，獲得相應的消息註冊文件更新信息。

優選的，所述消息中心獲取發起方服務端的消息註冊文件更新信息後，生成該消息的唯一的標識碼（id碼，簡稱id）並發送至該發起方服務端，所述發起方服務端將獲取的標識碼記錄到相應的消息封裝預編文件內，對該消息進行封裝,所述消息封裝預編文件用於在消息發送前獲取該文件內的標識碼進行消息封裝。

消息的標識碼方法可以為：將一條消息分為消息頭、消息體和消息尾三部分進行封裝；所述消息頭包括所述消息的標識碼，用於消息中心對消息的分類和分發；所述消息體包括由消息id（該消息的標識碼）和消息內容組成的鍵值對，用於記錄消息的具體內容；所述消息尾包括用於記錄消息當前狀態的狀態位，通過消息尾的狀態位和消息id對多條同一id的消息進行拼接。

優選的，所述消息中心包括：

消息註冊單元，用於註冊各種業務和服務系統的消息類型；

消息代理單元，用於將源自客戶端的消息轉送至相關的服務端；

服務監控單元，用於對註冊的客戶端進行實時狀態監控；

流量控制單元，用於統計各種類型的消息流量，並按照消息流量對客戶端進行管控；

加密傳輸單元，用於對傳遞的消息進行加密；

消息統計單元，用於統計消息中心內各種類型業務或服務的消息數量。

優選的，所述消息中心還包括:

創建消息單元，用於定義消息內容的固定格式和欄位；

查詢消息單元，用於查詢各種類型業務或服務消息的記錄；

處理消息單元，用於通過相應的服務組件處理對應業務或服務的消息，框架內設有統一的消息處理接口。

優選的，所述消息中心還包括：

微信服務組件，用於同微信服務端通信/交互；

語音服務組件，用於同語音服務端通信/交互；

CRM服務組件，用於同CRM服務端通信/交互；

OA服務組件，用於同OA服務端通信/交互；

簡訊服務組件，用於同簡訊服務端通信/交互，

服務組件的種類/設置應依據所涉相關消息（或稱業務）的類型，與外部各種不同的服務端相適應，以分別作為消息中心與各服務端的通信接口進行信息傳送和交互。

優選的，所述流量控制單元根據一種消息的歷史流量評估消息流量的負載，設置流量閾值，當消息中心內的消息流量超過此消息的流量閾值時所述流量控制單元發出警報並進行相應調整，所述調整包括：（1）對消息的流量進行擴容，提高閾值上限；（2）當消息流量超過提高後的閾值上限時，消息中心停止接收此種類型的消息服務。

優選的，所述服務監控單元通過發送心跳信號定時對所述服務端的服務狀態進行監控，判斷服務端的狀態是否正常。

本發明的有益效果為：

本發明通過設置消息中心將各種業務或服務系統中的用戶數據統一，由消息中心呈現給用戶，為用戶提供一體化消息服務，實現了消息的整合和集成。能夠對所傳遞消息進行加密，併合理安排信息的傳遞流程，保證消息傳遞的安全性；能夠通過訪問日誌記錄查詢正在處理的消息的當前狀態。本發明克服了現有的技術下各種類型消息不能同步傳遞、消息傳遞效率低下和各種業務間消息傳遞障礙多、時效性差的缺陷。

附圖說明

圖1是本發明消息中心的單元化結構簡圖；

圖2是本發明的新消息註冊流程簡圖；

圖3是本發明處理OA服務端消息的流程簡圖。

具體實施方式

參見圖1-3，本發明公開了一種融合多通信方式的企業一體化信息處理方法，包括以下步驟：

步驟1，通知人通過其客戶端向發起方服務端發送消息，發起方服務端據此更新消息註冊文件，消息中心獲取發起方服務端的消息註冊文件更新信息；

步驟2，所述消息中心向接收方服務端發出消息提醒，接收方服務端將消息提醒發送至被通知人的客戶端；

步驟3，被通知人獲悉其客戶端的消息提醒後，依據需要，通過其客戶端向接收方服務端發出查看消息請求，所述接收方服務端將所述查看消息請求轉發至消息中心，消息中心向發起方服務端發出相應的查看消息請求；

步驟4，發起方服務端依據消息中心的查看消息請求，將相關消息發送至消息中心，消息中心將該消息發送至接收方服務端。

所述服務端包括微信服務端、語音服務端、CRM服務端、OA服務端和簡訊服務端，也可以根據需要對接QQ服務端和飛信服務端等其他服務端。

所述消息中心獲取發起方服務端的消息註冊文件更新信息的方式為：發起方服務端更新消息註冊文件後，開啟埠監聽接口以接收來自所述消息中心的消息檢測請求，所述消息中心定時發送消息檢測請求，檢測各相關服務端是否有消息註冊文件更新，當相關服務端上存在消息註冊文件更新時，獲得相應的消息註冊文件更新信息。

所述消息中心獲取發起方服務端的消息註冊文件更新信息後，生成該消息的唯一的標識碼（id碼，簡稱id）並發送至該發起方服務端，所述發起方服務端將獲取的標識碼記錄到相應的消息封裝預編文件內，對該消息進行封裝,所述消息封裝預編文件用於在消息發送前獲取該文件內的標識碼進行消息封裝。

圖2所示為本發明的新消息註冊流程簡圖，其註冊流程為：客戶端更新新的消息並上傳至服務端，消息中心通過消息檢測請求檢測到服務端內的新消息並獲取相關消息提醒，消息中心為新消息生成唯一的標識碼進行新消息id註冊，服務端獲取所述新消息的標識碼，並對所述消息的內容進行消息封裝後發送至所述消息中心。

所述消息封裝的方法為：將一條消息分為消息頭、消息體和消息尾三部分進行封裝；所述消息頭包括所述消息的標識碼（通常可以為一個無符號32位的字符），用於消息中心對消息的分類和將消息分發至多個被通知人；所述消息體包括由消息id（通常可以為一個32位的字符）和消息內容（通常可以為256位字符）組成的鍵值對，用於記錄消息的具體內容；所述消息尾包括用於記錄消息當前狀態（通常可以為終止或中止）的狀態位（通常可以為一個32位字符），通過消息尾的狀態位和消息id對多條同一id的消息進行拼接。

所述消息中心包括：

消息註冊單元，用於註冊各種業務和服務系統的消息類型。優選的，註冊單元採用分布式註冊機制，即註冊單元可以在不同的處理器上，通過消息處理系統的主動查詢方式，主動發起檢測請求，在註冊節點上有服務註冊時，觸發事件狀態，對服務系統中的註冊服務進行更新操作；

消息代理單元，用於接收來自客戶端的消息；

服務監控單元，用於對註冊的客戶端進行實時狀態監控；

流量控制單元，用於統計各種類型的消息流量，並按照消息流量對客戶端進行管控，通過對消息的流量統計設置不同的閾值，當流量超過閾值時，消息系統發出通知給管理者，並處理響應時間；

加密傳輸單元，用於對傳遞的消息進行加密，增加傳輸安全性；

消息統計單元，用於統計消息中心內各種類型業務或服務的消息數量。

所述消息中心還包括：

創建消息單元，用於定義消息內容的固定格式和欄位。其主要格式為一條消息包含消息頭，消息體和消息結束符。主要欄位是指，在消息頭中主要定義消息的類型，通過唯一標識符標記。在消息體中主要包括兩個欄位，關鍵字和對應的消息體。結束符中包括了該消息的編號和判定消息結束的標誌位。

查詢消息單元，用於查詢各種類型業務或服務消息的記錄。

所述消息中心各部分（各單元和各服務組件）在相互間數據傳遞和交互時，可根據需要進行相關的數據形式轉換。

以下實例通過OA服務端的請假消息，對消息查詢的步驟進行闡述：

OA服務端發送消息通知員工A需要請假，時間從9月28日到10月9日，通知人是經理B。消息中心按照消息id記錄該條消息，並發送通知到經理B， 經理B在核對時間時通過日誌記錄查詢消息記錄，日誌記錄通過消息接口和OA服務端對接。如果通知人有多個，那麼消息中心對消息進行分解，分解成多條消息發送到各個通知人。

處理消息單元，用於通過相應的服務組件處理對應業務或服務的消息，框架內設有統一的消息處理接口。

所述消息中心還包括：

微信服務組件，用於同微信服務端通信/交互；

語音服務組件，用於同語音服務端通信/交互；

CRM服務組件，用於同CRM服務端通信/交互；

OA服務組件，用於同OA服務端通信/交互；

簡訊服務組件，用於同簡訊服務端通信/交互。

所述流量控制單元根據一種消息的歷史流量評估消息流量的負載，設置流量閾值，當消息中心內的消息流量超過此消息的流量閾值時所述流量控制單元發出警報並進行相應調整，所述調整包括：（1）對消息的流量進行擴容，提高閾值上限；（2）當消息流量超過提高後的閾值上限時，消息中心停止接收此種類型的消息服務。

所述服務監控單元通過發送心跳信號定時對所述服務端的服務狀態進行監控，判斷服務端的狀態是否正常。

所述加密傳輸單元在傳輸消息的過程中對消息進行加密，所述加密包括按消息的類型進行消息類型加密和對消息的具體內容進行消息內容加密，消息加密的方式可以採用各種適宜的加密方式，例如MD5。

所述客戶端能夠通過訪問所述消息中心查看相關消息的日誌記錄，查詢消息的流程和當前狀態。所述日誌記錄存放於不同的伺服器內並設有備份。對於非連續消息，提供消息整合服務，從日誌中提取對應的消息id組，組成一個完整的消息。

如圖3所示，為本發明OA服務端發送消息的流程，包括：

1、消息中心檢測並獲取所述OA服務端的消息；

2、所述消息中心處理所述OA消息；

3、所述消息中心向被通知人的客戶端發送OA消息提醒；

4、被通知人接收到所述OA消息提醒後向所述消息中心發出查看消息請求；

5、所述消息中心處理所述查看消息請求；

6、所述消息中心向所述OA服務端轉發所述查看消息請求；

7、所述OA服務端將消息發送至所述消息中心；

8、所述消息中心接收所述OA服務端的消息並處理；

9、所述消息中心將消息發送至被通知人的客戶端。

圖1所示是本發明消息中心的單元化結構簡圖，本發明的消息中心可以接收來自微信服務端、語音服務端、CRM服務端、OA服務端和簡訊服務端的消息並進行消息整合，為用戶提供一體化的消息服務。

所述消息中心設有消息註冊單元，用於註冊各種業務和服務的消息類型，並籤發唯一的消息類型編號；所述消息註冊單元採用分布式註冊機制，可以在不同的處理器上，通過消息中心的主動查詢方式，主動發起檢測請求。在註冊節點上有服務註冊時，觸發事件狀態，對系統中的註冊服務進行更新操作。

所述消息中心設有消息代理單元，用於接收來自客戶端的消息，提供一體化的消息服務。

所述消息中心設有服務監控單元，對註冊的客戶端進行實時狀態監控。在消息中心中通過發送心跳信號定時對系統中的業務或服務進行狀態監控。

所述消息中心設有流量控制單元，用於對消息的流量進行統計，通過計算消息流量評估負載，設置不同的閾值，對業務或服務的消息進行統計，計算消息流量和閾值的差值，當流量超過閾值時，消息中心發出通知給管理者，並處理響應時間。以簡訊消息為例，當簡訊條數超過閾值數時，消息中心發出通知給服務系統端，管理員通過通知獲取相關信息並對流量進行擴容，增加閾值。當超過閾值滿足一定時限時，消息中心即停止該業務的消息服務。

所述消息中心設有加密傳輸單元，消息中心在消息傳輸過程中通過加密方式對傳輸的消息進行安全封裝，通過對消息傳輸時的加密，增加傳輸安全性。對不同業務場景進行分別加密，優選MD5方式對消息進行傳輸加密。

所述消息中心設有消息統計單元，統計消息中心內各種類型服務和業務的消息數量，以生成日誌記錄供查詢使用。

本發明公開的各優選和可選的技術手段，除特別說明外及一個優選或可選技術手段為另一技術手段的進一步限定外，均可以任意組合，形成若干不同的技術方案。