门户网站开发费需入无形资产,凡客建网站,网站如何提高用户量,外贸网站管理系统1. 数据同步
elasticsearch中的酒店数据来自于mysql数据库#xff0c;因此mysql数据发生改变时#xff0c;elasticsearch也必须跟着改变#xff0c;这个就是elasticsearch与mysql之间的数据同步。 1.1. 思路分析
常见的数据同步方案有三种#xff1a; 同步调用 异步通知…1. 数据同步
elasticsearch中的酒店数据来自于mysql数据库因此mysql数据发生改变时elasticsearch也必须跟着改变这个就是elasticsearch与mysql之间的数据同步。 1.1. 思路分析
常见的数据同步方案有三种 同步调用 异步通知 监听binlog
1.2. 同步调用
方案一同步调用 基本步骤如下 hotel-demo对外提供接口用来修改elasticsearch中的数据 酒店管理服务在完成数据库操作后直接调用hotel-demo提供的接口
优缺点 优点实现简单粗暴 缺点业务耦合度高
1.3. 异步通知
方案二异步通知 流程如下 hotel-admin对mysql数据库数据完成增、删、改后发送MQ消息 hotel-demo监听MQ接收到消息后完成elasticsearch数据修改
优缺点 优点低耦合实现难度一般 缺点依赖mq的可靠性
1.4. 监听binlog
方案三监听binlog: 流程如下 给mysql开启binlog功能 (平时默认关闭 mysql完成增、删、改操作都会记录在binlog中 hotel-demo基于canal监听binlog变化实时更新elasticsearch中的内容
1.5. 总结
实现elasticsearch和数据库数据同步一般有以下三种方法
方式一同步调用 优点实现简单粗暴 缺点业务耦合度高
方式二异步通知 优点低耦合实现难度一般 缺点依赖mq的可靠性
方式三监听binlog 优点完全解除服务间耦合 缺点开启binlog增加数据库负担、实现复杂度高
2. 实现数据同步
2.1. 思路
利用hotel-admin项目作为酒店管理的微服务。当酒店数据发生增、删、改时要求对elasticsearch中数据也要完成相同操作。
步骤 声明exchange、queue、RoutingKey 在hotel-admin中的增、删、改业务中完成消息发送 在hotel-demo中完成消息监听并更新elasticsearch中数据 启动并测试数据同步功能
2.2. hotel-admin
其中包含了酒店的CRUD功能 2.3. 声明交换机和队列
MQ结构如图 2.3.1. 引入依赖
在hotel-admin、hotel-demo中引入rabbitmq的依赖
!--amqp--
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId
/dependency
2.3.2. 声明交换机名称
在hotel-admin和hotel-demo中的cn.itcast.hotel.constatnts包下新建一个类MqConstants 代码如下
public class MqConstants {//交换机名称public final static String HOTEL_EXCHANGE hotel.topic;//监听新增和修改的队列public final static String HOTEL_INSERT_QUEUE hotel.insert.queue;//监听删除的队列public final static String HOTEL_DELETE_QUEUE hotel.delete.queue;//新增或修改的RoutingKeypublic final static String HOTEL_INSERT_KEY hotel.insert;//删除的RoutingKeypublic final static String HOTEL_DELETE_KEY hotel.delete;}
2.3.3. 声明队列交换机
在hotel-demo中建一个config包包下建一个配置类MqConfig声明队列、交换机
package cn.itcast.hotel.config;import cn.itcast.hotel.constants.MqConstants;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 基于Bean的形式生成交换机和队列* 以及将他们绑定*/
Configuration
public class MqConfig {//生成topic交换机Beanpublic TopicExchange topicExchange(){return new TopicExchange(MqConstants.HOTEL_EXCHANGE,true,false);}//insert队列Beanpublic Queue insertQueue(){return new Queue(MqConstants.HOTEL_INSERT_QUEUE,true);}//delete队列Beanpublic Queue deleteQueue(){return new Queue(MqConstants.HOTEL_DELETE_QUEUE,true);}//绑定insert队列和交换机Beanpublic Binding insertQueueBinding(){return BindingBuilder.bind(insertQueue()).to(topicExchange()).with(MqConstants.HOTEL_INSERT_KEY);}//绑定delete队列和交换机Beanpublic Binding deleteQueueBinding(){return BindingBuilder.bind(deleteQueue()).to(topicExchange()).with(MqConstants.HOTEL_DELETE_KEY);}}2.4. 发送MQ消息
在hotel-admin中的增、删、改业务中分别发送MQ消息
2.5. 接受MQ消息
hotel-demo接收到MQ消息要做的事情包括 新增消息根据传递的hotel的id查询hotel信息然后新增一条数据到索引库 删除消息根据传递的hotel的id删除索引库中的一条数据
2.5.1. 添加新增、删除业务
首先在hotel-demo的cn.itcast.hotel.service包下的IHotelService中新增新增、删除业务
void deleteById(Long id);void insertById(Long id);
2.5.2. 实现业务
Override
public void deleteById(Long id) {try {// 1.准备RequestDeleteRequest request new DeleteRequest(hotel, id.toString());// 2.发送请求client.delete(request, RequestOptions.DEFAULT);} catch (IOException e) {throw new RuntimeException(e);}
}Override
public void insertById(Long id) {try {// 0.根据id查询酒店数据Hotel hotel getById(id);// 转换为文档类型HotelDoc hotelDoc new HotelDoc(hotel);// 1.准备Request对象IndexRequest request new IndexRequest(hotel).id(hotel.getId().toString());// 2.准备Json文档request.source(JSON.toJSONString(hotelDoc), XContentType.JSON);// 3.发送请求client.index(request, RequestOptions.DEFAULT);} catch (IOException e) {throw new RuntimeException(e);}
}
2.5.3. 编写监听器
在hotel-demo中的cn.itcast.hotel.mq包新增一个类
package cn.itcast.hotel.mq;import cn.itcast.hotel.constants.MqConstants;
import cn.itcast.hotel.service.IHotelService;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;Component
public class HotelListener {Autowiredprivate IHotelService hotelService;/*** 监听酒店新增或修改的业务* param id 酒店id*/RabbitListener(queues MqConstants.HOTEL_INSERT_QUEUE)public void listenHotelInsertOrUpdate(Long id){hotelService.insertById(id);}/*** 监听酒店删除的业务* param id 酒店id*/RabbitListener(queues MqConstants.HOTEL_DELETE_QUEUE)public void listenHotelDelete(Long id){hotelService.deleteById(id);}
}
这样就可以实现elasticsearch和Mysql数据库的数据同步了
3. 测试
tips记得开启RabbitMQ 我们来测试一下
3.1 启动hotel-demo和hotel-admin服务
访问浏览器 我们看到“上海虹口三至喜来登酒店” 的价格是 1899
我们去酒店管理端修改一下
3.2. 修改操作
打开酒店管理端然后找到该酒店进行修改
我们将价格改为1898 3.3.查看结果
此时可以先打开RabbitMQ的控制台可以看见确实有消息发送了 我们再打开前端页面刷新查看 “上海虹口三至喜来登酒店” 价格确实变成了1898
在此期间我们并未对elasticsearch进行手动修改数据说明我们确实完成了基于MQ的elasticsearch和mysql数据库之间数据的消息同步
