Curator 分布式计数器的示例

客官°小女子只卖身不卖艺 2022-02-02 14:31 171阅读 0赞

package com.aop8.curator.atomicinteger;
    
    import org.apache.curator.RetryPolicy;
    import org.apache.curator.framework.CuratorFramework;
    import org.apache.curator.framework.CuratorFrameworkFactory;
    import org.apache.curator.framework.recipes.atomic.AtomicValue;
    import org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger;
    import org.apache.curator.retry.ExponentialBackoffRetry;
    import org.apache.curator.retry.RetryNTimes;
    
    import com.aop8.CommonsUtils;
    
    public class CuratorAtomicInteger { 
    
    	/** session超时时间 */
    	static final int SESSION_OUTTIME = 5000;//ms 
    	
    	public static void main(String[] args) throws Exception { 
    		
    		//1 重试策略：初次间隔时间为1s 重试 10次
    		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 10);
    		//2 通过工厂创建连接
    		CuratorFramework cf = CuratorFrameworkFactory.builder()
    					.connectString("127.0.0.1:2181")
    					.sessionTimeoutMs(SESSION_OUTTIME)
    					.retryPolicy(retryPolicy)
    					.build();
    		//3 开启连接
    		cf.start();
    		//cf.delete().forPath("/super");
    		
    
    		//4 使用DistributedAtomicInteger
    		DistributedAtomicInteger atomicIntger = 
    				new DistributedAtomicInteger(cf, "/distribute/atomic", new RetryNTimes(3, 1000));
    		
    		AtomicValue<Integer> value = atomicIntger.add(3);
    		System.out.println("操作状态："+value.succeeded());
    		System.out.println("原始值: "+value.preValue());	//原始值
    		System.out.println("最新值: "+value.postValue());	//最新值
    		
    	}
    }

运行结果：

操作状态：true
    原始值: 0
    最新值: 3

如果再次运行，结果是

操作状态：true
    原始值: 3
    最新值: 6