首页 > 数据库 >Elasticsearch与MySql实现数据同步

Elasticsearch与MySql实现数据同步

时间:2023-06-04 20:11:17浏览次数:47  
标签:同步 spring boot host Elasticsearch MySql 服务端

选择方案
基于RabbitMq的异步通知

流程如下:

  • 管理端对mysql数据库数据完成增、删、改后,发送MQ消息
  • 服务端监听MQ,接收到消息后完成elasticsearch数据修改

优点:低耦合,实现难度一般
缺点:依赖mq的可靠性

实现步骤

  1. 在管理端和服务端都导入依赖坐标和配置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 # 密码
  1. 在服务端配置交换机,一个用于新增和更新,一个用于删除。
  2. 在管理端发送消息给服务端。
  3. 服务端编写监听管理端的代码。

标签:同步,spring,boot,host,Elasticsearch,MySql,服务端
From: https://www.cnblogs.com/wzh-Official/p/17456081.html

相关文章

  • Install Elasticsearch 2.x on CentOS 6 by rpm
     http://techieroop.com/install-elasticsearch-2-x-on-centos-6/ ThisarticlewillcoverinstallElasticsearch2.xversiononCentOS6.AlsoguidelinetochangetoDefaultClusterandIndexsettingsinElasticsearch2.x.SoLet’sstartwithprerequisitesPrer......
  • Mysql && Oracle case when用法
    CASEWHEN1.对值判断2.条件判断--方式一:对值判断SELECTCASE 指定字段 WHEN条件值1THEN 结果1 WHEN条件值2THEN 结果2 WHEN条件值3THEN 结果3 ELSE默认值 END字段别名FROM 表名SELECTCASE STATUS WHEN0THEN '等待' WHEN1THEN ......
  • Mysql如何新建一个用户并赋予视图权限
    Mysql如何新建一个用户并赋予视图权限 --新建用户CREATEUSER'viewUser'@'%'IDENTIFIEDBY'password'; -- 赋予视图权限GRANTSELECT,SHOWVIEWON`views`TO'viewUser'@'%' -- 并把视图内容关系到的表权限赋予新用户GRANTSELECTON`tableName`......
  • postgresql 集群和同步以及企业解决方案
    pgpool-II入门教程[url]http://www.pgpool.net/docs/latest/tutorial-zh_cn.html[/url],集群教程[size=medium][color=red][b]方案1:pgpool[/b][/color][/size]pgpool:设置简单,实现SharedNothing的双机写入同步,及查询负载均衡。也可结合Slony实现双机异步复制,提高写数据性能。......
  • MYSQL级联查询,包括向上向下的级联
    --名称:mysql递归查询存储过程(2014-04-05)--入:@table表名[varchar(200)]--入:@field要查询返回的字段名(例如:name,age,remark)[text]--入:@order返回结果的排序(例如namedesc,ageasc)[text]--入:@idName主键列名[varchar(200)]--入:@pidName父键列名[var......
  • MySQL逻辑架构图
    整体架构MySQL可以分为Server层和存储引擎层两部分。不同的存储引擎(不同的表可以设置不同的存储引擎)共用一个Server层(从连接器到执行器)。查询流程连接器Command列显示Sleep表示空闲连接。如果客户端太长时间没动静,那么连接器会自动将它断开,由参数wait_timeout控制,默认值是8......
  • 数据库管理工具远程连接MySQL实例服务失败Host ... is not allowed to connect to thi
    MySQL社区版数据库8.0版本添加账号、分配权限、删除账号MySQL安全连接失败问题排查......
  • 4、数据库:MySQL部署 - 系统部署系列文章
          MySQL数据库在其它博文中有介绍,包括学习规划系列。今天就讲讲MySQL的部署事情。一、先下载MySQL数据库;到下面这个网址去下载数据库,这里下载的社区版:https://dev.mysql.com/downloads/installer/二、安装数据库;打开EXE文件;       ......
  • mysql-5.6.13在windows平台下的安装、使用(图解)
    一、首先电脑要具备.NetFramework4以上环境二、MySQL下载、安装、执行1.下载http://cdn.mysql.com/Downloads/MySQL-5.6/mysql-5.6.13-win32.zip2.安装点击“installMySQLproducts”选中“Iacceptthelicenceterms”,点击next选中“Skipthecheckforupdate......
  • Mysql索引类型介绍
    1.定义索引(index)是帮助Mysql高效获取数据的数据结构2.分类主键索引(Primarykey)唯一的标识,主键不可重复,一个表中只能有一个列作为主键唯一索引(Uniquekey)不能重复,一个表中多个列可以标识为唯一索引常规索引(key/index)默认的索引,可以重复,多个列可以标识为常规......