主流的网站开发语言如何申请自己的个人网站

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

主流的网站开发语言,如何申请自己的个人网站,网站栏目合理性,做网站导出用什么色彩模式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增加数据库负担、实现复杂度高

1. 实现数据同步 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数据库的数据同步了
2. 测试 tips记得开启RabbitMQ 我们来测试一下 3.1 启动hotel-demo和hotel-admin服务 访问浏览器 我们看到“上海虹口三至喜来登酒店” 的价格是 1899 我们去酒店管理端修改一下 3.2. 修改操作 打开酒店管理端然后找到该酒店进行修改 我们将价格改为1898 3.3.查看结果 此时可以先打开RabbitMQ的控制台可以看见确实有消息发送了 我们再打开前端页面刷新查看 “上海虹口三至喜来登酒店” 价格确实变成了1898 在此期间我们并未对elasticsearch进行手动修改数据说明我们确实完成了基于MQ的elasticsearch和mysql数据库之间数据的消息同步