基於用戶標籤管理中心實現用戶半自動化運營管理的方法與流程
2023-12-01 13:31:32 1
1.本發明涉及網際網路雲端系統技術領域，具體的說，是一種基於用戶標籤管理中心實現用戶半自動化運營管理的方法。
背景技術：
2.在微服務化系統應用與單體應用共存的情況下，這些應用服務都需要通過獲取用戶精細化標籤數據，現有技術中尚沒有一種方法能夠統一管理且兼容這兩種服務且實現半自動化管理這些應用。
技術實現要素：
3.本發明的目的在於提供一種基於用戶標籤管理中心實現用戶半自動化運營管理的方法，用於解決現有技術中尚沒有能夠統一管理且兼容微服務化系統應用與單體應用且實現半自動化管理這些應用的問題。
4.本發明通過下述技術方案解決上述問題：
5.一種基於用戶標籤管理中心實現用戶半自動化運營管理的方法，包括：
6.步驟s100、搭建持久化資料庫mysql，創建資料庫表system_manager和資料庫表rule_manager，資料庫表rule_manager用於存儲管理規則配置，資料庫表system_manager用於存儲與業務系統註冊相關數據；
7.步驟s200、搭建微服務註冊中和配置中心，搭建數據清洗中心，基於springcloud分布式微服務框架搭建用戶標籤管理中心，該用戶標籤管理中心用於運營規則配置與接入的業務系統手動註冊管理，手動初始化錄入規則與接入應用信息；
8.步驟s300、將用戶標籤管理中心和數據清洗中心註冊到微服務註冊中和配置中心的服務註冊中心，並通過微服務註冊中和配置中心的配置中心管理配置文件；
9.步驟s400、在用戶標籤管理中心開發功能模塊，用於對資料庫表system_manager與資料庫表rule_manager進行數據增加、修改和刪除操作；操作人員在用戶標籤管理中心錄入規則且審批通過後，則通過http請求方式主動將規則以及相關信息推送到數據清洗中心進行數據處理並修改mysql中當前規則數據對應的狀態為「已發送」，同時用戶標籤管理中心主動輪詢數據清洗中心獲取結果，第一次主動查詢數據清洗中心得到反饋信息正常則將狀態修改為「清洗中」狀態；
10.步驟s500、基於springcloudgateway框架搭建分布式網關服務，在網關工程上開發全局過濾器實現globalfilter接口和ordered接口，用於根據當前請求訪問的業務系統system的值獲取mysql中資料庫表system_manager與資料庫表rule_manager中的數據；以及用於完成推送後從mysql中獲取用戶標籤管理中心的相關配置信息並保存到內存中，填充到設定的uri中，通過網關工程將做服務間的負載均衡與請求轉發到用戶標籤管理中心；用戶標籤管理中心通過基於http方式通信的開發的異步通知接口，以流的方式返回結果給數據清洗中心；
11.步驟s600、用戶標籤管理中心通過主動查詢或者異步回調通知得到清洗結果為清洗完成後，將mysql中的狀態修改為「清洗完成」，同時使用break終止循環查詢，通過異步接口返回表示正確接收到通知的success欄位，數據清洗中心無需再通知；
12.步驟s700、為了獲取用戶標籤數據，基於分布式微服務方式開發的應用服務通過註冊到微服務註冊中和配置中心，並且錄入信息到用戶標籤管理中心進行手動註冊控制，單體應用服務只需要錄入信息到用戶標籤管理中心進行手動註冊控制，錄入的信息即system_manager表與rule_manager表中核心欄位的信息內容；
13.步驟s800、接入的應用服務獲取當前用戶標籤數據需要通過網關工程的校驗，校驗當前請求的spring.application.name在資料庫中存在，狀態為「清洗完成」且當前請求時間在規則開始和結束時間範圍內則視為校驗通過，通過後根據配置信息轉發到對應的數據清洗中心獲取數據。
14.資料庫表system_manager的核心欄位包括業務系統system和標籤label；資料庫表rule_manager的核心欄位包括system_manager表主鍵id、匹配規則rule、規則生效時間start_time、規則失效時間end_time、狀態status以及用戶分類type；狀態用於記錄當前規則與標籤的狀態，其中，狀態status分類為：
15.新建：新錄入系統的標籤規則數據；
16.審核中：將新建的標籤規則數據提交上級審核中的狀態；
17.審核通過：完成審核並通過的審核；
18.審核駁回：需要重新調整的規則，可再次發起審核；
19.已發送：處於審核通過的規則且發送給標籤結果清洗中心進準備開始進行用戶標籤清洗；
20.清洗中：通過用戶標籤管理中心查詢標籤結果清洗中心的清洗結果反饋，若當前規則仍然在清洗中，則處於清洗中的狀態；
21.清洗完成：通過標籤結果清洗中心異步回調通知或主動查詢標籤結果得到返回當前的規則已清洗完成的狀態。
22.本發明與現有技術相比，具有以下優點及有益效果：
23.本發明搭建用戶標籤管理中心與網關服務共同管理微服務化系統應用與單體應用，只需要在初始化時候手動將這些接入的應用註冊到用戶標籤管理中心即可，後續就無須人員編碼等幹預。實現了這兩種服務的兼容和統一管理以及半自動化管理這些應用。
附圖說明
24.圖1為本發明的原理框圖；
25.圖2為本發明中用戶標籤管理中心的數據錄入以及處理流程圖；
26.圖3為本發明中接入的應用服務獲取數據的流程圖。
具體實施方式
27.下面結合實施例對本發明作進一步地詳細說明，但本發明的實施方式不限於此。
28.實施例：
29.結合附圖1所示，一種基於用戶標籤管理中心實現用戶半自動化運營管理的方法，
包括：
30.步驟s100、搭建持久化資料庫mysql，創建資料庫表system_manager和資料庫表rule_manager，資料庫表rule_manager用於存儲管理規則配置，資料庫表system_manager用於存儲與業務系統註冊相關數據；
31.system_manager的核心欄位有：
32.業務系統system，system的值用於在用戶標籤管理中心中唯一標識當前的業務系統，該值與業務系統是一一對應的，如果是基於分布式微服務架構的設值為應用的spring.application.name的值並且以lb://開頭；如果是獨立的業務服務則設值為具體的服務地址連接，並且以http開頭；
33.標籤label，用於用戶分類的標識，一個系統下可以配置多個標籤。例如：用戶的標籤的值有老年人標籤、女性標籤、男性標籤、四川省地域標籤等。
34.rule_manager的核心欄位有：
35.system_manager表主鍵id；
36.匹配規則rule，匹配規則rule用於數據清洗中心匹配當前標籤的關鍵信息，與標籤label屬於一對多的關係，採用文本方式記錄，根據數據特點分析可以是任何文本格式，該值與數據清洗中心線下約定達成一致，通過用戶標籤管理中心錄入進行統一管理和控制。例如：四川省的地域標籤，可以通過日誌參數的接口請求ip段來區分請求的電視機在哪個地區；老年人標籤，則可以通過聽歌的類型佔比，看電視類佔比等進行區分。規則的值就包含了通過分析數據內心，提取出對應的關鍵字等信息，或者智能ai算法規則配置，用於匹配規則生效時間start_time、規則失效時間end_time，規則生效時間start_time可用於自動定時開啟當前規則，規則失效時間end_time可用於自動定時結束當前規則數據下發；
37.狀態status，用於記錄當前規則與標籤的狀態，狀態分類為：
38.新建：新錄入系統的標籤規則數據；
39.審核中：將新建的標籤規則數據提交上級審核中的狀態；
40.審核通過：完成審核並通過的審核；
41.審核駁回：需要重新調整的規則，可再次發起審核；
42.已發送：處於審核通過的規則且發送給標籤結果清洗中心進準備開始進行用戶標籤清洗；
43.清洗中：通過用戶標籤管理中心查詢標籤結果清洗中心的清洗結果反饋，若當前規則任然在清洗中，則處於清洗中的狀態；
44.清洗完成：通過標籤結果清洗中心異步回調通知或主動查詢標籤結果得到返回當前的規則已清洗完成的狀態；
45.用戶分類type，在接入的系統用戶都存在兩種用戶：設備用戶和系統用戶，因此業務系統獲取標籤可分為以下三類進行處理：機器用戶設備唯一識別號mac、系統用戶各個應用接入系統的用戶唯一識別主鍵、綜合用戶包含機器用戶和系統用戶。
46.步驟s200、搭建微服務註冊中和配置中心，搭建數據清洗中心，基於springcloud分布式微服務框架搭建用戶標籤管理中心，該用戶標籤管理中心用於運營規則配置與接入的業務系統手動註冊管理，手動初始化錄入規則與接入應用信息；
47.步驟s300、將用戶標籤管理中心和數據清洗中心註冊到微服務註冊中和配置中心
的服務註冊中心，並通過微服務註冊中和配置中心的配置中心管理配置文件；
48.步驟s400、在用戶標籤管理中心開發功能模塊，用於對資料庫表system_manager與資料庫表rule_manager進行數據增加、修改和刪除操作；操作人員在用戶標籤管理中心錄入規則且審批通過後，則通過http請求方式主動將規則以及相關信息推送到數據清洗中心進行數據處理，如圖2所示，推送完成後，修改mysql中當前規則數據對應的狀態為「已發送」，同時執行循環查詢，循環查詢頻率為10秒一次sleep(10)以降低服務cpu壓力，由用戶標籤管理中心主動輪詢查詢數據清洗中心獲取結果，第一次主動查詢數據清洗中心得到反饋信息正常則將狀態修改為「清洗中」狀態；
49.步驟s500、基於springcloudgateway框架搭建分布式網關服務，在網關工程上開發全局過濾器實現globalfilter接口和ordered接口，
50.public class customfilter implements globalfilter,ordered{
51.@override
52.public mono《void》filter(serverwebexchange exchange,gatewayfilterchain chain){
53.//具體的業務實現
54.//1.根據當前請求訪問的系統spring.application.name值獲取mysql資料庫中核心規則數據內容,即system_manager表與rule_manager中數據
55.}
56.}；
57.用於根據當前請求訪問的業務系統system的值獲取mysql中資料庫表system_manager與資料庫表rule_manager中的數據；以及用於完成推送後從mysql中獲取用戶標籤管理中心的相關配置信息並保存到內存中，填充到builder.routes.route("applicationname",r-》r.uri("xxx"))的uri中，通過網關工程將做服務間的負載均衡與請求轉發到用戶標籤管理中心；用戶標籤管理中心通過基於http方式通信的開發的異步通知接口，以流的方式返回結果給數據清洗中心；
58.@postmapping("/data/notice")
59.public void hwmonthcountnotice(httpservletrequest request,httpservletresponse response){
60.//具體的業務邏輯代碼，success表明已經正確接收到通知，數據清洗中心不再繼續發通知
61.response.getoutputstream.print("success")；
62.response.getoutputstream.flush；
63.}
64.步驟s600、用戶標籤管理中心通過主動查詢或者異步回調通知得到清洗結果為清洗完成後，將mysql中的狀態修改為「清洗完成」，同時使用break終止循環查詢，通過異步接口返回表示正確接收到通知的success欄位，數據清洗中心無需再通知；
65.步驟s700、為了獲取用戶標籤數據，基於分布式微服務方式開發的應用服務通過註冊到微服務註冊中和配置中心，並且錄入信息到用戶標籤管理中心進行手動註冊控制，單體應用服務只需要錄入信息到用戶標籤管理中心進行手動註冊控制，錄入的信息即
system_manager表與rule_manager表中核心欄位的信息內容；
66.步驟s800、接入的應用服務獲取當前用戶標籤數據需要通過網關工程的校驗，校驗當前請求的spring.application.name在資料庫中存在，狀態為「清洗完成」且當前請求時間在規則開始和結束時間範圍內則視為校驗通過，通過後根據配置信息轉發到對應的數據清洗中心獲取數據，如圖3所示。
67.儘管這裡參照本發明的解釋性實施例對本發明進行了描述，上述實施例僅為本發明較佳的實施方式，本發明的實施方式並不受上述實施例的限制，應該理解，本領域技術人員可以設計出很多其他的修改和實施方式，這些修改和實施方式將落在本技術公開的原則範圍和精神之內。