zhouguofeng
- 浏览: 85210 次
-
文章分类
- 全部博客 (84)
- 前端 (2)
- 安装 (1)
- my (0)
- CentOS 下JDK安装 (1)
- nginx (2)
- JAVA多线程 (1)
- JAVA (7)
- ZooKeeper (4)
- XML格式化 (1)
- dubbox (2)
- JMS (3)
- mysql (3)
- spark (1)
- 传统企业转型升级趋势 (0)
- OFBiz (1)
- http://www.itmuch.com/page/2/ (0)
- DOCKER (2)
- Docker Compose (1)
- springboot mybatisplus (2)
- 将博客搬至CSDN (0)
- rabitmq (1)
- JaCoCo (1)
- springboot redis (1)
- redis (1)
最新评论
分布式系统中经常需要协调多进程，多个jvm，或者多台机器之间的同步问题，得益于zookeeper，实现了一个分布式的共享锁，方便在多台服务器之间竞争资源时，来协调各系统之间的协作和同步。
多线程的并发测试要复杂很多，下面是一个使用CountDownLatch实现的并发测试工具，可以简单模拟一些并发场景
下面使用这个工具来测试一下我们的分布式共享锁
测试结果：
package com.concurrent;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;
/**
DistributedLock lock = null;
try {
lock = new DistributedLock("127.0.0.1:2182","test");
lock.lock();
//do something...
} catch (Exception e) {
e.printStackTrace();
}
finally {
if(lock != null)
lock.unlock();
}
* @author xueliang
*
*/
public class DistributedLock implements Lock, Watcher{
private ZooKeeper zk;
private String root = "/locks";//根
private String lockName;//竞争资源的标志
private String waitNode;//等待前一个锁
private String myZnode;//当前锁
private CountDownLatch latch;//计数器
private int sessionTimeout = 30000;
private List<Exception> exception = new ArrayList<Exception>();
/**
* 创建分布式锁,使用前请确认config配置的zookeeper服务可用
* @param config 127.0.0.1:2181
* @param lockName 竞争资源标志,lockName中不能包含单词lock
*/
public DistributedLock(String config, String lockName){
this.lockName = lockName;
// 创建一个与服务器的连接
try {
zk = new ZooKeeper(config, sessionTimeout, this);
Stat stat = zk.exists(root, false);
if(stat == null){
// 创建根节点
zk.create(root, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
}
} catch (IOException e) {
exception.add(e);
} catch (KeeperException e) {
exception.add(e);
} catch (InterruptedException e) {
exception.add(e);
}
}
/**
* zookeeper节点的监视器
*/
public void process(WatchedEvent event) {
if(this.latch != null) {
this.latch.countDown();
}
}
public void lock() {
if(exception.size() > 0){
throw new LockException(exception.get(0));
}
try {
if(this.tryLock()){
System.out.println("Thread " + Thread.currentThread().getId() + " " +myZnode + " get lock true");
return;
}
else{
waitForLock(waitNode, sessionTimeout);//等待锁
}
} catch (KeeperException e) {
throw new LockException(e);
} catch (InterruptedException e) {
throw new LockException(e);
}
}
public boolean tryLock() {
try {
String splitStr = "_lock_";
if(lockName.contains(splitStr))
throw new LockException("lockName can not contains \\u000B");
//创建临时子节点
myZnode = zk.create(root + "/" + lockName + splitStr, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
System.out.println(myZnode + " is created ");
//取出所有子节点
List<String> subNodes = zk.getChildren(root, false);
//取出所有lockName的锁
List<String> lockObjNodes = new ArrayList<String>();
for (String node : subNodes) {
String _node = node.split(splitStr)[0];
if(_node.equals(lockName)){
lockObjNodes.add(node);
}
}
Collections.sort(lockObjNodes);
System.out.println(myZnode + "==" + lockObjNodes.get(0));
if(myZnode.equals(root+"/"+lockObjNodes.get(0))){
//如果是最小的节点,则表示取得锁
return true;
}
//如果不是最小的节点，找到比自己小1的节点
String subMyZnode = myZnode.substring(myZnode.lastIndexOf("/") + 1);
waitNode = lockObjNodes.get(Collections.binarySearch(lockObjNodes, subMyZnode) - 1);
} catch (KeeperException e) {
throw new LockException(e);
} catch (InterruptedException e) {
throw new LockException(e);
}
return false;
}
public boolean tryLock(long time, TimeUnit unit) {
try {
if(this.tryLock()){
return true;
}
return waitForLock(waitNode,time);
} catch (Exception e) {
e.printStackTrace();
}
return false;
}
private boolean waitForLock(String lower, long waitTime) throws InterruptedException, KeeperException {
Stat stat = zk.exists(root + "/" + lower,true);
//判断比自己小一个数的节点是否存在,如果不存在则无需等待锁,同时注册监听
if(stat != null){
System.out.println("Thread " + Thread.currentThread().getId() + " waiting for " + root + "/" + lower);
this.latch = new CountDownLatch(1);
this.latch.await(waitTime, TimeUnit.MILLISECONDS);
this.latch = null;
}
return true;
}
public void unlock() {
try {
System.out.println("unlock " + myZnode);
zk.delete(myZnode,-1);
myZnode = null;
zk.close();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (KeeperException e) {
e.printStackTrace();
}
}
public void lockInterruptibly() throws InterruptedException {
this.lock();
}
public Condition newCondition() {
return null;
}
public class LockException extends RuntimeException {
private static final long serialVersionUID = 1L;
public LockException(String e){
super(e);
}
public LockException(Exception e){
super(e);
}
}
}
多线程的并发测试要复杂很多，下面是一个使用CountDownLatch实现的并发测试工具，可以简单模拟一些并发场景
package com.concurrent;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;
/**
ConcurrentTask[] task = new ConcurrentTask[5];
for(int i=0;i<task.length;i++){
task[i] = new ConcurrentTask(){
public void run() {
System.out.println("==============");
}};
}
new ConcurrentTest(task);
* @author xueliang
*
*/
public class ConcurrentTest {
private CountDownLatch startSignal = new CountDownLatch(1);//开始阀门
private CountDownLatch doneSignal = null;//结束阀门
private CopyOnWriteArrayList<Long> list = new CopyOnWriteArrayList<Long>();
private AtomicInteger err = new AtomicInteger();//原子递增
private ConcurrentTask[] task = null;
public ConcurrentTest(ConcurrentTask... task){
this.task = task;
if(task == null){
System.out.println("task can not null");
System.exit(1);
}
doneSignal = new CountDownLatch(task.length);
start();
}
/**
* @param args
* @throws ClassNotFoundException
*/
private void start(){
//创建线程，并将所有线程等待在阀门处
createThread();
//打开阀门
startSignal.countDown();//递减锁存器的计数，如果计数到达零，则释放所有等待的线程
try {
doneSignal.await();//等待所有线程都执行完毕
} catch (InterruptedException e) {
e.printStackTrace();
}
//计算执行时间
getExeTime();
}
/**
* 初始化所有线程，并在阀门处等待
*/
private void createThread() {
long len = doneSignal.getCount();
for (int i = 0; i < len; i++) {
final int j = i;
new Thread(new Runnable(){
public void run() {
try {
startSignal.await();//使当前线程在锁存器倒计数至零之前一直等待
long start = System.currentTimeMillis();
task[j].run();
long end = (System.currentTimeMillis() - start);
list.add(end);
} catch (Exception e) {
err.getAndIncrement();//相当于err++
}
doneSignal.countDown();
}
}).start();
}
}
/**
* 计算平均响应时间
*/
private void getExeTime() {
int size = list.size();
List<Long> _list = new ArrayList<Long>(size);
_list.addAll(list);
Collections.sort(_list);
long min = _list.get(0);
long max = _list.get(size-1);
long sum = 0L;
for (Long t : _list) {
sum += t;
}
long avg = sum/size;
System.out.println("min: " + min);
System.out.println("max: " + max);
System.out.println("avg: " + avg);
System.out.println("err: " + err.get());
}
public interface ConcurrentTask {
void run();
}
}
下面使用这个工具来测试一下我们的分布式共享锁
package com.concurrent;
import com.concurrent.ConcurrentTest.ConcurrentTask;
public class ZkTest {
public static void main(String[] args) {
Runnable task1 = new Runnable(){
public void run() {
DistributedLock lock = null;
try {
lock = new DistributedLock("127.0.0.1:2182","test1");
//lock = new DistributedLock("127.0.0.1:2182","test2");
lock.lock();
Thread.sleep(3000);
System.out.println("===Thread " + Thread.currentThread().getId() + " running");
} catch (Exception e) {
e.printStackTrace();
}
finally {
if(lock != null)
lock.unlock();
}
}
};
new Thread(task1).start();
try {
Thread.sleep(1000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
ConcurrentTask[] tasks = new ConcurrentTask[10];
for(int i=0;i<tasks.length;i++){
ConcurrentTask task3 = new ConcurrentTask(){
public void run() {
DistributedLock lock = null;
try {
lock = new DistributedLock("127.0.0.1:2183","test2");
lock.lock();
System.out.println("Thread " + Thread.currentThread().getId() + " running");
} catch (Exception e) {
e.printStackTrace();
}
finally {
lock.unlock();
}
}
};
tasks[i] = task3;
}
new ConcurrentTest(tasks);
}
}
测试结果：
[INFO][08-26 15:05:58.472][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT [INFO][08-26 15:05:58.474][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:host.name=zhouguofeng-PC [INFO][08-26 15:05:58.474][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.version=1.8.0_101 [INFO][08-26 15:05:58.474][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.vendor=Oracle Corporation [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.home=D:\Program Files\Java\jre8 [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.class.path=D:\xgWorkspase\Test\target\classes;D:\xgWorkspase\Test\lib\jmagick.jar;D:\xgWorkspase\Test\lib\QRCode.jar;D:\xgWorkspase\Test\lib\Qrcodeen.jar;E:\maven\repository\log4j\log4j\1.2.12\log4j-1.2.12.jar;E:\maven\repository\commons-codec\commons-codec\1.6\commons-codec-1.6.jar;E:\maven\repository\commons-lang\commons-lang\2.5\commons-lang-2.5.jar;E:\maven\repository\commons-logging\commons-logging\1.1.1\commons-logging-1.1.1.jar;E:\maven\repository\junit\junit\4.9\junit-4.9.jar;E:\maven\repository\org\hamcrest\hamcrest-core\1.1\hamcrest-core-1.1.jar;E:\maven\repository\commons-io\commons-io\1.3.2\commons-io-1.3.2.jar;E:\maven\repository\org\apache\commons\commons-pool2\2.2\commons-pool2-2.2.jar;E:\maven\repository\org\csource\fastdfs\1.24\fastdfs-1.24.jar;E:\maven\repository\jmagick\jmagick\6.6.9\jmagick-6.6.9.jar;E:\maven\repository\org\im4java\im4java\1.4.0\im4java-1.4.0.jar;E:\maven\repository\org\apache\shiro\shiro-core\1.2.3\shiro-core-1.2.3.jar;E:\maven\repository\org\slf4j\slf4j-api\1.6.4\slf4j-api-1.6.4.jar;E:\maven\repository\commons-beanutils\commons-beanutils\1.8.3\commons-beanutils-1.8.3.jar;E:\maven\repository\com\google\zxing\core\2.0\core-2.0.jar;E:\maven\repository\org\apache\httpcomponents\httpclient\4.5.2\httpclient-4.5.2.jar;E:\maven\repository\org\apache\httpcomponents\httpcore\4.4.4\httpcore-4.4.4.jar;E:\maven\repository\org\apache\zookeeper\zookeeper\3.4.8\zookeeper-3.4.8.jar;E:\maven\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;E:\maven\repository\jline\jline\0.9.94\jline-0.9.94.jar;E:\maven\repository\io\netty\netty\3.7.0.Final\netty-3.7.0.Final.jar;E:\maven\repository\com\netflix\curator\curator-framework\1.2.3\curator-framework-1.2.3.jar;E:\maven\repository\com\netflix\curator\curator-client\1.2.3\curator-client-1.2.3.jar;E:\maven\repository\com\google\guava\guava\11.0.1\guava-11.0.1.jar;E:\maven\repository\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;E:\maven\repository\com\netflix\curator\curator-recipes\1.2.3\curator-recipes-1.2.3.jar;E:\maven\repository\com\netflix\curator\curator-test\1.2.3\curator-test-1.2.3.jar;E:\maven\repository\org\javassist\javassist\3.15.0-GA\javassist-3.15.0-GA.jar;E:\maven\repository\org\apache\commons\commons-math\2.2\commons-math-2.2.jar;E:\maven\repository\com\netflix\curator\curator-x-discovery\1.2.3\curator-x-discovery-1.2.3.jar;E:\maven\repository\org\codehaus\jackson\jackson-mapper-asl\1.9.2\jackson-mapper-asl-1.9.2.jar;E:\maven\repository\org\codehaus\jackson\jackson-core-asl\1.9.2\jackson-core-asl-1.9.2.jar [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.library.path=D:\Program Files\Java\jre8\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;D:/Program Files/Java/jre8/bin/server;D:/Program Files/Java/jre8/bin;D:/Program Files/Java/jre8/lib/amd64;C:\ProgramData\Oracle\Java\javapath;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.0\;D:\Program Files\Java\jdk1.8.0_101\bin;D:\Program Files\Java\jdk1.8.0_101\jre\bin;D:\JAVA\mysql-5.6.17\bin;D:\Program Files\nodejs\;D:\Program Files\TortoiseSVN\bin;C:\Users\zhouguofeng\AppData\Roaming\npm;d:\Program Files (x86)\SSH Communications Security\SSH Secure Shell;C:\Users\zhouguofeng\Desktop;;. [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.io.tmpdir=C:\Users\ZHOUGU~1\AppData\Local\Temp\ [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:java.compiler=<NA> [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:os.name=Windows 7 [INFO][08-26 15:05:58.475][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:os.arch=amd64 [INFO][08-26 15:05:58.476][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:os.version=6.1 [INFO][08-26 15:05:58.476][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:user.name=zhouguofeng [INFO][08-26 15:05:58.476][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:user.home=C:\Users\zhouguofeng [INFO][08-26 15:05:58.476][Thread-0][org.apache.zookeeper.ZooKeeper:100]: Client environment:user.dir=D:\xgWorkspase\Test [INFO][08-26 15:05:58.477][Thread-0][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@5563d6e7 [INFO][08-26 15:05:58.602][Thread-0-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:58.603][Thread-0-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:58.613][Thread-0-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e3, negotiated timeout = 40000 /locks/test1_lock_0000000192 is created /locks/test1_lock_0000000192==test1_lock_0000000192 Thread 10 /locks/test1_lock_0000000192 get lock true [INFO][08-26 15:05:59.371][Thread-1][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@7e7181b2 [INFO][08-26 15:05:59.372][Thread-6][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@772ba4ed [INFO][08-26 15:05:59.372][Thread-9][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@60988475 [INFO][08-26 15:05:59.380][Thread-6-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.381][Thread-6-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.372][Thread-5][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@68004e4f [INFO][08-26 15:05:59.371][Thread-4][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@679c1ee8 [INFO][08-26 15:05:59.371][Thread-3][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@62aaf848 [INFO][08-26 15:05:59.371][Thread-2][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@5d6f03ec [INFO][08-26 15:05:59.371][Thread-10][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@270e8fc8 [INFO][08-26 15:05:59.382][Thread-1-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.386][Thread-1-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.387][Thread-9-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.390][Thread-9-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.391][Thread-5-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.372][Thread-8][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@67eec7d2 [INFO][08-26 15:05:59.393][Thread-3-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.393][Thread-10-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.372][Thread-7][org.apache.zookeeper.ZooKeeper:438]: Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=300000 watcher=com.concurrent.DistributedLock@7837a6ba [INFO][08-26 15:05:59.394][Thread-6-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e4, negotiated timeout = 40000 [INFO][08-26 15:05:59.396][Thread-8-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.397][Thread-8-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.394][Thread-3-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.399][Thread-10-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.393][Thread-5-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.392][Thread-2-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.388][Thread-4-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.400][Thread-7-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1032]: Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [INFO][08-26 15:05:59.401][Thread-2-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.401][Thread-4-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.402][Thread-7-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:876]: Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session [INFO][08-26 15:05:59.402][Thread-1-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e5, negotiated timeout = 40000 [INFO][08-26 15:05:59.404][Thread-9-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e6, negotiated timeout = 40000 [INFO][08-26 15:05:59.406][Thread-5-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e7, negotiated timeout = 40000 /locks/test1_lock_0000000193 is created [INFO][08-26 15:05:59.407][Thread-3-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e8, negotiated timeout = 40000 [INFO][08-26 15:05:59.409][Thread-8-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900e9, negotiated timeout = 40000 /locks/test1_lock_0000000193==test1_lock_0000000192 等待锁-----test1_lock_0000000192 /locks/test1_lock_0000000194 is created [INFO][08-26 15:05:59.411][Thread-10-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900ea, negotiated timeout = 40000 Thread 18 waiting for /locks/test1_lock_0000000192 /locks/test1_lock_0000000194==test1_lock_0000000192 等待锁-----test1_lock_0000000193 [INFO][08-26 15:05:59.413][Thread-2-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900eb, negotiated timeout = 40000 /locks/test1_lock_0000000196 is created /locks/test1_lock_0000000195 is created [INFO][08-26 15:05:59.414][Thread-4-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900ec, negotiated timeout = 40000 /locks/test1_lock_0000000197 is created Thread 13 waiting for /locks/test1_lock_0000000193 [INFO][08-26 15:05:59.415][Thread-7-SendThread(127.0.0.1:2181)][org.apache.zookeeper.ClientCnxn:1299]: Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x156c53eab3900ed, negotiated timeout = 40000 /locks/test1_lock_0000000198 is created /locks/test1_lock_0000000199 is created /locks/test1_lock_0000000200 is created /locks/test1_lock_0000000197==test1_lock_0000000192 等待锁-----test1_lock_0000000196 /locks/test1_lock_0000000196==test1_lock_0000000192 等待锁-----test1_lock_0000000195 /locks/test1_lock_0000000201 is created /locks/test1_lock_0000000202 is created /locks/test1_lock_0000000199==test1_lock_0000000192 等待锁-----test1_lock_0000000198 /locks/test1_lock_0000000198==test1_lock_0000000192 等待锁-----test1_lock_0000000197 /locks/test1_lock_0000000201==test1_lock_0000000192 等待锁-----test1_lock_0000000200 /locks/test1_lock_0000000200==test1_lock_0000000192 等待锁-----test1_lock_0000000199 Thread 15 waiting for /locks/test1_lock_0000000195 Thread 20 waiting for /locks/test1_lock_0000000198 Thread 17 waiting for /locks/test1_lock_0000000196 Thread 14 waiting for /locks/test1_lock_0000000199 Thread 16 waiting for /locks/test1_lock_0000000200 /locks/test1_lock_0000000202==test1_lock_0000000192 等待锁-----test1_lock_0000000201 Thread 22 waiting for /locks/test1_lock_0000000197 /locks/test1_lock_0000000195==test1_lock_0000000192 等待锁-----test1_lock_0000000194 Thread 19 waiting for /locks/test1_lock_0000000201 Thread 21 waiting for /locks/test1_lock_0000000194 ===Thread 10 running 释放锁--------------------------unlock /locks/test1_lock_0000000192 [INFO][08-26 15:06:01.635][Thread-0][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e3 closed [INFO][08-26 15:06:01.638][Thread-0-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e3 Thread 18 running 释放锁--------------------------unlock /locks/test1_lock_0000000193 [INFO][08-26 15:06:02.641][Thread-6][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e4 closed [INFO][08-26 15:06:02.642][Thread-6-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e4 Thread 13 running 释放锁--------------------------unlock /locks/test1_lock_0000000194 [INFO][08-26 15:06:03.651][Thread-1][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e5 closed [INFO][08-26 15:06:03.653][Thread-1-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e5 Thread 21 running 释放锁--------------------------unlock /locks/test1_lock_0000000195 [INFO][08-26 15:06:04.657][Thread-9][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e6 closed [INFO][08-26 15:06:04.657][Thread-9-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e6 Thread 15 running 释放锁--------------------------unlock /locks/test1_lock_0000000196 [INFO][08-26 15:06:05.661][Thread-3][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e8 closed [INFO][08-26 15:06:05.661][Thread-3-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e8 Thread 17 running 释放锁--------------------------unlock /locks/test1_lock_0000000197 [INFO][08-26 15:06:06.664][Thread-5][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e7 closed [INFO][08-26 15:06:06.664][Thread-5-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e7 Thread 22 running 释放锁--------------------------unlock /locks/test1_lock_0000000198 [INFO][08-26 15:06:07.677][Thread-10][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900ea closed [INFO][08-26 15:06:07.677][Thread-10-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900ea Thread 20 running 释放锁--------------------------unlock /locks/test1_lock_0000000199 [INFO][08-26 15:06:08.682][Thread-8][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900e9 closed [INFO][08-26 15:06:08.682][Thread-8-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900e9 Thread 14 running 释放锁--------------------------unlock /locks/test1_lock_0000000200 [INFO][08-26 15:06:09.690][Thread-2][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900eb closed [INFO][08-26 15:06:09.690][Thread-2-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900eb Thread 16 running 释放锁--------------------------unlock /locks/test1_lock_0000000201 [INFO][08-26 15:06:10.694][Thread-4][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900ec closed [INFO][08-26 15:06:10.695][Thread-4-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900ec Thread 19 running 释放锁--------------------------unlock /locks/test1_lock_0000000202 [INFO][08-26 15:06:11.701][Thread-7][org.apache.zookeeper.ZooKeeper:684]: Session: 0x156c53eab3900ed closed min: 3270 max: 12330 avg: 7800 [INFO][08-26 15:06:11.701][Thread-7-EventThread][org.apache.zookeeper.ClientCnxn:519]: EventThread shut down for session: 0x156c53eab3900ed err: 0
- java.rar (4.7 KB)
- 下载次数: 0
分享到：
发表评论
相关推荐
- **测试代码**：展示了如何在实际应用中使用Zookeeper实现分布式锁的示例，包括创建锁、获取锁、释放锁以及异常处理等操作。 - **实用工具类**：封装了与Zookeeper交互的常用方法，如创建节点、设置监听、检查节点...
分布式全局锁是分布式系统中一个重要的同步控制工具，它允许在多节点环境下，对共享资源进行独占式访问，防止并发问题。Zookeeper，作为Apache的一个高性能、高可用的分布式协调服务，常被用于实现这样的功能。在这...
在分布式系统中，数据一致性是至关重要的，而实现这一目标的一种常见方法是使用分布式锁。本文将深入探讨基于Zookeeper实现的分布式读写锁，并利用Zkclient客户端进行操作。Zookeeper是一个分布式服务协调框架，它...
在实际项目中，可以使用Java的ZooKeeper客户端库（如Curator）来简化分布式锁的实现。这些库提供了高级API，帮助开发者更方便地处理ZooKeeper的操作，例如创建、删除节点，以及设置节点监视器等。 总之，ZooKeeper...
本文将详细讲解如何使用Java与Apache ZooKeeper实现一个分布式锁的示例。 ZooKeeper是一个分布式协调服务，它提供了一种可靠的方式来管理和同步分布式系统的数据。在分布式锁的场景中，ZooKeeper可以作为一个中心化...
**Zookeeper的分布式锁实现原理** 1. **节点创建与监视**: Zookeeper允许客户端创建临时节点，这些节点会在客户端断开连接时自动删除。分布式锁的实现通常会为每个请求创建一个临时顺序节点，按照创建的顺序形成一...
在这个场景下，我们将关注ZooKeeper如何实现分布式锁，特别是不可重入锁、可重入锁以及可重入读写锁的概念与实践。 首先，我们要理解什么是分布式锁。在多节点并发访问共享资源时，分布式锁能确保同一时刻只有一个...
Zookeeper 实现分布式锁是指使用 Zookeeper 来管理分布式环境中的共享资源，实现互斥访问，以保证数据的一致性。 分布式锁的介绍 分布式锁是指在分布式环境中保护跨进程、跨主机、跨网络的共享资源，实现互斥...
在Zookeeper中，可以通过创建多个顺序节点来实现，每个读请求创建一个节点，所有读请求节点共享锁。 2. **互斥锁（写锁）**：只允许一个线程写入，不允许读取和其他写入。这与排他锁类似，通过创建临时节点并监听...
如何操作Redis和zookeeper实现分布式锁 在分布式场景下，有很多种情况都需要实现最终一致性。在设计远程上下文的领域事件的时候，为了保证最终一致性，在通过领域事件进行通讯的方式中，可以共享存储（领域模型和...
ZooKeeper是一个广泛使用的分布式锁实现方案，本文将对ZooKeeper分布式锁进行详细的介绍。 什么是分布式锁 分布式锁是指在分布式系统中，多个节点之间对共享资源的访问控制机制。分布式锁可以确保在分布式环境中，...
Zookeeper的核心理念是通过一个中心化的服务器集群来维护共享状态，使得分布式系统中的各个节点可以高效、一致地获取和更新数据。它基于一个叫做ZNode的数据结构模型，每个ZNode都是一个路径，可以存储数据，并且...
通过深入理解Zookeeper的工作原理以及ZookeeperNet库的使用，开发者可以有效地在C#环境中实现高可用的分布式锁，保障多节点之间的协同工作和数据一致性。在实际项目中，分布式锁可以广泛应用于数据库操作、并发任务...
4. **分布式锁**：ZooKeeper可以实现分布式锁，确保在多线程或分布式环境下，对共享资源的访问有序且互斥。 5. **领导者选举**：ZooKeeper的ZAB协议可以用于分布式环境中的领导者选举，确保集群的高可用性。 **三...
分布式锁是一种在分布式系统中实现同步的技术，它允许多个节点在同一时间访问共享资源。在大型分布式环境中，确保数据的一致性和正确性至关重要，这就是分布式锁发挥作用的地方。Zookeeper，一个由Apache开发的...
- **分布式锁**：通过特定的ZNode结构，实现共享锁服务。 - **队列服务**：FIFO（先进先出）的队列可以通过ZNode的顺序创建实现。 3. **ZooKeeper的架构** - **客户端-服务器模型**：每个客户端连接到一个或多个...
分布式锁用于在多个进程中控制对共享资源的访问；主选举是确定集群中某个角色的唯一领导者。 书中详细介绍了ZooKeeper的数据模型，这是一个层次化的命名空间，类似于文件系统，由节点（ZNode）构成，每个节点可以...
《从Paxos到Zookeeper分布式一致性原理与实践》是一本深入探讨分布式系统一致性问题的著作，其中重点讲解了Paxos算法与Zookeeper在实际应用中的理论与实践。Paxos是分布式计算领域中著名的共识算法，为解决分布式...
3. **分布式锁**：ZooKeeper可以实现分布式锁，避免多个进程或线程同时访问同一资源，确保操作的互斥性。 4. **命名服务**：提供分布式环境下的全局唯一ID生成，或者为分布式服务提供可读易记的名称。 5. **分组...