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

公司网站建设介绍中文wordpress企业主题

wzjs 2025/9/7 11:23:57
公司网站建设介绍,中文wordpress企业主题,资料查询网站怎么做,wordpress模板服务器目录 实践例子1. 先创建一个持久结点2. 创建一个结点监听程序3. 锁程序4. 测试和输出截图测试说明 回顾zkNode类型zookeeper分布式锁的优缺点 实践例子 1. 先创建一个持久结点 ./bin/zkServer.sh start conf/zoo_local.cfg ./bin/zkCli.sh -server 127.0.0.1:21812. 创建一个…

目录

    • 实践例子
      • 1. 先创建一个持久结点
      • 2. 创建一个结点监听程序
      • 3. 锁程序
      • 4. 测试和输出截图
      • 测试说明
    • 回顾zkNode类型
    • zookeeper分布式锁的优缺点

实践例子

1. 先创建一个持久结点

在这里插入图片描述

./bin/zkServer.sh start conf/zoo_local.cfg
./bin/zkCli.sh  -server 127.0.0.1:2181

在这里插入图片描述

2. 创建一个结点监听程序

<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>5.1.0</version>
</dependency>
  • CuratorTest
package com.test;import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.ChildData;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.framework.recipes.cache.NodeCacheListener;
import org.apache.curator.framework.recipes.cache.PathChildrenCache;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
import org.apache.curator.framework.recipes.cache.TreeCache;
import org.apache.curator.framework.recipes.cache.TreeCacheEvent;
import org.apache.curator.framework.recipes.cache.TreeCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;/*** @Author mubi* @Date 2020/3/27 23:43*/
public class CuratorTest {private static String clusterNode = "/mylock";private static CuratorFramework cf;private static PathChildrenCache pathChildrenCache;private static NodeCache nodeCache;private static TreeCache treeCache;public static void main(String[] args) throws Exception {CuratorTest curatorTest = new CuratorTest();RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);cf = CuratorFrameworkFactory.newClient("127.0.0.1:2181",5000, 1000, retryPolicy);cf.start();curatorTest.setPathCacheListener(clusterNode, true);curatorTest.setNodeCacheListener(clusterNode, false);curatorTest.setTreeCacheListener(clusterNode);System.in.read();}/*** 设置Path Cache, 监控本节点的子节点被创建,更新或者删除，注意是子节点, 子节点下的子节点不能递归监控* 可重入监听*/public void setPathCacheListener(String path, boolean cacheData) throws Exception {try {pathChildrenCache = new PathChildrenCache(cf, path, cacheData);PathChildrenCacheListener childrenCacheListener = new PathChildrenCacheListener() {@Overridepublic void childEvent(CuratorFramework client, PathChildrenCacheEvent event) {ChildData data = event.getData();switch (event.getType()) {case CHILD_ADDED:System.out.println("子节点增加:" + data.getPath() + " " + data.getData());try {String rs = new String(data.getData(), "utf-8");System.out.println("data string:" + rs);} catch (Exception e) {}break;case CHILD_UPDATED:System.out.println("子节点更新:" + data.getPath() + " " + data.getData());break;case CHILD_REMOVED:System.out.println("子节点删除:" + data.getPath() + " " + data.getData());break;default:break;}}};pathChildrenCache.getListenable().addListener(childrenCacheListener);pathChildrenCache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);} catch (Exception e) {System.out.println("PathCache监听失败, path=" + path);}}/*** 设置Node Cache, 监控本节点的新增,删除,更新*/public void setNodeCacheListener(String path, boolean dataIsCompressed) {try {nodeCache = new NodeCache(cf, path, dataIsCompressed);NodeCacheListener nodeCacheListener = new NodeCacheListener() {@Overridepublic void nodeChanged() throws Exception {ChildData childData = nodeCache.getCurrentData();System.out.println("ZNode节点状态改变, path=" + childData.getPath());System.out.println("ZNode节点状态改变, data=" + childData.getData());try {String rs = new String(childData.getData(), "utf-8");System.out.println("data string:" + rs);} catch (Exception e) {}System.out.println("ZNode节点状态改变, stat=" + childData.getStat());}};nodeCache.getListenable().addListener(nodeCacheListener);nodeCache.start();} catch (Exception e) {System.out.println("创建NodeCache监听失败, path=" + path);}}/*** 设置Tree Cache, 监控本节点的新增,删除,更新* 节点的update可以监控到, 如果删除不会自动再次创建* 可重入监听*/public void setTreeCacheListener(final String path) {try {treeCache = new TreeCache(cf, path);TreeCacheListener treeCacheListener = new TreeCacheListener() {@Overridepublic void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {ChildData data = event.getData();if (data != null) {switch (event.getType()) {case NODE_ADDED:System.out.println("[TreeCache]子节点增加" + data.getPath() + " " + data.getData());break;case NODE_UPDATED:System.out.println("[TreeCache]子节点更新" + data.getPath() + " " + data.getData());try {String rs = new String(data.getData(), "utf-8");System.out.println("data string:" + rs);} catch (Exception e) {}System.out.println();break;case NODE_REMOVED:System.out.println("[TreeCache]子节点删除" + data.getPath() + " " + data.getData());break;default:break;}}else {System.out.println("[TreeCache]节点数据为空, path=" + data.getPath());}}};treeCache.getListenable().addListener(treeCacheListener);treeCache.start();} catch (Exception e) {System.out.println("创建TreeCache监听失败, path=" + path);}}
}

3. 锁程序

  • ZooKeeperLock
package com.test;import org.apache.zookeeper.*;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;/*** @Author mubi* @Date 2020/3/28 11:03*/
public class ZooKeeperLock {private String clusterNode = "mylock";private AtomicInteger atomicInteger = new AtomicInteger(0);private ZooKeeper zk;CountDownLatch countDownLatch = new CountDownLatch(1);public ZooKeeperLock() {try {zk = new ZooKeeper("127.0.0.1:2181", 5000, new Watcher() {@Overridepublic void process(WatchedEvent event) {if (Watcher.Event.KeeperState.SyncConnected.equals(event.getState())) {System.out.println("zk连接成功" + event);countDownLatch.countDown();}}});} catch (Exception e) {e.printStackTrace();}}public Node lock() {Node node = createNode();if (!tryAcquire(node)) {// 没有获取到锁，就等待synchronized (node) {try {node.wait();} catch (Exception e) {e.printStackTrace();}}}return node;}private boolean tryAcquire(Node node) {try {String path = "/" + clusterNode;// 结点下所有路径，从小到大List<String> subList = zk.getChildren(path, true);subList = subList.stream().sorted().map(n -> path + "/" + n).collect(Collectors.toList());// 是最小结点，表示获取到锁了，直接返回String smallestPath = subList.get(0);if (smallestPath.isEmpty() || node.getPath().equals(smallestPath)) {return true;}else {// 否则要等待前一个结点释放锁int index = subList.indexOf(node.getPath());String preNodePath = subList.get(index - 1);zk.exists(preNodePath, new Watcher() {@Overridepublic void process(WatchedEvent event) {if (event.getType() == Event.EventType.NodeDeleted) {// 前一个节点删除了释放锁了，就唤醒本结点synchronized (node) {node.notify();}}}});return false;}} catch (Exception e) {return false;}}public void unlock(Node node) {try {zk.delete(node.path, -1);} catch (Exception e) {e.printStackTrace();}}/*** 临时有序结点*/class Node {private String path;public Node(String path) {this.path = path;}public String getPath() {return path;}public void setPath(String path) {this.path = path;}}public Node createNode() {try {String path = "/" + clusterNode + "/lock-";String createdPath = zk.create(path,path.getBytes("utf-8"),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);Node node = new Node(createdPath);System.out.println("create EPHEMERAL_SEQUENTIAL: " + createdPath);return node;} catch (Exception e) {e.printStackTrace();return null;}}}
  • Test
package com.test;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;/*** @Author mubi* @Date 2020/3/28 11:03*/
public class Test {private int a = 0;ZooKeeperLock zooKeeperLock = new ZooKeeperLock();public void add() {try {// 业务逻辑TimeUnit.MILLISECONDS.sleep(300);a++;} catch (Exception e) {} finally {}}public void lockAdd() {ZooKeeperLock.Node node = null;try {node = zooKeeperLock.lock();if (node != null) {// 业务逻辑TimeUnit.MILLISECONDS.sleep(300);a++;}} catch (Exception e) {
//            e.printStackTrace();System.out.println("lock error");} finally {zooKeeperLock.unlock(node);}}public int getA() {return a;}public static void main(String[] args) throws Exception {List<Thread> threadList = new ArrayList<>();Test test = new Test();int n = 20;for (int i = 0; i < n; i++) {threadList.add(new Thread(() -> {test.lockAdd();}));}for (int i = 0; i < n; i++) {threadList.get(i).start();}for (int i = 0; i < n; i++) {threadList.get(i).join();}System.out.println(test.getA());}}

4. 测试和输出截图

  • 测试输出
    在这里插入图片描述

  • 监听
    在这里插入图片描述

测试说明

加锁过程

  1. 先创建有序临时结点，然后如果加锁成功就返回，否则等待
public Node lock() {Node node = createNode();if (!tryAcquire(node)) {// 没有获取到锁，就等待synchronized (node) {try {node.wait();} catch (Exception e) {e.printStackTrace();}}}return node;
}

public Node createNode() {try {String path = "/" + clusterNode + "/lock-";String createdPath = zk.create(path,path.getBytes("utf-8"),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);Node node = new Node(createdPath);System.out.println("create EPHEMERAL_SEQUENTIAL: " + createdPath);return node;} catch (Exception e) {e.printStackTrace();return null;}
}
  1. 判断当前是最小结点就成功；否则判断前序结点是否删除，删除了就可以当前结点；因为加锁的有序的从小到大加上的，也是公平的体现，先来后到
 private boolean tryAcquire(Node node) {try {String path = "/" + clusterNode;// 结点下所有路径，从小到大List<String> subList = zk.getChildren(path, true);subList = subList.stream().sorted().map(n -> path + "/" + n).collect(Collectors.toList());// 是最小结点，表示获取到锁了，直接返回String smallestPath = subList.get(0);if (smallestPath.isEmpty() || node.getPath().equals(smallestPath)) {return true;}else {// 否则要等待前一个结点释放锁int index = subList.indexOf(node.getPath());String preNodePath = subList.get(index - 1);zk.exists(preNodePath, new Watcher() {@Overridepublic void process(WatchedEvent event) {if (event.getType() == Event.EventType.NodeDeleted) {// 前一个节点删除了释放锁了，就唤醒本结点synchronized (node) {node.notify();}}}});return false;}} catch (Exception e) {return false;}}

回顾zkNode类型

1.持久节点（PERSISTENT）：这类节点被创建后，就会一直存在于Zk服务器上。直到手动删除。

2.持久顺序节点（PERSISTENT_SEQUENTIAL）：它的基本特性同持久节点，不同在于增加了顺序性。父节点会维护一个自增整性数字，用于子节点的创建的先后顺序。

3.临时节点（EPHEMERAL）：临时节点的生命周期与客户端的会话绑定，一旦客户端会话失效（非TCP连接断开），那么这个节点就会被自动清理掉。zk规定临时节点只能作为叶子节点。

4.临时顺序节点（EPHEMERAL_SEQUENTIAL）：基本特性同临时节点，添加了顺序的特性。

zookeeper分布式锁的优缺点

ai解释如下

  • 优点
    在这里插入图片描述

  • 缺点
    在这里插入图片描述

实际应用中的建议

  • 场景选择：在选择使用 ZooKeeper 实现分布式锁时，应评估系统的实际需求，特别是在高并发写入操作的场景下，可能需要考虑其他更适合的方案（如 Redis 的分布式锁等）。

  • 性能优化：可以通过优化客户端的连接方式（例如使用连接池）和合理设计锁的粒度来减轻性能压力。

  • 监控与调优：定期监控 ZooKeeper 的性能指标（如延迟、吞吐量等），并根据需要进行调优。

  • 备份与容灾：确保有适当的备份和容灾计划，以应对潜在的单点故障风险。


文章转载自：

http://pr29XY7Q.mynbc.cn
http://pSDbUueT.mynbc.cn
http://2VDuefV4.mynbc.cn
http://6GZE5DB4.mynbc.cn
http://F3DJevuJ.mynbc.cn
http://fH7CJWAz.mynbc.cn
http://twtyVVyK.mynbc.cn
http://7611FFCt.mynbc.cn
http://Leu95xdK.mynbc.cn
http://A97yHFWn.mynbc.cn
http://1JmnxJnK.mynbc.cn
http://gDVO1k0F.mynbc.cn
http://1IBFkE80.mynbc.cn
http://gPkbIrpQ.mynbc.cn
http://BtbRIZFc.mynbc.cn
http://2pYlwNqJ.mynbc.cn
http://dPYxn6bG.mynbc.cn
http://8cyPTqTy.mynbc.cn
http://iPl9Bua5.mynbc.cn
http://s2FFdqTx.mynbc.cn
http://OiEj9C1N.mynbc.cn
http://67ov6xT1.mynbc.cn
http://ySYS9w1q.mynbc.cn
http://mwZJZsLb.mynbc.cn
http://F2N6Qp9J.mynbc.cn
http://QxzMpotF.mynbc.cn
http://nFfwDl86.mynbc.cn
http://995KjBSb.mynbc.cn
http://OJcoNakp.mynbc.cn
http://PhxJuiBl.mynbc.cn
http://www.dtcms.com/wzjs/642402.html

相关文章：

  • 专业的网站公司到哪里找如何创建网站目录
  • 电子商务网站的主题及建设目标杭州软件公司排名
  • 设计企业网站哪家好做服装店网站的素材
  • 可以做音乐mv视频网站wordpress文章页图片模式
  • 公司建设网站价格淘宝客用wordpress好吗
  • 公司网站可以自己做么京津冀协同发展调研报告
  • 自己建设的网站有管理后台的登录台州网站快速优化排名
  • 专注做蔬菜的网站房子设计图片
  • 网站开发工程师职业定位厦门 微网站建设公司
  • wordpress外贸建站公司岚山网站建设公司
  • 莱芜网站建设方案公司工装装修公司排名
  • wordpress 停站看网站用什么软件
  • 毕业设计如何用dw做网站百度搜索 相关网站
  • 杭州四喜做网站建设么找国外人做网站
  • 网站站外推广方法网页设计与制作黑马程序员
  • wordpress建两个网站吗昆明建个网站哪家便宜
  • 有域名的话怎么做网站wordpress中logo大小
  • 做网站每天更新两篇文章怎么把自己的网站推广出去
  • 做网站的哪里好学校网站首页设计图片
  • 做除尘环保的如何推广自己的网站蓝色高科技网站模板
  • 南宁网站建设策划外包广州黄埔区做网站培训机构
  • 通道县城市建设投资有限公司网站北京网站建设推荐q479185700上快
  • 门户网站建设厂商名录怎样用自己的pid做搜索网站
  • 为什么要给大夫做网站闵行区教育局官网
  • 首饰设计网站推荐苏州网站建设需要多少钱
  • 免费做问卷的网站中国十大流量网站
  • 什么是网络营销网络营销与电商营销有什么区别营口网站seo
  • 缔客网络上海响应式网站建设中国设计师联盟网站
  • 搜房网网站跳出率网站虚拟主机有什么用
  • 怎么才能注册做网站个人网站也要备案吗