Stories

Detail Return Return

Cancel如何同步Mq信息 - Stories Detail

編寫MQ監聽器,繼承抽象的RabbitMQ監聽器,然後調用父類的方法解析這個消息

解析消息

1.首先需要進行數據格式轉換,因為我們拿到的是一個Json字符串;把它轉換成我們需要的數據實體。
2.首先判斷這個數據是不是增刪改或者根本就沒有拿到該數據,因為後續如果還需要擴展其他業務的話,可以避免其他業務干擾到核心業務
3.然後判斷這個數據是否是單條數據,是,則走單條數據處理的方法。否,則走批量數據處理方法。如果業務出現了錯誤,則讓它休眠一秒鐘後重試

單條數據處理的方法

1.首先我們繼續進行數據格式轉換,這樣可以更方便的讓進行數據處理
2.由於是單條操作,所以我們就直接拿集合中的第一條數據即可,這個可以明顯的提升速度
3.然後將屬性重新在進行更精確的數據格式轉換,獲取該操作是更新還是增加。
4.然後我們可以創建一個方法來獲取這個類型的參數,這個就可以具有更好的通用性
5.在上一步中我們得到了這個類型的參數,然後判斷這個參數是否未空;接下來判斷這個操作是否是保存操作,是,就將這個數據轉換成我們需要的類型,在進行保存數據;
否,則獲取這個類型的id,並調用刪除方法

多條數據處理的方法

跟單條數據處理的操作大差不差,就是把不是隻有一條數據嗎,現在有多條數據就進行循環獲取這個數據,在調用保存數據的方法,或者刪除數據的方法

數據具體的刪除、增加的業務需要由子類實現

子類實現刪除、增加方法

增加

這裏的增加方法就是把數據批量增加到ES上

刪除

同增加方法相同是就是從ES上批量刪除數據

user avatar xiaoniuhululu Avatar u_15702012 Avatar shuyixiaobututou Avatar aipaobudezuoyeben Avatar wuliaodechaye Avatar tuhooo Avatar chuck1sn Avatar itxiaoma Avatar xiaoxiansheng_5e75673e1ae30 Avatar lpc63szb Avatar dreamlu Avatar chengxy Avatar
Favorites 29 users favorite the story!
Favorites

Add a new Comments

Some HTML is okay.