一、Zookeeper概述 1.1 概述
美团，饿了么，淘宝，58同城等等应用都是zookeeper的现实生活版
老孙我开了个饭店，如何才能让大家都能吃到我们的饭菜？需要入驻美团，这样大家就可以在美团
app中看到我的饭店，下订单，从而完成一次交易
Zookeeper是一个开源的分布式（多台服务器干一件事）的，为分布式应用提供协调服务的
在大数据技术生态圈中，zookeeper（动物管理员），Hadoop（大象），Hive（蜜蜂），Pig（猪）等技术
1.2 工作机制
Zookeeper从设计模式角度来理解：是一个基于观察者模式（一个人干活，有人盯着他）设计的分布式服务管理框架
它负责 存储 和 管理 大家都关心的数据
然后接受观察者的注册，一旦这些数据的发生变化
Zookeeper就将负责通知已经注册的那些观察者做出相应的反应
从而实现集群中类似Master/Slave管理模式
Zookeeper = 文件系统 + 通知机制
商家营业并入驻
获取到当前营业的饭店列表
服务器节点下线
服务器节点上下线事件通知
重新再去获取服务器列表，并注册监听
1.3 特点 分布式和集群的区别？
无论分布式和集群，都是很多人在做事情。具体区别如下：
例如：我有一个饭店，越来越火爆，我得多招聘一些工作人员
分布式：招聘1个厨师，1个服务员，1个前台，三个人负责的工作不一样 ，但是最终目的都是为饭店工作
集群：招聘3个服务员，3个人的工作一样
1.4 数据结构
ZooKeeper数据模型的结构与linux文件系统很类似，整体上可以看作是一棵树，每个节点称做一个ZNode（ZookeeperNode）。
每一个ZNode默认能够存储1MB的数据（元数据），每个ZNode的路径都是唯一的
元数据（Metadata），又称中介数据、中继数据，为描述数据的数据（data about data），主要是描述数据属性（property）的信息，用来支持如指示存储位置、历史数据、资源查找、文件记录等功能
1.5 应用场景
提供的服务包括：统一命名服务、统一配置管理、统一集群管理、服务器节点动态上下线、软负载均衡等
1.5.1 统一命名服务
在分布式环境下，通常需要对应用或服务进行统一的命名，便于识别
例如：服务器的IP地址不容易记，但域名相比之下却是很容易记住
1.5.2 统一配置管理
分布式环境下，配置文件做同步是必经之路
1000台服务器，如果配置文件作出修改，那一台一台的修改，运维人员肯定会疯，如何做到修改一处就快速同步到每台服务器上
将配置管理交给Zookeeper
将配置信息写入到Zookeeper的某个节点上
每个客户端都监听这个节点
一旦节点中的数据文件被修改，Zookeeper这个话匣子就会通知每台客户端服务器
1.5.3 服务器节点动态上下线
客户端能实时获取服务器上下线的变化
在美团APP上实时可以看到商家是否正在营业或打样
1.5.4 软负载均衡
Zookeeper会记录每台服务器的访问数，让访问数最少的服务器去处理最新的客户请求（雨露均沾）
都是自己的孩子，得一碗水端平
1.6 下载地址 镜像库地址：http://archive.apache.org/dist/zookeeper/
apache-zookeeper-3.6.0.tar.gz需要安装maven，然后再运行mvn clean install 和mvnjavadoc:aggregate，前一个命令会下载安装好多jar包，不知道要花多长时间
apache-zookeeper-3.6.0-bin.tar.gz已经自带所需要的各种jar包
二、Zookeeper本地模式安装 2.1 本地模式安装 2.1.1 安装前准备
安装jdk
拷贝apache-zookeeper-3.6.0-bin.tar.gz到opt目录
解压安装包
1 [root@localhost opt]# tar -zxvf apache-zookeeper-3.6.0-bin.tar.gz
重命名
1 [root@localhost opt]# mv apache-zookeeper-3.6.0-bin zookeeper
2.1.2 配置修改 1、在/opt/zookeeper/这个目录上创建zkData和zkLog目录
1 2 [root@localhost zookeeper]# mkdir zkData [root@localhost zookeeper]# mkdir zkLog
2、进入/opt/zookeeper/conf这个路径，复制一份 zoo_sample.cfg 文件并命名为 zoo.cfg
1 [root@localhost conf]# cp zoo_sample.cfg zoo.cfg
3、编辑zoo.cfg文件，修改dataDir路径：
1 2 dataDir =/ opt/zookeeper/zkDatadataLogDir =/ opt/zookeeper/zkLog
2.1.3 操作Zookeeper 1、启动Zookeeper
1 [root@localhost bin]# ./zkServer.sh start
2、查看进程是否启动
1 [root@localhost bin]# jps
QuorumPeerMain：是zookeeper集群的启动入口类，是用来加载配置启动QuorumPeer线程的
3、查看状态：
1 [root@localhost bin]# ./zkServer.sh status
4、启动客户端
1 [root@localhost bin]# ./zkCli.sh
5、退出客户端
1 [zk: localhost:2181 (CONNECTED) 0 ] quit
2.2 配置参数解读 Zookeeper中的配置文件zoo.cfg中参数含义解读如下：
三、Zookeeper内部原理 3.1 选举机制（面试重点）
半数机制：集群中半数以上机器存活，集群可用。所以Zookeeper适合安装奇数台服务器
虽然在配置文件中并没有指定Master和Slave。但是，Zookeeper工作时，是有一个节点为
Server1先投票，投给自己 ，自己为1票，没有超过半数，根本无法成为leader，顺水推舟将票数投给了id比自己大的Server2
Server2也把自己的票数投给了自己，再加上Server1给的票数，总票数为2票，没有超过半数，也无法成为leader，也学习Server1，顺水推舟，将自己所有的票数给了id比自己大的Server3
Server3得到了Server1和Server2的两票，再加上自己投给自己的一票。3票超过半数，顺利成为leader
Server4和Server5都投给自己，但是无法改变Server3的票数，只好听天由命，承认Server3是leader
3.2 节点类型
持久型（persistent）：
持久化目录节点 （persistent）客户端与zookeeper断开连接后，该节点依旧存在持久化顺序编号目录节点 （persistent_sequential）客户端与zookeeper断开连接后，该节点依旧存在，创建znode时设置顺序 标识，znode名称后会附加一个值，顺序号是一个单调递增的计数器，由父节点维护，例如：Znode001，Znode002…
短暂型（ephemeral）：
临时目录节点 （ephemeral）客户端和服务器端断开连接后，创建的节点自动删除临时顺序编号目录节点 （ephemeral_sequential）客户端与zookeeper断开连接后，该节点被删除，创建znode时设置顺序 标识，znode名称后会附加一个值，顺序号是一个单调递增的计数器，由父节点维护，例如：Znode001，Znode002…
注意：序号是相当于i++，和数据库中的自增长类似
3.3 监听器原理（面试重点）
在main方法中创建Zookeeper客户端的同时就会创建两个线程，一个负责网络连接通信，一个负责监听
监听事件就会通过网络通信发送给zookeeper
zookeeper获得注册的监听事件后，立刻将监听事件添加到监听列表里
zookeeper监听到 数据变化 或 路径变化，就会将这个消息发送给监听线程
监听节点数据的变化：get path [watch]
监听子节点增减的变化：ls path [watch]
监听线程就会在内部调用process方法（需要我们实现process方法内容）
3.4 写数据流程
Client 想向 ZooKeeper 的 Server1 上写数据，必须的先发送一个写的请求
如果Server1不是Leader，那么Server1 会把接收到的请求进一步转发给Leader。
这个Leader 会将写请求广播给各个Server，各个Server写成功后就会通知Leader。
当Leader收到半数以上的 Server 数据写成功了，那么就说明数据写成功了。
随后，Leader会告诉Server1数据写成功了。
Server1会反馈通知 Client 数据写成功了，整个流程结束
四、Zookeeper实战（开发重点） 这里是用虚拟机做的演示
4.1 分布式安装部署 集群思路：先搞定一台服务器，再克隆出两台，形成集群！
4.1.1 安装zookeeper
4.1.2 配置服务器编号
在/opt/zookeeper/zkData创建myid文件
1 [root@localhost zkData]# vim myid
在文件中添加与server对应的编号：1
其余两台服务器分别对应2和3
4.1.3 配置zoo.cfg文件
1 2 3 4 #######################cluster########################## server.1 =192.168 .204 .141 :2888 :3888 server.2 =192.168 .204 .142 :2888 :3888 server.3 =192.168 .204 .143 :2888 :3888
4.1.4 配置其余两台服务器
在虚拟机数据目录vms下，创建zk02
将本台服务器数据目录下的.vmx文件和所有的.vmdk文件分别拷贝zk02下
虚拟机->文件->打开 （选择zk02下的.vmx文件）
开启此虚拟机，弹出对话框，选择“我已复制该虚拟机”
进入系统后，修改linux中的ip，修改/opt/zookeeper/zkData/myid中的数值为2
第三台服务器zk03,重复上面的步骤
4.1.5 集群操作
1 [root@localhost bin]# systemctl stop firewalld.service
1 [root@localhost bin]# ./zkServer.sh start
1 [root@localhost bin]# ./zkServer.sh status
1 2 3 4 ZooKeeper JMX enabled by default Using config: /opt/zookeeper/bin/../conf/zoo.cfg Client port found: 2181. Client address: localhost. Error contacting service. It is probably not running.
注意：因为没有超过半数以上的服务器，所以集群失败 （防火墙没有关闭也会导致失败）
当启动第2台服务器时
查看第1台的状态：Mode: follower
查看第2台的状态：Mode: leader
4.2 客户端命令行操作
1 [root@localhost bin]# ./zkCli.sh
信息字段
意思
cZxid
创建节点的事务:每次修改ZooKeeper状态都会收到一个zxid形式的时间戳，也就是ZooKeeper事务ID。事务ID是ZooKeeper中所有修改总的次序。每个修改都有唯一的zxid，如果zxid1小于zxid2，那么zxid1在zxid2之前发生。
ctime
被创建的毫秒数(从1970年开始)
mZxid
最后更新的事务zxid
mtime
最后修改的毫秒数(从1970年开始)
pZxid
最后更新的子节点zxid
cversion
创建版本号，子节点修改次数
dataVersion
数据变化版本号
aclVersion
权限版本号
ephemeralOwner
如果是临时节点，这个是znode拥有者的session id。如果不是临时节点则是0。
dataLength
数据长度
numChildren
子节点数
分别创建2个普通节点
1 2 create /china create /usa
在根目录下，创建俄罗斯节点，并保存“普京”数据到节点上
多级创建节点
在中国节点下，创建武汉”下雨”
china必须提前创建好，否则会报错“节点不存在”
1 create /china/ wuhan "下雨"
获得节点的值
创建短暂节点：创建成功之后，quit退出客户端，重新连接，短暂的节点消失
1 2 3 4 create -e /uk ls / quit ls /
创建带序号的节点
1 2 3 create -s /ru/city ls /ru[city0000000000, city0000000001, city0000000002]
如果原来没有序号节点，序号从0开始递增。
如果原节点下已有2个节点，则再排序时从2开始，以此类推
修改节点数据值
监听 节点的值变化 或 子节点变化（路径变化）
在server3主机上注册监听/usa节点的数据变化
删除节点
不仅删除/ru，而且/ru下的所有子节点也随之删除
4.3 API应用 4.3.1 IDEA环境搭建 1) 创建一个Maven工程
2) 添加pom文件
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 <dependencies > <dependency > <groupId > org.apache.logging.log4j</groupId > <artifactId > log4j-core</artifactId > <version > 2.8.2</version > </dependency > <dependency > <groupId > org.apache.zookeeper</groupId > <artifactId > zookeeper</artifactId > <version > 3.6.0</version > </dependency > <dependency > <groupId > junit</groupId > <artifactId > junit</artifactId > <version > 4.12</version > </dependency > </dependencies >
3) 在resources下创建log4j.properties
1 2 3 4 5 6 7 8 log4j.rootLogger =INFO, stdout log4j.appender.stdout =org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout =org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern =%d %p [%c] - %m%n log4j.appender.logfile =org.apache.log4j.FileAppender log4j.appender.logfile.File =target/zk.log log4j.appender.logfile.layout =org.apache.log4j.PatternLayout log4j.appender.logfile.layout.ConversionPattern =%d %p [%c] - %m%n
4.3.2 创建ZooKeeper客户端 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 public class TestZK { private String connStr = "192.168.249.81:2181,192.168.249.82:2181,192.168.249.83:2181" ; private int sessionTimeout = 60000 ; @Test public void init () throws IOException { Watcher watcher = new Watcher () { public void process (WatchedEvent watchedEvent) { } }; ZooKeeper zk = new ZooKeeper (connStr, sessionTimeout, watcher); } }
4.3.3 创建节点 一个ACL对象就是一个Id和permission对
表示哪个/哪些范围的Id（Who）在通过了怎样的鉴权（How）之后，就允许进行那些操作（What）：Who How What；
permission（What）就是一个int表示的位码，每一位代表一个对应操作的允许状态。
类似linux的文件权限，不同的是共有5种操作：CREATE、READ、WRITE、DELETE、ADMIN(对应更改ACL的权限)
OPEN_ACL_UNSAFE：创建开放节点，允许任意操作 （用的最少，其余的权限用的很少）
READ_ACL_UNSAFE：创建只读节点
CREATOR_ALL_ACL：创建者才有全部权限
1 2 3 4 5 6 7 8 9 10 11 12 13 14 @Before public void init () throws IOException{ } @Test public void createNode () throws Exception { String nodeCreated = zKcli.create("/lagou" , "laosun" .getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); System.out.println("nodeCreated = " + nodeCreated); }
4.3.4 查询节点的值 1 2 3 4 5 6 7 @Test public void find () throws Exception{ byte [] bs = zKcli.getData("/lagou" , false , new Stat ()); String data = new String (bs); System.out.println("查询到数据：" +data); }
4.3.5 修改节点的值 1 2 3 4 5 6 @Test public void update () throws Exception{ Stat stat = zKcli.setData("/lagou" , "laosunA" .getBytes(), 0 ); System.out.println(stat); }
4.3.6 删除节点 1 2 3 4 5 6 @Test public void delete () throws Exception { zKcli.delete("/lagou" , 1 ); System.out.println("删除成功！" ); }
4.3.7 获取子节点 1 2 3 4 5 6 7 8 @Test public void getChildren () throws Exception { List<String> children = zKcli.getChildren("/" ,false ); for (String child : children) { System.out.println(child); } }
4.3.8 监听子节点的变化 1 2 3 4 5 6 7 8 9 10 @Test public void getChildren () throws Exception { List<String> children = zKcli.getChildren("/" , true ); for (String child : children) { System.out.println(child); } System.in.read(); }
程序在运行的过程中，我们在linux下创建一个节点
IDEA的控制台就会做出响应：NodeChildrenChanged–/
4.3.9 判断Znode是否存在 1 2 3 4 5 @Test public void exist () throws Exception { Stat stat = zKcli.exists("/lagou" , false ); System.out.println(stat == null ? "不存在" : "存在" ); }
4.4 案例1：模拟美团商家上下线 4.4.1 需求
模拟美团服务平台，商家营业通知，商家打烊通知
提前在根节点下，创建好 /meituan 节点
4.4.2 商家服务类1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 public class ShopServer { private static String connectString = "192.168.204.141:2181,192.168.204.142:2181,192.168.204.143:2181" ; private static int sessionTimeout = 60000 ; private ZooKeeper zk = null ; public void getConnect () throws IOException { zk = new ZooKeeper (connectString, sessionTimeout, new Watcher () { public void process (WatchedEvent event) { } } ); } public void register (String ShopName) throws Exception { String create = zk.create("/meituan/Shop" , ShopName.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); System.out.println("【" +ShopName+"】 开始营业！ " + create); } public void business (String ShopName) throws Exception { System.out.println("【" +ShopName+"】 正在营业中 ..." ); System.in.read(); } public static void main (String[] args) throws Exception { ShopServer shop = new ShopServer (); shop.getConnect(); shop.register(args[0 ]); shop.business(args[0 ]); } }
4.4.3 客户类 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 public class Customers { private static String connectString = "192.168.204.141:2181,192.168.204.142:2181,192.168.204.143:2181" ; private static int sessionTimeout = 60000 ; private ZooKeeper zk = null ; public void getConnect () throws IOException { zk = new ZooKeeper (connectString, sessionTimeout, new Watcher () { public void process (WatchedEvent event) { try { getShopList(); } catch (Exception e) { e.printStackTrace(); } } } ); } public void getShopList () throws Exception { List<String> shops = zk.getChildren("/meituan" , true ); ArrayList<String> shoplist = new ArrayList (); for (String shop : shops) { byte [] data = zk.getData("/meituan/" + shop, false , new Stat ()); shoplist.add(new String (data)); } System.out.println(shoplist); } public void business () throws Exception { System.out.println("客户正在浏览商家 ..." ); System.in.read(); } public static void main (String[] args) throws Exception { Customers client = new Customers (); client.getConnect(); client.getShopList(); client.business(); } }
1）运行客户类，就会得到商家列表
2）首先在linux中添加一个商家，然后观察客户端的控制台输出（商家列表会立刻更新出最新商家），多添加几个，也会实时输出商家列表
1 2 3 create /meituan/ KFC "KFC" create /meituan/ BKC "BurgerKing" create /meituan/ baozi "baozi"
3）在linux中删除商家，在客户端的控制台也会实时看到商家移除后的最新商家列表
4）运行商家服务类（以main方法带参数的形式运行）
4.5 案例2：分布式锁-商品秒杀
锁：我们在多线程中接触过，作用就是让当前的资源不会被其他线程访问！
我的日记本，不可以被别人看到。所以要锁在保险柜中
当我打开锁，将日记本拿走了，别人才能使用这个保险柜
在zookeeper中使用传统的锁引发的 “羊群效应” ：1000个人创建节点，只有一个人能成功，999人需要等待！
羊群是一种很散乱的组织，平时在一起也是盲目地左冲右撞，但一旦有一只头羊动起来，其他的羊也会不假思索地一哄而上，全然不顾旁边可能有的狼和不远处更好的草。羊群效应就是比喻人都有一种从众心理，从众心理很容易导致盲从，而盲从往往会陷入骗局或遭到失败。
所有请求进来，在/lock下创建 临时顺序节点 ，放心，zookeeper会帮你编号排序
判断自己是不是/lock下最小的节点
是，获得锁（创建节点）
否，对前面小我一级的节点进行监听
获得锁请求，处理完业务逻辑，释放锁（删除节点），后一个节点得到通知（比你年轻的死了，你成为最嫩的了）
重复步骤2
实现步骤
1）初始化数据库 创建数据库zkproduct，使用默认的字符集utf8
1 2 3 4 5 6 7 8 create table product( id int primary key auto_increment, product_name varchar (20 ) not null , stock int not null , version int not null ) insert into product (product_name,stock,version) values ('锦鲤-清空购物车-大奖' ,5 ,0 )
1 2 3 4 5 6 create table `order `( id varchar (100 ) primary key , pid int not null , userid int not null )
2）搭建工程 搭建ssm框架，对库存表-1，对订单表+1
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 <packaging > war</packaging > <properties > <spring.version > 5.2.7.RELEASE</spring.version > </properties > <dependencies > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-context</artifactId > <version > ${spring.version}</version > </dependency > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-beans</artifactId > <version > ${spring.version}</version > </dependency > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-webmvc</artifactId > <version > ${spring.version}</version > </dependency > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-jdbc</artifactId > <version > ${spring.version}</version > </dependency > <dependency > <groupId > org.mybatis</groupId > <artifactId > mybatis</artifactId > <version > 3.5.5</version > </dependency > <dependency > <groupId > org.mybatis</groupId > <artifactId > mybatis-spring</artifactId > <version > 2.0.5</version > </dependency > <dependency > <groupId > com.alibaba</groupId > <artifactId > druid</artifactId > <version > 1.1.10</version > </dependency > <dependency > <groupId > mysql</groupId > <artifactId > mysql-connector-java</artifactId > <version > 8.0.20</version > </dependency > <dependency > <groupId > junit</groupId > <artifactId > junit</artifactId > <version > 4.12</version > <scope > test</scope > </dependency > </dependencies > <build > <plugins > <plugin > <groupId > org.apache.tomcat.maven</groupId > <artifactId > tomcat7-maven-plugin</artifactId > <configuration > <port > 8001</port > <path > /</path > </configuration > <executions > <execution > <phase > package</phase > <goals > <goal > run</goal > </goals > </execution > </executions > </plugin > </plugins > </build >
1 2 3 4 5 6 7 8 <?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd" > <configuration > <settings > <setting name ="logImpl" value ="STDOUT_LOGGING" /> </settings > </configuration >
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 <?xml version="1.0" encoding="UTF-8" ?> <beans xmlns ="http://www.springframework.org/schema/beans" xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc ="http://www.springframework.org/schema/mvc" xmlns:context ="http://www.springframework.org/schema/context" xmlns:tx ="http://www.springframework.org/schema/tx" xsi:schemaLocation ="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd" > <context:component-scan base-package ="controller,service,mapper" /> <bean id ="dataSource" class ="com.alibaba.druid.pool.DruidDataSource" destroy-method ="close" > <property name ="url" value ="jdbc:mysql://192.168.204.131:3306/zkproduct? serverTimezone=GMT" /> <property name ="driverClassName" value ="com.mysql.jdbc.Driver" /> <property name ="username" value ="root" /> <property name ="password" value ="123123" /> <property name ="maxActive" value ="10" /> <property name ="minIdle" value ="5" /> </bean > <bean id ="sqlSessionFactory" class ="org.mybatis.spring.SqlSessionFactoryBean" > <property name ="dataSource" ref ="dataSource" > </property > <property name ="configLocation" value ="classpath:mybatis/mybatis- config.xml" > </property > </bean > <bean class ="org.mybatis.spring.mapper.MapperScannerConfigurer" > <property name ="basePackage" value ="mapper" > </property > </bean > <bean id ="transactionManager" class ="org.springframework.jdbc.datasource.DataSourceTransactionManager" > <property name ="dataSource" ref ="dataSource" > </property > </bean > <tx:annotation-driven /> </beans >
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 <?xml version="1.0" encoding="UTF-8" ?> <web-app xmlns ="http://xmlns.jcp.org/xml/ns/javaee" xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation ="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" version ="3.1" > <servlet > <servlet-name > springMVC</servlet-name > <servlet- class > org.springframework.web.servlet.DispatcherServlet </servlet-class > <init-param > <param-name > contextConfigLocation</param-name > <param-value > classpath:spring/spring.xml</param-value > </init-param > <load-on-startup > 1</load-on-startup > <async-supported > true</async-supported > </servlet > <servlet-mapping > <servlet-name > springMVC</servlet-name > <url-pattern > /</url-pattern > </servlet-mapping > </web-app >
1 2 3 4 5 6 7 @Mapper @Component public interface OrderMapper { @Insert("insert into `order` (id,pid,userid) values (#{id},#{pid},# {userid})") int insert (Order order) ; }
1 2 3 4 5 6 7 8 9 10 @Mapper @Component public interface ProductMapper { @Select("select * from product where id = #{id}") Product getProduct (@Param("id") int id) ; @Update("update product set stock = stock-1 where id = #{id}") int reduceStock (@Param("id") int id) ; }
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 @Service public class OrderServiceImpl implements OrderService { @Autowired ProductMapper productMapper; @Autowired OrderMapper orderMapper; @Override public void reduceStock (int id) throws Exception { Product product = productMapper.getProduct(id); Thread.sleep(1000 ); if (product.getStock() <= 0 ) throw new RuntimeException ("已抢光！" ); int i = productMapper.reduceStock(id); if (i == 1 ){ Order order = new Order (); order.setId(UUID.randomUUID().toString()); order.setPid(id); order.setUserid(101 ); orderMapper.insert(order); } elsethrow new RuntimeException ("减库存失败，请重试！" ); } }
1 2 3 4 5 6 7 8 9 10 @Controller public class ProductAction { @Autowired private OrderService orderService; @GetMapping("/product/reduce") @ResponseBody public Object reduceStock (int id) throws Exception{ orderService.reduceStock(id); return "ok" ; } }
3）启动测试
启动两次工程，端口号分别8001和8002
使用nginx做负载均衡
1 2 3 4 5 6 7 8 9 10 11 12 13 upstream sga{ server 192.168.204.1:8001 ; server 192.168.204.1:8002 ; } server { listen 80 ; server_name localhost; location / { proxy_pass http://sga; root html; index index.html index.htm; } }
使用 JMeter 模拟1秒内发出10个http请求
查看测试结果，10次请求全部成功
查看数据库，stock库存变成 -5 （并发导致的数据结果错误）
4）apahce提供的zookeeper客户端 基于zookeeper原生态的客户端类实现分布式是非常麻烦的，我们使用apahce提供了一个zookeeper客户端来实现
Curator ：http://curator.apache.org/
1 2 3 4 5 <dependency > <groupId > org.apache.curator</groupId > <artifactId > curator-recipes</artifactId > <version > 4.2.0</version > </dependency >
recipes是curator族谱大全，里面包含zookeeper和framework
5）在控制层中加入分布式锁的逻辑代码 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 @Controller public class ProductAction { @Autowired private ProductService productService; private static String connectString = "192.168.204.141:2181,192.168.204.142:2181,192.168.204.143:2181" ; @GetMapping("/product/reduce") @ResponseBody public Object reduce ( int id) throws Exception { RetryPolicy retryPolicy = new ExponentialBackoffRetry (1000 , 3 ); CuratorFramework client = CuratorFrameworkFactory.newClient(connectString, retryPolicy); client.start(); InterProcessMutex lock = new InterProcessMutex (client, "/product_" +id); try { lock.acquire(); productService.reduceStock(id); } catch (Exception e){ if (e instanceof RuntimeException){ throw e; } } finally { lock.release(); } return "ok" ; } }
6）再次测试，并发问题解决！ 
