业务需求:
-
1、商品上架时:search-service新增商品到elasticsearch
-
2、商品下架时:search-service删除elasticsearch中的商品
需求分析:
数据同步是希望,当我们商品修改了数据库中的商品信息,索引库中的信息也会跟着改。在微服务中数据库和索引库是在两个不同的服务中。如果,商品的服务,向es的服务中发个消息,通知ES服务就可以实现数据的同步。此时我们利用MQ接收商品服务的消息,实现ES服务对消息的监听就可以了。
业务模型:
文章来源:https://www.toymoban.com/news/detail-531250.html
业务实现:
商品微服务:消息发送
pom.xml文章来源地址https://www.toymoban.com/news/detail-531250.html
1.引入amqp依赖
<!--amqp-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
2.application.yml文件中配置MQ的地址(5大参数)
到了这里,关于企业级开发项目实战——基于RabbitMQ实现数据库、elasticsearch的数据同步的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!