logo
搜索
我的图书馆

发文章

发文工具

其他工具

留言交流
搜索
分享

ElasticSearch搜索引擎的使用整合SpringMVC

 昵称13716297 2019-09-24

下载、安装、工具

下载并加压：ElasticSearch，来自 how2j

中文分词器：http:///frontdownload?bean.id=1696

执行安装分词器：（从github安装）

elasticsearch-plugin install https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v6.2.2/elasticsearch-analysis-ik-6.2.2.zip

从本地安装：

cd 安装路径

elasticsearch-plugin install zip路径/elasticsearch-analysis-ik-6.2.2.zip

工具：kibana

搭建

SpringMvc部分参照文章：ssm maven 工程目录以及环境搭建

pom包：

  1. <!--elasticsearch-rest-high-level-client -->
  2.     <dependency>
  3.       <groupId>org.elasticsearch.client</groupId>
  4.       <artifactId>elasticsearch-rest-high-level-client</artifactId>
  5.       <version>6.3.2</version>
  6.     </dependency>

工具类：

  1. public class ElasticUtils {
  3.     // 相当于数据库名称（数据量小）
  4.     public static String indexName = "shose";
  8.     // 初始化api客户端
  9.     public static RestHighLevelClient client = new RestHighLevelClient(
  10.             RestClient.builder(
  11.                     new HttpHost("localhost", 9200, "http")
  12.             ));
  14.     // 关键字搜索 指定匹配类型
  15.     public static List<Map<String, Object>> search(String type,String fieldName, String keyword, int start, int count) throws IOException {
  18.         SearchRequest searchRequest = new SearchRequest(indexName);
  20.         SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
  21.         //关键字匹配对应字段
  22.         MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder(fieldName, keyword);
  23.         //模糊匹配
  24.         matchQueryBuilder.fuzziness(Fuzziness.AUTO);
  25.         sourceBuilder.query(matchQueryBuilder);
  26.         //第几页
  27.         sourceBuilder.from(start);
  28.         //第几条
  29.         sourceBuilder.size(count);
  31.         searchRequest.source(sourceBuilder);
  32.         searchRequest.types(type);
  33.         //匹配度从高到低
  34.         sourceBuilder.sort(new ScoreSortBuilder().order(SortOrder.DESC));
  36.         SearchResponse searchResponse = client.search(searchRequest);
  38.         SearchHits hits = searchResponse.getHits();
  40.         List<Map<String, Object>> matchRsult = new LinkedList<Map<String, Object>>();
  42.         for (SearchHit hit : hits.getHits())
  43.         {
  44.             matchRsult.add(hit.getSourceAsMap());
  45.         }
  46.         return matchRsult;
  47.     }
  48.     //删除指定类型
  49.     public static void deleteDocument(Object object) throws IOException {
  50.         if(object instanceof Product){
  51.             DeleteRequest deleteRequest = new DeleteRequest (indexName,"product", ((Product) object).getId());
  52.             System.out.println("已经从ElasticSearch服务器上删除id="+((Product) object).getId()+"的product文档");
  53.             client.delete(deleteRequest);
  54.         }
  55.     }
  56.     // 获得指定type指定id的数据 json
  57.     public static Map getDocument(String type,String id) throws IOException {
  58.         // TODO Auto-generated method stub
  59.         GetRequest request = new GetRequest(
  60.                 indexName,
  61.                 type,
  62.                 id);
  64.         GetResponse response = client.get(request);
  66.         if(!response.isExists()){
  67.             System.out.println("检查到服务器上 "+type+" id="+id+ "的文档不存在");
  68.             return null;
  69.         }
  70.         else{
  71.             String source = response.getSourceAsString();
  72.             System.out.print("获取到服务器上 "+type+" id="+id+ "的文档内容是：");
  73.             System.out.println(source);
  74.             return response.getSourceAsMap();
  75.         }
  76.     }
  77.     // 插入指定type，数据
  78.     public static void addDocument(Object object) throws IOException {
  79.         Map<String, Object> jsonMap = new HashMap<>();
  80.         if(object instanceof Product){
  81.             jsonMap.put("id", ((Product)object).getId());
  82.             jsonMap.put("name", ((Product)object).getName());
  83.             jsonMap.put("price", ((Product)object).getPrice());
  84.             jsonMap.put("detail", ((Product)object).getDetail());
  85.             IndexRequest indexRequest = new IndexRequest(indexName, "product", ((Product)object).getId())
  86.                     .source(jsonMap);
  87.             client.index(indexRequest);
  88.             System.out.println("已经向ElasticSearch服务器增加Product："+object);
  89.         }
  91.     }
  92.     // 更新数据
  93.     public static void updateDocument(Object object) throws IOException {
  95.         if(object instanceof Product){
  96.             UpdateRequest updateRequest = new UpdateRequest (indexName, "product", ((Product) object).getId())
  97.                     .doc("name",((Product) object).getId())
  98.                     .doc("price",((Product) object).getPrice())
  99.                     .doc("detail",((Product) object).getDetail());
  100.             client.update(updateRequest);
  101.             System.out.println("已经在ElasticSearch服务器修改产品为："+object);
  102.         }
  105.     }
  106.     private static boolean checkExistIndex(String indexName) throws IOException {
  107.         boolean result =true;
  108.         try {
  110.             OpenIndexRequest openIndexRequest = new OpenIndexRequest(indexName);
  111.             client.indices().open(openIndexRequest).isAcknowledged();
  113.         } catch (ElasticsearchStatusException ex) {
  114.             String m = "Elasticsearch exception [type=index_not_found_exception, reason=no such index]";
  115.             if (m.equals(ex.getMessage())) {
  116.                 result = false;
  117.             }
  118.         }
  119.         if(result)
  120.             System.out.println("索引:" +indexName + " 是存在的");
  121.         else
  122.             System.out.println("索引:" +indexName + " 不存在");
  124.         return result;
  126.     }
  128.     private static void deleteIndex(String indexName) throws IOException {
  129.         DeleteIndexRequest request = new DeleteIndexRequest(indexName);
  130.         client.indices().delete(request);
  131.         System.out.println("删除了索引："+indexName);
  133.     }
  135.     private static void createIndex(String indexName) throws IOException {
  136.         // TODO Auto-generated method stub
  137.         CreateIndexRequest request = new CreateIndexRequest(indexName);
  138.         client.indices().create(request);
  139.         System.out.println("创建了索引："+indexName);
  140.     }
  142.     // 批量插入
  143. //    private static void batchInsert(List<Product> products) throws IOException {
  144. //        // TODO Auto-generated method stub
  145. //        BulkRequest request = new BulkRequest();
  146. //
  147. //        for (Product product : products) {
  148. //            Map<String,Object> m  = product.toMap();
  149. //            IndexRequest indexRequest= new IndexRequest(indexName, "product", String.valueOf(product.getId())).source(m);
  150. //            request.add(indexRequest);
  151. //        }
  152. //
  153. //        client.bulk(request);
  154. //        System.out.println("批量插入完成");
  155. //    }
  156.     public static String getIndexName() {
  157.         return indexName;
  158.     }
  160.     public static void setIndexName(String indexName) {
  161.         ElasticUtils.indexName = indexName;
  162.     }
  164.     public static RestHighLevelClient getClient() {
  165.         return client;
  166.     }
  168.     public static void setClient(RestHighLevelClient client) {
  169.         ElasticUtils.client = client;
  170.     }
  172. }

实体类：

Controller：

  1. @Controller
  2. public class ElasticController {
  4.     @Autowired
  5.     private ElasticService elasticService;
  7.     @RequestMapping(value = "product",method = RequestMethod.POST)
  8.     @ResponseBody
  9.     public Message addProduct(
  10.             @RequestParam(name = "id")String id,
  11.             @RequestParam(name = "name")String name,
  12.             @RequestParam(name = "price")String price,
  13.             @RequestParam(name = "detail")String detail){
  14.         return elasticService.addProduct(new Product(id,name,price,detail));
  15.     }
  17.     @RequestMapping(value = "product",method = RequestMethod.DELETE)
  18.     @ResponseBody
  19.     public Message delProduct(
  20.             @RequestParam(name = "id")String id){
  21.         return elasticService.delProduct(id);
  22.     }
  24.     @RequestMapping(value = "product",method = RequestMethod.PUT)
  25.     @ResponseBody
  26.     public Message updateProduct(
  27.             @RequestParam(name = "id")String id,
  28.             @RequestParam(name = "name")String name,
  29.             @RequestParam(name = "price")String price,
  30.             @RequestParam(name = "detail")String detail){
  31.         return elasticService.updateProduct(new Product(id,name,price,detail));
  32.     }
  34.     @RequestMapping(value = "product",method = RequestMethod.GET)
  35.     @ResponseBody
  36.     public Message searchProduct(
  37.             @RequestParam(name = "fieldName",required = false)String fieldName,
  38.             @RequestParam(name = "name",required = false)String name,
  39.             @RequestParam(name = "start",required = false)Integer start,
  40.             @RequestParam(name = "count",required = false)Integer count,
  41.             @RequestParam(name = "id",required = false)String id){
  42.         if(id != null){
  43.             return elasticService.getProduct(id);
  44.         }else {
  45.             return elasticService.searchProduct(fieldName,name,start,count);
  46.         }
  47.     }
  49. }

Service

  1. @Service
  2. public class ElasticServiceImpl implements ElasticService {
  5.     @Override
  6.     public Message addProduct(Product product) {
  7.         try {
  8.             ElasticUtils.addDocument(product);
  9.         } catch (IOException e) {
  10.             e.printStackTrace();
  11.             return new Message("500",null);
  12.         }
  13.         return new Message("200",null);
  14.     }
  16.     @Override
  17.     public Message delProduct(String id) {
  18.         Product product = new Product();
  19.         product.setId(id);
  20.         try {
  21.             ElasticUtils.deleteDocument(product);
  22.         } catch (IOException e) {
  23.             e.printStackTrace();
  24.             return new Message("500",null);
  25.         }
  26.         return new Message("200",null);
  27.     }
  29.     @Override
  30.     public Message getProduct(String id)  {
  31.         try {
  32.             return new Message("200",ElasticUtils.getDocument("product",id));
  33.         } catch (IOException e) {
  34.             e.printStackTrace();
  35.             return new Message("500",null);
  36.         }
  37.     }
  39.     @Override
  40.     public Message searchProduct(String fieldName,String keyword,int start,int count) {
  41.         try {
  42.             return new Message("200",ElasticUtils.search("product",fieldName,keyword,start,count));
  43.         } catch (IOException e) {
  44.             e.printStackTrace();
  45.             return new Message("500",null);
  46.         }
  47.     }
  49.     @Override
  50.     public Message updateProduct(Product product) {
  51.         try {
  52.             ElasticUtils.updateDocument(product);
  53.         } catch (IOException e) {
  54.             e.printStackTrace();
  55.             return new Message("500",null);
  56.         }
  57.         return new Message("200",null);
  58.     }
  59. }

测试

添加一个product：成功

通过id查询product类型的数据：成功

模糊搜索数据：

删除数据：

再次查询：没有匹配数据

 更多功能有待测试 

    本站是提供个人知识管理的网络存储空间，所有内容均由用户发布，不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息，谨防诈骗。如发现有害或侵权内容，请点击一键举报。
    转藏 分享 献花（0）

    来自： 昵称13716297 > 《待分类》

    举报/认领

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多