SpringBoot2.0.3整合elasticsearch5.6.10

avatar 2018年08月29日15:25:46 6 4733 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
之前整合过一次 SpringBoot1.59和elasticsearch2.4.4，而 elasticsearch 更新很快，已经有版本 6了，且对之前的版本2不再更新。为了避免以后出现问题不好解决，我们这次试用elasticsearch5。

之前的那篇文章已经不适用了，下面介绍SpringBoot2.0.3整合elasticsearch5.6.10。



环境说明：
  • spring boot 使用 2.0.3.RELEASE
  • elasticsearch为5.6.10
  • 本地安装ES集群为 5.6.11版本



一、添加依赖

  1. <!--引入ElasticSearch的依赖包，默认使用elasticsearch5.6.10版本-->
  2. <dependency>
  3.     <groupId>org.springframework.boot</groupId>
  4.     <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  5. </dependency>
  7. <!--需要引入transport-netty3-client，否则会启动报错-->
  8. <dependency>
  9.     <groupId>org.elasticsearch.plugin</groupId>
  10.     <artifactId>transport-netty3-client</artifactId>
  11.     <version>5.6.10</version>
  12. </dependency>

因为我的 SpringBoot 版本是2.0.3，所以默认的es是5.6.10版本，必须添加transport-netty3-client，否则会报错 Java.lang.ClassNotFoundException: org.elasticsearch.transport.RemoteTransportException 之类错误。


二、添加配置，将 ES CLient 组件加入到Spring 容器

  1. /**
  2.  * @author 言曌
  3.  * @date 2018/8/29 下午1:16
  4.  */
  5. @Configuration
  6. public class ElasticSearchConfig {
  8.     private static final Logger logger = LoggerFactory.getLogger(ElasticSearchConfig.class);
  10.     @Bean
  11.     public TransportClient transportClient() {
  12.         logger.info("初始化开始。。。。。");
  13.         TransportClient client = null;
  14.         try {
  15.             TransportAddress transportAddress = new InetSocketTransportAddress(InetAddress.getByName("localhost"),
  16.                     Integer.valueOf(9300));
  18.             // 配置信息
  19.             Settings esSetting = Settings.builder()
  20.                     .put("cluster.name","elasticsearch")
  21.                     .build();
  23.             //配置信息Settings自定义
  24.             client = new PreBuiltTransportClient(esSetting);
  26.             client.addTransportAddresses(transportAddress);
  29.         } catch (Exception e) {
  30.             logger.error("elasticsearch TransportClient create error!!!", e);
  31.         }
  33.         return client;
  34.     }
  35. }


三、测试


关于安装 ES 和 head 插件这里就不再介绍了

1、手动创建索引
  1. {
  2.     "settings":{
  3.         "number_of_shards": 3,
  4.         "number_of_replicas": 0
  5.     },
  6.     "mappings":{
  7.         "post":{
  8.             "properties":{
  9.                 "title":{
  10.                     "type": "text"
  11.                 },
  12.                 "content":{
  13.                      "type": "text"
  14.                 },
  15.                 "author":{
  16.                      "type": "keyword"
  17.                 },
  18.                 "create_time":{
  19.                     "type": "date",
  20.                     "format": "yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis"
  21.                 }
  22.             }
  23.         }
  24.     }
  25. }



2、手动创建一条记录

PUT  http://127.0.0.1:9200/article/post/1
  1. {
  2.     "title": "静夜思",
  3.     "content": "静夜思全文，省略...",
  4.     "author": "李白",
  5.     "create_time": "2018-08-29 15:12:13"
  6. }



使用 elasticsearch-head 来查看我们刚才添加的记录，成功







3、单元测试
  1. @SpringBootTest
  2. @RunWith(SpringRunner.class)
  3. public class EsTest {
  5.     @Autowired
  6.     private TransportClient client;
  8.     @Test
  9.     public void test() {
  10.         //查询ID为1的文章
  11.         GetResponse result = client.prepareGet("article","post","1").get();
  12.         System.out.println(result);
  13.     }
  14. }



运行结果如下



历史上的今天
八月
29日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0