项目使用到集群环境,流程发送时如果确保一个流程不会被两个流程同时调用?
有一种办法是用文件锁的方式来实现。
代码如下:
锁接口:
- packagelock;
- importjava.io.FileNotFoundException;
- importjava.io.IOException;
- publicinterfaceLock{
- /**
- *检测是否被锁定
- *@returntrue被锁定,false空闲
- **/
- publicabstractbooleanisLocked()throwsFileNotFoundException;
- /**
- *获取锁资源
- *@returntrue成功锁定目标资源,false锁定操作失败
- **/
- publicabstractbooleanobtain()throwsIOException;
- /**
- *释放锁
- **/
- publicabstractvoidunlock();
- }
文件锁的实现:
- packagelock;
- importjava.io.File;
- importjava.io.FileNotFoundException;
- importjava.io.IOException;
- importjava.io.RandomAccessFile;
- importjava.nio.channels.FileChannel;
- importjava.nio.channels.FileLock;
- importjava.nio.channels.OverlappingFileLockException;
- publicclassFileProgrameLockimplementsLock{
- privateStringcallerThreadID=null;
- privateStringlockFileName=null;
- FileChannelchannel=null;
- privateFileLocklock=null;
- publicstaticLockget(StringfileName,StringcallerThreadID){
- FileProgrameLockd=newFileProgrameLock(fileName);
- d.callerThreadID=callerThreadID;
- return(Lock)d;
- }
- publicFileProgrameLock(StringlockFileName){
- this.lockFileName=lockFileName;
- }
- /**
- *检测是否被锁定-不建议使用
- *@returntrue被锁定,false空闲
- *@deprecated
- **/
- publicbooleanisLocked()throwsFileNotFoundException{
- Filetf=newFile(lockFileName);
- if(!tf.exists()){
- returnfalse;
- }
- FileChannel__channel=newRandomAccessFile(tf,"rw").getChannel();
- FileLocktl=null;
- try{
- tl=__channel.tryLock();
- if(tl==null){
- returntrue;
- }else{
- returnfalse;
- }
- }catch(OverlappingFileLockExceptione){
- returntrue;
- }catch(IOExceptione){
- returntrue;
- }catch(Exceptione){
- returntrue;
- }finally{
- try{
- if(tl!=null){
- tl.release();
- }
- tl=null;
- if(__channel.isOpen()){
- __channel.close();
- }
- __channel=null;
- tf=null;
- }catch(IOExceptione){
- e.printStackTrace();
- }
- }
- }
- /**
- *获取锁资源
- *@returntrue成功锁定目标资源,false锁定操作失败
- **/
- publicbooleanobtain()throwsIOException{
- Filetf=newFile(lockFileName);
- createFile();
- channel=newRandomAccessFile(tf,"rw").getChannel();
- try{
- //System.out.println("getlock000>>>>>>>>>>>>>>>");
- lock=channel.lock();
- //System.out.println("getlock>>>>>>>>>>>>>>>");
- returntrue;
- }catch(OverlappingFileLockExceptione){
- returnfalse;
- }catch(Exceptione){
- returnfalse;
- }
- }
- /**
- *释放锁
- **/
- publicvoidunlock(){
- try{
- if(lock!=null){
- lock.release();
- }
- System.out.println(callerThreadID+"unlockXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX");
- if(channel!=null&&channel.isOpen()){
- channel.close();
- }
- lock=null;
- channel=null;
- this.deleteFile();
- }catch(IOExceptione){
- }
- }
- protectedvoidfinalize()throwsThrowable{
- System.out.println(callerThreadID+this.getClass()+".finalize()");
- super.finalize();
- }
- privatevoidcreateFile()throwsIOException{
- try{
- Filetf=newFile(lockFileName);
- if(!tf.exists()){
- tf.createNewFile();
- }
- tf=null;
- }catch(IOExceptione){
- System.out.println(e+lockFileName);
- throwe;
- }
- }
- privatevoiddeleteFile(){
- Filetf=newFile(lockFileName);
- if(tf.exists()){
- tf.delete();
- }
- tf=null;
- }
- }
工厂类:
- packagelock;
- importjava.io.File;
- importjava.io.FileNotFoundException;
- importjava.io.IOException;
- publicclassMakeLockimplementsRunnable{
- privateStringthreadID="";
- publicvoidrun(){
- try{
- while(true){
- test2(threadID);
- Thread.sleep(200);
- }
- }catch(IOExceptione){
- System.out.println(e);
- e.printStackTrace();
- }catch(InterruptedExceptione){
- System.out.println(e);
- }
- }
- publicvoidtest2(StringthreadID)throwsFileNotFoundException,IOException,InterruptedException{
- Locklock=newMakeLock(threadID).getLock("c:/001/lockfile001.lock",threadID);
- System.out.println(threadID+":obtain...");
- booleanb=lock.obtain();
- //当有重叠时会发生等待,所以外侧先执行isLocked()判断
- System.out.println(threadID+":obtained"+b);
- if(b){//执行业务逻辑
- Thread.sleep(390);
- for(inti=0;i<Integer.MAX_VALUE;i++){
- ;
- }
- lock.unlock();
- }
- lock=null;
- }
- publicMakeLock(StringthreadID){
- this.threadID=threadID;
- }
- publicLockgetLock(Stringname,StringthreadID){
- finalStringBufferbuf=newStringBuffer();
- returnFileProgrameLock.get(name,threadID);
- }
- }
使用方法:
- publicvoidtest2(StringthreadID)throwsFileNotFoundException,IOException,InterruptedException{
- Locklock=newMakeLock(threadID).getLock("c:/001/lockfile001.lock",threadID);
- if(!lock.isLocked()){
- System.out.println(threadID+":obtain...");
- booleanb=lock.obtain();
- System.out.println(threadID+":obtained"+b);
- if(b){//执行业务逻辑
- Thread.sleep(390);
- for(inti=0;i<Integer.MAX_VALUE;i++){
- ;
- }
- lock.unlock();
- }
- }else{
- System.out.println(threadID+":can'tgetalock:"+lock);
- }
- lock=null;
- }
多线程调用测试:
- publicstaticvoidmain(String[]args){
- //newAAA().test();
- System.out.println("=========================================");
- Threadth1=newThread(newMakeLock("====================thread1===================="));
- Threadth2=newThread(newMakeLock("####################thread2####################"));
- Threadth3=newThread(newMakeLock("@@@@@@@@@@@@@@@@@@@@thread3@@@@@@@@@@@@@@@@@@@@"));
- Threadth4=newThread(newMakeLock("$$$$$$$$$$$$$$$$$$$$thread4$$$$$$$$$$$$$$$$$$$$"));
- Threadth5=newThread(newMakeLock("&&&&&&&&&&&&&&&&&&&&thread5&&&&&&&&&&&&&&&&&&&&"));
- th1.start();
- th2.start();
- th3.start();
- th4.start();
- th5.start();
- }
=================
经测试可以在共享文件系统下工作。
附件中AAA.java多线程测试代码可以直接运行。
相关推荐
:Java新IO】_文件锁笔记032003
主要介绍了java 文件锁的简单实现的相关资料,需要的朋友可以参考下
NULL 博文链接:https://sosuny.iteye.com/blog/704587
只锁一个文件,excel word 自带密码不好用,就试一下这个吧单个文锁,目前我也没找到破解的方法,如果忘记密码的了呵呵呵,上帝保佑,如你知也通知我一下吧 ths
Java NIO 源码适合初学者,里面包括通道和Buffer的基本适用,以及文件锁,和内存文件映射等等
java 读取 XML 使用 xml 。。。。。。。。。。。
此文档能够让读者彻底了解JAVA开发中的多线程并发锁的使用
很久以前的工具类代码不过很实用,java的文件读写创建目录复制,移动,文件序列化,反序列化,文件锁,xml文件的读取,诸多内容囊括其中注释也十分详细,学习文件流的不二选择
该项目旨在实现h5与fastdfs之间的高性能断点续传、秒传、大文件上传以及使用redis文件锁。系统提供了文件上传、文件处理、文件存储等功能。通过该项目,开发者可以学习并实践Java技术的应用,为后续的Web开发奠定...
javacore.txt文件用jca打开,heapdump.phd文件用ha打开。...包括 Java 虚拟机的参数,环境变量,内存段的分配情况,垃圾回收日志,各种内部锁的状态,各线程在当前时刻的运行栈,以及类加载状态等。
文件锁、映射的I/O技术以及数据结构与集合;服务器端Java技术部分讨论了JFC/Swing CGI开发、Applet、容器布局以及图形编程等技术;企业级Java技术部分讨论了JDBC API、EJB体系结构的基础知识、Java平台安全方案以及...
该文件是使用javaweb相关的知识编写的关于用户登录界面实现滑动图片解锁实现安全登录的功能项目
java.util.jar 提供读写 JAR (Java ARchive) 文件格式的类,该格式基于具有可选清单文件的标准 ZIP 文件格式。 java.util.logging 提供 JavaTM 2 平台核心日志工具的类和接口。 java.util.prefs 此包允许应用程序...
CDN静态文件访问 分布式存储 分布式搜索引擎 应用发布与监控 应用容灾及机房规划 系统动态扩容 分布式架构策略-分而治之 从简到难,从网络通信探究分布式通信原理 基于消息方式的系统间通信 理解通信协议...
java.util.jar 提供读写 JAR (Java ARchive) 文件格式的类,该格式基于具有可选清单文件的标准 ZIP 文件格式。 java.util.logging 提供 JavaTM 2 平台核心日志工具的类和接口。 java.util.prefs 此包允许应用程序...
适合已经学过锁这方面知识的小伙伴进行学习,思维导图对各种锁进行了详细整理总结,采用思维导图的方式更加方便大伙们学习并记忆。
由于Java Web开发技术大全pdf文件太大120多M,上传资源要求在20M以内,所以大家必须要把Java Web开发技术大全.z01,Java Web开发技术大全.z02,Java Web开发技术大全.z03,Java Web开发技术大全.z04,Java Web开发...
直接给文件夹的内容加上一个密码锁,可以防止外人访问内容。
实现一个拷贝文件的类使用字节流还是字符串.mp4 │ Java面试题13.线程的实现方式 怎么启动线程怎么区分线程.mp4 │ Java面试题14.线程并发库和线程池的作用?.mp4 │ Java面试题15.设计模式和常用的设计模式.mp4 │ ...