美文网首页java从0到架构师
82_熟练掌握ES Java API_client集群自动探查以

82_熟练掌握ES Java API_client集群自动探查以

作者: 小山居 | 来源:发表于2020-03-04 16:29 被阅读0次

    82_熟练掌握ES Java API_client集群自动探查以及汽车零售店案例背景

    快速入门篇,讲解过了一些基本的java api,包括了document增删改查,基本的搜索,基本的聚合

    高手进阶篇,必须将java api这块深入讲解一下,介绍一些最常用的,最核心的一些api的使用,用一个模拟现实的案例背景,让大家在学习的时候更加贴近业务

    话说在前面,我们是不可能将所有的java api用视频全部录制一遍的,因为api太多了。。。。

    我们之前讲解各种功能,各种知识点,花了那么多的时间,哪儿些才是最最关键的,知识,原理,功能,es restful api,最次最次,哪怕是搞php,搞python的人也可以来学习

    如果说,现在要将所有所有的api全部用java api实现一遍和讲解,太耗费时间了,几乎不可能接受

    采取的粗略,将核心的java api语法,还有最最常用的那些api都给大家上课演示了

    然后最后一讲,会告诉大家,在掌握了之前那些课程讲解的各种知识点之后,如果要用java api去实现和开发,应该怎么自己去探索和掌握

    java api,api的学习,实际上是最最简单的,纯用,没什么难度,技术难度,你掌握了课上讲解的这些api之后,自己应该就可以举一反三,后面自己去探索和尝试出自己要用的各种功能对应的java api是什么。。。

    1、client集群自动探查

    默认情况下,是根据我们手动指定的所有节点,依次轮询这些节点,来发送各种请求的,如下面的代码,我们可以手动为client指定多个节点

    TransportClient client = new PreBuiltTransportClient(settings)
                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost1"), 9300))
                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost2"), 9300))
                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost3"), 9300));
    

    但是问题是,如果我们有成百上千个节点呢?难道也要这样手动添加吗?

    es client提供了一种集群节点自动探查的功能,打开这个自动探查机制以后,es client会根据我们手动指定的几个节点连接过去,然后通过集群状态自动获取当前集群中的所有data node,然后用这份完整的列表更新自己内部要发送请求的node list。默认每隔5秒钟,就会更新一次node list。

    但是注意,es cilent是不会将Master node纳入node list的,因为要避免给master node发送搜索等请求。

    这样的话,我们其实直接就指定几个master node,或者1个node就好了,client会自动去探查集群的所有节点,而且每隔5秒还会自动刷新。非常棒。

    Settings settings = Settings.builder()
            .put("client.transport.sniff", true).build();
    TransportClient client = new PreBuiltTransportClient(settings);
    
    

    使用上述的settings配置,将client.transport.sniff设置为true即可打开集群节点自动探查功能

    在实际的生产环境中,都是这么玩儿的。。。

    2、汽车零售案例背景

    简单来说,会涉及到三个数据,汽车信息,汽车销售记录,汽车4S店信息

    相关文章

      网友评论

        本文标题:82_熟练掌握ES Java API_client集群自动探查以

        本文链接:https://www.haomeiwen.com/subject/nzhblhtx.html