关于zookeeper统一配置管理

萌新今天在看zk的相关知识,有些问题想请教,不然睡不着。1. zk里面我们一般操作的是node(创建 删除 更新等),没有具体的文件操作,那这里提到的配置文件管理是个什么概念?2. 大多数应用程序在读取配置文件后都是要重启的,在这种情况下即使zk监控到文件更新,应用程序还是需要做重启的动作,也会有宕机的可能。。有谁帮我理解一下吗?

1个回答

在操作node的时候,每个node里面都有自己的数据,这些数据zookeeper是用byte[]来保存的,所以里面可以是任何的内容,也就可以是配置文件了;

第二个问题:你的理解是正确的,配置文件更改了要重新启动是不可避免的,但是如果用zookeeper来管理配置文件,那么带来的好处是你只需要修改一下就可以了,不需要在每台服务器上去修改配置文件。不知道这样说明白没有。

zzzzzz55300411
哈喽我的天啊 回复萝卜地里的兔子: 说的很清楚,谢谢你![图片说明](http://forum.csdn.net/PointForum/ui/scripts/csdn/Plugin/001/face/0.gif)
大约 3 年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
Zookeeper统一配置管理,配置文件到底怎么处理的
第一次接触这个,不太明白,我只知道可以用create命令去创建节点。 但是一整个配置文件,在部署的时候,总不能一个节点一个节点的创建吧。 各位大神,你们是怎么做的。
solr集群向zookeeper上传配置文件超时
zookeeper集群已经搭建好,并测试成功 现在搭建solr集群并向zookeeper上传配置文件,失败~~ ./zkcli.sh -zkhost 192.168.26.128:2182,192.168.26.128:2183,192.168.26.128:2184 -cmd upconfig -confdir /usr/local/tomcat-solr-cloud/solr-4/solrhome/collection1/conf -confname myconf ``` INFO - 2019-12-19 14:18:56.497; org.apache.zookeeper.ClientCnxn$SendThread; Opening socket connection to server 192.168.26.128/192.168.26.128:2182. Will not attempt to authenticate using SASL (unknown error) ERROR - 2019-12-19 14:18:56.498; org.apache.zookeeper.ClientCnxnSocketNIO; Unable to open socket to 192.168.26.128/192.168.26.128:2182 INFO - 2019-12-19 14:18:56.607; org.apache.zookeeper.ZooKeeper; Session: 0x0 closed INFO - 2019-12-19 14:18:56.609; org.apache.zookeeper.ClientCnxn$EventThread; EventThread shut down Exception in thread "main" org.apache.solr.common.SolrException: java.util.concurrent.TimeoutException: Could not connect to ZooKeeper 192.168.26.128:2182,192.168.26.128:2183,192.168.26.128:2184 within 30000 ms at org.apache.solr.common.cloud.SolrZkClient.<init>(SolrZkClient.java:163) at org.apache.solr.common.cloud.SolrZkClient.<init>(SolrZkClient.java:114) at org.apache.solr.common.cloud.SolrZkClient.<init>(SolrZkClient.java:104) at org.apache.solr.cloud.ZkCLI.main(ZkCLI.java:175) Caused by: java.util.concurrent.TimeoutException: Could not connect to ZooKeeper 192.168.26.128:2182,192.168.26.128:2183,192.168.26.128:2184 within 30000 ms at org.apache.solr.common.cloud.ConnectionManager.waitForConnected(ConnectionManager.java:223) at org.apache.solr.common.cloud.SolrZkClient.<init>(SolrZkClient.java:155) ... 3 more ``` 求解,如何解决,防火墙已经处于关闭状态~IP端口都正确
关于Storm/Zookeeper集群配置
我在搭建一套Zookeeper+Kafka+Storm的集群环境,由于只有两台服务器,所以Zookeeper搭建 了三个节点,服务器1有两个zookeeper节点,端口分别是2181,2182。在Strom.yaml配置文件中,![图片说明](http://img.ask.csd n.net/upload/201707/31/1501469925_400368.png) 请问:1、storm的配置文件中的端口配置是否正确? 2、在服务器1中启动Storm的nimbus节点和UI,在服务器2启动Storm的supervisor节点,但是在Storm ui中并没有显的supervisor节点?
dubbo zookeeper配置中心
dubbo中有没有方法可以获取到配置中心拿到的所有配置? 或者说与spring中的定义的properties配置合并, 自定义优先级。 当zookeeper配置发生改变时有没有办法进行监听? 不想自己去连接zk获取或者进行监听。 非常感谢。。
安装sheepdog时,使用zookeeper作为集群管理,configure时报错
安装sheepdog时,使用zookeeper作为集群管理,configure时报错:"libzookeeper not found"
关于zookeeper的问题?
zookeeper宕机会出现什么情况,dubbo还能连接吗,会出现什么情况,详细说明下
关于zookeeper启动报虚拟机溢出问题
今天在启动zookeeper的时候突然报下面这个错误,不知道怎么解决了,有知道怎么解决的吗 ? # # A fatal error has been detected by the Java Runtime Environment: # # EXCEPTION_ACCESS_VIOLATION (0xc0000005) at pc=0x000000005fb52ec3, pid=1348, tid=4676 # # JRE version: (9.0+11) (build ) # Java VM: Java HotSpot(TM) 64-Bit Server VM (9.0.1+11, mixed mode, tiered, compressed oops, g1 gc, windows-amd64) # Problematic frame: # V [jvm.dll+0x1b2ec3] # # No core dump will be written. Minidumps are not enabled by default on client versions of Windows # # If you would like to submit a bug report, please visit: # http://bugreport.java.com/bugreport/crash.jsp # --------------- S U M M A R Y ------------ Command Line: -Dzookeeper.log.dir=D:\zookeeper\bin\.. -Dzookeeper.root.logger=INFO,CONSOLE org.apache.zookeeper.server.quorum.QuorumPeerMain D:\zookeeper\bin\..\conf\zoo.cfg Host: Intel(R) Core(TM) i5-3230M CPU @ 2.60GHz, 4 cores, 7G, Windows 8.1 , 64 bit Build 9600 (6.3.9600.17415) Time: Tue Nov 07 17:12:55 2017 ?D1ú±ê×?ê±?? elapsed time: 0 seconds (0d 0h 0m 0s) --------------- T H R E A D --------------- Current thread (0x0000002701f51800): JavaThread "Unknown thread" [_thread_in_vm, id=4676, stack(0x0000002703a20000,0x0000002703b20000)] Stack: [0x0000002703a20000,0x0000002703b20000], sp=0x0000002703b1f520, free space=1021k Native frames: (J=compiled Java code, j=interpreted, Vv=VM code, C=native code) siginfo: EXCEPTION_ACCESS_VIOLATION (0xc0000005), reading address 0x0000000000000000 Registers: RAX=0x0000000000000001, RBX=0x0000000000000000, RCX=0x0000000000000000, RDX=0x0000002701f3fb01 RSP=0x0000002703b1f520, RBP=0x0000000000000000, RSI=0x0000002703b1f958, RDI=0x0000002701f51800 R8 =0x0000000000000000, R9 =0x0000000000000007, R10=0x0000000000000006, R11=0x0000002703b1ee50 R12=0x000000005fedf800, R13=0x0000002701f2f0f0, R14=0x0000002701f39408, R15=0x0000000000000000 RIP=0x000000005fb52ec3, EFLAGS=0x0000000000010256 Top of Stack: (sp=0x0000002703b1f520) 0x0000002703b1f520: 0000002701f5cc00 000000005ff4d9c3 0x0000002703b1f530: 0000000000000038 000000005ff018cd 0x0000002703b1f540: 0000000060179708 0000000060117d60 0x0000002703b1f550: 0000000000000140 0000002703b1f5b0 0x0000002703b1f560: 0000002701f51800 000000005ff01c25 0x0000002703b1f570: 0000002701f50960 0000000000000000 0x0000002703b1f580: 0000000000000000 000000005ff01607 0x0000002703b1f590: 0000000000000000 000000005ff4d7b9 0x0000002703b1f5a0: 0000000e07618c6a 000000005f9a0000 0x0000002703b1f5b0: 0000002701f5cc00 0000000000000000 0x0000002703b1f5c0: 0000000000000004 0000a717b1e0ffbe 0x0000002703b1f5d0: 0000000000000000 000000005fb52a75 0x0000002703b1f5e0: 0000000000000004 0000000000000000 0x0000002703b1f5f0: 0000002701f2f0f0 0000002703b1f958 0x0000002703b1f600: 0000002703b1f640 000000005fb50e21 0x0000002703b1f610: 0000000000000000 0000002703b1f640 Instructions: (pc=0x000000005fb52ec3) 0x000000005fb52ea3: 48 33 c4 48 89 84 24 a8 00 00 00 0f b6 c2 88 54 0x000000005fb52eb3: 24 31 48 8b e9 49 83 c8 ff 0f 1f 40 00 49 ff c0 0x000000005fb52ec3: 41 80 3c 08 00 75 f6 33 f6 45 33 ed 88 44 24 30 0x000000005fb52ed3: 45 85 c0 0f 8e 78 02 00 00 8b 0d 62 01 7e 00 65 --------------- P R O C E S S --------------- Java Threads: ( => current thread ) Other Threads: [error occurred during error reporting (printing all threads), id 0xc0000005] VM state:not at safepoint (not fully initialized) VM Mutex/Monitor currently owned by a thread: None [error occurred during error reporting (printing compressed oops mode), id 0xc0000005] Deoptimization events (0 events): No events Classes redefined (0 events): No events Internal exceptions (0 events): No events Events (0 events): No events Dynamic libraries: 0x00007ff7ab210000 - 0x00007ff7ab24e000 C:\ProgramData\Oracle\Java\javapath\java.exe 0x00007ff85b840000 - 0x00007ff85b9ed000 C:\Windows\SYSTEM32\ntdll.dll 0x00007ff859bb0000 - 0x00007ff859cee000 C:\Windows\system32\KERNEL32.DLL 0x00007ff858b50000 - 0x00007ff858c65000 C:\Windows\system32\KERNELBASE.dll 0x00007ff859150000 - 0x00007ff8591fa000 C:\Windows\system32\ADVAPI32.dll 0x00007ff859810000 - 0x00007ff859987000 C:\Windows\system32\USER32.dll 0x00007ff8565b0000 - 0x00007ff85682b000 C:\Windows\WinSxS\amd64_microsoft.windows.common-controls_6595b64144ccf1df_6.0.9600.18006_none_623f33d3ecbe86e8\COMCTL32.dll 0x00007ff857f10000 - 0x00007ff857f1a000 C:\Windows\SYSTEM32\VERSION.dll 0x00007ff859260000 - 0x00007ff85930a000 C:\Windows\system32\msvcrt.dll 0x00007ff858ed0000 - 0x00007ff858f29000 C:\Windows\SYSTEM32\sechost.dll 0x00007ff85b440000 - 0x00007ff85b580000 C:\Windows\system32\RPCRT4.dll 0x00007ff859000000 - 0x00007ff85914b000 C:\Windows\system32\GDI32.dll 0x00007ff858ea0000 - 0x00007ff858ece000 C:\Windows\system32\SspiCli.dll 0x00007ff859520000 - 0x00007ff859556000 C:\Windows\system32\IMM32.DLL 0x00007ff8596b0000 - 0x00007ff859801000 C:\Windows\system32\MSCTF.dll 0x00007ff842050000 - 0x00007ff84213f000 D:\Code\Java\jre\bin\msvcr120.dll 0x00007ff841ea0000 - 0x00007ff841f46000 D:\Code\Java\jre\bin\msvcp120.dll 0x000000005f9a0000 - 0x00000000603c4000 D:\Code\Java\jre\bin\server\jvm.dll 0x00007ff856840000 - 0x00007ff856849000 C:\Windows\SYSTEM32\WSOCK32.dll 0x00007ff852960000 - 0x00007ff852982000 C:\Windows\SYSTEM32\WINMM.dll 0x00007ff85b580000 - 0x00007ff85b587000 C:\Windows\system32\PSAPI.DLL 0x00007ff859320000 - 0x00007ff85937a000 C:\Windows\system32\WS2_32.dll 0x00007ff851c10000 - 0x00007ff851c3a000 C:\Windows\SYSTEM32\WINMMBASE.dll 0x00007ff859580000 - 0x00007ff859589000 C:\Windows\system32\NSI.dll 0x00007ff858c70000 - 0x00007ff858cbf000 C:\Windows\SYSTEM32\cfgmgr32.dll 0x00007ff8573d0000 - 0x00007ff8573f8000 C:\Windows\SYSTEM32\DEVOBJ.dll 0x00007ff8543e0000 - 0x00007ff8543ef000 D:\Code\Java\jre\bin\verify.dll 0x00007ff8442e0000 - 0x00007ff844307000 D:\Code\Java\jre\bin\java.dll 0x00007ff8488b0000 - 0x00007ff8488c6000 D:\Code\Java\jre\bin\zip.dll 0x00007ff854250000 - 0x00007ff85425a000 D:\Code\Java\jre\bin\jimage.dll 0x00007ff84e9e0000 - 0x00007ff84eb69000 C:\Windows\SYSTEM32\dbghelp.dll VM Arguments: jvm_args: -Dzookeeper.log.dir=D:\zookeeper\bin\.. -Dzookeeper.root.logger=INFO,CONSOLE java_command: org.apache.zookeeper.server.quorum.QuorumPeerMain D:\zookeeper\bin\..\conf\zoo.cfg java_class_path (initial): D:\zookeeper\bin\..\build\classes;D:\zookeeper\bin\..\build\lib\*;D:\zookeeper\bin\..\zookeeper-3.3.6.jar;D:\zookeeper\bin\..\lib\jline-0.9.94.jar;D:\zookeeper\bin\..\lib\log4j-1.2.15.jar;D:\zookeeper\bin\..\conf Launcher Type: SUN_STANDARD Logging: Log output configuration: #0: stdout all=warning uptime,level,tags #1: stderr all=off uptime,level,tags Environment Variables: JAVA_HOME=D:\Code\Java JRE_HOME=D:\Code\Java\jre CLASSPATH=D:\zookeeper\bin\..\build\classes;D:\zookeeper\bin\..\build\lib\*;D:\zookeeper\bin\..\*;D:\zookeeper\bin\..\lib\*;D:\zookeeper\bin\..\conf PATH=C:\ProgramData\Oracle\Java\javapath;D:\Code\Java\bin;D:\Code\Java\jre;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.0\;;D:\Code\OracleClient\bin;C:\TDM-GCC-64\bin;D:\Code\MySQL\bin;D:\maven\apache-maven-3.3.9\bin;C:\Program Files (x86)\ATI Technologies\ATI.ACE\Core-Static;C:\Program Files (x86)\AMD\ATI.ACE\Core-Static;D:\Code\gradle-3.4\bin;;D:\zookeeper/bin; D:\zookeeper/conf;D:\Code\nodejs\;D:\Code\nodejs\;D:\Code\nodejs\node_global\node_modules\hexo\bin;D:\Code\Java\bin;D:\Code\Java\jre\bin;D:\Code\Python\Scripts\;D:\Code\Python\;C:\Users\tianlinpc\AppData\Local\atom\bin;D:\Program Files\mongodb\bin;D:\Code\Microsoft VS Code\bin;D:\Program Files\Git\bin;D:\Code\gradle-3.4\bin;;D:\zookeeper/bin; D:\zookeeper/conf;D:\Code\nodejs\;C:\Users\tianlinpc\AppData\Roaming\npm;D:\Code\nodejs\node_global\node_modules\hexo\bin;D:\Code\Java\bin;D:\Code\Java\jre\bin USERNAME=tianlinpc OS=Windows_NT PROCESSOR_IDENTIFIER=Intel64 Family 6 Model 58 Stepping 9, GenuineIntel --------------- S Y S T E M --------------- OS: Windows 8.1 , 64 bit Build 9600 (6.3.9600.17415) CPU:total 4 (initial active 4) Memory: 4k page, physical 8281448k(5748736k free), swap 13000040k(7724396k free) vm_info: Java HotSpot(TM) 64-Bit Server VM (9.0.1+11) for windows-amd64 JRE (9.0.1+11), built on Sep 28 2017 04:54:03 by "mach5one" with MS VC++ 12.0 (VS2013) END.
zookeeper超时怎么配置,参数怎么配大一点?
提示zookeeper超时了, curator-default-connection-timeout默认配的60000,求问怎么改大一点,springboot
kafka启动报错,java.lang.NoSuchMethodError: org.apache.zookeeper.ZooKeeper.multi(Ljava/lang/Iterable;Lorg/apache/zookeeper/AsyncCallback$MultiCallback;Ljava/lang/Object;)V
试过很多方法,降级zk使其和kafka依赖的版本保持一致; zk3.414 ,kafka2.3 删除了scala的环境变量,依然不行; java_home只有一个 java.lang.NoSuchMethodError: org.apache.zookeeper.ZooKeeper.multi(Ljava/lang/Iterable;Lorg/apache/zookeeper/AsyncCallback$MultiCallback;Ljava/lang/Object;)V at kafka.zookeeper.ZooKeeperClient.send(ZooKeeperClient.scala:238) at kafka.zookeeper.ZooKeeperClient.$anonfun$handleRequests$2(ZooKeeperClient.scala:160) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.zookeeper.ZooKeeperClient.$anonfun$handleRequests$1(ZooKeeperClient.scala:160) at kafka.zookeeper.ZooKeeperClient.$anonfun$handleRequests$1$adapted(ZooKeeperClient.scala:156) at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62) at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49) at kafka.zookeeper.ZooKeeperClient.handleRequests(ZooKeeperClient.scala:156) at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1660) at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1647) at kafka.zk.KafkaZkClient.retryRequestUntilConnected(KafkaZkClient.scala:1642) at kafka.zk.KafkaZkClient$CheckedEphemeral.create(KafkaZkClient.scala:1712) at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1689) at kafka.zk.KafkaZkClient.registerBroker(KafkaZkClient.scala:97) at kafka.server.KafkaServer.startup(KafkaServer.scala:262) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38) at kafka.Kafka$.main(Kafka.scala:84) at kafka.Kafka.main(Kafka.scala)
关于SpringMvc Zookeeper的问题
我现在有一个SpringMvc的web项目。我现在的需求是监听zookeeper的节点变化。我需要怎么实现呢???
请问AIX下可以配置Zookeeper么,若可以,请问如何配置
如题,在AIX下配置Zookeeper一直失败,启动zkServer.sh,就提示找不到这个文件。请问是怎么回事啊
zookeeper客户端连接一直报无法定位登录配置信息,可能原因有哪些?求教?
启动三台主机,有两台主机客户端连接zookeeper时一直报错无法定位登录配置,可能都有哪些原因造成的?
dubbo注册zookeeper问题
dubbo在zookeeper注册,我配置的zookeeper地址是192.168.1.65(测试环境zookeeper),但是dubbo同时在192.168.1.65和192.168.1.195(开发环境的zookeeper)同时都注册了,而且禁用一个,调用的时候,会调用另外一个,麻烦那个高人解答下。
hive启动之后,查询语句执行特别慢,之后发现日志中zookeeper报错
hive启动之后,输入查询语句如:show databases; 执行特别慢,之后发现日志中zookeeper报错: ``` 2019-12-30T09:51:20,816 INFO [151e439b-e32e-47fb-9535-baa6b617f672 main-SendThread(localhost:2181)] zookeeper.ClientCnxn: Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) 2019-12-30T09:51:20,817 WARN [151e439b-e32e-47fb-9535-baa6b617f672 main-SendThread(localhost:2181)] zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.8.0_231] at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[?:1.8.0_231] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) ~[zookeeper-3.4.6.jar:3.4.6-1569965] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) ~[zookeeper-3.4.6.jar:3.4.6-1569965] ``` 求帮助!
关于zooKeeper,下面这个例子能保证数据安全吗
package zooKeeper.zooKeeperLock; 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 = "/build";//根 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); } } }
Java原生api连接zookeeper特别慢,求问什么原因
zookeeper装在我的虚拟机里,虚拟机系统是centos7.0 下面是我java原生api连接zookeeper的代码段 ``` try{ zooKeeper =new ZooKeeper(connectString,timeout,new secondTry()); try { new Thread().sleep(19000); System.out.println(zooKeeper.getState()); } catch (InterruptedException e) { e.printStackTrace(); } }catch (IOException e){ e.printStackTrace(); if(zooKeeper!=null){ try{ zooKeeper.close(); }catch (InterruptedException e1){ e1.printStackTrace(); } } } ``` 最快也要十多秒,别人都是瞬间连上,zookeeper的配置文件也配了,虚拟机的网络也设置了好多遍,没有一点点起色。
关于docker的问题。请大神帮忙
每次项目push之后更新后,zookeeper就会一直找不到,明明docker上启动好的了,还有配置也没改。只是重拉了项目,之前的电脑没问题,最近换了台电脑,一直出这个问题。clean过了,而且项目启动docker上的vbox machine的ip和报错里面请求的ip不一样
求助,hbase自带的zookeeper在哪里启动配置
我在试着搭一个hbase,单机模式的,所以用自带的zookeeper,hadoop配好了,但是启动start-hbase.cmd时总是报错。 报错信息是这样的: 2017-12-06 16:38:11,275 INFO [M:0;WIN-52F19LCA43O:55968] client.ZooKeeperRegistry: ClusterId read in ZooKeeper is null 2017-12-06 16:38:18,010 INFO [SessionTracker] server.ZooKeeperServer: Expiring session 0x1602af5c9830003, timeout of 10000ms exceeded 2017-12-06 16:38:18,010 INFO [SessionTracker] server.ZooKeeperServer: Expiring session 0x1602af5c9830001, timeout of 10000ms exceeded 2017-12-06 16:38:18,010 INFO [ProcessThread(sid:0 cport:-1):] server.PrepRequestProcessor : Processed session termination for sessionid: 0x1602af5c9830003 2017-12-06 16:38:18,010 INFO [ProcessThread(sid:0 cport:-1):] server.PrepRequestProcessor: Processed session termination for sessionid: 0x1602af5c9830001 2017-12-06 16:38:40,606 FATAL [WIN-52F19LCA43O:55968.activeMasterManager] master.HMaster:Failed to become active master java.io.IOException: Mkdirs failed to create file:/localhost:9000/.tmp (exists=false, cwd=file:/F:/360Downloads/hbase-1.2.3/bin) 启动之前的节点是这样的: F:\360Downloads\hbase-1.2.3\bin>jps 11232 NameNode 12592 Jps 9412 DataNode F:\360Downloads\hbase-1.2.3\bin>start-hbase.cmd 好像是这个zookeeper从来没有连上过,一直是空的,求各位帮忙看一下。
zookeeper小白,不知道配置文件错哪了,谢谢了
[root@itcast conf]# vim zoo.cfg # tickTime=2000 # initLimit=10 # syncLimit=5 dataDir=/root/zookeeper-3.4.6/data # the port at which the clients will connect clientPort=2181 # the maximum number of client connections. # increase this if you need to handle more clients #maxClientCnxns=60 # # Be sure to read the maintenance section of the # administrator guide before turning on autopurge. # # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance # # The number of snapshots to retain in dataDir #autopurge.snapRetainCount=3 # Purge task interval in hours # Set to "0" to disable auto purge feature #autopurge.purgeInterval=1 ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ "zoo.cfg" 25L, 618C 已写入 报的错 Exception in thread "main" org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /zoo2 网上说是配置文件的原因但我不知道错哪了
相见恨晚的超实用网站
搞学习 知乎:www.zhihu.com 简答题:http://www.jiandati.com/ 网易公开课:https://open.163.com/ted/ 网易云课堂:https://study.163.com/ 中国大学MOOC:www.icourse163.org 网易云课堂:study.163.com 哔哩哔哩弹幕网:www.bilibili.com 我要自学网:www.51zxw
花了20分钟,给女朋友们写了一个web版群聊程序
参考博客 [1]https://www.byteslounge.com/tutorials/java-ee-html5-websocket-example
爬虫福利二 之 妹子图网MM批量下载
爬虫福利一:27报网MM批量下载    点击 看了本文,相信大家对爬虫一定会产生强烈的兴趣,激励自己去学习爬虫,在这里提前祝:大家学有所成! 目标网站:妹子图网 环境:Python3.x 相关第三方模块:requests、beautifulsoup4 Re:各位在测试时只需要将代码里的变量 path 指定为你当前系统要保存的路径,使用 python xxx.py 或IDE运行即可。
字节跳动视频编解码面经
引言 本文主要是记录一下面试字节跳动的经历。 三四月份投了字节跳动的实习(图形图像岗位),然后hr打电话过来问了一下会不会opengl,c++,shador,当时只会一点c++,其他两个都不会,也就直接被拒了。 七月初内推了字节跳动的提前批,因为内推没有具体的岗位,hr又打电话问要不要考虑一下图形图像岗,我说实习投过这个岗位不合适,不会opengl和shador,然后hr就说秋招更看重基础。我当时
开源一个功能完整的SpringBoot项目框架
福利来了,给大家带来一个福利。 最近想了解一下有关Spring Boot的开源项目,看了很多开源的框架,大多是一些demo或者是一个未成形的项目,基本功能都不完整,尤其是用户权限和菜单方面几乎没有完整的。 想到我之前做的框架,里面通用模块有:用户模块,权限模块,菜单模块,功能模块也齐全了,每一个功能都是完整的。 打算把这个框架分享出来,供大家使用和学习。 为什么用框架? 框架可以学习整体
Java学习的正确打开方式
在博主认为,对于入门级学习java的最佳学习方法莫过于视频+博客+书籍+总结,前三者博主将淋漓尽致地挥毫于这篇博客文章中,至于总结在于个人,实际上越到后面你会发现学习的最好方式就是阅读参考官方文档其次就是国内的书籍,博客次之,这又是一个层次了,这里暂时不提后面再谈。博主将为各位入门java保驾护航,各位只管冲鸭!!!上天是公平的,只要不辜负时间,时间自然不会辜负你。 何谓学习?博主所理解的学习,它
程序员必须掌握的核心算法有哪些?
由于我之前一直强调数据结构以及算法学习的重要性,所以就有一些读者经常问我,数据结构与算法应该要学习到哪个程度呢?,说实话,这个问题我不知道要怎么回答你,主要取决于你想学习到哪些程度,不过针对这个问题,我稍微总结一下我学过的算法知识点,以及我觉得值得学习的算法。这些算法与数据结构的学习大多数是零散的,并没有一本把他们全部覆盖的书籍。下面是我觉得值得学习的一些算法以及数据结构,当然,我也会整理一些看过
Python——画一棵漂亮的樱花树(不同种樱花+玫瑰+圣诞树喔)
最近翻到一篇知乎,上面有不少用Python(大多是turtle库)绘制的树图,感觉很漂亮,我整理了一下,挑了一些我觉得不错的代码分享给大家(这些我都测试过,确实可以生成喔~) one 樱花树 动态生成樱花 效果图(这个是动态的): 实现代码 import turtle as T import random import time # 画樱花的躯干(60,t) def Tree(branch
深深的码丨Java HashMap 透析
HashMap 相关概念 HashTab、HashMap、TreeMap 均以键值对像是存储或操作数据元素。HashTab继承自Dictionary,HashMap、TreeMap继承自AbstractMap,三者均实现Map接口 **HashTab:**同步哈希表,不支持null键或值,因为同步导致性能影响,很少被使用 **HashMap:**应用较多的非同步哈希表,支持null键或值,是键值对...
大学四年自学走来,这些私藏的实用工具/学习网站我贡献出来了
大学四年,看课本是不可能一直看课本的了,对于学习,特别是自学,善于搜索网上的一些资源来辅助,还是非常有必要的,下面我就把这几年私藏的各种资源,网站贡献出来给你们。主要有:电子书搜索、实用工具、在线视频学习网站、非视频学习网站、软件下载、面试/求职必备网站。 注意:文中提到的所有资源,文末我都给你整理好了,你们只管拿去,如果觉得不错,转发、分享就是最大的支持了。 一、电子书搜索 对于大部分程序员...
linux系列之常用运维命令整理笔录
本博客记录工作中需要的linux运维命令,大学时候开始接触linux,会一些基本操作,可是都没有整理起来,加上是做开发,不做运维,有些命令忘记了,所以现在整理成博客,当然vi,文件操作等就不介绍了,慢慢积累一些其它拓展的命令,博客不定时更新 顺便拉下票,我在参加csdn博客之星竞选,欢迎投票支持,每个QQ或者微信每天都可以投5票,扫二维码即可,http://m234140.nofollow.ax.
Python 基础(一):入门必备知识
目录1 标识符2 关键字3 引号4 编码5 输入输出6 缩进7 多行8 注释9 数据类型10 运算符10.1 常用运算符10.2 运算符优先级 1 标识符 标识符是编程时使用的名字,用于给变量、函数、语句块等命名,Python 中标识符由字母、数字、下划线组成,不能以数字开头,区分大小写。 以下划线开头的标识符有特殊含义,单下划线开头的标识符,如:_xxx ,表示不能直接访问的类属性,需通过类提供
程序员接私活怎样防止做完了不给钱?
首先跟大家说明一点,我们做 IT 类的外包开发,是非标品开发,所以很有可能在开发过程中会有这样那样的需求修改,而这种需求修改很容易造成扯皮,进而影响到费用支付,甚至出现做完了项目收不到钱的情况。 那么,怎么保证自己的薪酬安全呢? 我们在开工前,一定要做好一些证据方面的准备(也就是“讨薪”的理论依据),这其中最重要的就是需求文档和验收标准。一定要让需求方提供这两个文档资料作为开发的基础。之后开发
网页实现一个简单的音乐播放器(大佬别看。(⊙﹏⊙))
今天闲着无事,就想写点东西。然后听了下歌,就打算写个播放器。 于是乎用h5 audio的加上js简单的播放器完工了。 欢迎 改进 留言。 演示地点跳到演示地点 html代码如下`&lt;!DOCTYPE html&gt; &lt;html&gt; &lt;head&gt; &lt;title&gt;music&lt;/title&gt; &lt;meta charset="utf-8"&gt
Python十大装B语法
Python 是一种代表简单思想的语言,其语法相对简单,很容易上手。不过,如果就此小视 Python 语法的精妙和深邃,那就大错特错了。本文精心筛选了最能展现 Python 语法之精妙的十个知识点,并附上详细的实例代码。如能在实战中融会贯通、灵活使用,必将使代码更为精炼、高效,同时也会极大提升代码B格,使之看上去更老练,读起来更优雅。 1. for - else 什么?不是 if 和 else 才
数据库优化 - SQL优化
前面一篇文章从实例的角度进行数据库优化,通过配置一些参数让数据库性能达到最优。但是一些“不好”的SQL也会导致数据库查询变慢,影响业务流程。本文从SQL角度进行数据库优化,提升SQL运行效率。 判断问题SQL 判断SQL是否有问题时可以通过两个表象进行判断: 系统级别表象 CPU消耗严重 IO等待严重 页面响应时间过长
2019年11月中国大陆编程语言排行榜
2019年11月2日,我统计了某招聘网站,获得有效程序员招聘数据9万条。针对招聘信息,提取编程语言关键字,并统计如下: 编程语言比例 rank pl_ percentage 1 java 33.62% 2 c/c++ 16.42% 3 c_sharp 12.82% 4 javascript 12.31% 5 python 7.93% 6 go 7.25% 7
通俗易懂地给女朋友讲:线程池的内部原理
餐厅的约会 餐盘在灯光的照耀下格外晶莹洁白,女朋友拿起红酒杯轻轻地抿了一小口,对我说:“经常听你说线程池,到底线程池到底是个什么原理?”我楞了一下,心里想女朋友今天是怎么了,怎么突然问出这么专业的问题,但做为一个专业人士在女朋友面前也不能露怯啊,想了一下便说:“我先给你讲讲我前同事老王的故事吧!” 大龄程序员老王 老王是一个已经北漂十多年的程序员,岁数大了,加班加不动了,升迁也无望,于是拿着手里
经典算法(5)杨辉三角
杨辉三角 是经典算法,这篇博客对它的算法思想进行了讲解,并有完整的代码实现。
腾讯算法面试题:64匹马8个跑道需要多少轮才能选出最快的四匹?
昨天,有网友私信我,说去阿里面试,彻底的被打击到了。问了为什么网上大量使用ThreadLocal的源码都会加上private static?他被难住了,因为他从来都没有考虑过这个问题。无独有偶,今天笔者又发现有网友吐槽了一道腾讯的面试题,我们一起来看看。 腾讯算法面试题:64匹马8个跑道需要多少轮才能选出最快的四匹? 在互联网职场论坛,一名程序员发帖求助到。二面腾讯,其中一个算法题:64匹
面试官:你连RESTful都不知道我怎么敢要你?
面试官:了解RESTful吗? 我:听说过。 面试官:那什么是RESTful? 我:就是用起来很规范,挺好的 面试官:是RESTful挺好的,还是自我感觉挺好的 我:都挺好的。 面试官:… 把门关上。 我:… 要干嘛?先关上再说。 面试官:我说出去把门关上。 我:what ?,夺门而去 文章目录01 前言02 RESTful的来源03 RESTful6大原则1. C-S架构2. 无状态3.统一的接
JDK12 Collectors.teeing 你真的需要了解一下
前言 在 Java 12 里面有个非常好用但在官方 JEP 没有公布的功能,因为它只是 Collector 中的一个小改动,它的作用是 merge 两个 collector 的结果,这句话显得很抽象,老规矩,我们先来看个图(这真是一个不和谐的图????): 管道改造经常会用这个小东西,通常我们叫它「三通」,它的主要作用就是将 downstream1 和 downstre...
为啥国人偏爱Mybatis,而老外喜欢Hibernate/JPA呢?
关于SQL和ORM的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行了一番讨论,感触还是有一些,于是就有了今天这篇文。 声明:本文不会下关于Mybatis和JPA两个持久层框架哪个更好这样的结论。只是摆事实,讲道理,所以,请各位看官勿喷。 一、事件起因 关于Mybatis和JPA孰优孰劣的问题,争论已经很多年了。一直也没有结论,毕竟每个人的喜好和习惯是大不相同的。我也看
项目中的if else太多了,该怎么重构?
介绍 最近跟着公司的大佬开发了一款IM系统,类似QQ和微信哈,就是聊天软件。我们有一部分业务逻辑是这样的 if (msgType = "文本") { // dosomething } else if(msgType = "图片") { // doshomething } else if(msgType = "视频") { // doshomething } else { // doshom...
致 Python 初学者
欢迎来到“Python进阶”专栏!来到这里的每一位同学,应该大致上学习了很多 Python 的基础知识,正在努力成长的过程中。在此期间,一定遇到了很多的困惑,对未来的学习方向感到迷茫。我非常理解你们所面临的处境。我从2007年开始接触 python 这门编程语言,从2009年开始单一使用 python 应对所有的开发工作,直至今天。回顾自己的学习过程,也曾经遇到过无数的困难,也曾经迷茫过、困惑过。开办这个专栏,正是为了帮助像我当年一样困惑的 Python 初学者走出困境、快速成长。希望我的经验能真正帮到你
“狗屁不通文章生成器”登顶GitHub热榜,分分钟写出万字形式主义大作
一、垃圾文字生成器介绍 最近在浏览GitHub的时候,发现了这样一个骨骼清奇的雷人项目,而且热度还特别高。 项目中文名:狗屁不通文章生成器 项目英文名:BullshitGenerator 根据作者的介绍,他是偶尔需要一些中文文字用于GUI开发时测试文本渲染,因此开发了这个废话生成器。但由于生成的废话实在是太过富于哲理,所以最近已经被小伙伴们给玩坏了。 他的文风可能是这样的: 你发现,...
程序员:我终于知道post和get的区别
是一个老生常谈的话题,然而随着不断的学习,对于以前的认识有很多误区,所以还是需要不断地总结的,学而时习之,不亦说乎
《程序人生》系列-这个程序员只用了20行代码就拿了冠军
你知道的越多,你不知道的越多 点赞再看,养成习惯GitHub上已经开源https://github.com/JavaFamily,有一线大厂面试点脑图,欢迎Star和完善 前言 这一期不算《吊打面试官》系列的,所有没前言我直接开始。 絮叨 本来应该是没有这期的,看过我上期的小伙伴应该是知道的嘛,双十一比较忙嘛,要值班又要去帮忙拍摄年会的视频素材,还得搞个程序员一天的Vlog,还要写BU...
加快推动区块链技术和产业创新发展,2019可信区块链峰会在京召开
11月8日,由中国信息通信研究院、中国通信标准化协会、中国互联网协会、可信区块链推进计划联合主办,科技行者协办的2019可信区块链峰会将在北京悠唐皇冠假日酒店开幕。   区块链技术被认为是继蒸汽机、电力、互联网之后,下一代颠覆性的核心技术。如果说蒸汽机释放了人类的生产力,电力解决了人类基本的生活需求,互联网彻底改变了信息传递的方式,区块链作为构造信任的技术有重要的价值。   1...
程序员把地府后台管理系统做出来了,还有3.0版本!12月7号最新消息:已在开发中有github地址
第一幕:缘起 听说阎王爷要做个生死簿后台管理系统,我们派去了一个程序员…… 996程序员做的梦: 第一场:团队招募 为了应对地府管理危机,阎王打算找“人”开发一套地府后台管理系统,于是就在地府总经办群中发了项目需求。 话说还是中国电信的信号好,地府都是满格,哈哈!!! 经常会有外行朋友问:看某网站做的不错,功能也简单,你帮忙做一下? 而这次,面对这样的需求,这个程序员...
相关热词 c#处理浮点数 c# 生成字母数字随机数 c# 动态曲线 控件 c# oracle 开发 c#选择字体大小的控件 c# usb 批量传输 c#10进制转8进制 c#转base64 c# 科学计算 c#下拉列表获取串口
立即提问