五分钟在springboot中集成Elasticsearch

桃扇骨 2023-02-18 15:25 146阅读 0赞

Elasticsearch 是一个开源的分布式 RESTful 搜索和分析引擎，它使您可以快速，近乎实时地存储，搜索和分析大量数据，能够解决越来越多不同的应用场景。

*  比如用作搜索网络商店的商品，用户的搜索，交易数据的搜索。
 *  业务的收集和存储
 *  报表的分析

在Springboot中如何使用elasticsearch去存储和查询数据呢，目前来说有以下几种方式比较便捷：

*  REST Client
 *  Spring Data
 *  Spring Data Elasticsearch Repositories

本文将使用Spring Data Elasticsearch Repositories这种方式去访问Elasticsearch。

## 准备 ##

需要自己搭建一台Elasticsearch，elasticsearch的版本为7.7.0。本次Elasticsearch为单机版本Elasticsearch，生产环境要使用集群版本。执行下面命令安装

# 下载elasticsearch的rpm
    wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.7.0-x86_64.rpm
    wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.7.0-x86_64.rpm.sha512
    shasum -a 512 -c elasticsearch-7.7.0-x86_64.rpm.sha512 
    sudo rpm --install elasticsearch-7.7.0-x86_64.rpm
    sudo systemctl daemon-reload
    sudo systemctl enable elasticsearch.service
    sudo systemctl start elasticsearch.servic

修改es给其他ip访问：

cluster.name: "docker-cluster"
    network.host: 0.0.0.0
    
    # custom config
    node.name: "node-1"
    discovery.seed_hosts: ["127.0.0.1", "[::1]"]
    cluster.initial_master_nodes: ["node-1"]
    # 开启跨域访问支持，默认为false
    http.cors.enabled: true
    # 跨域访问允许的域名地址，(允许所有域名)以上使用正则
    http.cors.allow-origin: /.*/

## Spring boot集成Elasticsearch ##

在springboot的工程的pom文件中引入elasticsearch的起步依赖spring-boot-starter-data-elasticsearch，如下：

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>

在springboot的配置文件application.properties文件填写elasticesearch的配置，这里使用的9300端口，即使用TCP协议端口。

server.port=8500
    spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
    spring.data.elasticsearch.cluster-name=my-application

和大多数spring-boot-starter-data-jpa类似，都是使用实体对象和数据库的存储结构字段对应起来的。使用@Document(indexName = “user”)注解，会在elasticesearch里面创建一个user的索引，@Id注解白名uId字段为elasticsearch的id字段。

@Document(indexName = "user")
    public class User implements Serializable { 
    
        @Id
        private String uId;
    
        private String name;
    
        private Integer age;
    
        private String address;
        
        //省略getter setter 
        }

写一个接口UserRepository继承ElasticsearchRepository，ElasticsearchRepository包含了基本的增删改查的能力，并在接口类上加上@Repository注解，注入到spring 容器中。

@Repository
    public interface UserRepository extends ElasticsearchRepository<User, String> { 
    
    }

UserServiceImpl类去操作UserRepository的接口，去操作Elasticsearch。

@Service
    public class UserServiceImpl implements UserService { 
    
        @Autowired
        private UserRepository userRepository;
    
    
        @Override
        public long count() { 
            return userRepository.count();
        }
    
        @Override
        public User save(User user) { 
            return userRepository.save(user);
        }
    
        @Override
        public void delete(User user) { 
            userRepository.delete(user);
        }
    
        @Override
        public Iterable<User> getAll() { 
            return userRepository.findAll();
        }
    
        @Override
        public List<User> getByName(String name) { 
            List<User> list = new ArrayList<>();
            MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("name", name);
            Iterable<User> iterable = userRepository.search(matchQueryBuilder);
            iterable.forEach(e->list.add(e));
            return list;
        }
    
        @Override
        public Page<User> pageQuery(Integer pageNo, Integer pageSize, String kw) { 
            NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
                    .withQuery(QueryBuilders.matchPhraseQuery("name", kw))
                    .withPageable(PageRequest.of(pageNo, pageSize))
                    .build();
            return userRepository.search(searchQuery);
        }
    }

写一个测试类，然后依次调用接口：

@RestController
    public class TestController { 
    
        @Autowired
        private UserService userService;
    
    
        @GetMapping("/testInsert")
        public void testInsert() { 
            User user = new User();
            user.setuId("1");
            user.setName("zhangsna");
            user.setAge(101);
            user.setAddress("广东省深圳市");
            userService.save(user);
    
            user.setuId("2");
            user.setName("lisi");
            user.setAge(32);
            user.setAddress("广东省深圳市");
            userService.save(user);
    
            user.setuId("3");
            user.setName("wangwu");
            user.setAge(34);
            user.setAddress("广东省深圳市");
            userService.save(user);
    
        }
    
        @GetMapping("/testDelete")
        public void testDelete() { 
            User user = new User();
            user.setuId("1");
            userService.delete(user);
        }
    
        @GetMapping("/testGetAll")
        public void testGetAll() { 
            Iterable<User> iterable = userService.getAll();
            iterable.forEach(e -> System.out.println(e.toString()));
        }
    
        @GetMapping("/testGetByName")
        public void testGetByName() { 
            List<User> list = userService.getByName("lisi");
            System.out.println(list);
        }
    
        @GetMapping("/testPage")
        public void testPage() { 
            Page<User> page = userService.pageQuery(0, 10, "wangwu");
            System.out.println(page.getTotalPages());
            System.out.println(page.getNumber());
            System.out.println(page.getContent());
        }
    }

## kibana展示数据 ##

首先需要按照kibana，安装命令如下：

wget https://artifacts.elastic.co/downloads/kibana/kibana-7.7.0-x86_64.rpm
    shasum -a 512 kibana-7.7.0-x86_64.rpm 
    sudo rpm --install kibana-7.7.0-x86_64.rpm
    
    //设置kibana开机自启
    sudo /bin/systemctl daemon-reload
    sudo /bin/systemctl enable kibana.service
    
    
    sudo systemctl start kibana.service //启动kibana
    sudo systemctl stop kibana.service   //停止kibana

启动成功后，在浏览器上访问kibana的地址http://10.10.10.1:5601，进入kibana的主界面。然后进到Discover界面。选择user的索引，就可以正常展示数据，数据如下：

![format_png][]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cDovL3N0YXRpYy5qYXZhamlrZS5jb20vaW1nLzIwMjAvMDYvZXMvZXMwMS5wbmc?x-oss-process=image/format,png