首先，我使用的方式是高級客戶端（restHighLevelClient），也就是java api的方式做了批量同步，現(xiàn)在貼上我的代碼：

以為貼代碼不好控制格式，所以就直接貼圖了。代碼思路是：

1.先去數(shù)據(jù)庫查詢出所有需要同步的數(shù)據(jù)

2.然后轉換成map的格式，因為elasticsearch的批量同步方法貌似只接受map格式的參數(shù)

3.然后通過request的add方法，把所有的參數(shù)遍歷添加到request中

4.最后在add完了之后，我做了一個分批，一千條去同步一次

現(xiàn)在有一個疑問，一千條同步完了之后，我這里的request要怎么處理呢，直接給null的話，下一次add就會報錯，request也沒有clean的方法，怎么才能解決這個問題呢？