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

网站制作教程一般地建网络百度助手免费下载

news 2025/7/7 3:04:17
网站制作教程一般地建网络,百度助手免费下载,投融资平台,哪个网站可以做相册前言 今天要跟大家分享的是监控数据变化，实现自己的业务的另一个思路，基于数据库的binglog。我这里是用的Binlog4j实现，希望看总结的，直接看最后。 一、Binlog4j是什么？ Binlog4j是轻量级 Mysql Binlog 客户端, 提供宕…

前言

       今天要跟大家分享的是监控数据变化，实现自己的业务的另一个思路，基于数据库的binglog。我这里是用的Binlog4j实现，希望看总结的，直接看最后。

一、Binlog4j是什么？

       Binlog4j是轻量级 Mysql Binlog 客户端, 提供宕机续读, 高可用集群等特性等等。具体看一看它的官网，目前已经出到1.9.0版本，项目加入了Dromara 社区。

二、使用步骤

先说下我这里用上这个的原因：

  • 多个数据增删改触发重新计算
  • 不想在每个业务操作方法后调用重新计算
  • 不想aop切面处理，实现重新计算
  • 不想用springboot的事件、监听实现重新计算
  • 骨子里想创新，接受新事物、新思路
    所以我选择了它，下面我简单介绍下使用。

官网其实有demo，我这里是与springboot集成。

1.引入库

<!-- binlog支持 --><dependency><groupId>com.gitee.Jmysy</groupId><artifactId>binlog4j-spring-boot-starter</artifactId><version>1.9.0</version></dependency>

       mysql的依赖、redis的依赖自行补充。

2.配置文件

spring:  binlog4j:database: 要监听的数据库（一个实例上有多个库）redis-config: #redis配置host: ipport: 端口password: 密码client-configs:master:username: 数据库用户password: 密码host: 数据库ipport: 端口serverId: 1990

配置说明

  • timeOffset 时间偏移量, 单位：毫秒
  • serverId 编号
  • redisConfig Redis 配置信息, 详见 RedisConfig
  • inaugural 首次启动, 如果为 true 在启动时不再读取 Redis 记录
  • persistence 是否启用持久化, 默认为 false
  • strict 严格模式, 默认为 true
  • mode 模式, 详见: BinlogClientMode
  • username 数据库账户
  • password 数据库密码
  • host 数据库所在服务器 IP 地址
  • port 数据库占用端口, 默认 3306
  • hikariConfig 数据库连接池配置

3.统一监听处理

MyBinlogEventHandler


import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import cn.hutool.core.date.StopWatch;
import cn.hutool.json.JSONUtil;
import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
import com.gitee.Jmysy.binlog4j.springboot.starter.annotation.BinlogSubscriber;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import site.morn.rest.RestBuilders;
import site.morn.rest.RestMessage;import javax.annotation.Resource;/*** binlog事件处理器* 连接数据的用户需要有binlog读权限** @author zwmac*/
@Slf4j
@BinlogSubscriber(clientName = "master")
public class MyBinlogEventHandler implements IBinlogEventHandler {@Value("${spring.binlog4j.database:linkappdb}")public String monitorDatabase;@Resourceprivate ProgressWarnService progressWarnService;@Overridepublic void onInsert(BinlogEvent binlogEvent) {//log.info("数据库：" + binlogEvent.getDatabase());//log.info("数据表：" + binlogEvent.getTable());//log.info("插入数据：" + binlogEvent.getData());//需要重新计算场景//1、插入设置 app_progress_warn_config//2、新增实际进度详情 app_progress_real_detail//3、新增进度计划任务（子节点）app_progress_infoRestMessage restMessage = RestBuilders.successMessage();CalProgressWarnVo calVo = new CalProgressWarnVo();calVo.setType(1);String tableName = binlogEvent.getTable();if ("app_progress_warn_config".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(1);ProgressWarnConfig progressWarnConfig = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getData()), ProgressWarnConfig.class, true, CopyOptions.create().ignoreNullValue());calVo.setNewData(progressWarnConfig);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("新增[进度预警配置]数据触发binlog事件执行结果:{}-耗时:{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}if ("app_progress_real_detail".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(2);ProgressRealDetail realDetail = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getData()), ProgressRealDetail.class, true, CopyOptions.create().ignoreNullValue());calVo.setNewData(realDetail);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("新增[实际进度详情]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}if ("app_progress_info".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();Object progressInfoObj = binlogEvent.getData();ProgressInfo progressInfo = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getData()), ProgressInfo.class, true, CopyOptions.create().ignoreNullValue());if (progressInfo.getType() == 2) {//计划任务才需要重新计算calVo.setDataType(3);calVo.setNewData(progressInfo);restMessage = progressWarnService.calProgressWarn(calVo);}sw.stop();log.info("新增[进度任务]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}}@Overridepublic void onUpdate(BinlogEvent binlogEvent) {//log.info("数据库：" + binlogEvent.getDatabase());//log.info("数据表：" + binlogEvent.getTable());//log.info("原数据：" + binlogEvent.getOriginalData());//log.info("新数据：" + binlogEvent.getData());//需要重新计算场景//1、设置表变更 app_progress_warn_config//2、进度详情记录变更 app_progress_real_detail//3、进度计划任务变更（计划开始时间、计划结束时间、工期）app_progress_infoRestMessage restMessage = null;CalProgressWarnVo calVo = new CalProgressWarnVo();calVo.setType(2);String tableName = binlogEvent.getTable();if ("app_progress_warn_config".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(1);ProgressWarnConfig oldConfig = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getOriginalData()), ProgressWarnConfig.class, true, CopyOptions.create().ignoreNullValue());ProgressWarnConfig newConfig = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getData()), ProgressWarnConfig.class, true, CopyOptions.create().ignoreNullValue());calVo.setNewData(newConfig);calVo.setOldData(oldConfig);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("修改[进度预警配置]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}if ("app_progress_real_detail".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(2);ProgressRealDetail oldDetail = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getOriginalData()), ProgressRealDetail.class, true, CopyOptions.create().ignoreNullValue());ProgressRealDetail newDetail = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getData()), ProgressRealDetail.class, true, CopyOptions.create().ignoreNullValue());calVo.setNewData(newDetail);calVo.setOldData(oldDetail);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("修改[进度详情]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}if ("app_progress_info".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(3);ProgressInfo oldInfo = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getOriginalData()), ProgressInfo.class, true, CopyOptions.create().ignoreNullValue());ProgressInfo newInfo = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getData()), ProgressInfo.class, true, CopyOptions.create().ignoreNullValue());calVo.setNewData(newInfo);calVo.setOldData(oldInfo);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("修改[进度计划任务]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}}@Overridepublic void onDelete(BinlogEvent binlogEvent) {//log.info("数据库：" + binlogEvent.getDatabase());//log.info("数据表：" + binlogEvent.getTable());//log.info("删除数据：" + binlogEvent.getData());//需要重新计算场景//1、删除进度详情记录 app_progress_real_detail//2、删除进度任务（子节点）app_progress_infoRestMessage restMessage = null;CalProgressWarnVo calVo = new CalProgressWarnVo();calVo.setType(3);String tableName = binlogEvent.getTable();if ("app_progress_real_detail".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(2);ProgressRealDetail oldDetail = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getOriginalData()), ProgressRealDetail.class, true, CopyOptions.create().ignoreNullValue());calVo.setOldData(oldDetail);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("删除[进度详情]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}if ("app_progress_info".equals(tableName)) {StopWatch sw = new StopWatch();sw.start();calVo.setDataType(3);ProgressInfo oldInfo = BeanUtil.mapToBean(JSONUtil.parseObj(binlogEvent.getOriginalData()), ProgressInfo.class, true, CopyOptions.create().ignoreNullValue());calVo.setOldData(oldInfo);restMessage = progressWarnService.calProgressWarn(calVo);sw.stop();log.info("删除[进度计划任务]数据触发binlog事件执行结果:{}-耗时{}ms", restMessage.getCode(), sw.getTotalTimeMillis());}}@Overridepublic boolean isHandle(String database, String table) {//log.info("database:{},table:{}", database, table);//只监控aep数据库if (monitorDatabase.equals(database)) {return true;}return false;}}

CalProgressWarnVo

import lombok.Data;/*** 计算进度预警参数Vo** @author zwmac*/
@Data
public class CalProgressWarnVo {/*** 类型：1新增，2变更,3删除*/private Integer type;/*** 数据类型：1进度预警配置，2进度详情,3进度计划任务*/private Integer dataType;/*** 旧数据*/private Object oldData;/*** 新数据*/private Object newData;}

       从入参可以看出3类数据增删改都触发重新计算，这里的oldData、newData可以直接用于修改的时候传参，不用在查一次数据库。

progressWarnService.calProgressWarn(calVo);就是重新计算的具体实现了，这就涉及到业务了，各位自己实现。

总结

  • 配置的账号要有binlog的读权限
  • 项目在跑，直接用其他工具操作数据库，也可以触发（这就是监听binlog的美妙）
  • 其他项目操作本项目的表，也可以监听到（原理同上）
  • 统一入口，不用有aop、事件、业务调用那么多入口需要考虑
           好了，就写到这里，希望可以帮到大家，拥抱新事物，uping！
http://www.hrbkazy.com/news/12451.html

相关文章：

  • 公司官网建设宁波seo在线优化
  • 门户网站开发java网站排名优化软件联系方式
  • 高密做网站的公司网站设计的毕业论文
  • 在线制作gif宁波seo快速优化
  • 天津外贸公司网站制作seo任务
  • 怎么在网站文本框内做超连接被国家禁止访问的网站怎么打开
  • 学做网站后台开发好网站
  • 网页设计与制作一课一文深圳最好的外贸seo培训
  • 网站建设人员岗位设置小程序制作流程
  • 济南高端网站设计建设做游戏推广一个月能拿多少钱
  • 商业网站建设开发如何进行推广
  • 网络服务提供者接到权利人的通知后未及时采取必要措施百度seo关键词报价
  • 夫妻性做受视频什么网站市场营销模式有哪些
  • 营销网站模板htlm河南网站关键词优化
  • 菏泽做网站推广2020最成功的网络营销
  • 网站开发可以申请著作权吗seo搜索引擎优化费用
  • 网站的按钮怎么做全球搜索引擎排名2022
  • 如何做网站流量买卖seo基本步骤
  • 建设网站公司哪家性价比高关键词排名优化品牌
  • 微信分销算b2c网站吗深圳百度seo公司
  • 万峰科技.jsp网站开发四酷全书[m]百度app下载安装官方免费下载
  • 网站做零售宁波seo推广咨询
  • 做计算机题的网站螺蛳粉营销策划方案
  • 微网站 建设方案百度广告投诉电话
  • 做银行设计有好的网站参考吗免费自助建站平台
  • 移动电商网站开发需求网络营销十大成功案例
  • 工程公司转让惠州seo招聘
  • 购物返利网站怎么做定制网站建设推广服务
  • 网站开发运行环境全国最新疫情最新消息
  • 自己做的网站能卖么搜索引擎优化期末考试答案