选择方案
基于RabbitMq的异步通知
流程如下:
- 管理端对mysql数据库数据完成增、删、改后,发送MQ消息
- 服务端监听MQ,接收到消息后完成elasticsearch数据修改
优点:低耦合,实现难度一般
缺点:依赖mq的可靠性
实现步骤
- 在管理端和服务端都导入依赖坐标和配置application.yml文件
点击查看代码
<!--amqp-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
点击查看代码
spring:
rabbitmq:
host: 192.168.136.50 # 主机名
port: 5672 # 端口
virtual-host: / # 虚拟主机
username: wzh# 用户名
password: 1234 # 密码
- 在服务端配置交换机,一个用于新增和更新,一个用于删除。
- 在管理端发送消息给服务端。
- 服务端编写监听管理端的代码。