時間：2023-05-30 10:15:01 | 來源：網(wǎng)站運(yùn)營
時間：2023-05-30 10:15:01 來源：網(wǎng)站運(yùn)營
利用Elasticsearch 的java 客戶端為網(wǎng)站開發(fā)一個搜索服務(wù)：Elasticsearch 是什么
在線咨詢
<elasticsearch.version>6.2.3</elasticsearch.version><!--引入ES相關(guān)的包 --> <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>transport</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.1.1.RELEASE</version> </dependency> <dependency> <groupId>org.elasticsearch.distribution.integ-test-zip</groupId> <artifactId>elasticsearch</artifactId> <type>zip</type> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>org.elasticsearch.plugin</groupId> <artifactId>transport-netty4-client</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-client</artifactId> <version>${elasticsearch.version}</version> <exclusions> <exclusion> <artifactId>commons-logging</artifactId> <groupId>commons-logging</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>commons-logging</groupId> <artifactId>commons-logging</artifactId> <version>1.2</version> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-client</artifactId> <version>${elasticsearch.version}</version> </dependency>創(chuàng)建一個ES client 類public class EsClient { static RestHighLevelClient client; public static synchronized void initClint(){ if(client==null){ client = new RestHighLevelClient( RestClient.builder(new HttpHost("192.168.0.1", 9200, "http") )); } } public static RestHighLevelClient getClient(){ initClint(); return client; } public void closeClient(String s) { try { client.close(); } catch (IOException e) { e.printStackTrace(); } }}這邊使用的 RestHighLevelClient 客戶端和ES服務(wù)端進(jìn)行通信，將 192.168.0.1 替換成自己的 ES 服務(wù)地址。public class SaveClient { /** * 數(shù)據(jù)保存到es * @param text * @param fileName * @param id */ public static void save(String text,String fileName,String id){ Map<String, Object> jsonMap = new HashMap<>(); jsonMap.put("url", "http://127.0.0.1:9123/mdwiki.html#!"+fileName); jsonMap.put("postDate", new Date()); jsonMap.put("message", text); IndexRequest indexRequest = new IndexRequest("posts", "doc",id).source(jsonMap); try { EsClient.getClient().index(indexRequest); } catch (IOException e) { e.printStackTrace(); } }}關(guān)鍵代碼：EsClient.getClient().index(indexRequest); import java.io.File;import java.util.regex.Pattern;public class SaveContentTest { public static void main(String[] args) { //調(diào)用保存方法 setConent(); } /** * 讀取目錄下的makedown文件 */ public static void setConent(){ String pendingPath="E://mdwiki//mdwiki-0.6.2//"; File file = new File(pendingPath); File[] fileList = file.listFiles(); for(File fileOjb:fileList){ if (fileOjb.isFile()) { String name= fileOjb.getName(); String names[] = name.split("//."); if(names.length==2 && "md".equals( names[1].toLowerCase() ) ){ putEs(pendingPath,name,MD5Util.md5low(name)); } } } } /** * 將makedown文件通過正則替換掉特殊字符，然后保存到ES * @param pendingPath * @param fileName * @param id */ public static void putEs(String pendingPath,String fileName,String id){ ReadFileUtil readFileUtil=new ReadFileUtil(); String text= readFileUtil.read(pendingPath, fileName, new ReadFileUtil.FixLine() { @Override public String fixLine(String buff) { String jsonString=Pattern.compile(".*!//[.*?//]//(.*?//).*").matcher(buff).replaceAll(""); jsonString=Pattern.compile(".*//<iframe(.*?)><///iframe//>.*").matcher(jsonString).replaceAll(""); jsonString=jsonString.replaceAll("-",""); jsonString=jsonString.replaceAll("//*",""); jsonString=jsonString.replaceAll("`",""); jsonString=jsonString.replaceAll(">",""); jsonString=jsonString.replaceAll("=",""); return jsonString; } }); System.out.println(text); //數(shù)據(jù)添加ES SaveClient.save(text,fileName,id); }}創(chuàng)建一個搜索工具類@Componentpublic class SearchClient { public String doSearch(String s) { //構(gòu)建一個搜索對象 SearchRequest searchRequest = new SearchRequest("posts"); SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); sourceBuilder.query(QueryBuilders.matchPhraseQuery("message", s)); sourceBuilder.from(0); sourceBuilder.size(5); sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS)); searchRequest.source(sourceBuilder); SearchResponse searchResponse = null; try { searchResponse = EsClient.getClient().search(searchRequest); } catch (IOException e) { e.printStackTrace(); } StringBuilder bu=new StringBuilder(); bu.append("<div>"); SearchHits hits = searchResponse.getHits(); for (SearchHit hit : hits.getHits()) { String text= hit.getSourceAsString(); HtmlBean htmlBean= JsonUtils.convert2bean(text,HtmlBean.class); text=htmlBean.getMessage(); int indexOf= text.indexOf(s); int lastOf= text.lastIndexOf(s); int startIndex=(indexOf-100) < 0 ? 0 : indexOf-100 ; int lastIndex=(lastOf +100) > text.length() ? text.length() : lastOf+100 ; text=text.substring( startIndex,lastIndex); text= text.replaceAll(s,"<span style=/"background: yellow;/"> "+s+"</span>"); bu.append("<a href='"); bu.append(htmlBean.getUrl()); bu.append("'>"); bu.append(text); bu.append("</a>"); bu.append("</br>"); } bu.append("</div>"); return bu.toString(); } static class HtmlBean { private String postDate; private String message; private String url; public String getPostDate() { return postDate; } public void setPostDate(String postDate) { this.postDate = postDate; } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public String getUrl() { return url; } public void setUrl(String url) { this.url = url; } }}構(gòu)建一個SearchController 提高h(yuǎn)ttp請求@Controllerpublic class SearchController { private static final Logger logger= LoggerFactory.getLogger(SearchController.class); @Autowired SearchClient searchClientStandardServiceImpl; @ResponseBody @RequestMapping(value = "/search") public String search(String text){ return searchClientStandardServiceImpl.doSearch(text); }}輸入 http://127.0.0.1:9300/sync/search?text=控件關(guān)鍵詞：服務(wù),利用
客戶&案例
營銷資訊
關(guān)于我們
微信公眾號
版權(quán)所有? 億企邦 1997-2025 保留一切法律許可權(quán)利。
