ElasticSearch、ki、head、kibana安装与基本使用

ElasticSearch安装与基本使用**

官网地址：https://www.elastic.co/cn/downloads/past-releases#elasticsearch

1.下载与安装

先去官网下载自己需要的的版本这里我用的是7.10.2，Windows版本

还需要下载一个Kibana(可视化软件)，要注意的是，版本需要跟上面下载的一样，不然会报错

然后再来一个分词器elasticsearch ik

下载地址：https://github.com/medcl/elasticsearch-analysis-ik/releases/tag/v5.6.16

最后加上一个elasticsearch-head(客户端工具)

下载地址：https://github.com/mobz/elasticsearch-head

最后下载完会得到四个压缩包

首先解压第一个，注意安装路径不能带空格和中文

除了ik，，其他三个建议全部解压缩到磁盘根目录

ik解压到elasticsearch的plugins目录下

最后浏览器需要安装一个插件，以谷歌浏览器为例

访问chrome://extensions/

会得到一个这个

点击右边的就会出现当前页面

2.运行

接下来就可以尝试跑起来了

双击这个目录下的这个文件，启动完成之后访问浏览器localhost:9200端口，看到以下页面就算安装成功了

5601

9200

点击小三角运行之后，去客户端点击连接

3.语法添加

语法：PUT /索引名

在没有特殊设置的情况下，默认有1个分片，1个备份，也可以通过请求参数的方式来指定

参数格式：

默认：

PUT my_index

明确指定：

PUT /my_index

{

  "settings": {


"number_of_shards": 5, //设置5个片区

"number_of_replicas": 1 //设置1个备份


  }

}

注意：

1：索引不能有大写字母

2：参数格式必须是标准的json格式

查看单个

GET /索引名

查看所有

GET _cat/indices

删除

语法：DELETE /索引名

设置映射(列)

创建

类型跟映射一起创建
语法：
PUT /索引名
{
“mappings”: {
“properties”: {
字段名: {
“type”: 字段类型,
“analyzer”: 分词器类型,
“search_analyzer”: 分词器类型,
…
},
…
}
}
}
字段类型就是：数据类型

创建数据

POST /product/_bulk

{“create”:{"_id": 1}}

{“id”:1,“title”:“Apple iPhone XR (A2108) 128GB 白色移动联通电信4G手机双卡双待”,“price”:5299,“intro”:"【iPhoneXR限时特惠！】6.1英寸视网膜显示屏，A12仿生芯片，面容识别，无线充电，支持双卡！选【换修无忧版】获 AppleCare 原厂服务，享只换不修！更有快速换机、保值换新、轻松月付！",“brand”:“Apple”}

GET /索引/_search

{

  "query": {


"match": {field: value}


  }

}

GET /product/_search

{

  "query": {


"match":{

  "title": "游戏 手机"

}


  }

}

multi_match

参数格式：

GET /索引/_search

{

  "query": {


"multi_match": {

  "query": value,

  "fields": [field1, field2, ...]

}


  }

}

4.springboot集成 1.依赖



        org.springframework.boot

        spring-boot-starter-parent

        2.4.3

        

    



        org.springframework.boot

        spring-boot-starter-data-elasticsearch

    



    commons-beanutils

    commons-beanutils

    1.9.4





            org.projectlombok

            lombok

        

        

            org.springframework.boot

            spring-boot-starter-test

            test

application.properties

配置集群名称，名称写错会连不上服务器，默认elasticsearch

spring.data.elasticsearch.cluster-name=elasticsearch

配置集群节点

spring.data.elasticsearch.cluster-nodes=localhost:9300

是否开启本地存储

spring.data.elasticsearch.repositories.enabled=true
过期原因:
es官方打算在es7设置TransportClient 过期, es8之后抛弃, 直接使用 High Level REST Client 替换TransportClient
https://docs.spring.io/spring-data/elasticsearch/docs/3.2.3.RELEASE/reference/html/#reference
spring.elasticsearch.rest.uris = localhost:9200

domain

@Getter
@Setter
@ToString
@NoArgsConstructor
@AllArgsConstructor
@document(indexName="es_shop", type="shop_product")
public class Product {
    @Id
    private String id;
    @Field(analyzer="ik_smart",searchAnalyzer="ik_smart",type = FieldType.Text)
    private String title;
    private Integer price;
    @Field(analyzer="ik_smart",searchAnalyzer="ik_smart",type = FieldType.Text)
    private String intro;
    @Field(type=FieldType.Keyword)
    private String brand;
}

### CRUD

public interface ProductRepository  extends ElasticsearchRepository{
}
public interface IProductService {
    void save(Product product);
    void update(Product product);
    void delete(String id);
    Product get(String id);
    List list();
}
@Service
public class ProductServiceImpl implements IProductService {
    @Autowired
    private ProductRepository repository;
    @Autowired
    private ElasticsearchTemplate  template;
    @Override
    public void save(Product product) {
        repository.save(product);
    }
    @Override
    public void update(Product product) {
        repository.save(product);
    }
    @Override
    public void delete(String id) {
        repository.deleteById(id);
    }
    @Override
    public Product get(String id) {
        return repository.findById(id).get();
    }
    @Override
    public List list() {
        Iterable all = repository.findAll();
        List p = new ArrayList<>();
        all.forEach(a->p.add(a));
        return p;
    }
}

@SpringBootTest
public class ElasticsearchDemoApplicationTests {
	@Autowired
	private IProductService productService;
	@Test
	public void testSave() {
		Product p = new Product();
        p.setId("123")
		p.setBrand("dafei");
		p.setIntro("dafei手机");
		p.setPrice(1000);
		p.setTitle("全球最帅的手机");
		productService.save(p);
	}
	@Test
	public void testUpate() {
		Product p = new Product();
		p.setId("ue5r1m4BXlaPW5P0TegF");
		p.setBrand("dafei");
		p.setIntro("dafei手机");
		p.setPrice(1000);
		p.setTitle("全球最sb的手机");
		productService.update(p);
	}
	@Test
	public void testDelete() {
		productService.delete("123");
	}
	@Test
	public void testGet() {
		System.out.println(productService.get("123"));
	}
	@Test
	public void testList() {
		System.err.println(productService.list());
	}
}

### 各类查询


- match

  // 查询商品标题中符合"游戏 手机"的字样的商品
      @Test
      public void testQuery4(){
          NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();
          
          builder.withQuery(
                  QueryBuilders.matchQuery("title", "游戏 手机")
          );
          builder.withPageable(PageRequest.of(0, 100));
          Page search = repository.search(builder.build());
          search.getContent().forEach(System.err::println);
      }

- multi_match

  // 查询商品标题或简介中符合"蓝牙 指纹 双卡"的字样的商品


  @Test

  public void testQuery7(){

      NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();

      
      
      builder.withQuery(
      
              QueryBuilders.multiMatchQuery("蓝牙 指纹 双卡", "title", "intro")
      
      );
      
      builder.withPageable(PageRequest.of(0, 100, Sort.Direction.DESC, "price"));
      
      Page search = repository.search(builder.build());
      
      search.getContent().forEach(System.err::println);

  }

### 高亮显示

@Test
public void testHighlight() throws Exception {

	//定义索引库

	SearchRequest searchRequest = new SearchRequest("product");

	SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

	//定义query查询

	MultiMatchQueryBuilder queryBuilder = QueryBuilders.multiMatchQuery("蓝牙 指纹 双卡",

			"title", "intro");

	HighlightBuilder highlightBuilder = new HighlightBuilder(); // 生成高亮查询器

	highlightBuilder.field("title");// 高亮查询字段

	highlightBuilder.field("intro");// 高亮查询字段

	highlightBuilder.requireFieldMatch(false); // 如果要多个字段高亮,这项要为false

	highlightBuilder.preTags(""); // 高亮设置

	highlightBuilder.postTags("");

	highlightBuilder.fragmentSize(800000); // 最大高亮分片数

	highlightBuilder.numOfFragments(0); // 从第一个分片获取高亮片段

	Pageable pageable = PageRequest.of(1, 2); // 设置分页参数

	NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()

			.withQuery(queryBuilder) // match查询

			.withPageable(pageable).withHighlightBuilder(highlightBuilder) // 设置高亮

			.build();

	SearchHits searchHits = template.search(searchQuery, Product.class);

	List list = new ArrayList();

	for (SearchHit searchHit : searchHits) { // 获取搜索到的数据

		Product content = searchHit.getContent();

		// 处理高亮

		Map> highlightFields = searchHit.getHighlightFields();

		for (Map.Entry> stringHighlightFieldEntry : highlightFields.entrySet()) {

			String key = stringHighlightFieldEntry.getKey();

			if (StringUtils.equals(key, "title")) {

				List fragments = stringHighlightFieldEntry.getValue();

				StringBuilder sb = new StringBuilder();

				for (String fragment : fragments) {

					sb.append(fragment.toString());

				}

				content.setTitle(sb.toString());

			}

			if (StringUtils.equals(key, "intro")) {

				List fragments = stringHighlightFieldEntry.getValue();

				StringBuilder sb = new StringBuilder();

				for (String fragment : fragments) {

					sb.append(fragment.toString());

				}

				content.setIntro(sb.toString());

			}

		}

		list.add(content);

	}

	Page page = new PageImpl(list, pageable, searchHits.getTotalHits());

	list.forEach(System.out::println);

}

ingBuilder sb = new StringBuilder();

			for (String fragment : fragments) {

				sb.append(fragment.toString());

			}

			content.setTitle(sb.toString());

		}

		if (StringUtils.equals(key, "intro")) {

			List fragments = stringHighlightFieldEntry.getValue();

			StringBuilder sb = new StringBuilder();

			for (String fragment : fragments) {

				sb.append(fragment.toString());

			}

			content.setIntro(sb.toString());

		}

	}

	list.add(content);

}

Page page = new PageImpl(list, pageable, searchHits.getTotalHits());

list.forEach(System.out::println);

}

ElasticSearch、ki、head、kibana安装与基本使用

大数据系统相关栏目本月热门文章