13518219792
怎么分析ZooKeeper分布式任务调度中心，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
成都网站设计、做网站的开发，更需要了解用户，从用户角度来建设网站，获得较好的用户体验。创新互联公司多年互联网经验，见的多，沟通容易、能帮助客户提出的运营建议。作为成都一家网络公司，打造的就是网站建设产品直销的概念。选择创新互联公司，不只是建站，我们把建站作为产品，不断的更新、完善，让每位来访用户感受到浩方产品的价值服务。
一： 背景
软件系统中，定时任务往往不可或缺，大家可能会采用Spring quartz 建立定时任务模块。 当任务模块进行了分布式部署，通常会出现定时任务重复执行的情况。 怎么避免这种情况呢，是否可以构建一个任务注册中心，Quartz负责注册任务，但不具体执行任务内的业务逻辑。
任务注册中心解决任务重复注册的问题，同时将任务分配给若干处理器进行具体的业务处理，保证在同一个时间内，一个任务只会被一个处理器进行处理。如下图
二：任务注册中心与调度中心
采用ZooKeeper的客户端框架Curator, 利用ZooKeeper的Master选举机制实现。 注册任务就相当于在ZooKeeper中创建或更新一个节点。通过更新节点的内容，来记录任务的执行状态。
三：代码模拟
public class ZookeeperDemo5 {
private static String PATH = "/zkbk2";
private static String FINISH_FLAG="finish";
private static CuratorFramework client = CuratorFrameworkFactory.builder()
.connectString("10.243.3.18:2181,10.243.3.17:2181,10.243.3.27:2181").sessionTimeoutMs(5000)
.retryPolicy(new ExponentialBackoffRetry(100, 3)).build();
public static void main(String[] args) throws Exception {
client.start();
PathChildrenCache cache = new PathChildrenCache(client, PATH, true);
cache.start(StartMode.POST_INITIALIZED_EVENT);
cache.getListenable().addListener(new PathChildrenCacheListener() {
@Override
public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) {
switch (event.getType()) {
case CHILD_ADDED:
System.out.println("CHILD_ADDED," + event.getData().getPath());
deal(event);
break;
case CHILD_UPDATED:
System.out.println("CHILD_UPDATED," + event.getData().getPath());
deal(event);
break;
case CHILD_REMOVED:
System.out.println("CHILD_REMOVED," + event.getData().getPath());
break;
default:
break;
}
}
});
Thread.sleep(Integer.MAX_VALUE);
}
private static void deal( PathChildrenCacheEvent event)
{
final LeaderLatch latch = new LeaderLatch(client, event.getData().getPath());
latch.addListener(new LeaderLatchListener() {
@Override
public void notLeader() {
}
@Override
public void isLeader() {
try {
System.out.println("======begin deal==========" + event.getData().getPath());
String data = new String(client.getData().forPath(event.getData().getPath()));
if (!data.contains("finish")) {
Thread.sleep(10000L);
System.out.println("");
System.out.println("");
System.out.println("**************************************");
System.out.println("**************************************");
System.out.println("**************************************");
System.out.println("**************************************");
System.out.println("");
System.out.println("");
client.setData().forPath(event.getData().getPath(), FINISH_FLAG.getBytes());
}
System.out.println("======finish deal==========" + event.getData().getPath());
latch.close();
}
catch (Exception e) {
e.printStackTrace();
}
}
});
try {
latch.start();
}
catch (Exception e) {
e.printStackTrace();
}
}
}
看完上述内容，你们掌握怎么分析ZooKeeper分布式任务调度中心的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联行业资讯频道，感谢各位的阅读！
