寫在前面 —— 本文原始碼

在使用ElasticSearch(下文簡稱es)經常會遇到將本地庫的資料傳入的es中進行索引.我們在完成批量同步的時候可以使用官方提供的logstash來進行同步,也可以自己編寫java api 利用es的blak進行批量同步.
在實際生產中利用es做搜尋引擎,將資料庫中的資料索引到es中,在這種情況下需要的是實時性和更高的操作性,有如下幾種方法可以完成:

• 使用資料庫二進位制監控(中介軟體)
  
  • 使用一些資料庫二進位制檔案監控中介軟體,通過監控資料庫的二進位制檔案來判斷資料庫發生的增刪改查,從而去動態的更新es中的索引資訊例如阿里的精衛,等二進位制日誌監控元件.
• 使用訊息轉發(訊息中介軟體)
  
  • 通過RabbitMq或者是訊息佇列將需要索引到es的資料上報給search服務然後在服務裡使用es的api進行操作將資料索引到es上.

涉及到的技術

• ElasticSearch:2.3.2(有待升級,emmmm和老大說了好久終於準備升級到最新版本了,所以涉及到的很多api可能都用不了了,這裡暫時就先用SpringBoot提供的jpa簡單操作下~~畢竟沒有涉及到搜尋,目前只是對資料進行索引.
• Spring Boot:1.5.10
• RabbitMq:Spring Boot封裝的api
• FastJson:阿里的json操控包
• 命令模式:為了統一規範化,在search服務中使用命令模式定義各種操作命令,之後進行組裝來完成對es的操作.

簡單的架構圖和資料流圖

命令模式簡介

模式結構

命令模式包含如下角色:
- Command:抽象命令
- ConcreteCommand:具體命令類
- Invoker:呼叫者
- Receiver:接收者
- Client:客戶類

意圖

命令模式(Command Pattern):將請求封裝為一個物件,從而使我們可用不同的請求對客戶進>行引數化;隊請求排隊或者記錄請求日誌,以及支援可撤銷操作.命令模式是一種物件行為模式,泣別名為動作(Action)模式或事物(Transaction)模式.

模式結構

命令模式包含如下角色:
- Command:抽象命令
- ConcreteCommand:具體命令類
- Invoker:呼叫者
- Receiver:接收者
- Client:客戶類

適用情況

• command模式類似於過程語言中的回撥,command是將回調通過面向物件的方式來實現,在我們需要將方法提前設計出來在需要的時候被呼叫,此時我們就可以使用命令模式.
• 在不同的時刻指定,排序和執行請求.一個Command隊想可以有一個與初始請求無關的生存週期.如果一個請求的接受者可以用一種與地址空間無關的方式表達,那麼就可以將請求的命令傳送到另一個不同的程序並在那實現請求.
• 支援取消的操作.再設計Command的介面可以設計一個Unexcute用來實現將上一部的執行取消的操作.通過excute和unexcute來控制命令的執行效果.
• 支援修改日誌.在使用命令模式的時候我們可以新增一個儲存裝置將執行的操作儲存起來以防止系統down機的時候進行回覆.
• 用來在源操作語言上構建更高層的作業系統.命令模式是一種典型的支援事務的設計模式
• 通過一個Command藉口來進行建模.

效果

Command有如下的效果:
1. Command將呼叫操作的物件與如何實現該操作的物件進行解耦.
2. Command是頭等物件他可以被擴充套件和操控.
3. 可以將多個命令集合起來變成一個組合命令.
4. 新增一個Command很容易因為他是頭等類無需改變任何程式碼.

search-server關鍵程式碼類圖