{"id":59611,"date":"2026-01-14T07:49:28","date_gmt":"2026-01-13T23:49:28","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/59611.html"},"modified":"2026-01-14T07:49:28","modified_gmt":"2026-01-13T23:49:28","slug":"nrt-%e8%bf%91%e5%ae%9e%e6%97%b6%e6%90%9c%e7%b4%a2%e6%b7%b1%e5%ba%a6%e8%a7%a3%e6%9e%90%ef%bc%9aelasticsearch-%e6%a0%b8%e5%bf%83%e6%9c%ba%e5%88%b6%e4%b8%8e%e5%ba%94%e7%94%a8%e5%ae%9e%e8%b7%b5","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/59611.html","title":{"rendered":"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5"},"content":{"rendered":"

\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n

\u672c\u6587\u6df1\u5165\u63a2\u8ba8 NRT（Near Real-Time）\u8fd1\u5b9e\u65f6\u641c\u7d22\u7684\u6838\u5fc3\u539f\u7406，\u8be6\u7ec6\u5206\u6790 Elasticsearch \u5982\u4f55\u5b9e\u73b0\u8fd1\u5b9e\u65f6\u641c\u7d22，\u5e76\u63d0\u4f9b\u5b8c\u6574\u7684\u5b9e\u6218\u5e94\u7528\u6848\u4f8b\u3002<\/p>\n

\u4e00\u3001NRT \u8fd1\u5b9e\u65f6\u641c\u7d22：\u6982\u5ff5\u4e0e\u6f14\u8fdb<\/h3>\n

1.1 \u4ece\u5b9e\u65f6\u5230\u8fd1\u5b9e\u65f6：\u641c\u7d22\u6280\u672f\u7684\u6f14\u8fdb<\/h4>\n

\u5728\u4f20\u7edf\u641c\u7d22\u7cfb\u7edf\u4e2d，\u6570\u636e\u7d22\u5f15\u901a\u5e38\u91c7\u7528\u6279\u5904\u7406\u6a21\u5f0f，\u8fd9\u610f\u5473\u7740\u6570\u636e\u66f4\u65b0\u540e\u9700\u8981\u7b49\u5f85\u7d22\u5f15\u91cd\u5efa\u5b8c\u6210\u624d\u80fd\u88ab\u641c\u7d22\u5230\u3002\u968f\u7740\u4e92\u8054\u7f51\u5e94\u7528\u7684\u5feb\u901f\u53d1\u5c55，\u8fd9\u79cd\u5ef6\u8fdf\u9010\u6e10\u53d8\u5f97\u4e0d\u53ef\u63a5\u53d7\u3002<\/p>\n

NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u586b\u8865\u4e86\u5b9e\u65f6\u641c\u7d22\u548c\u6279\u5904\u7406\u641c\u7d22\u4e4b\u95f4\u7684\u7a7a\u767d：<\/p>\n

#mermaid-svg-nHaYDMpgBZtcxkSX{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;fill:#333;}@keyframes edge-animation-frame{from{stroke-dashoffset:0;}}@keyframes dash{to{stroke-dashoffset:0;}}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-nHaYDMpgBZtcxkSX .error-icon{fill:#552222;}#mermaid-svg-nHaYDMpgBZtcxkSX .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-nHaYDMpgBZtcxkSX .marker{fill:#333333;stroke:#333333;}#mermaid-svg-nHaYDMpgBZtcxkSX .marker.cross{stroke:#333333;}#mermaid-svg-nHaYDMpgBZtcxkSX svg{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-nHaYDMpgBZtcxkSX p{margin:0;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge{stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .section–1 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section–1 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section–1 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section–1 path{fill:hsl(240, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section–1 text{fill:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon–1{font-size:40px;color:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge–1{stroke:hsl(240, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth–1{stroke-width:17;}#mermaid-svg-nHaYDMpgBZtcxkSX .section–1 line{stroke:hsl(60, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-0 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-0 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-0 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-0 path{fill:hsl(60, 100%, 73.5294117647%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-0 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-0{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-0{stroke:hsl(60, 100%, 73.5294117647%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-0{stroke-width:14;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-0 line{stroke:hsl(240, 100%, 83.5294117647%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-1 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-1 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-1 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-1 path{fill:hsl(80, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-1 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-1{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-1{stroke:hsl(80, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-1{stroke-width:11;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-1 line{stroke:hsl(260, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-2 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-2 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-2 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-2 path{fill:hsl(270, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-2 text{fill:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-2{font-size:40px;color:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-2{stroke:hsl(270, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-2{stroke-width:8;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-2 line{stroke:hsl(90, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-3 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-3 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-3 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-3 path{fill:hsl(300, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-3 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-3{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-3{stroke:hsl(300, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-3{stroke-width:5;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-3 line{stroke:hsl(120, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-4 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-4 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-4 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-4 path{fill:hsl(330, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-4 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-4{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-4{stroke:hsl(330, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-4{stroke-width:2;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-4 line{stroke:hsl(150, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-5 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-5 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-5 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-5 path{fill:hsl(0, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-5 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-5{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-5{stroke:hsl(0, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-5{stroke-width:-1;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-5 line{stroke:hsl(180, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-6 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-6 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-6 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-6 path{fill:hsl(30, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-6 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-6{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-6{stroke:hsl(30, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-6{stroke-width:-4;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-6 line{stroke:hsl(210, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-7 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-7 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-7 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-7 path{fill:hsl(90, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-7 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-7{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-7{stroke:hsl(90, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-7{stroke-width:-7;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-7 line{stroke:hsl(270, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-8 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-8 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-8 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-8 path{fill:hsl(150, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-8 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-8{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-8{stroke:hsl(150, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-8{stroke-width:-10;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-8 line{stroke:hsl(330, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-9 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-9 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-9 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-9 path{fill:hsl(180, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-9 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-9{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-9{stroke:hsl(180, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-9{stroke-width:-13;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-9 line{stroke:hsl(0, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-10 rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-10 path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-10 circle,#mermaid-svg-nHaYDMpgBZtcxkSX .section-10 path{fill:hsl(210, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-10 text{fill:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .node-icon-10{font-size:40px;color:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-edge-10{stroke:hsl(210, 100%, 76.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .edge-depth-10{stroke-width:-16;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-10 line{stroke:hsl(30, 100%, 86.2745098039%);stroke-width:3;}#mermaid-svg-nHaYDMpgBZtcxkSX .lineWrapper line{stroke:black;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled circle,#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:lightgray;}#mermaid-svg-nHaYDMpgBZtcxkSX .disabled text{fill:#efefef;}#mermaid-svg-nHaYDMpgBZtcxkSX .section-root rect,#mermaid-svg-nHaYDMpgBZtcxkSX .section-root path,#mermaid-svg-nHaYDMpgBZtcxkSX .section-root circle{fill:hsl(240, 100%, 46.2745098039%);}#mermaid-svg-nHaYDMpgBZtcxkSX .section-root text{fill:#ffffff;}#mermaid-svg-nHaYDMpgBZtcxkSX .icon-container{height:100%;display:flex;justify-content:center;align-items:center;}#mermaid-svg-nHaYDMpgBZtcxkSX .edge{fill:none;}#mermaid-svg-nHaYDMpgBZtcxkSX .eventWrapper{filter:brightness(120%);}#mermaid-svg-nHaYDMpgBZtcxkSX :root{–mermaid-font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;}\u4f20\u7edf\u65f6\u4ee3 (2000\u5e74\u524d)\u6279\u5904\u7406\u641c\u7d22\u5c0f\u65f6\/\u5929\u7ea7\u5ef6\u8fdf\u5168\u91cf\u7d22\u5f15\u91cd\u5efa\u6bcf\u6b21\u66f4\u65b0\u90fd\u9700\u91cd\u5efaWeb 2.0 \u65f6\u4ee3 (2000-2010)\u589e\u91cf\u7d22\u5f15\u5206\u949f\u7ea7\u5ef6\u8fdf\u5206\u7247\u6280\u672f\u90e8\u5206\u6570\u636e\u5b9e\u65f6\u5927\u6570\u636e\u65f6\u4ee3 (2010-2020)\u8fd1\u5b9e\u65f6\u641c\u7d22\u79d2\u7ea7\u5ef6\u8fdfLucene + Translog\u5199\u5165\u5373\u53ef\u641cAI \u65f6\u4ee3 (2020\u81f3\u4eca)\u4e9a\u79d2\u7ea7\u641c\u7d22\u6beb\u79d2\u7ea7\u5ef6\u8fdf\u5411\u91cf\u641c\u7d22\u7ed3\u5408\u8bed\u4e49\u7406\u89e3\u641c\u7d22\u6280\u672f\u6f14\u8fdb\u65f6\u95f4\u7ebf<\/p>\n

1.2 NRT \u7684\u6838\u5fc3\u5b9a\u4e49<\/h4>\n

NRT（Near Real-Time） \u662f\u6307\u6570\u636e\u5199\u5165\u540e，\u80fd\u591f\u5728\u79d2\u7ea7（\u901a\u5e381\u79d2\u5185） \u88ab\u641c\u7d22\u5230\u7684\u80fd\u529b\u3002\u4e0e\u771f\u6b63\u7684\u5b9e\u65f6\u641c\u7d22（\u6beb\u79d2\u7ea7）\u76f8\u6bd4，NRT\u5728\u4fdd\u8bc1\u641c\u7d22\u6027\u80fd\u7684\u540c\u65f6，\u63d0\u4f9b\u4e86\u66f4\u597d\u7684\u7cfb\u7edf\u7a33\u5b9a\u6027\u548c\u541e\u5410\u91cf\u3002<\/p>\n

\/\/ NRT\u4e0e\u5b9e\u65f6\u3001\u6279\u5904\u7406\u7684\u5bf9\u6bd4<\/span>
\npublic<\/span> class<\/span> SearchLatencyComparison<\/span> {<\/span><\/p>\n

\/**
\n * \u4e0d\u540c\u641c\u7d22\u6a21\u5f0f\u7684\u5ef6\u8fdf\u5bf9\u6bd4
\n *\/<\/span>
\n public<\/span> void<\/span> compareSearchModes<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ \u6279\u5904\u7406\u6a21\u5f0f（\u4f20\u7edf\u6570\u636e\u5e93）<\/span>
\n long<\/span> batchLatency =<\/span> 1000<\/span> *<\/span> 60<\/span> *<\/span> 60<\/span>;<\/span> \/\/ 1\u5c0f\u65f6<\/span><\/p>\n

\/\/ \u8fd1\u5b9e\u65f6\u6a21\u5f0f（Elasticsearch）<\/span>
\n long<\/span> nrtLatency =<\/span> 1000<\/span>;<\/span> \/\/ 1\u79d2<\/span><\/p>\n

\/\/ \u5b9e\u65f6\u6a21\u5f0f（\u5185\u5b58\u6570\u636e\u5e93）<\/span>
\n long<\/span> realtimeLatency =<\/span> 10<\/span>;<\/span> \/\/ 10\u6beb\u79d2<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u6279\u5904\u7406\u5ef6\u8fdf: "<\/span> +<\/span> batchLatency +<\/span> "ms"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u8fd1\u5b9e\u65f6\u5ef6\u8fdf: "<\/span> +<\/span> nrtLatency +<\/span> "ms"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u5b9e\u65f6\u5ef6\u8fdf: "<\/span> +<\/span> realtimeLatency +<\/span> "ms"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ NRT\u7684\u4f18\u52bf：\u5728\u53ef\u63a5\u53d7\u7684\u5ef6\u8fdf\u5185\u63d0\u4f9b\u6700\u4f73\u6027\u4ef7\u6bd4<\/span>
\n double<\/span> costPerformance =<\/span> calculateCostPerformance<\/span>(<\/span>
\n batchLatency,<\/span> nrtLatency,<\/span> realtimeLatency
\n )<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"NRT\u6027\u4ef7\u6bd4\u6307\u6570: "<\/span> +<\/span> costPerformance)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * NRT\u7684\u5e94\u7528\u6743\u8861
\n *\/<\/span>
\n public<\/span> void<\/span> nrtTradeoffs<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ NRT\u4e0d\u662f\u8ffd\u6c42\u7edd\u5bf9\u5b9e\u65f6，\u800c\u662f\u5728\u591a\u4e2a\u56e0\u7d20\u95f4\u627e\u5230\u5e73\u8861：<\/span>
\n \/\/ 1. \u6570\u636e\u65b0\u9c9c\u5ea6 vs \u7cfb\u7edf\u6027\u80fd<\/span>
\n \/\/ 2. \u641c\u7d22\u5ef6\u8fdf vs \u5199\u5165\u541e\u5410\u91cf<\/span>
\n \/\/ 3. \u6570\u636e\u4e00\u81f4\u6027 vs \u53ef\u7528\u6027<\/span><\/p>\n

Map<\/span><<\/span>String<\/span>,<\/span> String<\/span>><\/span><\/span> tradeoffs =<\/span> new<\/span> HashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span>
\n tradeoffs.<\/span>put<\/span>(<\/span>"\u6570\u636e\u65b0\u9c9c\u5ea6"<\/span>,<\/span> "1\u79d2\u5185\u53ef\u641c"<\/span>)<\/span>;<\/span>
\n tradeoffs.<\/span>put<\/span>(<\/span>"\u5199\u5165\u6027\u80fd"<\/span>,<\/span> "\u9ad8\u541e\u5410\u91cf"<\/span>)<\/span>;<\/span>
\n tradeoffs.<\/span>put<\/span>(<\/span>"\u7cfb\u7edf\u8d44\u6e90"<\/span>,<\/span> "\u5408\u7406\u7684\u5185\u5b58\u548cCPU\u4f7f\u7528"<\/span>)<\/span>;<\/span>
\n tradeoffs.<\/span>put<\/span>(<\/span>"\u6210\u672c\u6548\u76ca"<\/span>,<\/span> "\u6bd4\u5b9e\u65f6\u7cfb\u7edf\u6210\u672c\u4f4e70%"<\/span>)<\/span>;<\/span><\/p>\n

tradeoffs.<\/span>forEach<\/span>(<\/span>(<\/span>k,<\/span> v)<\/span> -><\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>k +<\/span> ": "<\/span> +<\/span> v)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u4e8c\u3001Elasticsearch NRT \u67b6\u6784\u6df1\u5ea6\u5256\u6790<\/h3>\n

2.1 Elasticsearch NRT \u7684\u6838\u5fc3\u7ec4\u4ef6<\/h4>\n

#mermaid-svg-OlCbLNKA2lM7XocF{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;fill:#333;}@keyframes edge-animation-frame{from{stroke-dashoffset:0;}}@keyframes dash{to{stroke-dashoffset:0;}}#mermaid-svg-OlCbLNKA2lM7XocF .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-OlCbLNKA2lM7XocF .error-icon{fill:#552222;}#mermaid-svg-OlCbLNKA2lM7XocF .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-OlCbLNKA2lM7XocF .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-OlCbLNKA2lM7XocF .marker{fill:#333333;stroke:#333333;}#mermaid-svg-OlCbLNKA2lM7XocF .marker.cross{stroke:#333333;}#mermaid-svg-OlCbLNKA2lM7XocF svg{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-OlCbLNKA2lM7XocF p{margin:0;}#mermaid-svg-OlCbLNKA2lM7XocF .label{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;color:#333;}#mermaid-svg-OlCbLNKA2lM7XocF .cluster-label text{fill:#333;}#mermaid-svg-OlCbLNKA2lM7XocF .cluster-label span{color:#333;}#mermaid-svg-OlCbLNKA2lM7XocF .cluster-label span p{background-color:transparent;}#mermaid-svg-OlCbLNKA2lM7XocF .label text,#mermaid-svg-OlCbLNKA2lM7XocF span{fill:#333;color:#333;}#mermaid-svg-OlCbLNKA2lM7XocF .node rect,#mermaid-svg-OlCbLNKA2lM7XocF .node circle,#mermaid-svg-OlCbLNKA2lM7XocF .node ellipse,#mermaid-svg-OlCbLNKA2lM7XocF .node polygon,#mermaid-svg-OlCbLNKA2lM7XocF .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-OlCbLNKA2lM7XocF .rough-node .label text,#mermaid-svg-OlCbLNKA2lM7XocF .node .label text,#mermaid-svg-OlCbLNKA2lM7XocF .image-shape .label,#mermaid-svg-OlCbLNKA2lM7XocF .icon-shape .label{text-anchor:middle;}#mermaid-svg-OlCbLNKA2lM7XocF .node .katex path{fill:#000;stroke:#000;stroke-width:1px;}#mermaid-svg-OlCbLNKA2lM7XocF .rough-node .label,#mermaid-svg-OlCbLNKA2lM7XocF .node .label,#mermaid-svg-OlCbLNKA2lM7XocF .image-shape .label,#mermaid-svg-OlCbLNKA2lM7XocF .icon-shape .label{text-align:center;}#mermaid-svg-OlCbLNKA2lM7XocF .node.clickable{cursor:pointer;}#mermaid-svg-OlCbLNKA2lM7XocF .root .anchor path{fill:#333333!important;stroke-width:0;stroke:#333333;}#mermaid-svg-OlCbLNKA2lM7XocF .arrowheadPath{fill:#333333;}#mermaid-svg-OlCbLNKA2lM7XocF .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-OlCbLNKA2lM7XocF .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-OlCbLNKA2lM7XocF .edgeLabel{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-OlCbLNKA2lM7XocF .edgeLabel p{background-color:rgba(232,232,232, 0.8);}#mermaid-svg-OlCbLNKA2lM7XocF .edgeLabel rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-OlCbLNKA2lM7XocF .labelBkg{background-color:rgba(232, 232, 232, 0.5);}#mermaid-svg-OlCbLNKA2lM7XocF .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-OlCbLNKA2lM7XocF .cluster text{fill:#333;}#mermaid-svg-OlCbLNKA2lM7XocF .cluster span{color:#333;}#mermaid-svg-OlCbLNKA2lM7XocF div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-OlCbLNKA2lM7XocF .flowchartTitleText{text-anchor:middle;font-size:18px;fill:#333;}#mermaid-svg-OlCbLNKA2lM7XocF rect.text{fill:none;stroke-width:0;}#mermaid-svg-OlCbLNKA2lM7XocF .icon-shape,#mermaid-svg-OlCbLNKA2lM7XocF .image-shape{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-OlCbLNKA2lM7XocF .icon-shape p,#mermaid-svg-OlCbLNKA2lM7XocF .image-shape p{background-color:rgba(232,232,232, 0.8);padding:2px;}#mermaid-svg-OlCbLNKA2lM7XocF .icon-shape rect,#mermaid-svg-OlCbLNKA2lM7XocF .image-shape rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-OlCbLNKA2lM7XocF .label-icon{display:inline-block;height:1em;overflow:visible;vertical-align:-0.125em;}#mermaid-svg-OlCbLNKA2lM7XocF .node .label-icon path{fill:currentColor;stroke:revert;stroke-width:revert;}#mermaid-svg-OlCbLNKA2lM7XocF :root{–mermaid-font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;}<\/p>\n

Elasticsearch NRT \u67b6\u6784<\/p>\n

<\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/p>\n

\u6570\u636e\u5199\u5165<\/p>\n

<\/span><\/p>\n

Indexing Buffer<\/p>\n

<\/span><\/p>\n

Lucene Segment<\/p>\n

<\/span><\/p>\n

Translog<\/p>\n

<\/span><\/p>\n

Refresh \u64cd\u4f5c<\/p>\n

<\/span><\/p>\n

\u65b0Segment\u53ef\u641c\u7d22<\/p>\n

<\/span><\/p>\n

\u641c\u7d22\u8bf7\u6c42<\/p>\n

<\/span><\/p>\n

\u6240\u6709Segments<\/p>\n

<\/span><\/p>\n

\u8fd4\u56de\u7ed3\u679c<\/p>\n

<\/span><\/p>\n

\u5b9a\u671fFlush<\/p>\n

<\/span><\/p>\n

Segment\u6301\u4e45\u5316<\/p>\n

<\/span><\/p>\n

\u6e05\u7406Translog<\/p>\n

<\/span><\/p>\n

2.2 Lucene Segment：NRT \u7684\u57fa\u7840<\/h4>\n

\/**
\n * Lucene Segment \u7ba1\u7406\u793a\u4f8b
\n * Segment\u662fLucene\u7d22\u5f15\u7684\u57fa\u672c\u5355\u5143，\u4e5f\u662fNRT\u5b9e\u73b0\u7684\u57fa\u7840
\n *\/<\/span>
\npublic<\/span> class<\/span> LuceneSegmentExample<\/span> {<\/span><\/p>\n

\/**
\n * \u6a21\u62dfSegment\u7684\u521b\u5efa\u548c\u641c\u7d22\u8fc7\u7a0b
\n *\/<\/span>
\n public<\/span> void<\/span> segmentLifecycle<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ 1. \u521d\u59cb\u72b6\u6001：\u7a7a\u7684Segment<\/span>
\n List<\/span><<\/span>Document<\/span>><\/span><\/span> segment =<\/span> new<\/span> ArrayList<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 2. \u6587\u6863\u5199\u5165：\u6dfb\u52a0\u5230\u5185\u5b58\u4e2d\u7684Segment<\/span>
\n for<\/span> (<\/span>int<\/span> i =<\/span> 0<\/span>;<\/span> i <<\/span> 100<\/span>;<\/span> i++<\/span>)<\/span> {<\/span>
\n Document<\/span> doc =<\/span> createDocument<\/span>(<\/span>i)<\/span>;<\/span>
\n segment.<\/span>add<\/span>(<\/span>doc)<\/span>;<\/span><\/p>\n

\/\/ \u6bcf\u4e2aSegment\u6709\u5927\u5c0f\u9650\u5236（\u9ed8\u8ba41GB）<\/span>
\n if<\/span> (<\/span>segment.<\/span>size<\/span>(<\/span>)<\/span> >=<\/span> 1000<\/span>)<\/span> {<\/span> \/\/ \u7b80\u5316\u793a\u4f8b<\/span>
\n \/\/ 3. Segment\u5237\u65b0：\u53d8\u5f97\u53ef\u641c\u7d22<\/span>
\n refreshSegment<\/span>(<\/span>segment)<\/span>;<\/span><\/p>\n

\/\/ 4. \u65b0\u7684\u7a7aSegment\u51c6\u5907\u63a5\u6536\u6570\u636e<\/span>
\n segment =<\/span> new<\/span> ArrayList<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/\/ 5. \u641c\u7d22\u65f6\u67e5\u8be2\u6240\u6709Segments<\/span>
\n SearchResult<\/span> result =<\/span> searchAcrossSegments<\/span>(<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u641c\u7d22\u5230\u6587\u6863\u6570: "<\/span> +<\/span> result.<\/span>getTotalHits<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * Segment\u5408\u5e76\u7b56\u7565
\n *\/<\/span>
\n public<\/span> void<\/span> segmentMergeStrategy<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ Elasticsearch\u7684Segment\u5408\u5e76\u7b56\u7565\u76f4\u63a5\u5f71\u54cdNRT\u6027\u80fd<\/span>
\n Map<\/span><<\/span>String<\/span>,<\/span> Object<\/span>><\/span><\/span> mergePolicy =<\/span> new<\/span> HashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

mergePolicy.<\/span>put<\/span>(<\/span>"\u7b56\u7565\u7c7b\u578b"<\/span>,<\/span> "TieredMergePolicy"<\/span>)<\/span>;<\/span>
\n mergePolicy.<\/span>put<\/span>(<\/span>"\u6bcf\u5c42\u6700\u5927Segments"<\/span>,<\/span> 10<\/span>)<\/span>;<\/span>
\n mergePolicy.<\/span>put<\/span>(<\/span>"\u6bcf\u5c42\u6700\u5c0fSegments"<\/span>,<\/span> 2<\/span>)<\/span>;<\/span>
\n mergePolicy.<\/span>put<\/span>(<\/span>"\u6700\u5927\u5408\u5e76Segment\u5927\u5c0f"<\/span>,<\/span> "5GB"<\/span>)<\/span>;<\/span>
\n mergePolicy.<\/span>put<\/span>(<\/span>"\u5408\u5e76\u56e0\u5b50"<\/span>,<\/span> 10<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5408\u5e76\u7684\u6743\u8861：<\/span>
\n \/\/ – \u66f4\u591a\u5c0fSegments：\u66f4\u597d\u7684NRT\u6027\u80fd，\u4f46\u641c\u7d22\u66f4\u6162<\/span>
\n \/\/ – \u66f4\u5c11\u5927Segments：\u641c\u7d22\u66f4\u5feb，\u4f46NRT\u5ef6\u8fdf\u589e\u52a0<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"Segment\u5408\u5e76\u7b56\u7565\u914d\u7f6e:"<\/span>)<\/span>;<\/span>
\n mergePolicy.<\/span>forEach<\/span>(<\/span>(<\/span>k,<\/span> v)<\/span> -><\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>" "<\/span> +<\/span> k +<\/span> ": "<\/span> +<\/span> v)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

2.3 Refresh \u64cd\u4f5c：NRT \u7684\u5173\u952e\u673a\u5236<\/h4>\n

# Elasticsearch\u7d22\u5f15\u7684Refresh\u914d\u7f6e<\/span>
\nPUT \/my_index\/_settings
\n{<\/span>
\n "index"<\/span>:<\/span> {<\/span>
\n # Refresh\u95f4\u9694：\u63a7\u5236NRT\u7684"\u8fd1\u5b9e\u65f6"\u7a0b\u5ea6<\/span>
\n "refresh_interval"<\/span>:<\/span> "1s"<\/span>,<\/span> # \u9ed8\u8ba41\u79d2，\u53ef\u8c03\u6574<\/span><\/p>\n

# Indexing Buffer：\u63a7\u5236\u5185\u5b58\u4f7f\u7528<\/span>
\n "refresh_interval"<\/span>:<\/span> "1s"<\/span>,<\/span>
\n "translog"<\/span>:<\/span> {<\/span>
\n "flush_threshold_size"<\/span>:<\/span> "512mb"<\/span>,<\/span> # Translog\u5927\u5c0f\u9608\u503c<\/span>
\n "sync_interval"<\/span>:<\/span> "5s"<\/span>,<\/span> # \u540c\u6b65\u95f4\u9694<\/span>
\n "durability"<\/span>:<\/span> "request"<\/span> # \u6301\u4e45\u5316\u7ea7\u522b<\/span>
\n }<\/span>,<\/span><\/p>\n

# Segment\u76f8\u5173\u8bbe\u7f6e<\/span>
\n "merge"<\/span>:<\/span> {<\/span>
\n "policy"<\/span>:<\/span> {<\/span>
\n "max_merged_segment"<\/span>:<\/span> "5gb"<\/span>,<\/span>
\n "segments_per_tier"<\/span>:<\/span> 10<\/span>,<\/span>
\n "max_merge_at_once"<\/span>:<\/span> 10<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# Indexing\u6027\u80fd\u4f18\u5316<\/span>
\n "indexing"<\/span>:<\/span> {<\/span>
\n "slowlog"<\/span>:<\/span> {<\/span>
\n "threshold"<\/span>:<\/span> {<\/span>
\n "index"<\/span>:<\/span> {<\/span>
\n "warn"<\/span>:<\/span> "10s"<\/span>,<\/span>
\n "info"<\/span>:<\/span> "5s"<\/span>,<\/span>
\n "debug"<\/span>:<\/span> "2s"<\/span>,<\/span>
\n "trace"<\/span>:<\/span> "500ms"<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\/**
\n * Refresh\u64cd\u4f5c\u7684\u5de5\u4f5c\u539f\u7406
\n *\/<\/span>
\npublic<\/span> class<\/span> RefreshMechanism<\/span> {<\/span><\/p>\n

\/**
\n * \u6a21\u62dfRefresh\u8fc7\u7a0b
\n *\/<\/span>
\n public<\/span> void<\/span> simulateRefresh<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ 1. \u6570\u636e\u5199\u5165\u9636\u6bb5<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"=== \u6570\u636e\u5199\u5165\u9636\u6bb5 ==="<\/span>)<\/span>;<\/span>
\n List<\/span><<\/span>Document<\/span>><\/span><\/span> indexingBuffer =<\/span> new<\/span> ArrayList<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5199\u5165\u4e00\u4e9b\u6587\u6863<\/span>
\n for<\/span> (<\/span>int<\/span> i =<\/span> 1<\/span>;<\/span> i <=<\/span> 5<\/span>;<\/span> i++<\/span>)<\/span> {<\/span>
\n Document<\/span> doc =<\/span> new<\/span> Document<\/span>(<\/span>"doc_"<\/span> +<\/span> i,<\/span> "content_"<\/span> +<\/span> i)<\/span>;<\/span>
\n indexingBuffer.<\/span>add<\/span>(<\/span>doc)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u5199\u5165\u6587\u6863: "<\/span> +<\/span> doc.<\/span>getId<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ 2. Refresh\u89e6\u53d1\u6761\u4ef6\u68c0\u67e5<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\n=== Refresh\u89e6\u53d1\u68c0\u67e5 ==="<\/span>)<\/span>;<\/span>
\n boolean<\/span> shouldRefresh =<\/span> checkRefreshConditions<\/span>(<\/span>indexingBuffer)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>shouldRefresh)<\/span> {<\/span>
\n \/\/ 3. \u6267\u884cRefresh<\/span>
\n executeRefresh<\/span>(<\/span>indexingBuffer)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

private<\/span> boolean<\/span> checkRefreshConditions<\/span>(<\/span>List<\/span><<\/span>Document<\/span>><\/span><\/span> buffer)<\/span> {<\/span>
\n \/\/ Refresh\u89e6\u53d1\u7684\u6761\u4ef6：<\/span>
\n \/\/ 1. \u65f6\u95f4\u6761\u4ef6：\u8fbe\u5230refresh_interval（\u9ed8\u8ba41\u79d2）<\/span>
\n \/\/ 2. \u7f13\u51b2\u533a\u6761\u4ef6：\u8fbe\u5230\u4e00\u5b9a\u5927\u5c0f<\/span>
\n \/\/ 3. \u624b\u52a8\u89e6\u53d1：API\u8c03\u7528<\/span><\/p>\n

long<\/span> currentTime =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span>
\n long<\/span> lastRefreshTime =<\/span> getLastRefreshTime<\/span>(<\/span>)<\/span>;<\/span>
\n long<\/span> refreshInterval =<\/span> 1000<\/span>;<\/span> \/\/ 1\u79d2<\/span><\/p>\n

\/\/ \u68c0\u67e5\u65f6\u95f4\u95f4\u9694<\/span>
\n if<\/span> (<\/span>currentTime –<\/span> lastRefreshTime >=<\/span> refreshInterval)<\/span> {<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u65f6\u95f4\u6761\u4ef6\u6ee1\u8db3：\u8ddd\u79bb\u4e0a\u6b21Refresh\u8d85\u8fc7"<\/span> +<\/span> refreshInterval +<\/span> "ms"<\/span>)<\/span>;<\/span>
\n return<\/span> true<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u68c0\u67e5\u7f13\u51b2\u533a\u5927\u5c0f<\/span>
\n int<\/span> bufferSizeThreshold =<\/span> 1000<\/span>;<\/span> \/\/ \u5047\u8bbe\u9608\u503c1000\u6761<\/span>
\n if<\/span> (<\/span>buffer.<\/span>size<\/span>(<\/span>)<\/span> >=<\/span> bufferSizeThreshold)<\/span> {<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u7f13\u51b2\u533a\u6761\u4ef6\u6ee1\u8db3：\u8fbe\u5230"<\/span> +<\/span> bufferSizeThreshold +<\/span> "\u6761"<\/span>)<\/span>;<\/span>
\n return<\/span> true<\/span>;<\/span>
\n }<\/span><\/p>\n

return<\/span> false<\/span>;<\/span>
\n }<\/span><\/p>\n

private<\/span> void<\/span> executeRefresh<\/span>(<\/span>List<\/span><<\/span>Document<\/span>><\/span><\/span> buffer)<\/span> {<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\n=== \u6267\u884cRefresh\u64cd\u4f5c ==="<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u521b\u5efa\u65b0\u7684Lucene Segment<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"1. \u521b\u5efa\u65b0\u7684Segment"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 2. \u5c06\u5185\u5b58\u4e2d\u7684\u6587\u6863\u5199\u5165Segment<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"2. \u5199\u5165"<\/span> +<\/span> buffer.<\/span>size<\/span>(<\/span>)<\/span> +<\/span> "\u4e2a\u6587\u6863\u5230Segment"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 3. \u91cd\u65b0\u6253\u5f00IndexReader（\u4f7f\u65b0\u6570\u636e\u53ef\u641c\u7d22）<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"3. \u91cd\u65b0\u6253\u5f00IndexReader"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 4. \u6e05\u7a7aIndexing Buffer（\u51c6\u5907\u63a5\u6536\u65b0\u6570\u636e）<\/span>
\n buffer.<\/span>clear<\/span>(<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"4. \u6e05\u7a7aIndexing Buffer"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 5. \u66f4\u65b0Segment\u5217\u8868<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"5. \u66f4\u65b0\u53ef\u641c\u7d22\u7684Segment\u5217\u8868"<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u2713 Refresh\u5b8c\u6210，\u65b0\u6570\u636e\u73b0\u5728\u53ef\u641c\u7d22"<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u4e0d\u540cRefresh\u7b56\u7565\u7684\u5f71\u54cd
\n *\/<\/span>
\n public<\/span> void<\/span> compareRefreshStrategies<\/span>(<\/span>)<\/span> {<\/span>
\n Map<\/span><<\/span>String<\/span>,<\/span> Map<\/span><<\/span>String<\/span>,<\/span> Object<\/span>><\/span>><\/span><\/span> strategies =<\/span> new<\/span> HashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u7b56\u75651：\u9891\u7e41Refresh（\u6700\u4f73NRT）<\/span>
\n strategies.<\/span>put<\/span>(<\/span>"\u9891\u7e41Refresh"<\/span>,<\/span> Map<\/span>.<\/span>of<\/span>(<\/span>
\n "interval"<\/span>,<\/span> "500ms"<\/span>,<\/span>
\n "nrt_latency"<\/span>,<\/span> "~500ms"<\/span>,<\/span>
\n "throughput_impact"<\/span>,<\/span> "\u9ad8"<\/span>,<\/span>
\n "recommended_for"<\/span>,<\/span> "\u76d1\u63a7\u3001\u65e5\u5fd7\u5206\u6790"<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u7b56\u75652：\u9ed8\u8ba4Refresh（\u5e73\u8861\u6a21\u5f0f）<\/span>
\n strategies.<\/span>put<\/span>(<\/span>"\u9ed8\u8ba4Refresh"<\/span>,<\/span> Map<\/span>.<\/span>of<\/span>(<\/span>
\n "interval"<\/span>,<\/span> "1s"<\/span>,<\/span>
\n "nrt_latency"<\/span>,<\/span> "~1s"<\/span>,<\/span>
\n "throughput_impact"<\/span>,<\/span> "\u4e2d"<\/span>,<\/span>
\n "recommended_for"<\/span>,<\/span> "\u7535\u5546\u3001\u5185\u5bb9\u5e73\u53f0"<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u7b56\u75653：\u8f83\u5c11Refresh（\u6700\u4f73\u541e\u5410\u91cf）<\/span>
\n strategies.<\/span>put<\/span>(<\/span>"\u8f83\u5c11Refresh"<\/span>,<\/span> Map<\/span>.<\/span>of<\/span>(<\/span>
\n "interval"<\/span>,<\/span> "30s"<\/span>,<\/span>
\n "nrt_latency"<\/span>,<\/span> "~30s"<\/span>,<\/span>
\n "throughput_impact"<\/span>,<\/span> "\u4f4e"<\/span>,<\/span>
\n "recommended_for"<\/span>,<\/span> "\u6279\u91cf\u6570\u636e\u5904\u7406"<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u7b56\u75654：\u5173\u95ed\u81ea\u52a8Refresh<\/span>
\n strategies.<\/span>put<\/span>(<\/span>"\u624b\u52a8Refresh"<\/span>,<\/span> Map<\/span>.<\/span>of<\/span>(<\/span>
\n "interval"<\/span>,<\/span> "-1"<\/span>,<\/span>
\n "nrt_latency"<\/span>,<\/span> "\u624b\u52a8\u63a7\u5236"<\/span>,<\/span>
\n "throughput_impact"<\/span>,<\/span> "\u6700\u4f4e"<\/span>,<\/span>
\n "recommended_for"<\/span>,<\/span> "\u6570\u636e\u8fc1\u79fb\u3001\u6279\u91cf\u7d22\u5f15"<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u4e0d\u540cRefresh\u7b56\u7565\u5bf9\u6bd4:"<\/span>)<\/span>;<\/span>
\n strategies.<\/span>forEach<\/span>(<\/span>(<\/span>name,<\/span> config)<\/span> -><\/span> {<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\n"<\/span> +<\/span> name +<\/span> ":"<\/span>)<\/span>;<\/span>
\n config.<\/span>forEach<\/span>(<\/span>(<\/span>k,<\/span> v)<\/span> -><\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>" "<\/span> +<\/span> k +<\/span> ": "<\/span> +<\/span> v)<\/span>)<\/span>;<\/span>
\n }<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

2.4 Translog：\u6570\u636e\u5b89\u5168\u6027\u7684\u4fdd\u969c<\/h4>\n

\/**
\n * Translog（\u4e8b\u52a1\u65e5\u5fd7）\u5de5\u4f5c\u539f\u7406
\n * Translog\u4fdd\u8bc1\u4e86\u6570\u636e\u5728\u5237\u65b0\u5230\u78c1\u76d8\u524d\u7684\u5b89\u5168\u6027
\n *\/<\/span>
\npublic<\/span> class<\/span> TranslogMechanism<\/span> {<\/span><\/p>\n

\/**
\n * Translog\u7684\u53cc\u91cd\u4f5c\u7528
\n *\/<\/span>
\n public<\/span> void<\/span> translogDualRole<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ \u89d2\u82721：\u5d29\u6e83\u6062\u590d（Crash Recovery）<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"=== Translog\u7684\u5d29\u6e83\u6062\u590d\u673a\u5236 ==="<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6a21\u62df\u5d29\u6e83\u573a\u666f<\/span>
\n simulateCrashRecovery<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u89d2\u82722：\u5b9e\u65f6\u6027\u4fdd\u8bc1<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\n=== Translog\u7684\u5b9e\u65f6\u6027\u4fdd\u8bc1 ==="<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5373\u4f7f\u6ca1\u6709Refresh，\u901a\u8fc7Translog\u4e5f\u80fd\u63d0\u4f9b\u5b9e\u65f6Get\u64cd\u4f5c<\/span>
\n demonstrateRealTimeGet<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

private<\/span> void<\/span> simulateCrashRecovery<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ \u573a\u666f：Elasticsearch\u8282\u70b9\u7a81\u7136\u5d29\u6e83<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u573a\u666f：\u8282\u70b9\u7a81\u7136\u5d29\u6e83，\u5185\u5b58\u4e2d\u7684\u6570\u636e\u4e22\u5931"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6062\u590d\u8fc7\u7a0b：<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"1. \u91cd\u542f\u8282\u70b9"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"2. \u8bfb\u53d6Translog（\u6301\u4e45\u5316\u5728\u78c1\u76d8）"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"3. \u91cd\u653eTranslog\u4e2d\u7684\u64cd\u4f5c"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"4. \u6062\u590d\u5230\u5d29\u6e83\u524d\u7684\u72b6\u6001"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"5. \u7ee7\u7eed\u6b63\u5e38\u670d\u52a1"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Translog\u914d\u7f6e\u9009\u9879：<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\nTranslog\u914d\u7f6e\u9009\u9879："<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"- durability: request (\u6bcf\u6b21\u8bf7\u6c42\u90fdfsync，\u6700\u5b89\u5168)"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"- durability: async (\u5f02\u6b65fsync，\u66f4\u9ad8\u6027\u80fd)"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"- flush_threshold_size: 512mb (\u89e6\u53d1flush\u7684\u5927\u5c0f)"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"- sync_interval: 5s (\u540c\u6b65\u5230\u78c1\u76d8\u7684\u95f4\u9694)"<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

private<\/span> void<\/span> demonstrateRealTimeGet<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ \u5373\u4f7f\u6587\u6863\u8fd8\u6ca1\u6709\u88abRefresh\u5230Segment\u4e2d<\/span>
\n \/\/ \u901a\u8fc7Translog\u4ecd\u7136\u53ef\u4ee5\u5b9e\u65f6\u83b7\u53d6<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u6587\u6863\u5199\u5165\u6d41\u7a0b："<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"1. \u6587\u6863\u5199\u5165 -> Indexing Buffer"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"2. \u540c\u65f6\u5199\u5165 -> Translog"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"3. \u672aRefresh\u524d，\u6587\u6863\u5728\u5185\u5b58\u4e2d"<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\n\u5b9e\u65f6Get\u64cd\u4f5c："<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"1. \u9996\u5148\u68c0\u67e5\u5185\u5b58\u4e2d\u7684Indexing Buffer"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"2. \u7136\u540e\u68c0\u67e5Translog"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"3. \u6700\u540e\u68c0\u67e5\u5df2\u5237\u65b0\u7684Segments"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\u2713 \u786e\u4fdd\u603b\u662f\u80fd\u83b7\u53d6\u5230\u6700\u65b0\u6570\u636e"<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * Translog\u4e0e\u6027\u80fd\u7684\u6743\u8861
\n *\/<\/span>
\n public<\/span> void<\/span> translogPerformanceTradeoff<\/span>(<\/span>)<\/span> {<\/span>
\n Map<\/span><<\/span>String<\/span>,<\/span> TranslogConfig<\/span>><\/span><\/span> configs =<\/span> new<\/span> HashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u914d\u7f6e1：\u6700\u9ad8\u5b89\u5168\u6027<\/span>
\n configs.<\/span>put<\/span>(<\/span>"\u6700\u9ad8\u5b89\u5168\u6027"<\/span>,<\/span> new<\/span> TranslogConfig<\/span>(<\/span>
\n "request"<\/span>,<\/span> \/\/ durability<\/span>
\n 100<\/span>,<\/span> \/\/ flush_threshold_ops<\/span>
\n "100mb"<\/span>,<\/span> \/\/ flush_threshold_size<\/span>
\n "1s"<\/span> \/\/ sync_interval<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u914d\u7f6e2：\u5e73\u8861\u6a21\u5f0f（\u9ed8\u8ba4）<\/span>
\n configs.<\/span>put<\/span>(<\/span>"\u5e73\u8861\u6a21\u5f0f"<\/span>,<\/span> new<\/span> TranslogConfig<\/span>(<\/span>
\n "request"<\/span>,<\/span>
\n 50000<\/span>,<\/span>
\n "512mb"<\/span>,<\/span>
\n "5s"<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u914d\u7f6e3：\u6700\u9ad8\u6027\u80fd<\/span>
\n configs.<\/span>put<\/span>(<\/span>"\u6700\u9ad8\u6027\u80fd"<\/span>,<\/span> new<\/span> TranslogConfig<\/span>(<\/span>
\n "async"<\/span>,<\/span>
\n 100000<\/span>,<\/span>
\n "1gb"<\/span>,<\/span>
\n "30s"<\/span>
\n )<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"Translog\u914d\u7f6e\u6027\u80fd\u5f71\u54cd:"<\/span>)<\/span>;<\/span>
\n configs.<\/span>forEach<\/span>(<\/span>(<\/span>name,<\/span> config)<\/span> -><\/span> {<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"\\\\n"<\/span> +<\/span> name +<\/span> ":"<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>" \u6570\u636e\u5b89\u5168\u6027: "<\/span> +<\/span>
\n (<\/span>config.<\/span>durability.<\/span>equals<\/span>(<\/span>"request"<\/span>)<\/span> ?<\/span> "\u9ad8"<\/span> :<\/span> "\u4e2d"<\/span>)<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>" \u5199\u5165\u6027\u80fd: "<\/span> +<\/span>
\n (<\/span>config.<\/span>flushThresholdSize.<\/span>equals<\/span>(<\/span>"1gb"<\/span>)<\/span> ?<\/span> "\u9ad8"<\/span> :<\/span> "\u4e2d"<\/span>)<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>" \u9002\u7528\u573a\u666f: "<\/span> +<\/span>
\n getRecommendedScenario<\/span>(<\/span>config)<\/span>)<\/span>;<\/span>
\n }<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

class<\/span> TranslogConfig<\/span> {<\/span>
\n String<\/span> durability;<\/span>
\n int<\/span> flushThresholdOps;<\/span>
\n String<\/span> flushThresholdSize;<\/span>
\n String<\/span> syncInterval;<\/span><\/p>\n

TranslogConfig<\/span>(<\/span>String<\/span> d,<\/span> int<\/span> ops,<\/span> String<\/span> size,<\/span> String<\/span> interval)<\/span> {<\/span>
\n this<\/span>.<\/span>durability =<\/span> d;<\/span>
\n this<\/span>.<\/span>flushThresholdOps =<\/span> ops;<\/span>
\n this<\/span>.<\/span>flushThresholdSize =<\/span> size;<\/span>
\n this<\/span>.<\/span>syncInterval =<\/span> interval;<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u4e09\u3001NRT \u5b9e\u6218\u5e94\u7528\u573a\u666f<\/h3>\n

3.1 \u573a\u666f\u4e00：\u7535\u5546\u5546\u54c1\u641c\u7d22<\/h4>\n

\/**
\n * \u7535\u5546\u5546\u54c1\u641c\u7d22NRT\u5b9e\u73b0
\n * \u9700\u6c42：\u5546\u54c1\u4e0a\u67b6\/\u4e0b\u67b6\/\u4ef7\u683c\u53d8\u66f4\u540e\u7acb\u5373\u53ef\u641c
\n *\/<\/span>
\n@Service<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> EcommerceProductSearch<\/span> {<\/span><\/p>\n

@Autowired<\/span>
\n private<\/span> RestHighLevelClient<\/span> esClient;<\/span><\/p>\n

\/**
\n * \u5546\u54c1\u7d22\u5f15\u914d\u7f6e（\u4f18\u5316NRT）
\n *\/<\/span>
\n public<\/span> void<\/span> createProductIndex<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n CreateIndexRequest<\/span> request =<\/span> new<\/span> CreateIndexRequest<\/span>(<\/span>"products"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ NRT\u4f18\u5316\u914d\u7f6e<\/span>
\n request.<\/span>settings<\/span>(<\/span>Settings<\/span>.<\/span>builder<\/span>(<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.number_of_shards"<\/span>,<\/span> 3<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.number_of_replicas"<\/span>,<\/span> 1<\/span>)<\/span>
\n \/\/ NRT\u5173\u952e\u914d\u7f6e<\/span>
\n .<\/span>put<\/span>(<\/span>"index.refresh_interval"<\/span>,<\/span> "1s"<\/span>)<\/span> \/\/ 1\u79d2\u5237\u65b0<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.durability"<\/span>,<\/span> "request"<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.sync_interval"<\/span>,<\/span> "1s"<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.flush_threshold_size"<\/span>,<\/span> "256mb"<\/span>)<\/span>
\n \/\/ \u7d22\u5f15\u6027\u80fd\u4f18\u5316<\/span>
\n .<\/span>put<\/span>(<\/span>"index.merge.scheduler.max_merge_count"<\/span>,<\/span> 3<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.merge.scheduler.max_thread_count"<\/span>,<\/span> 2<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.unassigned.node_left.delayed_timeout"<\/span>,<\/span> "5m"<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

\/\/ \u5546\u54c1\u6620\u5c04<\/span>
\n XContentBuilder<\/span> mapping =<\/span> JsonXContent<\/span>.<\/span>contentBuilder<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"properties"<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"product_id"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"title"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "text"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"analyzer"<\/span>,<\/span> "ik_max_word"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"search_analyzer"<\/span>,<\/span> "ik_smart"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"price"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "double"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"status"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "integer"<\/span>)<\/span> \/\/ 0:\u4e0b\u67b6, 1:\u4e0a\u67b6<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"stock"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "integer"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"update_time"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "date"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"format"<\/span>,<\/span> "epoch_millis"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n \/\/ \u7528\u4e8e\u5b9e\u65f6\u8fc7\u6ee4\u7684\u70ed\u6570\u636e\u5b57\u6bb5<\/span>
\n .<\/span>startObject<\/span>(<\/span>"is_hot"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "boolean"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

request.<\/span>mapping<\/span>(<\/span>mapping)<\/span>;<\/span><\/p>\n

CreateIndexResponse<\/span> response =<\/span> esClient.<\/span>indices<\/span>(<\/span>)<\/span>
\n .<\/span>create<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

log.<\/span>info<\/span>(<\/span>"\u5546\u54c1\u7d22\u5f15\u521b\u5efa\u5b8c\u6210: {}"<\/span>,<\/span> response.<\/span>isAcknowledged<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u5546\u54c1\u4e0a\u67b6 – NRT\u4fdd\u8bc1
\n *\/<\/span>
\n @Transactional<\/span>
\n public<\/span> boolean<\/span> listProduct<\/span>(<\/span>ProductDTO<\/span> product)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n String<\/span> productId =<\/span> product.<\/span>getId<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u66f4\u65b0\u6570\u636e\u5e93\u72b6\u6001<\/span>
\n productRepository.<\/span>updateStatus<\/span>(<\/span>productId,<\/span> ProductStatus<\/span>.<\/span>LISTED)<\/span>;<\/span><\/p>\n

\/\/ 2. \u540c\u6b65\u5230Elasticsearch<\/span>
\n IndexRequest<\/span> request =<\/span> new<\/span> IndexRequest<\/span>(<\/span>"products"<\/span>)<\/span>
\n .<\/span>id<\/span>(<\/span>productId)<\/span>
\n .<\/span>source<\/span>(<\/span>JsonXContent<\/span>.<\/span>contentBuilder<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"product_id"<\/span>,<\/span> productId)<\/span>
\n .<\/span>field<\/span>(<\/span>"title"<\/span>,<\/span> product.<\/span>getTitle<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"description"<\/span>,<\/span> product.<\/span>getDescription<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"price"<\/span>,<\/span> product.<\/span>getPrice<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span> \/\/ \u4e0a\u67b6\u72b6\u6001<\/span>
\n .<\/span>field<\/span>(<\/span>"category"<\/span>,<\/span> product.<\/span>getCategory<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"brand"<\/span>,<\/span> product.<\/span>getBrand<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"stock"<\/span>,<\/span> product.<\/span>getStock<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"update_time"<\/span>,<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"is_hot"<\/span>,<\/span> product.<\/span>getIsHot<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n )<\/span>
\n \/\/ \u8bbe\u7f6eRefresh\u7b56\u7565<\/span>
\n .<\/span>setRefreshPolicy<\/span>(<\/span>WriteRequest.<\/span>RefreshPolicy<\/span>.<\/span>WAIT_UNTIL)<\/span>;<\/span><\/p>\n

IndexResponse<\/span> response =<\/span> esClient.<\/span>index<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ 3. \u9a8c\u8bc1\u53ef\u641c\u7d22\u6027<\/span>
\n if<\/span> (<\/span>response.<\/span>getResult<\/span>(<\/span>)<\/span> ==<\/span> DocWriteResponse.<\/span>Result<\/span>.<\/span>CREATED ||<\/span>
\n response.<\/span>getResult<\/span>(<\/span>)<\/span> ==<\/span> DocWriteResponse.<\/span>Result<\/span>.<\/span>UPDATED)<\/span> {<\/span><\/p>\n

\/\/ \u7b49\u5f85\u5e76\u9a8c\u8bc1\u53ef\u641c\u7d22<\/span>
\n return<\/span> verifySearchability<\/span>(<\/span>productId)<\/span>;<\/span>
\n }<\/span><\/p>\n

return<\/span> false<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u9a8c\u8bc1NRT\u641c\u7d22\u80fd\u529b
\n *\/<\/span>
\n private<\/span> boolean<\/span> verifySearchability<\/span>(<\/span>String<\/span> productId)<\/span> {<\/span>
\n int<\/span> maxRetries =<\/span> 10<\/span>;<\/span> \/\/ \u6700\u5927\u91cd\u8bd510\u6b21<\/span>
\n int<\/span> retryInterval =<\/span> 200<\/span>;<\/span> \/\/ \u6bcf\u6b21\u95f4\u9694200ms<\/span><\/p>\n

for<\/span> (<\/span>int<\/span> i =<\/span> 0<\/span>;<\/span> i <<\/span> maxRetries;<\/span> i++<\/span>)<\/span> {<\/span>
\n try<\/span> {<\/span>
\n \/\/ \u5c1d\u8bd5\u641c\u7d22\u521a\u4e0a\u67b6\u7684\u5546\u54c1<\/span>
\n SearchRequest<\/span> searchRequest =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"products"<\/span>)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>query<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"product_id"<\/span>,<\/span> productId)<\/span>)<\/span>;<\/span>
\n searchRequest.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>
\n searchRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>response.<\/span>getHits<\/span>(<\/span>)<\/span>.<\/span>getTotalHits<\/span>(<\/span>)<\/span>.<\/span>value ><\/span> 0<\/span>)<\/span> {<\/span>
\n long<\/span> latency =<\/span> (<\/span>i +<\/span> 1<\/span>)<\/span> *<\/span> retryInterval;<\/span>
\n log.<\/span>info<\/span>(<\/span>"\u5546\u54c1\u4e0a\u67b6\u540e {}ms \u53ef\u641c\u7d22: {}"<\/span>,<\/span> latency,<\/span> productId)<\/span>;<\/span>
\n return<\/span> true<\/span>;<\/span>
\n }<\/span><\/p>\n

Thread<\/span>.<\/span>sleep<\/span>(<\/span>retryInterval)<\/span>;<\/span><\/p>\n

}<\/span> catch<\/span> (<\/span>Exception<\/span> e)<\/span> {<\/span>
\n log.<\/span>warn<\/span>(<\/span>"\u9a8c\u8bc1\u641c\u7d22\u80fd\u529b\u5f02\u5e38"<\/span>,<\/span> e)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

log.<\/span>error<\/span>(<\/span>"\u5546\u54c1\u4e0a\u67b6\u540e {}ms \u4ecd\u4e0d\u53ef\u641c\u7d22: {}"<\/span>,<\/span>
\n maxRetries *<\/span> retryInterval,<\/span> productId)<\/span>;<\/span>
\n return<\/span> false<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u5546\u54c1\u641c\u7d22\u63a5\u53e3（\u652f\u6301\u5b9e\u65f6\u8fc7\u6ee4）
\n *\/<\/span>
\n public<\/span> SearchResult<\/span> searchProducts<\/span>(<\/span>ProductSearchRequest<\/span> searchReq)<\/span>
\n throws<\/span> IOException<\/span> {<\/span><\/p>\n

SearchRequest<\/span> request =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"products"<\/span>)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6784\u5efa\u5b9e\u65f6\u641c\u7d22\u67e5\u8be2<\/span>
\n BoolQueryBuilder<\/span> boolQuery =<\/span> QueryBuilders<\/span>.<\/span>boolQuery<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5173\u952e\u8bcd\u641c\u7d22<\/span>
\n if<\/span> (<\/span>StringUtils<\/span>.<\/span>isNotBlank<\/span>(<\/span>searchReq.<\/span>getKeyword<\/span>(<\/span>)<\/span>)<\/span>)<\/span> {<\/span>
\n boolQuery.<\/span>must<\/span>(<\/span>QueryBuilders<\/span>.<\/span>multiMatchQuery<\/span>(<\/span>searchReq.<\/span>getKeyword<\/span>(<\/span>)<\/span>,<\/span>
\n "title"<\/span>,<\/span> "description"<\/span>,<\/span> "category"<\/span>,<\/span> "brand"<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u5b9e\u65f6\u72b6\u6001\u8fc7\u6ee4：\u53ea\u663e\u793a\u4e0a\u67b6\u5546\u54c1<\/span>
\n boolQuery.<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5e93\u5b58\u8fc7\u6ee4：\u53ea\u663e\u793a\u6709\u5e93\u5b58\u5546\u54c1<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>isInStockOnly<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n boolQuery.<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>.<\/span>rangeQuery<\/span>(<\/span>"stock"<\/span>)<\/span>.<\/span>gt<\/span>(<\/span>0<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u4ef7\u683c\u533a\u95f4\u8fc7\u6ee4<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getMinPrice<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> ||<\/span> searchReq.<\/span>getMaxPrice<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
\n RangeQueryBuilder<\/span> priceRange =<\/span> QueryBuilders<\/span>.<\/span>rangeQuery<\/span>(<\/span>"price"<\/span>)<\/span>;<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getMinPrice<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
\n priceRange.<\/span>gte<\/span>(<\/span>searchReq.<\/span>getMinPrice<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getMaxPrice<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
\n priceRange.<\/span>lte<\/span>(<\/span>searchReq.<\/span>getMaxPrice<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n boolQuery.<\/span>filter<\/span>(<\/span>priceRange)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u70ed\u9500\u5546\u54c1\u4f18\u5148（\u5b9e\u65f6\u6392\u5e8f）<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>isPrioritizeHot<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n sourceBuilder.<\/span>sort<\/span>(<\/span>SortBuilders<\/span>.<\/span>fieldSort<\/span>(<\/span>"is_hot"<\/span>)<\/span>.<\/span>order<\/span>(<\/span>SortOrder<\/span>.<\/span>DESC)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u6700\u65b0\u5546\u54c1\u4f18\u5148（\u57fa\u4e8e\u66f4\u65b0\u65f6\u95f4）<\/span>
\n sourceBuilder.<\/span>sort<\/span>(<\/span>SortBuilders<\/span>.<\/span>fieldSort<\/span>(<\/span>"update_time"<\/span>)<\/span>.<\/span>order<\/span>(<\/span>SortOrder<\/span>.<\/span>DESC)<\/span>)<\/span>;<\/span><\/p>\n

sourceBuilder.<\/span>query<\/span>(<\/span>boolQuery)<\/span>;<\/span>
\n sourceBuilder.<\/span>from<\/span>(<\/span>searchReq.<\/span>getFrom<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>searchReq.<\/span>getSize<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u9ad8\u4eae\u663e\u793a<\/span>
\n HighlightBuilder<\/span> highlightBuilder =<\/span> new<\/span> HighlightBuilder<\/span>(<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>field<\/span>(<\/span>"title"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>field<\/span>(<\/span>"description"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>preTags<\/span>(<\/span>"<em>"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>postTags<\/span>(<\/span>"<\/em>"<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>highlighter<\/span>(<\/span>highlightBuilder)<\/span>;<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u805a\u5408\u5206\u6790（\u5b9e\u65f6\u7edf\u8ba1）<\/span>
\n TermsAggregationBuilder<\/span> categoryAgg =<\/span> AggregationBuilders<\/span>
\n .<\/span>terms<\/span>(<\/span>"by_category"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"category.keyword"<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>aggregation<\/span>(<\/span>categoryAgg)<\/span>;<\/span><\/p>\n

request.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

\/\/ \u6267\u884c\u641c\u7d22<\/span>
\n SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ \u89e3\u6790\u7ed3\u679c<\/span>
\n return<\/span> parseSearchResult<\/span>(<\/span>response)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u76d1\u63a7NRT\u6027\u80fd\u6307\u6807
\n *\/<\/span>
\n @Scheduled<\/span>(<\/span>fixedDelay =<\/span> 60000<\/span>)<\/span> \/\/ \u6bcf\u5206\u949f\u6267\u884c<\/span>
\n public<\/span> void<\/span> monitorNrtPerformance<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n \/\/ \u83b7\u53d6\u7d22\u5f15\u7edf\u8ba1\u4fe1\u606f<\/span>
\n IndicesStatsRequest<\/span> statsRequest =<\/span> new<\/span> IndicesStatsRequest<\/span>(<\/span>)<\/span>
\n .<\/span>indices<\/span>(<\/span>"products"<\/span>)<\/span>
\n .<\/span>clear<\/span>(<\/span>)<\/span>
\n .<\/span>refresh<\/span>(<\/span>true<\/span>)<\/span>
\n .<\/span>flush<\/span>(<\/span>true<\/span>)<\/span>;<\/span><\/p>\n

IndicesStatsResponse<\/span> stats =<\/span> esClient.<\/span>indices<\/span>(<\/span>)<\/span>
\n .<\/span>stats<\/span>(<\/span>statsRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ \u5206\u6790Refresh\u6027\u80fd<\/span>
\n RefreshStats<\/span> refreshStats =<\/span> stats.<\/span>getIndex<\/span>(<\/span>"products"<\/span>)<\/span>.<\/span>getRefresh<\/span>(<\/span>)<\/span>;<\/span>
\n FlushStats<\/span> flushStats =<\/span> stats.<\/span>getIndex<\/span>(<\/span>"products"<\/span>)<\/span>.<\/span>getFlush<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

Map<\/span><<\/span>String<\/span>,<\/span> Object<\/span>><\/span><\/span> metrics =<\/span> new<\/span> HashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span>
\n metrics.<\/span>put<\/span>(<\/span>"total_refreshes"<\/span>,<\/span> refreshStats.<\/span>getTotal<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n metrics.<\/span>put<\/span>(<\/span>"refresh_time_ms"<\/span>,<\/span> refreshStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n metrics.<\/span>put<\/span>(<\/span>"avg_refresh_latency"<\/span>,<\/span>
\n refreshStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span> \/<\/span> Math<\/span>.<\/span>max<\/span>(<\/span>refreshStats.<\/span>getTotal<\/span>(<\/span>)<\/span>,<\/span> 1<\/span>)<\/span>)<\/span>;<\/span>
\n metrics.<\/span>put<\/span>(<\/span>"total_flushes"<\/span>,<\/span> flushStats.<\/span>getTotal<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n metrics.<\/span>put<\/span>(<\/span>"flush_time_ms"<\/span>,<\/span> flushStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u8ba1\u7b97NRT\u5ef6\u8fdf\u6307\u6807<\/span>
\n double<\/span> nrtLatencyPercentile =<\/span> calculateNrtLatencyPercentile<\/span>(<\/span>)<\/span>;<\/span>
\n metrics.<\/span>put<\/span>(<\/span>"nrt_latency_p95"<\/span>,<\/span> nrtLatencyPercentile)<\/span>;<\/span><\/p>\n

\/\/ \u53d1\u9001\u5230\u76d1\u63a7\u7cfb\u7edf<\/span>
\n sendToMonitoringSystem<\/span>(<\/span>"nrt_performance"<\/span>,<\/span> metrics)<\/span>;<\/span><\/p>\n

log.<\/span>info<\/span>(<\/span>"NRT\u6027\u80fd\u76d1\u63a7: {}"<\/span>,<\/span> metrics)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

3.2 \u573a\u666f\u4e8c：\u65e5\u5fd7\u76d1\u63a7\u4e0e\u5206\u6790<\/h4>\n

\/**
\n * \u65e5\u5fd7\u76d1\u63a7\u7cfb\u7edf\u7684NRT\u5b9e\u73b0
\n * \u9700\u6c42：\u65e5\u5fd7\u4ea7\u751f\u540e\u79d2\u7ea7\u53ef\u5206\u6790\u3001\u53ef\u544a\u8b66
\n *\/<\/span>
\n@Component<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> LogMonitoringSystem<\/span> {<\/span><\/p>\n

@Autowired<\/span>
\n private<\/span> RestHighLevelClient<\/span> esClient;<\/span><\/p>\n

\/**
\n * \u65e5\u5fd7\u7d22\u5f15\u6a21\u677f（\u652f\u6301NRT）
\n *\/<\/span>
\n public<\/span> void<\/span> createLogIndexTemplate<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n PutIndexTemplateRequest<\/span> request =<\/span> new<\/span> PutIndexTemplateRequest<\/span>(<\/span>"logs_template"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5339\u914d\u6240\u6709logs-*\u7d22\u5f15<\/span>
\n request.<\/span>patterns<\/span>(<\/span>Collections<\/span>.<\/span>singletonList<\/span>(<\/span>"logs-*"<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ NRT\u4f18\u5316\u8bbe\u7f6e<\/span>
\n request.<\/span>settings<\/span>(<\/span>Settings<\/span>.<\/span>builder<\/span>(<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.number_of_shards"<\/span>,<\/span> 5<\/span>)<\/span> \/\/ \u66f4\u591a\u5206\u7247\u63d0\u9ad8\u5e76\u53d1<\/span>
\n .<\/span>put<\/span>(<\/span>"index.number_of_replicas"<\/span>,<\/span> 1<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.refresh_interval"<\/span>,<\/span> "1s"<\/span>)<\/span> \/\/ 1\u79d2\u5237\u65b0<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.durability"<\/span>,<\/span> "async"<\/span>)<\/span> \/\/ \u5f02\u6b65\u63d0\u9ad8\u541e\u5410<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.sync_interval"<\/span>,<\/span> "5s"<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.flush_threshold_size"<\/span>,<\/span> "1gb"<\/span>)<\/span> \/\/ \u66f4\u5927\u63d0\u9ad8\u6027\u80fd<\/span>
\n \/\/ \u4f18\u5316\u5199\u5165\u6027\u80fd<\/span>
\n .<\/span>put<\/span>(<\/span>"index.indexing.slowlog.threshold.index.warn"<\/span>,<\/span> "10s"<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.indexing.slowlog.threshold.index.info"<\/span>,<\/span> "5s"<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.indexing.slowlog.threshold.index.debug"<\/span>,<\/span> "2s"<\/span>)<\/span>
\n \/\/ \u4f18\u5316\u67e5\u8be2\u6027\u80fd<\/span>
\n .<\/span>put<\/span>(<\/span>"index.queries.cache.enabled"<\/span>,<\/span> true<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.max_result_window"<\/span>,<\/span> 100000<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

\/\/ \u65e5\u5fd7\u6620\u5c04\u5b9a\u4e49<\/span>
\n XContentBuilder<\/span> mapping =<\/span> JsonXContent<\/span>.<\/span>contentBuilder<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"properties"<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"@timestamp"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "date"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"format"<\/span>,<\/span> "epoch_millis"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"level"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span> \/\/ ERROR, WARN, INFO, DEBUG<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"message"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "text"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"analyzer"<\/span>,<\/span> "standard"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"service"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"host"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"trace_id"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n \/\/ \u52a8\u6001\u5b57\u6bb5：\u7528\u6237\u81ea\u5b9a\u4e49\u5b57\u6bb5<\/span>
\n .<\/span>startObject<\/span>(<\/span>"fields"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "object"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"dynamic"<\/span>,<\/span> true<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

request.<\/span>mapping<\/span>(<\/span>mapping)<\/span>;<\/span><\/p>\n

\/\/ \u522b\u540d\u8bbe\u7f6e（\u65b9\u4fbf\u641c\u7d22）<\/span>
\n request.<\/span>alias<\/span>(<\/span>new<\/span> Alias<\/span>(<\/span>"logs_current"<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

esClient.<\/span>indices<\/span>(<\/span>)<\/span>.<\/span>putTemplate<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span>
\n log.<\/span>info<\/span>(<\/span>"\u65e5\u5fd7\u7d22\u5f15\u6a21\u677f\u521b\u5efa\u5b8c\u6210"<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u6279\u91cf\u5199\u5165\u65e5\u5fd7（\u4f18\u5316NRT\u6027\u80fd）
\n *\/<\/span>
\n public<\/span> void<\/span> bulkIndexLogs<\/span>(<\/span>List<\/span><<\/span>LogEntry<\/span>><\/span><\/span> logs)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n if<\/span> (<\/span>logs ==<\/span> null<\/span> ||<\/span> logs.<\/span>isEmpty<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n return<\/span>;<\/span>
\n }<\/span><\/p>\n

BulkRequest<\/span> bulkRequest =<\/span> new<\/span> BulkRequest<\/span>(<\/span>)<\/span>;<\/span>
\n String<\/span> indexName =<\/span> getDailyIndexName<\/span>(<\/span>)<\/span>;<\/span> \/\/ \u6309\u5929\u5206\u7d22\u5f15<\/span><\/p>\n

for<\/span> (<\/span>LogEntry<\/span> logEntry :<\/span> logs)<\/span> {<\/span>
\n IndexRequest<\/span> request =<\/span> new<\/span> IndexRequest<\/span>(<\/span>indexName)<\/span>
\n .<\/span>source<\/span>(<\/span>JsonXContent<\/span>.<\/span>contentBuilder<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"@timestamp"<\/span>,<\/span> logEntry.<\/span>getTimestamp<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"level"<\/span>,<\/span> logEntry.<\/span>getLevel<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"message"<\/span>,<\/span> logEntry.<\/span>getMessage<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"service"<\/span>,<\/span> logEntry.<\/span>getService<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"host"<\/span>,<\/span> logEntry.<\/span>getHost<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"trace_id"<\/span>,<\/span> logEntry.<\/span>getTraceId<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"fields"<\/span>,<\/span> logEntry.<\/span>getFields<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

bulkRequest.<\/span>add<\/span>(<\/span>request)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u8bbe\u7f6eRefresh\u7b56\u7565（\u5e73\u8861\u6027\u80fd\u4e0e\u5b9e\u65f6\u6027）<\/span>
\n bulkRequest.<\/span>setRefreshPolicy<\/span>(<\/span>WriteRequest.<\/span>RefreshPolicy<\/span>.<\/span>NONE)<\/span>;<\/span><\/p>\n

\/\/ \u6267\u884c\u6279\u91cf\u5199\u5165<\/span>
\n BulkResponse<\/span> bulkResponse =<\/span> esClient.<\/span>bulk<\/span>(<\/span>bulkRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>bulkResponse.<\/span>hasFailures<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n log.<\/span>error<\/span>(<\/span>"\u6279\u91cf\u5199\u5165\u65e5\u5fd7\u5931\u8d25: {}"<\/span>,<\/span> bulkResponse.<\/span>buildFailureMessage<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span> else<\/span> {<\/span>
\n log.<\/span>debug<\/span>(<\/span>"\u6279\u91cf\u5199\u5165 {} \u6761\u65e5\u5fd7\u5b8c\u6210，\u8017\u65f6: {}ms"<\/span>,<\/span>
\n logs.<\/span>size<\/span>(<\/span>)<\/span>,<\/span> bulkResponse.<\/span>getTook<\/span>(<\/span>)<\/span>.<\/span>getMillis<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u5b9a\u671f\u624b\u52a8Refresh（\u4f18\u5316NRT）<\/span>
\n schedulePeriodicRefresh<\/span>(<\/span>indexName)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u5b9e\u65f6\u65e5\u5fd7\u641c\u7d22
\n *\/<\/span>
\n public<\/span> LogSearchResult<\/span> searchLogs<\/span>(<\/span>LogSearchRequest<\/span> searchReq)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n SearchRequest<\/span> request =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"logs_current"<\/span>)<\/span>;<\/span> \/\/ \u4f7f\u7528\u522b\u540d<\/span><\/p>\n

SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6784\u5efa\u65f6\u95f4\u8303\u56f4\u67e5\u8be2（\u5b9e\u65f6\u6570\u636e）<\/span>
\n RangeQueryBuilder<\/span> timeRange =<\/span> QueryBuilders<\/span>.<\/span>rangeQuery<\/span>(<\/span>"@timestamp"<\/span>)<\/span>
\n .<\/span>gte<\/span>(<\/span>searchReq.<\/span>getStartTime<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>lte<\/span>(<\/span>searchReq.<\/span>getEndTime<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

BoolQueryBuilder<\/span> boolQuery =<\/span> QueryBuilders<\/span>.<\/span>boolQuery<\/span>(<\/span>)<\/span>
\n .<\/span>must<\/span>(<\/span>timeRange)<\/span>;<\/span><\/p>\n

\/\/ \u65e5\u5fd7\u7ea7\u522b\u8fc7\u6ee4<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getLevels<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>searchReq.<\/span>getLevels<\/span>(<\/span>)<\/span>.<\/span>isEmpty<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n TermsQueryBuilder<\/span> levelQuery =<\/span> QueryBuilders<\/span>
\n .<\/span>termsQuery<\/span>(<\/span>"level"<\/span>,<\/span> searchReq.<\/span>getLevels<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n boolQuery.<\/span>must<\/span>(<\/span>levelQuery)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u670d\u52a1\u540d\u79f0\u8fc7\u6ee4<\/span>
\n if<\/span> (<\/span>StringUtils<\/span>.<\/span>isNotBlank<\/span>(<\/span>searchReq.<\/span>getService<\/span>(<\/span>)<\/span>)<\/span>)<\/span> {<\/span>
\n boolQuery.<\/span>must<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"service"<\/span>,<\/span> searchReq.<\/span>getService<\/span>(<\/span>)<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u5173\u952e\u8bcd\u641c\u7d22<\/span>
\n if<\/span> (<\/span>StringUtils<\/span>.<\/span>isNotBlank<\/span>(<\/span>searchReq.<\/span>getKeyword<\/span>(<\/span>)<\/span>)<\/span>)<\/span> {<\/span>
\n boolQuery.<\/span>must<\/span>(<\/span>QueryBuilders<\/span>.<\/span>matchQuery<\/span>(<\/span>"message"<\/span>,<\/span> searchReq.<\/span>getKeyword<\/span>(<\/span>)<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

sourceBuilder.<\/span>query<\/span>(<\/span>boolQuery)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>searchReq.<\/span>getSize<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6309\u65f6\u95f4\u5012\u5e8f（\u6700\u65b0\u65e5\u5fd7\u5728\u524d）<\/span>
\n sourceBuilder.<\/span>sort<\/span>(<\/span>"@timestamp"<\/span>,<\/span> SortOrder<\/span>.<\/span>DESC)<\/span>;<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u805a\u5408\u5206\u6790（\u5b9e\u65f6\u7edf\u8ba1）<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>isEnableAggregation<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n \/\/ \u6309\u65e5\u5fd7\u7ea7\u522b\u805a\u5408<\/span>
\n TermsAggregationBuilder<\/span> levelAgg =<\/span> AggregationBuilders<\/span>
\n .<\/span>terms<\/span>(<\/span>"log_levels"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"level"<\/span>)<\/span>
\n .<\/span>size<\/span>(<\/span>10<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6309\u670d\u52a1\u805a\u5408<\/span>
\n TermsAggregationBuilder<\/span> serviceAgg =<\/span> AggregationBuilders<\/span>
\n .<\/span>terms<\/span>(<\/span>"services"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"service"<\/span>)<\/span>
\n .<\/span>size<\/span>(<\/span>20<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u65f6\u95f4\u76f4\u65b9\u56fe（\u6700\u8fd11\u5c0f\u65f6）<\/span>
\n DateHistogramAggregationBuilder<\/span> timeAgg =<\/span> AggregationBuilders<\/span>
\n .<\/span>dateHistogram<\/span>(<\/span>"logs_over_time"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"@timestamp"<\/span>)<\/span>
\n .<\/span>calendarInterval<\/span>(<\/span>DateHistogramInterval<\/span>.<\/span>MINUTE)<\/span>
\n .<\/span>minDocCount<\/span>(<\/span>0<\/span>)<\/span>;<\/span><\/p>\n

sourceBuilder.<\/span>aggregation<\/span>(<\/span>levelAgg)<\/span>;<\/span>
\n sourceBuilder.<\/span>aggregation<\/span>(<\/span>serviceAgg)<\/span>;<\/span>
\n sourceBuilder.<\/span>aggregation<\/span>(<\/span>timeAgg)<\/span>;<\/span>
\n }<\/span><\/p>\n

request.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

\/\/ \u6267\u884c\u641c\u7d22<\/span>
\n SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

return<\/span> parseLogSearchResult<\/span>(<\/span>response)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u5b9e\u65f6\u544a\u8b66\u7cfb\u7edf
\n *\/<\/span>
\n @Scheduled<\/span>(<\/span>fixedDelay =<\/span> 10000<\/span>)<\/span> \/\/ \u6bcf10\u79d2\u6267\u884c<\/span>
\n public<\/span> void<\/span> checkRealTimeAlerts<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n long<\/span> currentTime =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span>
\n long<\/span> startTime =<\/span> currentTime –<\/span> 60000<\/span>;<\/span> \/\/ \u6700\u8fd11\u5206\u949f<\/span><\/p>\n

SearchRequest<\/span> request =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"logs_current"<\/span>)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u67e5\u8be2\u6700\u8fd11\u5206\u949f\u7684ERROR\u65e5\u5fd7<\/span>
\n BoolQueryBuilder<\/span> boolQuery =<\/span> QueryBuilders<\/span>.<\/span>boolQuery<\/span>(<\/span>)<\/span>
\n .<\/span>must<\/span>(<\/span>QueryBuilders<\/span>.<\/span>rangeQuery<\/span>(<\/span>"@timestamp"<\/span>)<\/span>
\n .<\/span>gte<\/span>(<\/span>startTime)<\/span>
\n .<\/span>lte<\/span>(<\/span>currentTime)<\/span>)<\/span>
\n .<\/span>must<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"level"<\/span>,<\/span> "ERROR"<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6309\u670d\u52a1\u5206\u7ec4<\/span>
\n TermsAggregationBuilder<\/span> serviceAgg =<\/span> AggregationBuilders<\/span>
\n .<\/span>terms<\/span>(<\/span>"errors_by_service"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"service"<\/span>)<\/span>
\n .<\/span>size<\/span>(<\/span>50<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5b50\u805a\u5408：\u9519\u8bef\u6570\u91cf<\/span>
\n serviceAgg.<\/span>subAggregation<\/span>(<\/span>AggregationBuilders<\/span>.<\/span>count<\/span>(<\/span>"error_count"<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

sourceBuilder.<\/span>query<\/span>(<\/span>boolQuery)<\/span>;<\/span>
\n sourceBuilder.<\/span>aggregation<\/span>(<\/span>serviceAgg)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>0<\/span>)<\/span>;<\/span> \/\/ \u4e0d\u9700\u8981\u8fd4\u56de\u5177\u4f53\u6587\u6863<\/span><\/p>\n

request.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ \u89e3\u6790\u805a\u5408\u7ed3\u679c，\u68c0\u67e5\u662f\u5426\u89e6\u53d1\u544a\u8b66<\/span>
\n Terms<\/span> serviceTerms =<\/span> response.<\/span>getAggregations<\/span>(<\/span>)<\/span>.<\/span>get<\/span>(<\/span>"errors_by_service"<\/span>)<\/span>;<\/span><\/p>\n

for<\/span> (<\/span>Terms.<\/span>Bucket<\/span> bucket :<\/span> serviceTerms.<\/span>getBuckets<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n String<\/span> service =<\/span> bucket.<\/span>getKeyAsString<\/span>(<\/span>)<\/span>;<\/span>
\n long<\/span> errorCount =<\/span> (<\/span>(<\/span>ValueCount<\/span>)<\/span> bucket.<\/span>getAggregations<\/span>(<\/span>)<\/span>.<\/span>get<\/span>(<\/span>"error_count"<\/span>)<\/span>)<\/span>.<\/span>getValue<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u68c0\u67e5\u544a\u8b66\u89c4\u5219<\/span>
\n AlertRule<\/span> rule =<\/span> alertRuleService.<\/span>getRuleForService<\/span>(<\/span>service)<\/span>;<\/span>
\n if<\/span> (<\/span>rule !=<\/span> null<\/span> &&<\/span> errorCount >=<\/span> rule.<\/span>getThreshold<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n \/\/ \u89e6\u53d1\u5b9e\u65f6\u544a\u8b66<\/span>
\n triggerAlert<\/span>(<\/span>service,<\/span> errorCount,<\/span> rule)<\/span>;<\/span><\/p>\n

log.<\/span>warn<\/span>(<\/span>"\u670d\u52a1 {} \u5728\u6700\u8fd11\u5206\u949f\u5185\u4ea7\u751f {} \u4e2aERROR\u65e5\u5fd7，\u89e6\u53d1\u544a\u8b66"<\/span>,<\/span>
\n service,<\/span> errorCount)<\/span>;<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/**
\n * NRT\u6027\u80fd\u76d1\u63a7\u9762\u677f
\n *\/<\/span>
\n public<\/span> MonitoringDashboard<\/span> getNrtDashboard<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n MonitoringDashboard<\/span> dashboard =<\/span> new<\/span> MonitoringDashboard<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u83b7\u53d6\u7d22\u5f15\u7edf\u8ba1<\/span>
\n IndicesStatsRequest<\/span> statsRequest =<\/span> new<\/span> IndicesStatsRequest<\/span>(<\/span>)<\/span>
\n .<\/span>indices<\/span>(<\/span>"logs-*"<\/span>)<\/span>
\n .<\/span>clear<\/span>(<\/span>)<\/span>
\n .<\/span>refresh<\/span>(<\/span>true<\/span>)<\/span>;<\/span><\/p>\n

IndicesStatsResponse<\/span> stats =<\/span> esClient.<\/span>indices<\/span>(<\/span>)<\/span>
\n .<\/span>stats<\/span>(<\/span>statsRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ 2. \u8ba1\u7b97NRT\u6307\u6807<\/span>
\n RefreshStats<\/span> refreshStats =<\/span> stats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getRefresh<\/span>(<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setRefreshCount<\/span>(<\/span>refreshStats.<\/span>getTotal<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setRefreshTime<\/span>(<\/span>refreshStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setAvgRefreshTime<\/span>(<\/span>refreshStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span> \/<\/span>
\n Math<\/span>.<\/span>max<\/span>(<\/span>refreshStats.<\/span>getTotal<\/span>(<\/span>)<\/span>,<\/span> 1<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 3. \u83b7\u53d6Segment\u4fe1\u606f<\/span>
\n SegmentsStats<\/span> segmentsStats =<\/span> stats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getSegments<\/span>(<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setSegmentCount<\/span>(<\/span>segmentsStats.<\/span>getCount<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setMemoryUsed<\/span>(<\/span>segmentsStats.<\/span>getMemoryInBytes<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 4. \u67e5\u8be2\u5ef6\u8fdf\u7edf\u8ba1（\u6700\u8fd15\u5206\u949f）<\/span>
\n long<\/span> fiveMinutesAgo =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span> –<\/span> 300000<\/span>;<\/span><\/p>\n

SearchRequest<\/span> latencyRequest =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"logs_current"<\/span>)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> latencySource =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

latencySource.<\/span>query<\/span>(<\/span>QueryBuilders<\/span>.<\/span>rangeQuery<\/span>(<\/span>"@timestamp"<\/span>)<\/span>
\n .<\/span>gte<\/span>(<\/span>fiveMinutesAgo)<\/span>)<\/span>;<\/span>
\n latencySource.<\/span>aggregation<\/span>(<\/span>AggregationBuilders<\/span>
\n .<\/span>percentiles<\/span>(<\/span>"indexing_latency"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"indexing_latency"<\/span>)<\/span> \/\/ \u5047\u8bbe\u65e5\u5fd7\u5305\u542b\u7d22\u5f15\u5ef6\u8fdf\u5b57\u6bb5<\/span>
\n .<\/span>percentiles<\/span>(<\/span>50<\/span>,<\/span> 95<\/span>,<\/span> 99<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

latencyRequest.<\/span>source<\/span>(<\/span>latencySource)<\/span>;<\/span><\/p>\n

SearchResponse<\/span> latencyResponse =<\/span> esClient.<\/span>search<\/span>(<\/span>
\n latencyRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ \u89e3\u6790\u5ef6\u8fdf\u767e\u5206\u4f4d\u6570<\/span>
\n Percentiles<\/span> percentiles =<\/span> latencyResponse.<\/span>getAggregations<\/span>(<\/span>)<\/span>
\n .<\/span>get<\/span>(<\/span>"indexing_latency"<\/span>)<\/span>;<\/span><\/p>\n

dashboard.<\/span>setP50Latency<\/span>(<\/span>percentiles.<\/span>percentile<\/span>(<\/span>50<\/span>)<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setP95Latency<\/span>(<\/span>percentiles.<\/span>percentile<\/span>(<\/span>95<\/span>)<\/span>)<\/span>;<\/span>
\n dashboard.<\/span>setP99Latency<\/span>(<\/span>percentiles.<\/span>percentile<\/span>(<\/span>99<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

return<\/span> dashboard;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

3.3 \u573a\u666f\u4e09：\u65b0\u95fb\u8d44\u8baf\u5e73\u53f0<\/h4>\n

\/**
\n * \u65b0\u95fb\u8d44\u8baf\u5e73\u53f0\u7684NRT\u5b9e\u73b0
\n * \u9700\u6c42：\u65b0\u95fb\u53d1\u5e03\u540e\u79d2\u7ea7\u53ef\u641c，\u652f\u6301\u5b9e\u65f6\u70ed\u70b9\u6392\u884c
\n *\/<\/span>
\n@Service<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> NewsPlatformNRT<\/span> {<\/span><\/p>\n

@Autowired<\/span>
\n private<\/span> RestHighLevelClient<\/span> esClient;<\/span><\/p>\n

\/**
\n * \u65b0\u95fb\u7d22\u5f15\u914d\u7f6e（\u4f18\u5316\u5b9e\u65f6\u6027）
\n *\/<\/span>
\n public<\/span> void<\/span> createNewsIndex<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n CreateIndexRequest<\/span> request =<\/span> new<\/span> CreateIndexRequest<\/span>(<\/span>"news"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u9488\u5bf9\u65b0\u95fb\u53d1\u5e03\u7684NRT\u4f18\u5316\u914d\u7f6e<\/span>
\n request.<\/span>settings<\/span>(<\/span>Settings<\/span>.<\/span>builder<\/span>(<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.number_of_shards"<\/span>,<\/span> 2<\/span>)<\/span> \/\/ \u65b0\u95fb\u6570\u636e\u91cf\u4e0d\u5927，\u5206\u7247\u5c11\u4e9b<\/span>
\n .<\/span>put<\/span>(<\/span>"index.number_of_replicas"<\/span>,<\/span> 1<\/span>)<\/span>
\n \/\/ \u5173\u952eNRT\u914d\u7f6e<\/span>
\n .<\/span>put<\/span>(<\/span>"index.refresh_interval"<\/span>,<\/span> "500ms"<\/span>)<\/span> \/\/ \u66f4\u77ed\u7684\u5237\u65b0\u95f4\u9694<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.durability"<\/span>,<\/span> "request"<\/span>)<\/span> \/\/ \u786e\u4fdd\u6570\u636e\u5b89\u5168<\/span>
\n .<\/span>put<\/span>(<\/span>"index.translog.flush_threshold_size"<\/span>,<\/span> "128mb"<\/span>)<\/span>
\n \/\/ \u4f18\u5316\u65b0\u95fb\u641c\u7d22\u6027\u80fd<\/span>
\n .<\/span>put<\/span>(<\/span>"index.max_ngram_diff"<\/span>,<\/span> 10<\/span>)<\/span>
\n .<\/span>put<\/span>(<\/span>"index.highlight.max_analyzed_offset"<\/span>,<\/span> 1000000<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

\/\/ \u65b0\u95fb\u6620\u5c04\u5b9a\u4e49<\/span>
\n XContentBuilder<\/span> mapping =<\/span> JsonXContent<\/span>.<\/span>contentBuilder<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"properties"<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"news_id"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"title"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "text"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"analyzer"<\/span>,<\/span> "ik_max_word"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"search_analyzer"<\/span>,<\/span> "ik_smart"<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"fields"<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"keyword"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"ignore_above"<\/span>,<\/span> 256<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"content"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "text"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"analyzer"<\/span>,<\/span> "ik_max_word"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"search_analyzer"<\/span>,<\/span> "ik_smart"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"category"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"tags"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "keyword"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"publish_time"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "date"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"format"<\/span>,<\/span> "epoch_millis"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"update_time"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "date"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"format"<\/span>,<\/span> "epoch_millis"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n \/\/ \u5b9e\u65f6\u4e92\u52a8\u6570\u636e<\/span>
\n .<\/span>startObject<\/span>(<\/span>"view_count"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "long"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"like_count"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "long"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"comment_count"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "long"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>"share_count"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "long"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n \/\/ \u5b9e\u65f6\u70ed\u5ea6\u5206\u6570（\u52a8\u6001\u8ba1\u7b97）<\/span>
\n .<\/span>startObject<\/span>(<\/span>"hot_score"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "double"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n \/\/ \u65b0\u95fb\u72b6\u6001（0:\u8349\u7a3f, 1:\u5df2\u53d1\u5e03, 2:\u5df2\u5220\u9664）<\/span>
\n .<\/span>startObject<\/span>(<\/span>"status"<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"type"<\/span>,<\/span> "integer"<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

request.<\/span>mapping<\/span>(<\/span>mapping)<\/span>;<\/span><\/p>\n

esClient.<\/span>indices<\/span>(<\/span>)<\/span>.<\/span>create<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span>
\n log.<\/span>info<\/span>(<\/span>"\u65b0\u95fb\u7d22\u5f15\u521b\u5efa\u5b8c\u6210"<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u53d1\u5e03\u65b0\u95fb（\u786e\u4fddNRT\u53ef\u7528\u6027）
\n *\/<\/span>
\n @Transactional<\/span>
\n public<\/span> boolean<\/span> publishNews<\/span>(<\/span>NewsDTO<\/span> news)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n String<\/span> newsId =<\/span> news.<\/span>getNewsId<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u66f4\u65b0\u6570\u636e\u5e93\u72b6\u6001<\/span>
\n newsRepository.<\/span>updateStatus<\/span>(<\/span>newsId,<\/span> NewsStatus<\/span>.<\/span>PUBLISHED)<\/span>;<\/span><\/p>\n

\/\/ 2. \u540c\u6b65\u5230Elasticsearch（\u5f3a\u5236Refresh\u786e\u4fdd\u5b9e\u65f6）<\/span>
\n IndexRequest<\/span> request =<\/span> new<\/span> IndexRequest<\/span>(<\/span>"news"<\/span>)<\/span>
\n .<\/span>id<\/span>(<\/span>newsId)<\/span>
\n .<\/span>source<\/span>(<\/span>JsonXContent<\/span>.<\/span>contentBuilder<\/span>(<\/span>)<\/span>
\n .<\/span>startObject<\/span>(<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"news_id"<\/span>,<\/span> newsId)<\/span>
\n .<\/span>field<\/span>(<\/span>"title"<\/span>,<\/span> news.<\/span>getTitle<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"content"<\/span>,<\/span> news.<\/span>getContent<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"summary"<\/span>,<\/span> news.<\/span>getSummary<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"author"<\/span>,<\/span> news.<\/span>getAuthor<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"category"<\/span>,<\/span> news.<\/span>getCategory<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"tags"<\/span>,<\/span> news.<\/span>getTags<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"cover_image"<\/span>,<\/span> news.<\/span>getCoverImage<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"publish_time"<\/span>,<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"update_time"<\/span>,<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"view_count"<\/span>,<\/span> 0<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"like_count"<\/span>,<\/span> 0<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"comment_count"<\/span>,<\/span> 0<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"share_count"<\/span>,<\/span> 0<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"hot_score"<\/span>,<\/span> calculateInitialHotScore<\/span>(<\/span>news)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span> \/\/ \u5df2\u53d1\u5e03<\/span>
\n .<\/span>endObject<\/span>(<\/span>)<\/span>
\n )<\/span>
\n .<\/span>setRefreshPolicy<\/span>(<\/span>WriteRequest.<\/span>RefreshPolicy<\/span>.<\/span>IMMEDIATE)<\/span>;<\/span> \/\/ \u7acb\u5373\u5237\u65b0<\/span><\/p>\n

IndexResponse<\/span> response =<\/span> esClient.<\/span>index<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ 3. \u9a8c\u8bc1\u53d1\u5e03\u6210\u529f<\/span>
\n if<\/span> (<\/span>response.<\/span>getResult<\/span>(<\/span>)<\/span> ==<\/span> DocWriteResponse.<\/span>Result<\/span>.<\/span>CREATED)<\/span> {<\/span>
\n log.<\/span>info<\/span>(<\/span>"\u65b0\u95fb\u53d1\u5e03\u6210\u529f，news_id: {}"<\/span>,<\/span> newsId)<\/span>;<\/span><\/p>\n

\/\/ 4. \u89e6\u53d1\u5b9e\u65f6\u7d22\u5f15\u9884\u70ed<\/span>
\n preheatNewsIndex<\/span>(<\/span>newsId)<\/span>;<\/span><\/p>\n

return<\/span> true<\/span>;<\/span>
\n }<\/span><\/p>\n

return<\/span> false<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u65b0\u95fb\u641c\u7d22（\u652f\u6301\u5b9e\u65f6\u8fc7\u6ee4\u548c\u6392\u5e8f）
\n *\/<\/span>
\n public<\/span> NewsSearchResult<\/span> searchNews<\/span>(<\/span>NewsSearchRequest<\/span> searchReq)<\/span>
\n throws<\/span> IOException<\/span> {<\/span><\/p>\n

SearchRequest<\/span> request =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"news"<\/span>)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

BoolQueryBuilder<\/span> boolQuery =<\/span> QueryBuilders<\/span>.<\/span>boolQuery<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5fc5\u987b\u6761\u4ef6：\u53ea\u641c\u7d22\u5df2\u53d1\u5e03\u7684\u65b0\u95fb<\/span>
\n boolQuery.<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5173\u952e\u8bcd\u641c\u7d22（\u6807\u9898\u548c\u5185\u5bb9）<\/span>
\n if<\/span> (<\/span>StringUtils<\/span>.<\/span>isNotBlank<\/span>(<\/span>searchReq.<\/span>getKeyword<\/span>(<\/span>)<\/span>)<\/span>)<\/span> {<\/span>
\n MultiMatchQueryBuilder<\/span> multiMatch =<\/span> QueryBuilders<\/span>
\n .<\/span>multiMatchQuery<\/span>(<\/span>searchReq.<\/span>getKeyword<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"title"<\/span>,<\/span> 3.0f<\/span>)<\/span> \/\/ \u6807\u9898\u6743\u91cd\u66f4\u9ad8<\/span>
\n .<\/span>field<\/span>(<\/span>"content"<\/span>,<\/span> 1.0f<\/span>)<\/span>
\n .<\/span>field<\/span>(<\/span>"summary"<\/span>,<\/span> 2.0f<\/span>)<\/span>
\n .<\/span>type<\/span>(<\/span>MultiMatchQueryBuilder.<\/span>Type<\/span>.<\/span>BEST_FIELDS)<\/span>;<\/span><\/p>\n

boolQuery.<\/span>must<\/span>(<\/span>multiMatch)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u5206\u7c7b\u8fc7\u6ee4<\/span>
\n if<\/span> (<\/span>StringUtils<\/span>.<\/span>isNotBlank<\/span>(<\/span>searchReq.<\/span>getCategory<\/span>(<\/span>)<\/span>)<\/span>)<\/span> {<\/span>
\n boolQuery.<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"category"<\/span>,<\/span>
\n searchReq.<\/span>getCategory<\/span>(<\/span>)<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u6807\u7b7e\u8fc7\u6ee4<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getTags<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>searchReq.<\/span>getTags<\/span>(<\/span>)<\/span>.<\/span>isEmpty<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n boolQuery.<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>
\n .<\/span>termsQuery<\/span>(<\/span>"tags"<\/span>,<\/span> searchReq.<\/span>getTags<\/span>(<\/span>)<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u65f6\u95f4\u8303\u56f4\u8fc7\u6ee4<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getStartTime<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> ||<\/span> searchReq.<\/span>getEndTime<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
\n RangeQueryBuilder<\/span> timeRange =<\/span> QueryBuilders<\/span>
\n .<\/span>rangeQuery<\/span>(<\/span>"publish_time"<\/span>)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>searchReq.<\/span>getStartTime<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
\n timeRange.<\/span>gte<\/span>(<\/span>searchReq.<\/span>getStartTime<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>getEndTime<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
\n timeRange.<\/span>lte<\/span>(<\/span>searchReq.<\/span>getEndTime<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

boolQuery.<\/span>filter<\/span>(<\/span>timeRange)<\/span>;<\/span>
\n }<\/span><\/p>\n

sourceBuilder.<\/span>query<\/span>(<\/span>boolQuery)<\/span>;<\/span>
\n sourceBuilder.<\/span>from<\/span>(<\/span>searchReq.<\/span>getFrom<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>searchReq.<\/span>getSize<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5b9e\u65f6\u6392\u5e8f\u7b56\u7565<\/span>
\n configureRealtimeSorting<\/span>(<\/span>sourceBuilder,<\/span> searchReq)<\/span>;<\/span><\/p>\n

\/\/ \u9ad8\u4eae\u663e\u793a<\/span>
\n HighlightBuilder<\/span> highlightBuilder =<\/span> new<\/span> HighlightBuilder<\/span>(<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>field<\/span>(<\/span>"title"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>field<\/span>(<\/span>"content"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>preTags<\/span>(<\/span>"<em>"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>postTags<\/span>(<\/span>"<\/em>"<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>fragmentSize<\/span>(<\/span>200<\/span>)<\/span>;<\/span>
\n highlightBuilder.<\/span>numOfFragments<\/span>(<\/span>3<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>highlighter<\/span>(<\/span>highlightBuilder)<\/span>;<\/span><\/p>\n

\/\/ \u5b9e\u65f6\u805a\u5408\u5206\u6790<\/span>
\n if<\/span> (<\/span>searchReq.<\/span>isEnableAggregation<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n addRealtimeAggregations<\/span>(<\/span>sourceBuilder)<\/span>;<\/span>
\n }<\/span><\/p>\n

request.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

\/\/ \u6267\u884c\u641c\u7d22<\/span>
\n SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

return<\/span> parseNewsSearchResult<\/span>(<\/span>response)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u914d\u7f6e\u5b9e\u65f6\u6392\u5e8f
\n *\/<\/span>
\n private<\/span> void<\/span> configureRealtimeSorting<\/span>(<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder,<\/span>
\n NewsSearchRequest<\/span> searchReq)<\/span> {<\/span><\/p>\n

String<\/span> sortBy =<\/span> searchReq.<\/span>getSortBy<\/span>(<\/span>)<\/span>;<\/span>
\n SortOrder<\/span> sortOrder =<\/span> searchReq.<\/span>getSortOrder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>"hot"<\/span>.<\/span>equals<\/span>(<\/span>sortBy)<\/span>)<\/span> {<\/span>
\n \/\/ \u6309\u5b9e\u65f6\u70ed\u5ea6\u6392\u5e8f<\/span>
\n sourceBuilder.<\/span>sort<\/span>(<\/span>SortBuilders<\/span>
\n .<\/span>fieldSort<\/span>(<\/span>"hot_score"<\/span>)<\/span>
\n .<\/span>order<\/span>(<\/span>sortOrder !=<\/span> null<\/span> ?<\/span> sortOrder :<\/span> SortOrder<\/span>.<\/span>DESC)<\/span>)<\/span>;<\/span><\/p>\n

}<\/span> else<\/span> if<\/span> (<\/span>"time"<\/span>.<\/span>equals<\/span>(<\/span>sortBy)<\/span>)<\/span> {<\/span>
\n \/\/ \u6309\u53d1\u5e03\u65f6\u95f4\u6392\u5e8f<\/span>
\n sourceBuilder.<\/span>sort<\/span>(<\/span>SortBuilders<\/span>
\n .<\/span>fieldSort<\/span>(<\/span>"publish_time"<\/span>)<\/span>
\n .<\/span>order<\/span>(<\/span>sortOrder !=<\/span> null<\/span> ?<\/span> sortOrder :<\/span> SortOrder<\/span>.<\/span>DESC)<\/span>)<\/span>;<\/span><\/p>\n

}<\/span> else<\/span> if<\/span> (<\/span>"view"<\/span>.<\/span>equals<\/span>(<\/span>sortBy)<\/span>)<\/span> {<\/span>
\n \/\/ \u6309\u5b9e\u65f6\u6d4f\u89c8\u91cf\u6392\u5e8f<\/span>
\n sourceBuilder.<\/span>sort<\/span>(<\/span>SortBuilders<\/span>
\n .<\/span>fieldSort<\/span>(<\/span>"view_count"<\/span>)<\/span>
\n .<\/span>order<\/span>(<\/span>sortOrder !=<\/span> null<\/span> ?<\/span> sortOrder :<\/span> SortOrder<\/span>.<\/span>DESC)<\/span>)<\/span>;<\/span><\/p>\n

}<\/span> else<\/span> {<\/span>
\n \/\/ \u9ed8\u8ba4：\u76f8\u5173\u6027 + \u65f6\u95f4\u52a0\u6743<\/span>
\n ScriptSortBuilder<\/span> scriptSort =<\/span> SortBuilders<\/span>.<\/span>scriptSort<\/span>(<\/span>
\n new<\/span> Script<\/span>(<\/span>"_score * Math.log(2 + doc['view_count'].value)"<\/span>)<\/span>,<\/span>
\n ScriptSortBuilder.<\/span>ScriptSortType<\/span>.<\/span>NUMBER
\n )<\/span>.<\/span>order<\/span>(<\/span>SortOrder<\/span>.<\/span>DESC)<\/span>;<\/span><\/p>\n

sourceBuilder.<\/span>sort<\/span>(<\/span>scriptSort)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u5b9e\u65f6\u70ed\u70b9\u65b0\u95fb\u8ba1\u7b97
\n *\/<\/span>
\n @Scheduled<\/span>(<\/span>fixedDelay =<\/span> 30000<\/span>)<\/span> \/\/ \u6bcf30\u79d2\u8ba1\u7b97\u4e00\u6b21<\/span>
\n public<\/span> void<\/span> calculateHotNews<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n long<\/span> currentTime =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span>
\n long<\/span> timeWindow =<\/span> 24<\/span> *<\/span> 60<\/span> *<\/span> 60<\/span> *<\/span> 1000<\/span>;<\/span> \/\/ 24\u5c0f\u65f6<\/span><\/p>\n

\/\/ \u67e5\u8be2\u6700\u8fd124\u5c0f\u65f6\u53d1\u5e03\u7684\u65b0\u95fb<\/span>
\n SearchRequest<\/span> request =<\/span> new<\/span> SearchRequest<\/span>(<\/span>"news"<\/span>)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

BoolQueryBuilder<\/span> boolQuery =<\/span> QueryBuilders<\/span>.<\/span>boolQuery<\/span>(<\/span>)<\/span>
\n .<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span>)<\/span>
\n .<\/span>filter<\/span>(<\/span>QueryBuilders<\/span>.<\/span>rangeQuery<\/span>(<\/span>"publish_time"<\/span>)<\/span>
\n .<\/span>gte<\/span>(<\/span>currentTime –<\/span> timeWindow)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6309\u4e92\u52a8\u6570\u636e\u6392\u5e8f<\/span>
\n sourceBuilder.<\/span>query<\/span>(<\/span>boolQuery)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>1000<\/span>)<\/span>;<\/span> \/\/ \u6700\u591a1000\u6761<\/span><\/p>\n

\/\/ \u8ba1\u7b97\u70ed\u5ea6\u5206\u6570（\u57fa\u4e8e\u6d4f\u89c8\u3001\u70b9\u8d5e\u3001\u8bc4\u8bba\u3001\u5206\u4eab）<\/span>
\n ScriptFieldsBuilder<\/span> scriptFields =<\/span> new<\/span> ScriptFieldsBuilder<\/span>(<\/span>)<\/span>;<\/span>
\n scriptFields.<\/span>addScriptField<\/span>(<\/span>"calculated_hot_score"<\/span>,<\/span>
\n new<\/span> Script<\/span>(<\/span>"""
\n \/\/ \u70ed\u5ea6\u8ba1\u7b97\u516c\u5f0f
\n double timeFactor = 1.0 \/ (1.0 + (params.now – doc['publish_time'].value) \/ 3600000.0);
\n double viewScore = Math.log(1 + doc['view_count'].value) * 1.0;
\n double likeScore = doc['like_count'].value * 2.0;
\n double commentScore = doc['comment_count'].value * 3.0;
\n double shareScore = doc['share_count'].value * 5.0;<\/p>\n

return timeFactor * (viewScore + likeScore + commentScore + shareScore);
\n """<\/span>,<\/span>
\n Map<\/span>.<\/span>of<\/span>(<\/span>"now"<\/span>,<\/span> currentTime)<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

sourceBuilder.<\/span>scriptFields<\/span>(<\/span>scriptFields)<\/span>;<\/span><\/p>\n

request.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>request,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ \u6279\u91cf\u66f4\u65b0\u70ed\u5ea6\u5206\u6570<\/span>
\n BulkRequest<\/span> bulkRequest =<\/span> new<\/span> BulkRequest<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

for<\/span> (<\/span>SearchHit<\/span> hit :<\/span> response.<\/span>getHits<\/span>(<\/span>)<\/span>.<\/span>getHits<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n String<\/span> newsId =<\/span> hit.<\/span>getId<\/span>(<\/span>)<\/span>;<\/span>
\n double<\/span> hotScore =<\/span> (<\/span>double<\/span>)<\/span> hit.<\/span>getFields<\/span>(<\/span>)<\/span>
\n .<\/span>get<\/span>(<\/span>"calculated_hot_score"<\/span>)<\/span>.<\/span>getValues<\/span>(<\/span>)<\/span>.<\/span>get<\/span>(<\/span>0<\/span>)<\/span>;<\/span><\/p>\n

UpdateRequest<\/span> updateRequest =<\/span> new<\/span> UpdateRequest<\/span>(<\/span>"news"<\/span>,<\/span> newsId)<\/span>
\n .<\/span>doc<\/span>(<\/span>Map<\/span>.<\/span>of<\/span>(<\/span>"hot_score"<\/span>,<\/span> hotScore)<\/span>)<\/span>;<\/span><\/p>\n

bulkRequest.<\/span>add<\/span>(<\/span>updateRequest)<\/span>;<\/span>
\n }<\/span><\/p>\n

if<\/span> (<\/span>bulkRequest.<\/span>numberOfActions<\/span>(<\/span>)<\/span> ><\/span> 0<\/span>)<\/span> {<\/span>
\n esClient.<\/span>bulk<\/span>(<\/span>bulkRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span>
\n log.<\/span>info<\/span>(<\/span>"\u66f4\u65b0\u4e86 {} \u6761\u65b0\u95fb\u7684\u70ed\u5ea6\u5206\u6570"<\/span>,<\/span> bulkRequest.<\/span>numberOfActions<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u65b0\u95fb\u4e92\u52a8\u5b9e\u65f6\u66f4\u65b0（\u6d4f\u89c8\u3001\u70b9\u8d5e\u7b49）
\n *\/<\/span>
\n public<\/span> void<\/span> updateNewsInteraction<\/span>(<\/span>String<\/span> newsId,<\/span> String<\/span> interactionType)<\/span>
\n throws<\/span> IOException<\/span> {<\/span><\/p>\n

\/\/ \u4f7f\u7528Update By Query\u5b9e\u73b0\u539f\u5b50\u66f4\u65b0<\/span>
\n UpdateByQueryRequest<\/span> updateRequest =<\/span> new<\/span> UpdateByQueryRequest<\/span>(<\/span>"news"<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u53ea\u66f4\u65b0\u6307\u5b9a\u7684\u65b0\u95fb<\/span>
\n updateRequest.<\/span>setQuery<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"news_id"<\/span>,<\/span> newsId)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5b9a\u4e49\u66f4\u65b0\u811a\u672c<\/span>
\n Script<\/span> script =<\/span> new<\/span> Script<\/span>(<\/span>"""
\n \/\/ \u539f\u5b50\u589e\u52a0\u8ba1\u6570
\n if (ctx._source.status == 1) { \/\/ \u53ea\u66f4\u65b0\u5df2\u53d1\u5e03\u7684\u65b0\u95fb
\n if (params.type == 'view') {
\n ctx._source.view_count += 1;
\n } else if (params.type == 'like') {
\n ctx._source.like_count += 1;
\n } else if (params.type == 'comment') {
\n ctx._source.comment_count += 1;
\n } else if (params.type == 'share') {
\n ctx._source.share_count += 1;
\n }<\/p>\n

\/\/ \u5b9e\u65f6\u91cd\u65b0\u8ba1\u7b97\u70ed\u5ea6\u5206\u6570（\u7b80\u5316\u7248）
\n double timeFactor = 1.0 \/ (1.0 + (params.now – ctx._source.publish_time) \/ 3600000.0);
\n double viewScore = Math.log(1 + ctx._source.view_count) * 1.0;
\n double likeScore = ctx._source.like_count * 2.0;
\n double commentScore = ctx._source.comment_count * 3.0;
\n double shareScore = ctx._source.share_count * 5.0;<\/p>\n

ctx._source.hot_score = timeFactor * (viewScore + likeScore + commentScore + shareScore);
\n ctx._source.update_time = params.now;
\n }
\n """<\/span>,<\/span>
\n ScriptType<\/span>.<\/span>INLINE,<\/span>
\n "painless"<\/span>,<\/span>
\n Map<\/span>.<\/span>of<\/span>(<\/span>"type"<\/span>,<\/span> interactionType,<\/span> "now"<\/span>,<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

updateRequest.<\/span>setScript<\/span>(<\/span>script)<\/span>;<\/span>
\n updateRequest.<\/span>setRefresh<\/span>(<\/span>true<\/span>)<\/span>;<\/span> \/\/ \u7acb\u5373\u5237\u65b0<\/span><\/p>\n

\/\/ \u6267\u884c\u66f4\u65b0<\/span>
\n BulkByScrollResponse<\/span> response =<\/span> esClient.<\/span>updateByQuery<\/span>(<\/span>
\n updateRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

log.<\/span>debug<\/span>(<\/span>"\u65b0\u95fb\u4e92\u52a8\u66f4\u65b0\u5b8c\u6210，news_id: {}, type: {}, \u66f4\u65b0\u6587\u6863\u6570: {}"<\/span>,<\/span>
\n newsId,<\/span> interactionType,<\/span> response.<\/span>getUpdated<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u56db\u3001NRT \u6027\u80fd\u4f18\u5316\u7b56\u7565<\/h3>\n

4.1 \u7d22\u5f15\u914d\u7f6e\u4f18\u5316<\/h4>\n

# NRT\u4f18\u5316\u914d\u7f6e\u6a21\u677f<\/span>
\nPUT \/_template\/nrt_optimized_template
\n{<\/span>
\n "index_patterns"<\/span>:<\/span> [<\/span>"nrt-*"<\/span>]<\/span>,<\/span>
\n "settings"<\/span>:<\/span> {<\/span>
\n # \u5206\u7247\u914d\u7f6e<\/span>
\n "number_of_shards"<\/span>:<\/span> 3<\/span>,<\/span>
\n "number_of_replicas"<\/span>:<\/span> 1<\/span>,<\/span><\/p>\n

# NRT\u6838\u5fc3\u914d\u7f6e<\/span>
\n "refresh_interval"<\/span>:<\/span> "1s"<\/span>,<\/span>
\n "translog"<\/span>:<\/span> {<\/span>
\n "durability"<\/span>:<\/span> "async"<\/span>,<\/span>
\n "sync_interval"<\/span>:<\/span> "5s"<\/span>,<\/span>
\n "flush_threshold_size"<\/span>:<\/span> "512mb"<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u7d22\u5f15\u7f13\u51b2\u533a<\/span>
\n "indexing"<\/span>:<\/span> {<\/span>
\n "buffer"<\/span>:<\/span> {<\/span>
\n "size"<\/span>:<\/span> "10%"<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# Segment\u5408\u5e76\u4f18\u5316<\/span>
\n "merge"<\/span>:<\/span> {<\/span>
\n "scheduler"<\/span>:<\/span> {<\/span>
\n "max_thread_count"<\/span>:<\/span> 2<\/span>,<\/span>
\n "max_merge_count"<\/span>:<\/span> 3<\/span>
\n }<\/span>,<\/span>
\n "policy"<\/span>:<\/span> {<\/span>
\n "max_merged_segment"<\/span>:<\/span> "5gb"<\/span>,<\/span>
\n "segments_per_tier"<\/span>:<\/span> 10<\/span>,<\/span>
\n "max_merge_at_once"<\/span>:<\/span> 10<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u67e5\u8be2\u7f13\u5b58<\/span>
\n "queries"<\/span>:<\/span> {<\/span>
\n "cache"<\/span>:<\/span> {<\/span>
\n "enabled"<\/span>:<\/span> true<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u5b57\u6bb5\u6570\u636e\u7f13\u5b58<\/span>
\n "fielddata"<\/span>:<\/span> {<\/span>
\n "cache"<\/span>:<\/span> {<\/span>
\n "size"<\/span>:<\/span> "20%"<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

4.2 \u5199\u5165\u4f18\u5316\u7b56\u7565<\/h4>\n

\/**
\n * NRT\u5199\u5165\u4f18\u5316\u5b9e\u8df5
\n *\/<\/span>
\n@Component<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> NRTWriteOptimization<\/span> {<\/span><\/p>\n

\/**
\n * \u6279\u91cf\u5199\u5165\u4f18\u5316
\n *\/<\/span>
\n public<\/span> void<\/span> optimizedBulkWrite<\/span>(<\/span>List<\/span><<\/span>Document<\/span>><\/span><\/span> documents)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n BulkRequest<\/span> bulkRequest =<\/span> new<\/span> BulkRequest<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u5206\u6279\u5904\u7406（\u6bcf\u62791000\u6761）<\/span>
\n int<\/span> batchSize =<\/span> 1000<\/span>;<\/span>
\n for<\/span> (<\/span>int<\/span> i =<\/span> 0<\/span>;<\/span> i <<\/span> documents.<\/span>size<\/span>(<\/span>)<\/span>;<\/span> i +=<\/span> batchSize)<\/span> {<\/span>
\n int<\/span> end =<\/span> Math<\/span>.<\/span>min<\/span>(<\/span>i +<\/span> batchSize,<\/span> documents.<\/span>size<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n List<\/span><<\/span>Document<\/span>><\/span><\/span> batch =<\/span> documents.<\/span>subList<\/span>(<\/span>i,<\/span> end)<\/span>;<\/span><\/p>\n

\/\/ 2. \u6dfb\u52a0\u5230\u6279\u91cf\u8bf7\u6c42<\/span>
\n addToBulkRequest<\/span>(<\/span>bulkRequest,<\/span> batch)<\/span>;<\/span><\/p>\n

\/\/ 3. \u6267\u884c\u6279\u91cf\u5199\u5165<\/span>
\n if<\/span> (<\/span>bulkRequest.<\/span>numberOfActions<\/span>(<\/span>)<\/span> >=<\/span> batchSize)<\/span> {<\/span>
\n executeBulkWithOptimization<\/span>(<\/span>bulkRequest)<\/span>;<\/span>
\n bulkRequest =<\/span> new<\/span> BulkRequest<\/span>(<\/span>)<\/span>;<\/span> \/\/ \u91cd\u7f6e<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/\/ \u5904\u7406\u5269\u4f59\u6587\u6863<\/span>
\n if<\/span> (<\/span>bulkRequest.<\/span>numberOfActions<\/span>(<\/span>)<\/span> ><\/span> 0<\/span>)<\/span> {<\/span>
\n executeBulkWithOptimization<\/span>(<\/span>bulkRequest)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

private<\/span> void<\/span> executeBulkWithOptimization<\/span>(<\/span>BulkRequest<\/span> bulkRequest)<\/span>
\n throws<\/span> IOException<\/span> {<\/span><\/p>\n

\/\/ \u4f18\u5316\u914d\u7f6e<\/span>
\n bulkRequest.<\/span>timeout<\/span>(<\/span>TimeValue<\/span>.<\/span>timeValueMinutes<\/span>(<\/span>2<\/span>)<\/span>)<\/span>;<\/span>
\n bulkRequest.<\/span>setRefreshPolicy<\/span>(<\/span>WriteRequest.<\/span>RefreshPolicy<\/span>.<\/span>NONE)<\/span>;<\/span><\/p>\n

\/\/ \u4f7f\u7528\u7ba1\u9053\u63d0\u9ad8\u541e\u5410<\/span>
\n BulkResponse<\/span> response =<\/span> esClient.<\/span>bulk<\/span>(<\/span>bulkRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>response.<\/span>hasFailures<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n handleBulkFailures<\/span>(<\/span>response)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u5b9a\u671f\u624b\u52a8\u5237\u65b0（\u4f18\u5316NRT\u5ef6\u8fdf）<\/span>
\n scheduleManualRefresh<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/**
\n * \u7d22\u5f15\u9884\u70ed\u7b56\u7565
\n *\/<\/span>
\n public<\/span> void<\/span> warmUpIndex<\/span>(<\/span>String<\/span> indexName)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n \/\/ 1. \u6267\u884c\u4e00\u4e9b\u5178\u578b\u67e5\u8be2，\u9884\u70ed\u7f13\u5b58<\/span>
\n SearchRequest<\/span> warmupRequest =<\/span> new<\/span> SearchRequest<\/span>(<\/span>indexName)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6267\u884c\u4e0d\u540c\u7c7b\u578b\u7684\u67e5\u8be2\u9884\u70ed<\/span>
\n sourceBuilder.<\/span>query<\/span>(<\/span>QueryBuilders<\/span>.<\/span>matchAllQuery<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>0<\/span>)<\/span>;<\/span> \/\/ \u4e0d\u8fd4\u56de\u6587\u6863<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u805a\u5408\u9884\u70ed<\/span>
\n sourceBuilder.<\/span>aggregation<\/span>(<\/span>AggregationBuilders<\/span>
\n .<\/span>terms<\/span>(<\/span>"warmup_terms"<\/span>)<\/span>.<\/span>field<\/span>(<\/span>"category.keyword"<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

warmupRequest.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

\/\/ 2. \u6267\u884c\u9884\u70ed\u67e5\u8be2<\/span>
\n esClient.<\/span>search<\/span>(<\/span>warmupRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ 3. \u9884\u70ed\u5b57\u6bb5\u6570\u636e\u7f13\u5b58<\/span>
\n FieldStatsRequest<\/span> fieldStatsRequest =<\/span> new<\/span> FieldStatsRequest<\/span>(<\/span>)<\/span>
\n .<\/span>indices<\/span>(<\/span>indexName)<\/span>
\n .<\/span>fields<\/span>(<\/span>"hot_score"<\/span>,<\/span> "publish_time"<\/span>)<\/span>;<\/span><\/p>\n

esClient.<\/span>fieldStats<\/span>(<\/span>fieldStatsRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

log.<\/span>info<\/span>(<\/span>"\u7d22\u5f15\u9884\u70ed\u5b8c\u6210: {}"<\/span>,<\/span> indexName)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

4.3 \u76d1\u63a7\u4e0e\u8c03\u4f18<\/h4>\n

\/**
\n * NRT\u6027\u80fd\u76d1\u63a7\u4e0e\u8c03\u4f18
\n *\/<\/span>
\n@Component<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> NRTPerformanceMonitor<\/span> {<\/span><\/p>\n

@Autowired<\/span>
\n private<\/span> RestHighLevelClient<\/span> esClient;<\/span><\/p>\n

@Scheduled<\/span>(<\/span>fixedDelay =<\/span> 30000<\/span>)<\/span> \/\/ \u6bcf30\u79d2\u76d1\u63a7\u4e00\u6b21<\/span>
\n public<\/span> void<\/span> monitorNrtPerformance<\/span>(<\/span>)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n \/\/ 1. \u83b7\u53d6\u96c6\u7fa4\u5065\u5eb7\u72b6\u6001<\/span>
\n ClusterHealthRequest<\/span> healthRequest =<\/span> new<\/span> ClusterHealthRequest<\/span>(<\/span>)<\/span>
\n .<\/span>timeout<\/span>(<\/span>TimeValue<\/span>.<\/span>timeValueSeconds<\/span>(<\/span>5<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

ClusterHealthResponse<\/span> healthResponse =<\/span> esClient.<\/span>cluster<\/span>(<\/span>)<\/span>
\n .<\/span>health<\/span>(<\/span>healthRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ 2. \u83b7\u53d6\u7d22\u5f15\u7edf\u8ba1<\/span>
\n IndicesStatsRequest<\/span> statsRequest =<\/span> new<\/span> IndicesStatsRequest<\/span>(<\/span>)<\/span>
\n .<\/span>all<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

IndicesStatsResponse<\/span> statsResponse =<\/span> esClient.<\/span>indices<\/span>(<\/span>)<\/span>
\n .<\/span>stats<\/span>(<\/span>statsRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

\/\/ 3. \u5206\u6790NRT\u5173\u952e\u6307\u6807<\/span>
\n NrtMetrics<\/span> metrics =<\/span> analyzeNrtMetrics<\/span>(<\/span>statsResponse)<\/span>;<\/span><\/p>\n

\/\/ 4. \u81ea\u52a8\u8c03\u4f18\u5efa\u8bae<\/span>
\n List<\/span><<\/span>TuningRecommendation<\/span>><\/span><\/span> recommendations =<\/span>
\n generateTuningRecommendations<\/span>(<\/span>metrics)<\/span>;<\/span><\/p>\n

\/\/ 5. \u53d1\u9001\u544a\u8b66（\u5982\u679c\u6307\u6807\u5f02\u5e38）<\/span>
\n checkAndSendAlerts<\/span>(<\/span>metrics)<\/span>;<\/span><\/p>\n

\/\/ 6. \u8bb0\u5f55\u76d1\u63a7\u6570\u636e<\/span>
\n saveMonitoringData<\/span>(<\/span>metrics)<\/span>;<\/span>
\n }<\/span><\/p>\n

private<\/span> NrtMetrics<\/span> analyzeNrtMetrics<\/span>(<\/span>IndicesStatsResponse<\/span> stats)<\/span> {<\/span>
\n NrtMetrics<\/span> metrics =<\/span> new<\/span> NrtMetrics<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5206\u6790Refresh\u6027\u80fd<\/span>
\n RefreshStats<\/span> refreshStats =<\/span> stats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getRefresh<\/span>(<\/span>)<\/span>;<\/span>
\n metrics.<\/span>setAvgRefreshLatency<\/span>(<\/span>
\n refreshStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span> \/<\/span>
\n Math<\/span>.<\/span>max<\/span>(<\/span>refreshStats.<\/span>getTotal<\/span>(<\/span>)<\/span>,<\/span> 1<\/span>)<\/span>
\n )<\/span>;<\/span>
\n metrics.<\/span>setRefreshRate<\/span>(<\/span>
\n refreshStats.<\/span>getTotal<\/span>(<\/span>)<\/span> \/<\/span>
\n (<\/span>refreshStats.<\/span>getTotalTimeInMillis<\/span>(<\/span>)<\/span> \/<\/span> 1000.0<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

\/\/ \u5206\u6790Segment\u6027\u80fd<\/span>
\n SegmentsStats<\/span> segmentsStats =<\/span> stats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getSegments<\/span>(<\/span>)<\/span>;<\/span>
\n metrics.<\/span>setSegmentCount<\/span>(<\/span>segmentsStats.<\/span>getCount<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n metrics.<\/span>setSegmentMemory<\/span>(<\/span>segmentsStats.<\/span>getMemoryInBytes<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5206\u6790\u7d22\u5f15\u5ef6\u8fdf<\/span>
\n IndexingStats<\/span> indexingStats =<\/span> stats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getIndexing<\/span>(<\/span>)<\/span>;<\/span>
\n metrics.<\/span>setIndexingLatency<\/span>(<\/span>
\n indexingStats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getIndexTimeInMillis<\/span>(<\/span>)<\/span> \/<\/span>
\n Math<\/span>.<\/span>max<\/span>(<\/span>indexingStats.<\/span>getTotal<\/span>(<\/span>)<\/span>.<\/span>getIndexCount<\/span>(<\/span>)<\/span>,<\/span> 1<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

return<\/span> metrics;<\/span>
\n }<\/span><\/p>\n

private<\/span> List<\/span><<\/span>TuningRecommendation<\/span>><\/span><\/span> generateTuningRecommendations<\/span>(<\/span>
\n NrtMetrics<\/span> metrics)<\/span> {<\/span><\/p>\n

List<\/span><<\/span>TuningRecommendation<\/span>><\/span><\/span> recommendations =<\/span> new<\/span> ArrayList<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. Refresh\u95f4\u9694\u8c03\u4f18<\/span>
\n if<\/span> (<\/span>metrics.<\/span>getAvgRefreshLatency<\/span>(<\/span>)<\/span> ><\/span> 500<\/span>)<\/span> {<\/span>
\n recommendations.<\/span>add<\/span>(<\/span>new<\/span> TuningRecommendation<\/span>(<\/span>
\n "refresh_interval"<\/span>,<\/span>
\n "\u589e\u5927refresh_interval\u52302s"<\/span>,<\/span>
\n "\u5f53\u524d\u5e73\u5747\u5237\u65b0\u5ef6\u8fdf\u8fc7\u9ad8: "<\/span> +<\/span> metrics.<\/span>getAvgRefreshLatency<\/span>(<\/span>)<\/span> +<\/span> "ms"<\/span>,<\/span>
\n "PUT \/_settings {\\\\"index.refresh_interval\\\\": \\\\"2s\\\\"}"<\/span>
\n )<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ 2. Segment\u5408\u5e76\u5efa\u8bae<\/span>
\n if<\/span> (<\/span>metrics.<\/span>getSegmentCount<\/span>(<\/span>)<\/span> ><\/span> 1000<\/span>)<\/span> {<\/span>
\n recommendations.<\/span>add<\/span>(<\/span>new<\/span> TuningRecommendation<\/span>(<\/span>
\n "segment_merge"<\/span>,<\/span>
\n "\u4f18\u5316Segment\u5408\u5e76\u7b56\u7565"<\/span>,<\/span>
\n "Segment\u6570\u91cf\u8fc7\u591a: "<\/span> +<\/span> metrics.<\/span>getSegmentCount<\/span>(<\/span>)<\/span>,<\/span>
\n "\u8c03\u6574merge.policy.segments_per_tier\u548cmax_merge_at_once"<\/span>
\n )<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ 3. \u5185\u5b58\u4f18\u5316\u5efa\u8bae<\/span>
\n long<\/span> segmentMemoryGB =<\/span> metrics.<\/span>getSegmentMemory<\/span>(<\/span>)<\/span> \/<\/span> (<\/span>1024<\/span> *<\/span> 1024<\/span> *<\/span> 1024<\/span>)<\/span>;<\/span>
\n if<\/span> (<\/span>segmentMemoryGB ><\/span> 10<\/span>)<\/span> {<\/span>
\n recommendations.<\/span>add<\/span>(<\/span>new<\/span> TuningRecommendation<\/span>(<\/span>
\n "memory_usage"<\/span>,<\/span>
\n "\u589e\u52a0\u5806\u5185\u5b58\u6216\u4f18\u5316\u5b57\u6bb5\u7c7b\u578b"<\/span>,<\/span>
\n "Segment\u5185\u5b58\u5360\u7528\u8fc7\u9ad8: "<\/span> +<\/span> segmentMemoryGB +<\/span> "GB"<\/span>,<\/span>
\n "\u8003\u8651\u4f7f\u7528keyword\u4ee3\u66fftext，\u6216\u589e\u52a0JVM\u5806\u5185\u5b58"<\/span>
\n )<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

return<\/span> recommendations;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u4e94\u3001NRT \u5e38\u89c1\u95ee\u9898\u4e0e\u89e3\u51b3\u65b9\u6848<\/h3>\n

5.1 \u95ee\u9898\u8bca\u65ad\u6e05\u5355<\/h4>\n\n\u95ee\u9898\u73b0\u8c61\u53ef\u80fd\u539f\u56e0\u89e3\u51b3\u65b9\u6848<\/tr>\n\n\n\n\n\n\n
\u6570\u636e\u5199\u5165\u540e\u641c\u7d22\u4e0d\u5230<\/td>\nRefresh\u95f4\u9694\u592a\u957f<\/td>\n\u7f29\u77edrefresh_interval\u6216\u624b\u52a8refresh<\/td>\n<\/tr>\n
\u641c\u7d22\u5ef6\u8fdf\u6ce2\u52a8\u5927<\/td>\nSegment\u6570\u91cf\u8fc7\u591a<\/td>\n\u4f18\u5316\u5408\u5e76\u7b56\u7565，\u51cf\u5c11Segment\u6570\u91cf<\/td>\n<\/tr>\n
\u5199\u5165\u6027\u80fd\u4e0b\u964d<\/td>\nTranslog\u540c\u6b65\u9891\u7e41<\/td>\n\u8c03\u6574translog.durability\u4e3aasync<\/td>\n<\/tr>\n
\u5185\u5b58\u4f7f\u7528\u8fc7\u9ad8<\/td>\nIndexing Buffer\u592a\u5927<\/td>\n\u8c03\u6574indices.memory.index_buffer_size<\/td>\n<\/tr>\n
CPU\u4f7f\u7528\u7387\u9ad8<\/td>\n\u9891\u7e41Refresh\u548cMerge<\/td>\n\u4f18\u5316Refresh\u548cMerge\u7b56\u7565<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

5.2 NRT \u5ef6\u8fdf\u5206\u6790\u5de5\u5177<\/h4>\n

\/**
\n * NRT\u5ef6\u8fdf\u8bca\u65ad\u5de5\u5177
\n *\/<\/span>
\n@Component<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> NrtLatencyAnalyzer<\/span> {<\/span><\/p>\n

\/**
\n * \u8bca\u65adNRT\u5ef6\u8fdf\u95ee\u9898
\n *\/<\/span>
\n public<\/span> NrtDiagnosis<\/span> diagnoseLatency<\/span>(<\/span>String<\/span> indexName)<\/span> throws<\/span> IOException<\/span> {<\/span>
\n NrtDiagnosis<\/span> diagnosis =<\/span> new<\/span> NrtDiagnosis<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u68c0\u67e5\u7d22\u5f15\u914d\u7f6e<\/span>
\n diagnosis.<\/span>setIndexSettings<\/span>(<\/span>getIndexSettings<\/span>(<\/span>indexName)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 2. \u5206\u6790\u5f53\u524d\u72b6\u6001<\/span>
\n diagnosis.<\/span>setCurrentState<\/span>(<\/span>analyzeCurrentState<\/span>(<\/span>indexName)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 3. \u6536\u96c6\u6027\u80fd\u6307\u6807<\/span>
\n diagnosis.<\/span>setPerformanceMetrics<\/span>(<\/span>collectPerformanceMetrics<\/span>(<\/span>indexName)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 4. \u751f\u6210\u8bca\u65ad\u62a5\u544a<\/span>
\n diagnosis.<\/span>setRecommendations<\/span>(<\/span>generateDiagnosticReport<\/span>(<\/span>diagnosis)<\/span>)<\/span>;<\/span><\/p>\n

return<\/span> diagnosis;<\/span>
\n }<\/span><\/p>\n

\/**
\n * NRT\u6027\u80fd\u6d4b\u8bd5\u5de5\u5177
\n *\/<\/span>
\n public<\/span> NrtBenchmarkResult<\/span> runBenchmark<\/span>(<\/span>String<\/span> indexName,<\/span> int<\/span> documentCount)<\/span>
\n throws<\/span> IOException<\/span>,<\/span> InterruptedException<\/span> {<\/span><\/p>\n

NrtBenchmarkResult<\/span> result =<\/span> new<\/span> NrtBenchmarkResult<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 1. \u51c6\u5907\u6d4b\u8bd5\u6570\u636e<\/span>
\n List<\/span><<\/span>Document<\/span>><\/span><\/span> testDocuments =<\/span> generateTestDocuments<\/span>(<\/span>documentCount)<\/span>;<\/span><\/p>\n

\/\/ 2. \u6267\u884c\u5199\u5165\u6d4b\u8bd5<\/span>
\n long<\/span> startWrite =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span>
\n bulkIndexDocuments<\/span>(<\/span>indexName,<\/span> testDocuments)<\/span>;<\/span>
\n long<\/span> endWrite =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

result.<\/span>setWriteLatency<\/span>(<\/span>endWrite –<\/span> startWrite)<\/span>;<\/span>
\n result.<\/span>setWriteThroughput<\/span>(<\/span>documentCount \/<\/span> (<\/span>(<\/span>endWrite –<\/span> startWrite)<\/span> \/<\/span> 1000.0<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 3. \u6d4b\u8bd5NRT\u5ef6\u8fdf（\u4ece\u5199\u5165\u5230\u53ef\u641c\u7d22）<\/span>
\n List<\/span><<\/span>Long<\/span>><\/span><\/span> nrtLatencies =<\/span> new<\/span> ArrayList<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

for<\/span> (<\/span>Document<\/span> doc :<\/span> testDocuments.<\/span>subList<\/span>(<\/span>0<\/span>,<\/span> Math<\/span>.<\/span>min<\/span>(<\/span>100<\/span>,<\/span> documentCount)<\/span>)<\/span>)<\/span> {<\/span>
\n long<\/span> writeTime =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5199\u5165\u5355\u4e2a\u6587\u6863<\/span>
\n indexDocument<\/span>(<\/span>indexName,<\/span> doc)<\/span>;<\/span><\/p>\n

\/\/ \u6d4b\u8bd5\u641c\u7d22\u5ef6\u8fdf<\/span>
\n long<\/span> searchLatency =<\/span> measureSearchLatency<\/span>(<\/span>indexName,<\/span> doc.<\/span>getId<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n nrtLatencies.<\/span>add<\/span>(<\/span>searchLatency)<\/span>;<\/span><\/p>\n

log.<\/span>debug<\/span>(<\/span>"\u6587\u6863 {} \u7684NRT\u5ef6\u8fdf: {}ms"<\/span>,<\/span> doc.<\/span>getId<\/span>(<\/span>)<\/span>,<\/span> searchLatency)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u8ba1\u7b97\u5ef6\u8fdf\u7edf\u8ba1<\/span>
\n result.<\/span>setAvgNrtLatency<\/span>(<\/span>calculateAverage<\/span>(<\/span>nrtLatencies)<\/span>)<\/span>;<\/span>
\n result.<\/span>setP95NrtLatency<\/span>(<\/span>calculatePercentile<\/span>(<\/span>nrtLatencies,<\/span> 95<\/span>)<\/span>)<\/span>;<\/span>
\n result.<\/span>setP99NrtLatency<\/span>(<\/span>calculatePercentile<\/span>(<\/span>nrtLatencies,<\/span> 99<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ 4. \u6e05\u7406\u6d4b\u8bd5\u6570\u636e<\/span>
\n cleanupTestData<\/span>(<\/span>indexName,<\/span> testDocuments)<\/span>;<\/span><\/p>\n

return<\/span> result;<\/span>
\n }<\/span><\/p>\n

private<\/span> long<\/span> measureSearchLatency<\/span>(<\/span>String<\/span> indexName,<\/span> String<\/span> docId)<\/span>
\n throws<\/span> IOException<\/span>,<\/span> InterruptedException<\/span> {<\/span><\/p>\n

long<\/span> startTime =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span>;<\/span>
\n int<\/span> maxWaitTime =<\/span> 10000<\/span>;<\/span> \/\/ \u6700\u591a\u7b49\u5f8510\u79d2<\/span>
\n int<\/span> checkInterval =<\/span> 100<\/span>;<\/span> \/\/ \u6bcf100ms\u68c0\u67e5\u4e00\u6b21<\/span><\/p>\n

for<\/span> (<\/span>int<\/span> i =<\/span> 0<\/span>;<\/span> i <<\/span> maxWaitTime \/<\/span> checkInterval;<\/span> i++<\/span>)<\/span> {<\/span>
\n \/\/ \u5c1d\u8bd5\u641c\u7d22\u6587\u6863<\/span>
\n SearchRequest<\/span> searchRequest =<\/span> new<\/span> SearchRequest<\/span>(<\/span>indexName)<\/span>;<\/span>
\n SearchSourceBuilder<\/span> sourceBuilder =<\/span> new<\/span> SearchSourceBuilder<\/span>(<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>query<\/span>(<\/span>QueryBuilders<\/span>.<\/span>termQuery<\/span>(<\/span>"_id"<\/span>,<\/span> docId)<\/span>)<\/span>;<\/span>
\n sourceBuilder.<\/span>size<\/span>(<\/span>1<\/span>)<\/span>;<\/span><\/p>\n

searchRequest.<\/span>source<\/span>(<\/span>sourceBuilder)<\/span>;<\/span><\/p>\n

SearchResponse<\/span> response =<\/span> esClient.<\/span>search<\/span>(<\/span>
\n searchRequest,<\/span> RequestOptions<\/span>.<\/span>DEFAULT)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>response.<\/span>getHits<\/span>(<\/span>)<\/span>.<\/span>getTotalHits<\/span>(<\/span>)<\/span>.<\/span>value ><\/span> 0<\/span>)<\/span> {<\/span>
\n long<\/span> latency =<\/span> System<\/span>.<\/span>currentTimeMillis<\/span>(<\/span>)<\/span> –<\/span> startTime;<\/span>
\n return<\/span> latency;<\/span>
\n }<\/span><\/p>\n

Thread<\/span>.<\/span>sleep<\/span>(<\/span>checkInterval)<\/span>;<\/span>
\n }<\/span><\/p>\n

return<\/span> maxWaitTime;<\/span> \/\/ \u8d85\u65f6<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u516d\u3001\u603b\u7ed3\u4e0e\u6700\u4f73\u5b9e\u8df5<\/h3>\n

6.1 NRT \u914d\u7f6e\u6700\u4f73\u5b9e\u8df5<\/h4>\n

# \u751f\u4ea7\u73af\u5883NRT\u6700\u4f73\u914d\u7f6e\u6a21\u677f<\/span>
\nPUT \/_template\/production_nrt_template
\n{<\/span>
\n "index_patterns"<\/span>:<\/span> [<\/span>"prod-*"<\/span>]<\/span>,<\/span>
\n "order"<\/span>:<\/span> 1<\/span>,<\/span>
\n "settings"<\/span>:<\/span> {<\/span>
\n # \u57fa\u7840\u914d\u7f6e<\/span>
\n "number_of_shards"<\/span>:<\/span> 3<\/span>,<\/span>
\n "number_of_replicas"<\/span>:<\/span> 2<\/span>,<\/span><\/p>\n

# NRT\u6838\u5fc3\u914d\u7f6e（\u5e73\u8861\u578b）<\/span>
\n "refresh_interval"<\/span>:<\/span> "1s"<\/span>,<\/span>
\n "translog"<\/span>:<\/span> {<\/span>
\n "durability"<\/span>:<\/span> "request"<\/span>,<\/span>
\n "sync_interval"<\/span>:<\/span> "5s"<\/span>,<\/span>
\n "flush_threshold_size"<\/span>:<\/span> "512mb"<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u6027\u80fd\u4f18\u5316<\/span>
\n "indexing"<\/span>:<\/span> {<\/span>
\n "slowlog"<\/span>:<\/span> {<\/span>
\n "threshold"<\/span>:<\/span> {<\/span>
\n "index"<\/span>:<\/span> {<\/span>
\n "warn"<\/span>:<\/span> "10s"<\/span>,<\/span>
\n "info"<\/span>:<\/span> "5s"<\/span>,<\/span>
\n "debug"<\/span>:<\/span> "2s"<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u67e5\u8be2\u4f18\u5316<\/span>
\n "queries"<\/span>:<\/span> {<\/span>
\n "cache"<\/span>:<\/span> {<\/span>
\n "enabled"<\/span>:<\/span> true<\/span>,<\/span>
\n "size"<\/span>:<\/span> "10%"<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u5b57\u6bb5\u6570\u636e\u9650\u5236<\/span>
\n "fielddata"<\/span>:<\/span> {<\/span>
\n "cache"<\/span>:<\/span> {<\/span>
\n "size"<\/span>:<\/span> "20%"<\/span>
\n }<\/span>
\n }<\/span>,<\/span><\/p>\n

# \u7d22\u5f15\u751f\u547d\u5468\u671f\u7ba1\u7406（ILM）<\/span>
\n "lifecycle"<\/span>:<\/span> {<\/span>
\n "name"<\/span>:<\/span> "nrt_optimized_policy"<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

6.2 \u4e0d\u540c\u573a\u666f\u7684NRT\u7b56\u7565<\/h4>\n\n\u5e94\u7528\u573a\u666f\u63a8\u8350refresh_intervalTranslog\u8010\u4e45\u6027\u5206\u7247\u6570\u91cf\u9002\u7528\u573a\u666f\u8bf4\u660e<\/tr>\n\n\n\n\n\n\n
\u65e5\u5fd7\u76d1\u63a7<\/td>\n1s<\/td>\nasync<\/td>\n5-10<\/td>\n\u9ad8\u5199\u5165\u91cf，\u53ef\u63a5\u53d7\u5c11\u91cf\u6570\u636e\u4e22\u5931<\/td>\n<\/tr>\n
\u7535\u5546\u641c\u7d22<\/td>\n500ms<\/td>\nrequest<\/td>\n3-5<\/td>\n\u9700\u8981\u5feb\u901f\u4e0a\u67b6\u5546\u54c1，\u6570\u636e\u5fc5\u987b\u5b89\u5168<\/td>\n<\/tr>\n
\u65b0\u95fb\u8d44\u8baf<\/td>\n500ms<\/td>\nrequest<\/td>\n2-3<\/td>\n\u5b9e\u65f6\u6027\u8981\u6c42\u9ad8，\u6570\u636e\u4e00\u81f4\u6027\u91cd\u8981<\/td>\n<\/tr>\n
\u793e\u4ea4\u52a8\u6001<\/td>\n1s<\/td>\nasync<\/td>\n5-10<\/td>\n\u9ad8\u5e76\u53d1\u5199\u5165，\u5b9e\u65f6\u4e92\u52a8<\/td>\n<\/tr>\n
\u7269\u8054\u7f51\u6570\u636e<\/td>\n5s<\/td>\nasync<\/td>\n10+<\/td>\n\u6781\u9ad8\u5199\u5165\u91cf，\u5ef6\u8fdf\u8981\u6c42\u8f83\u4f4e<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

6.3 \u672a\u6765\u53d1\u5c55\u8d8b\u52bf<\/h4>\n
  • \u66f4\u4f4e\u7684\u5ef6\u8fdf：Elasticsearch\u6301\u7eed\u4f18\u5316，\u5411\u4e9a\u79d2\u7ea7NRT\u53d1\u5c55<\/li>\n
  • \u667a\u80fd\u8c03\u4f18：\u57fa\u4e8e\u673a\u5668\u5b66\u4e60\u7684\u81ea\u52a8\u53c2\u6570\u4f18\u5316<\/li>\n
  • \u4e91\u539f\u751f\u96c6\u6210：\u5728Kubernetes\u4e2d\u66f4\u597d\u7684NRT\u652f\u6301<\/li>\n
  • \u6df7\u5408\u641c\u7d22：\u7ed3\u5408\u5411\u91cf\u641c\u7d22\u7684\u5b9e\u65f6\u6df7\u5408\u68c0\u7d22<\/li>\n

    6.4 \u5173\u952e\u8981\u70b9\u56de\u987e<\/h4>\n
  • \u7406\u89e3NRT\u672c\u8d28：\u4e0d\u662f\u771f\u6b63\u7684\u5b9e\u65f6，\u800c\u662f\u79d2\u7ea7\u5ef6\u8fdf\u7684\u5e73\u8861\u65b9\u6848<\/li>\n
  • \u638c\u63e1\u6838\u5fc3\u673a\u5236：Refresh\u3001Translog\u3001Segment\u662f\u7406\u89e3NRT\u7684\u5173\u952e<\/li>\n
  • \u5408\u7406\u914d\u7f6e：\u6839\u636e\u4e1a\u52a1\u573a\u666f\u8c03\u6574refresh_interval\u548ctranslog\u7b56\u7565<\/li>\n
  • \u76d1\u63a7\u8c03\u4f18：\u6301\u7eed\u76d1\u63a7NRT\u6027\u80fd，\u53ca\u65f6\u8c03\u6574\u914d\u7f6e<\/li>\n
  • \u4e1a\u52a1\u9002\u914d：\u4e0d\u540c\u4e1a\u52a1\u573a\u666f\u9700\u8981\u4e0d\u540c\u7684NRT\u7b56\u7565<\/li>\n

    \"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n","protected":false},"excerpt":{"rendered":"

    \u672c\u6587\u6df1\u5165\u63a2\u8ba8 NRT（Near Real-Time）\u8fd1\u5b9e\u65f6\u641c\u7d22\u7684\u6838\u5fc3\u539f\u7406，\u8be6\u7ec6\u5206\u6790 Elasticsearch \u5982\u4f55\u5b9e\u73b0\u8fd1\u5b9e\u65f6\u641c\u7d22，\u5e76\u63d0\u4f9b\u5b8c\u6574\u7684\u5b9e\u6218\u5e94\u7528\u6848\u4f8b\u3002\u4e00\u3001NRT \u8fd1\u5b9e\u65f6\u641c\u7d22：\u6982\u5ff5\u4e0e\u6f14\u8fdb
    \n1.1 \u4ece\u5b9e\u65f6\u5230\u8fd1\u5b9e\u65f6：\u641c\u7d22\u6280\u672f\u7684\u6f14\u8fdb
    \n\u5728\u4f20\u7edf\u641c\u7d22\u7cfb\u7edf\u4e2d，\u6570\u636e\u7d22\u5f15\u901a\u5e38\u91c7\u7528\u6279\u5904\u7406\u6a21\u5f0f，\u8fd9\u610f\u5473\u7740\u6570\u636e\u66f4\u65b0\u540e\u9700\u8981\u7b49\u5f85\u7d22\u5f15\u91cd\u5efa\u5b8c\u6210\u624d\u80fd\u88ab\u641c\u7d22\u5230\u3002\u968f\u7740\u4e92\u8054\u7f51\u5e94\u7528\u7684\u5feb\u901f\u53d1\u5c55&#xff0<\/p>\n","protected":false},"author":2,"featured_media":59609,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[1299,323,2215],"topic":[],"class_list":["post-59611","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-elasticsearch","tag-323","tag-2215"],"yoast_head":"\nNRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/59611.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u672c\u6587\u6df1\u5165\u63a2\u8ba8 NRT（Near Real-Time）\u8fd1\u5b9e\u65f6\u641c\u7d22\u7684\u6838\u5fc3\u539f\u7406，\u8be6\u7ec6\u5206\u6790 Elasticsearch \u5982\u4f55\u5b9e\u73b0\u8fd1\u5b9e\u65f6\u641c\u7d22，\u5e76\u63d0\u4f9b\u5b8c\u6574\u7684\u5b9e\u6218\u5e94\u7528\u6848\u4f8b\u3002\u4e00\u3001NRT \u8fd1\u5b9e\u65f6\u641c\u7d22：\u6982\u5ff5\u4e0e\u6f14\u8fdb 1.1 \u4ece\u5b9e\u65f6\u5230\u8fd1\u5b9e\u65f6：\u641c\u7d22\u6280\u672f\u7684\u6f14\u8fdb \u5728\u4f20\u7edf\u641c\u7d22\u7cfb\u7edf\u4e2d，\u6570\u636e\u7d22\u5f15\u901a\u5e38\u91c7\u7528\u6279\u5904\u7406\u6a21\u5f0f，\u8fd9\u610f\u5473\u7740\u6570\u636e\u66f4\u65b0\u540e\u9700\u8981\u7b49\u5f85\u7d22\u5f15\u91cd\u5efa\u5b8c\u6210\u624d\u80fd\u88ab\u641c\u7d22\u5230\u3002\u968f\u7740\u4e92\u8054\u7f51\u5e94\u7528\u7684\u5feb\u901f\u53d1\u5c55&#xff0\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/59611.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-01-13T23:49:28+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260113234926-6966da06ed185.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"27 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/59611.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/59611.html\",\"name\":\"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-01-13T23:49:28+00:00\",\"dateModified\":\"2026-01-13T23:49:28+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/59611.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/59611.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/59611.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/59611.html","og_locale":"zh_CN","og_type":"article","og_title":"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u672c\u6587\u6df1\u5165\u63a2\u8ba8 NRT（Near Real-Time）\u8fd1\u5b9e\u65f6\u641c\u7d22\u7684\u6838\u5fc3\u539f\u7406，\u8be6\u7ec6\u5206\u6790 Elasticsearch \u5982\u4f55\u5b9e\u73b0\u8fd1\u5b9e\u65f6\u641c\u7d22，\u5e76\u63d0\u4f9b\u5b8c\u6574\u7684\u5b9e\u6218\u5e94\u7528\u6848\u4f8b\u3002\u4e00\u3001NRT \u8fd1\u5b9e\u65f6\u641c\u7d22：\u6982\u5ff5\u4e0e\u6f14\u8fdb 1.1 \u4ece\u5b9e\u65f6\u5230\u8fd1\u5b9e\u65f6：\u641c\u7d22\u6280\u672f\u7684\u6f14\u8fdb \u5728\u4f20\u7edf\u641c\u7d22\u7cfb\u7edf\u4e2d，\u6570\u636e\u7d22\u5f15\u901a\u5e38\u91c7\u7528\u6279\u5904\u7406\u6a21\u5f0f，\u8fd9\u610f\u5473\u7740\u6570\u636e\u66f4\u65b0\u540e\u9700\u8981\u7b49\u5f85\u7d22\u5f15\u91cd\u5efa\u5b8c\u6210\u624d\u80fd\u88ab\u641c\u7d22\u5230\u3002\u968f\u7740\u4e92\u8054\u7f51\u5e94\u7528\u7684\u5feb\u901f\u53d1\u5c55&#xff0","og_url":"https:\/\/www.wsisp.com\/helps\/59611.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-01-13T23:49:28+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260113234926-6966da06ed185.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"27 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/59611.html","url":"https:\/\/www.wsisp.com\/helps\/59611.html","name":"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-01-13T23:49:28+00:00","dateModified":"2026-01-13T23:49:28+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/59611.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/59611.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/59611.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"NRT \u8fd1\u5b9e\u65f6\u641c\u7d22\u6df1\u5ea6\u89e3\u6790\uff1aElasticsearch \u6838\u5fc3\u673a\u5236\u4e0e\u5e94\u7528\u5b9e\u8df5"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/59611","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=59611"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/59611\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/59609"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=59611"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=59611"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=59611"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=59611"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}