客服电话
APP下载
迪恩网络APP
随时随地掌握行业动态
官方微信
扫描二维码
关注迪恩网络微信公众号
开源软件名称：coody-elock开源软件地址：https://gitee.com/coodyer/coody-elock开源软件介绍：Coody-Elock动机：在实际产品研发生涯中，有很多业务会涉及到分布式锁的使用。其中比较成熟的，当属redisson(笔者在用)。 然，对于笔者这种有无限洁癖又不喜臃肿的野生技术员来说。使用redisson徒增了近12M的体积让笔者非常难受。 加上redisson配置过于繁琐，相对笨重，仅仅使用redisson来作为分布式锁，实在是宰牛刀杀鸡。 故此，笔者准备研发自己的分布式锁插件。 注：本插件在未来一段时间将不断迭代，提供切面、redis集群、zookeeper支持等拓展，归属Coody Framework下，将发布Maven中央仓库。传送门：https://gitee.com/coodyer/coody-icop 软件架构使用jedis基于redis订阅功能实现的分布式锁插件 使用说明1. 初始化JedisPool //直接传入连接池初始化 ELockCache.initJedisPool(JediPool); //传入ip、端口、密码、超时时间初始化 ELockCache.initJedisPool(host, port, secretKey, timeOut); //传入ip、端口、密码、超时时间、配置器初始化 ELockCache.initJedisPool(host, port, secretKey, timeOut, jedisPoolConfig);注：无密码请传null 2. 加锁LockHandle.lock(key, expireSecond);3. 释放锁LockHandle.unLock(key);4. 总揽
5. 注意加锁代码(LockHandle.lock(key, expireSecond);)。需try{}catch{}包围，并在finally释放锁(LockHandle.unLock(key);) try { LockHandle.lock(key, 100); for (int i = 0; i < 10; i++) { System.out.println(Thread.currentThread().getId() + ">>" + i); Thread.sleep(100l); } } catch (InterruptedException e) { e.printStackTrace(); } finally { LockHandle.unLock(key); }6. 测试代码package org.coody.framework.elock.test;import java.util.ArrayList;import java.util.List;import org.coody.framework.elock.LockHandle;import org.coody.framework.elock.redis.ELockCache;/** * 分布式锁测试 * @author Coody * * 2018年12月14日 * * @blog 54sb.org */public class ELockTest { //要加锁的key static String key = "TESTLOCK_1"; static { //初始化jedis连接 ELockCache.initJedisPool("127.0.0.1", 16379, "123456", 10000); } public static void main(String[] args) { List<Thread> threads = new ArrayList<Thread>(); for (int i = 0; i < 10; i++) { Thread thread = new Thread(new Runnable() { @Override public void run() { test(); } }); threads.add(thread); } //启动十个线程 for (Thread thread : threads) { thread.start(); } } //要锁的方法 private static void test() { try { LockHandle.lock(key, 100); for (int i = 0; i < 10; i++) { System.out.println(Thread.currentThread().getId() + ">>" + i); Thread.sleep(100l); } } catch (InterruptedException e) { e.printStackTrace(); } finally { LockHandle.unLock(key); } }}7. 执行效果
版权说明：在本项目源代码中，已有测试示例作者：Coody版权：©2014-2020 Test404 All right reserved. 版权所有反馈邮箱：[email protected] |
请发表评论