这期内容当中小编将会给大家带来有关ElasticSearch怎么在Spring boot中使用，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
1.安装ElasticSearch
解压，到bin目录，双击elasticsearch.bat
1.1安装elasticsearch-head
https://github.com/mobz/elasticsearch-head
elasticsearch-head是一个网页查看elasticsearch状态，操作的第三方东西
gitclonegit://github.com/mobz/elasticsearch-head.git
cdelasticsearch-head
npminstall
npmrunstart
openhttp://localhost:9100/
要先安装node.js
config/elasticsearch.yml 文件增加
http.cors.enabled: truehttp.cors.allow-origin: “*”
elasticsearch-head/Gruntfile.js
connect:{
server:{
options:{
hostname:'0.0.0.0',
port:9100,
base:'.',
keepalive:true
}
}
}8082改成你自己的端口
http://127.0.0.1:8082/swagger-ui.html#/
0是第一页
application.properties
#===esstart===
spring.data.elasticsearch.repositories.enabled=true
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
#===esend===
2.porm
4.0.0
org.springframework.boot
spring-boot-starter-parent
2.1.1.RELEASE
com.example
demo
0.0.1-SNAPSHOT
demo
DemoprojectforSpringBoot
jar
1.8
io.springfox
springfox-swagger2
2.6.1
io.springfox
springfox-swagger-ui
2.6.1
org.springframework.boot
spring-boot-starter-data-elasticsearch
org.springframework.boot
spring-boot-starter
org.springframework.boot
spring-boot-starter-test
test
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-maven-plugin
主要添加spring-boot-starter-data-elasticsearch，注意spring-boot-starter-parent的版本号
3. GoodsInfo
packagecom.example.demo.domain;
importorg.springframework.data.elasticsearch.annotations.Document;
importjava.io.Serializable;
@Document(indexName="testgoods",type="goods")
publicclassGoodsInfoimplementsSerializable{
privateLongid;
privateStringname;
privateStringdescription;
publicLonggetId(){
returnid;
}
publicvoidsetId(Longid){
this.id=id;
}
publicStringgetName(){
returnname;
}
publicvoidsetName(Stringname){
this.name=name;
}
publicStringgetDescription(){
returndescription;
}
publicvoidsetDescription(Stringdescription){
this.description=description;
}
publicGoodsInfo(Longid,Stringname,Stringdescription){
this.id=id;
this.name=name;
this.description=description;
}
publicGoodsInfo(){
}
}indexName 类似数据库名称,type类似表名字
4. GoodsRepository
packagecom.example.demo.repository;
importcom.example.demo.domain.GoodsInfo;
importorg.springframework.data.elasticsearch.repository.ElasticsearchRepository;
importorg.springframework.stereotype.Component;
@Component
publicinterfaceGoodsRepositoryextendsElasticsearchRepository{
}
这里会帮你封装了很多了
5. HelloWorldController
packagecom.example.demo.controller;
importcom.example.demo.domain.GoodsInfo;
importcom.example.demo.repository.GoodsRepository;
importio.swagger.annotations.Api;
importio.swagger.annotations.ApiImplicitParam;
importio.swagger.annotations.ApiOperation;
importorg.elasticsearch.index.query.QueryBuilder;
importorg.elasticsearch.index.query.QueryBuilders;
importorg.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.data.domain.Page;
importorg.springframework.data.domain.PageRequest;
importorg.springframework.data.domain.Pageable;
importorg.springframework.data.elasticsearch.core.query.NativeSearchQuery;
importorg.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
importorg.springframework.data.elasticsearch.core.query.SearchQuery;
importorg.springframework.stereotype.Controller;
importorg.springframework.web.bind.annotation.*;
importjava.util.List;
importjava.util.Optional;
importstaticorg.elasticsearch.index.query.QueryBuilders.queryStringQuery;
@Controller
@Api(value="HelloWorldController|一个用来测试swagger注解的控制器",tags="HelloWorldController",description="HelloWorldController")
publicclassHelloWorldController{
@Autowired
privateGoodsRepositorygoodsRepository;
@ResponseBody
@RequestMapping(value="/hello",method=RequestMethod.GET)
@ApiOperation(value="根据用户编号获取用户姓名",notes="test:仅1和2有正确返回")
@ApiImplicitParam(paramType="query",name="userNumber",value="用户编号",required=true,dataType="Integer")
publicStringindex(@RequestParamIntegeruserNumber){
if(userNumber==1){
return"小白";
}
elseif(userNumber==2){
return"小红";
}
else{
return"未知";
}
}
@ResponseBody
@RequestMapping(value="/save",method=RequestMethod.POST)
@ApiOperation(value="新增商品")
publicStringsave(){
GoodsInfogoodsInfo=newGoodsInfo(System.currentTimeMillis(),"商品"+System.currentTimeMillis(),"这是一个测试商品");
goodsRepository.save(goodsInfo);
return"success";
}
@ResponseBody
@RequestMapping(value="/delete",method=RequestMethod.POST)
@ApiOperation(value="删除商品")
@ApiImplicitParam(paramType="query",name="id",value="商品id",required=true,dataType="long")
publicStringdelete(@RequestParam(required=true)longid){
goodsRepository.deleteById(id);
return"success";
}
@ResponseBody
@RequestMapping(value="/update",method=RequestMethod.POST)
@ApiOperation(value="更新商品")
@ApiImplicitParam(paramType="query",name="id",value="商品id",required=true,dataType="long")
publicStringupdate(@RequestParam(required=true)longid,
@RequestParam(required=false)Stringname,
@RequestParam(required=false)Stringdescription){
OptionalgoodsInfo=goodsRepository.findById(id);
if(goodsInfo.isPresent()){
if(name!=null){
goodsInfo.get().setName(name);
}
if(description!=null){
goodsInfo.get().setDescription(description);
}
goodsRepository.save(goodsInfo.get());
return"success";
}else{
return"nofind";
}
}
@ResponseBody
@RequestMapping(value="/getOne",method=RequestMethod.GET)
@ApiOperation(value="得到一个商品")
@ApiImplicitParam(paramType="query",name="id",value="商品id",required=true,dataType="long")
publicOptionalgetOne(@RequestParam(required=true)longid){
OptionalgoodsInfo=goodsRepository.findById(id);
returngoodsInfo;
}
privateSearchQuerygetEntitySearchQuery(intpageNumber,StringsearchContent){
Pageablepageable=PageRequest.of(pageNumber,20);
SearchQuerysearchQuery=newNativeSearchQueryBuilder().withQuery(queryStringQuery(searchContent)).withPageable(pageable).build();
returnsearchQuery;
}
@ResponseBody
@RequestMapping(value="/search",method=RequestMethod.GET)
@ApiOperation(value="搜索商品")
publicListsearch(@RequestParam(required=true)IntegerpageNumber,@RequestParam(required=true)Stringquery){
SearchQuerysearchQuery=getEntitySearchQuery(pageNumber,query);
PagegoodsPage=goodsRepository.search(searchQuery);
returngoodsPage.getContent();
}
}上述就是小编为大家分享的ElasticSearch怎么在Spring boot中使用了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注恰卡编程网行业资讯频道。
