springboot整合消息索引

我们的应用经常需要添加检索功能，开源的 ElasticSearch 是目前全文搜索引擎的首选。他可以快速的存储、搜索和分析海量数据。Spring Boot通过整合SpringData ElasticSearch为我们提供了非常便捷的检索功能支持。

Elasticsearch是一个分布式搜索服务，提供Restful API，底层基于Lucene，采用多shard（分片）的方式保证数据安全，并且提供自动resharding的功能，github等大型的站点也是采用了ElasticSearch作为其搜索服务。

官方原话：

Elasticsearch 是一个分布式的开源搜索和分析引擎，适用于所有类型的数据，包括文本、数字、地理空间、结构化和非结构化数据。Elasticsearch 在 Apache Lucene 的基础上开发而成，由 Elasticsearch N.V.（即现在的 Elastic）于 2010 年首次发布。Elasticsearch 以其简单的 REST 风格 API、分布式特性、速度和可扩展性而闻名，是 Elastic Stack 的核心组件；Elastic Stack 是适用于数据采集、充实、存储、分析和可视化的一组开源工具。人们通常将 Elastic Stack 称为 ELK Stack（代指 Elasticsearch、Logstash 和 Kibana），目前 Elastic Stack 包括一系列丰富的轻量型数据采集代理，这些代理统称为 Beats，可用来向 Elasticsearch 发送数据。

1、Index (索引)

动词：相当于MySQL中的insert
名词：相当于MySQL中的Database
2、Type (类型)

在 Index (索引) 中，可以定义一个或多个类型，类似于MySQL中的Table，每一种类型的数据放在一起。
3、document (文档)

保存在某个索引 (index) 下，某种类型 (Type) 的一个数据 (document)。文档是JSON格式的，document就像是MySQL中的某个table里面的内容。
4、概念关系图一览

5、倒排索引机制

为了安装方便，我们还是以容器化技术Docker进行安装：

1、下载镜像文件

[howie@laizhenghua /]$ sudo docker search elasticsearch

docker pull elasticsearch:7.4.2 # 存储和检索数据
dicker pull kibana:7.4.2 # 可视化检索数据

[howie@laizhenghua /]$ sudo docker images
REPOSITORY      TAG       IMAGE ID       CREATED         SIZE
mysql           5.7       f07dfa83b528   3 weeks ago     448MB
redis           latest    ef47f3b6dc11   5 weeks ago     104MB
kibana          7.4.2     230d3ded1abc   14 months ago   1.1GB
elasticsearch   7.4.2     b1179d41a7b4   14 months ago   855MB

2、创建挂载目录

sudo mkdir -p /mydata/elasticsearch/config
sudo mkdir -p /mydata/elasticsearch/data
sudo chmod -R 777 /mydata/elasticsearch/
sudo echo "http.host: 0.0.0.0" >/mydata/elasticsearch/config/elasticsearch.yml

chmod：change mode -R(Recursion 递归)

3、启动elasticsearch

sudo docker run --name elasticsearch -p 9200:9200 -p 9300:9300 
-e  "discovery.type=single-node" 
-e ES_JAVA_OPTS="-Xms64m -Xmx512m" 
-v /mydata/elasticsearch/config/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.yml 
-v /mydata/elasticsearch/data:/usr/share/elasticsearch/data 
-v  /mydata/elasticsearch/plugins:/usr/share/elasticsearch/plugins 
-d elasticsearch:7.4.2

4、启动 kibana

sudo docker run --name kibana -e ELASTICSEARCH_HOSTS=http://https://es-0a8t6rzt.public.tencentelasticsearch.com:9200/lanlan/Article -p 5601:5601 -d kibana:7.4.2

[howie@laizhenghua /]$ sudo docker run --name kibana -e ELASTICSEARCH_HOSTS=https://es-0a8t6rzt.public.tencentelasticsearch.com:9200/lanlan/Article -p 5601:5601 -d kibana:7.4.2
9b88afc2f1c00891125eeb9610bb149a023b8044bb887568219f7f160059005d

访问服务器的5601端口！

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-RpqstGM6-1644044896802)(C:Users86157AppDataLocalTemp1643814866889.png)]

由于我之前的阿里云服务器的内存不够，于是我申请了一个腾讯云的es。

这次我们用到的是简单的ES的整合。

   org.springframework.boot
   spring-boot-starter-data-elasticsearch

@document(indexName = "lanlan")
@Data
public class Article {
    @Id
    private Integer id;
    @Field(type = FieldType.Text)
    private String author;
    @Field(type = FieldType.Text,analyzer = "ik_max_word")
    private String title;
}

public interface ArticleRepository extends ElasticsearchRepository {
    List findArticleByTitle(String title);
    List findByTitle(String title);
    List findByTitleContaining(String title);
}

@SpringBootTest
class Demo12ElasticsearchApplicationTests {


    @Autowired
    ArticleRepository articleRepository;

    @Autowired
    private ElasticsearchRestTemplate elasticsearchRestTemplate;

    @Test
    public void test03(){
   


        List Forest = articleRepository.findByTitleContaining("森林");
        for (Article article : Forest) {
            System.out.println(article);
        }
    }

    @Test
    public void test02(){
        Article article = new Article();
        article.setId(3);
        article.setTitle("挪威森林1");
        article.setAuthor("村上春树");
        articleRepository.save(article);
    }



}

ElasticsearchRepository中的方法名对应我在官网中找到了这样的依据，现在粘贴过来。

如表所示

docker pull rabbitmq

docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq

    org.springframework.amqp
    spring-rabbit
    2.4.2

        
            org.springframework.boot
            spring-boot-starter-amqp
        

spring:
  rabbitmq:
    host: 8.142.109.15
    username: guest
    password: guest

@EnableRabbit
@SpringBootApplication
public class Demo10RabbitMqApplication {

    public static void main(String[] args) {
        SpringApplication.run(Demo10RabbitMqApplication.class, args);
    }

}

@Configuration
public class MyAMQPConfig {

    @Bean
    public MessageConverter messageConverter() {
        return new Jackson2JsonMessageConverter();
    }
}

@Data
public class Book {
    private String bookName;
    private String author;
}

@Service
public class BookService {

    
    @RabbitListener(queues = "atguigu.news")
    public void receive(Book book){
        System.out.println("收到消息"+book);
    }
}

@Test
void boottest(){
    Book book = new Book();
    book.setBookName("挪威的森林");
    book.setAuthor("村上春书");
    rabbitTemplate.convertAndSend("exchange.direct","atguigu.news",book);
}

    @Test
    public void createEchange(){
//        amqpAdmin.declareExchange(new DirectExchange("xiaolan.direct"));
//        amqpAdmin.declareQueue(new Queue("amqpadmin.queue"));
        amqpAdmin.declareBinding(new Binding("amqpadmin.queue",Binding.DestinationType.QUEUE,"xiaolan.direct","amqp.haha",null));
        System.out.println("创建完成");
    }

    @Test
    public void createEchange(){
//        amqpAdmin.declareExchange(new DirectExchange("xiaolan.direct"));
//        amqpAdmin.declareQueue(new Queue("amqpadmin.queue"));
        amqpAdmin.declareBinding(new Binding("amqpadmin.queue",Binding.DestinationType.QUEUE,"xiaolan.direct","amqp.haha",null));
        System.out.println("创建完成");
    }