当前位置：首页 > news >正文

eblog搜索引擎架构：RabbitMQ+Elasticsearch实现高效全文检索

news 2026/3/26 20:37:25

eblog搜索引擎架构：RabbitMQ+Elasticsearch实现高效全文检索

【免费下载链接】eblogeblog是一个基于Springboot2.1.2开发的博客学习项目，为了让项目融合更多的知识点，达到学习目的，编写了详细的从0到1开发文档。主要学习包括：自定义Freemarker标签，redis的zset结构完成本周热议排行榜，t-io+websocket完成即时消息通知和群聊，rabbitmq+elasticsearch完成博客内容搜索引擎等。值得学习的地方很多！项目地址: https://gitcode.com/gh_mirrors/eb/eblog

eblog是一个基于Springboot2.1.2开发的博客学习项目，其搜索引擎架构采用RabbitMQ+Elasticsearch实现高效全文检索功能，为用户提供快速、准确的内容搜索体验。

搜索引擎架构设计概述

eblog的搜索引擎架构核心在于将消息队列与全文检索引擎相结合，形成一个异步、高效、可扩展的搜索系统。这种架构不仅能够处理大量的博客内容索引需求，还能保证搜索服务的稳定性和响应速度。

图：eblog搜索引擎架构采用RabbitMQ+Elasticsearch实现高效数据流转与检索

RabbitMQ消息队列配置与实现

在eblog项目中，RabbitMQ的配置主要集中在RabbitConfig.java文件中。该配置定义了用于搜索引擎的队列、交换机和绑定关系：

public final static String es_queue = "es_queue"; public final static String es_exchage = "es_exchage"; public final static String es_bind_key = "es_exchage"; @Bean public Queue exQueue() { return new Queue(es_queue); } @Bean DirectExchange exchange() { return new DirectExchange(es_exchage); } @Bean Binding binding(Queue exQueue, DirectExchange exchange) { return BindingBuilder.bind(exQueue).to(exchange).with(es_bind_key); }

消息处理机制

消息处理由MqMessageHandler.java类负责，通过@RabbitListener注解监听指定队列：

@RabbitListener(queues = RabbitConfig.es_queue) public class MqMessageHandler { @Autowired SearchService searchService; @RabbitHandler public void handler(PostMqIndexMessage message) { log.info("mq 收到一条消息： {}", message.toString()); switch (message.getType()) { case PostMqIndexMessage.CREATE_OR_UPDATE: searchService.createOrUpdateIndex(message); break; case PostMqIndexMessage.REMOVE: searchService.removeIndex(message); break; default: log.error("没找到对应的消息类型，请注意！！ --》 {}", message.toString()); break; } } }

消息实体设计

PostMqIndexMessage.java定义了消息实体，包含操作类型和文章ID：

@Data @AllArgsConstructor public class PostMqIndexMessage implements Serializable { public final static String CREATE_OR_UPDATE = "create_update"; public final static String REMOVE = "remove"; private Long postId; private String type; }

Elasticsearch文档模型

PostDocment.java定义了Elasticsearch中的文档结构，使用IK分词器优化中文搜索：

@Document(indexName="post", type="post", createIndex=true) public class PostDocment implements Serializable { @Id private Long id; @Field(type = FieldType.Text, searchAnalyzer="ik_smart", analyzer = "ik_max_word") private String title; @Field(type = FieldType.Long) private Long authorId; @Field(type = FieldType.Keyword) private String authorName; private String authorAvatar; // 其他字段... }