今天介绍用Flink读取Kafka生成的数据，并进行汇总的案例第一步：环境准备，kafka，flink，zookeeper。我这边是用的CDH环境，kafka跟zookeeper都安装完毕，并测试可以正常使用第二步：用kafka创建一个生产者进行消息生产./kafkaconsoleproducer.shbroker

1Checksum1.1checksum原理checksumtable的原理是对表中的数据进行一行一行的较验和计算,在执行checksum命令时，表会被加一个读锁(readlock)，因此对于大表，这是一个很耗时的过程。读锁：又叫S锁/共享锁；当MySQL

前言　　1）在数据库的锁机制中介绍过，数据库管理系统（DBMS）中的并发控制的任务是确保在多个事务同时存取数据库中同一数据时不破坏事务的隔离性和一致性以及数据库的一致性。　　2）加锁是为了解决更新丢失问题更新丢失　　两次更新同时进行，后一次更新覆盖了前一次更新的情况，更新丢失是数据没有保证一致性导致的。事务A查询余额，

前言Java中的 synchronized关键字可以在多线程环境下用来作为线程安全的同步锁。本文不讨论 synchronized 的具体使用，而是研究下synchronized底层的锁机制，以及这些锁分别的优缺点。一、synchronized机制synchro

一般用ReentrantLock的方式如下：//新建非公平锁实例LocklocknewReentrantLock();//新建非公平锁实例//LocklocknewReentrantLock(true);//加锁lock.lock();try{

自旋锁是采用让当前线程不停地的在循环体内执行实现的，当循环的条件被其他线程改变时才能进入临界区。JDK里面自旋锁的实现有SynchronousQueue 和LinkedTransferQueue。 本文只是自己对源码的简单理解。先说公平锁，先等待的线程先获得数据。SynchronousQueue的内部类TransferQueue实现了公平锁。

★1\表级锁情况SHOWSTATUSLIKE'table%';\行级锁情况SHOWSTATUSLIKE'innodb\_row\_lock%';\进程列表SHOWPROCESSLIST;SHOWSTATUS;★locate和instr和regexp

先把zookeeper在本地给安装好，这里的话讲述了两个工程一个工程是提供服务的，一个工程是调用服务的，因为dubbo是跟spring进行无缝连接的，故功能配置在spring的配置文件中，跟spring进行整合开发1、工程是以maven进行构建的，使用的jar包如下：!(https://static.oschina.net/uploads/i

一、zookeeper宕机现象：zookeeper注册中心宕机，还可以消费dubbo暴露的服务健壮性监控中心宕掉不影响使用，只是丢失部分采样数据数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务注册中心对等集群，任意一台宕掉后，将

01为什么要用锁？锁是为了解决并发操作引起的脏读、数据不一致的问题。02 锁实现的基本原理2.1、volatileJava编程语言允许线程访问共享变量，为了确保共享变量能被准确和一致地更新，线程应该确保通过排他锁单独获得这个变量。Java语言提供了volatile，在某些