java之nio（4）

FileLock

java新IO当中有对文件锁的支持，文件锁主要分为两种：共享锁（读锁）、独占锁（写锁）

 例子1：

 

package nio;

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.FileLock;

public class FileLockTest {
	public static void main(String[] args) throws Exception{
		//读文件
		FileInputStream in = new FileInputStream("F:\\1.txt");
		FileChannel inChannel = in.getChannel();
//		FileLock inFileLock = inChannel.lock();//获取独占所，有异常FileInputStream只能获取共享锁
//		FileLock inFileLock = inChannel.lock(0,in.available(),false);//获取独占所，有异常FileInputStream只能获取共享锁
//		FileLock inFileLock = inChannel.lock(0,in.available(),true);//获取共享锁
		
//		FileLock inFileLock = inChannel.tryLock();//获取独占所，有异常FileInputStream只能获取共享锁
//		FileLock inFileLock = inChannel.tryLock(0,in.available(),false);//获取独占所，有异常FileInputStream只能获取共享锁
		FileLock inFileLock = inChannel.tryLock(0,in.available(),true);//获取共享锁
		inFileLock.release();//锁释放
		inChannel.close();
		in.close();
		
		//写文件
		FileOutputStream out = new FileOutputStream("F:\\1.txt",true);//从文件末尾接着写入，避免之前的内容覆盖
		FileChannel outChannel = out.getChannel();
//		FileLock outFileLock = outChannel.lock();//获取文件的独占锁
//		FileLock outFileLock = outChannel.lock(2,100,true);//获取文件的共享锁
//		FileLock outFileLock = outChannel.lock(2,100,false);//获取文件的独占锁，锁定第2个到100个字节
//		FileLock outFileLock = outChannel.tryLock();//获取文件的独占锁
//		FileLock outFileLock = outChannel.tryLock(2,100,true);//获取文件的共享锁
		FileLock outFileLock = outChannel.tryLock(2,100,false);//获取文件的独占锁，锁定第2个到100个字节
		System.out.println("########");
		outFileLock.release();
		outChannel.close();
		out.close();
	}
	
	private static void printInfo(ByteBuffer buffer) {
		while(buffer.hasRemaining()) {
			System.out.print((char)buffer.get()+"、");
		}
		System.out.println();
	}
}

 上述代码是文件的读锁（共享锁）和写锁（独占锁）的使用方式。共享锁：多个线程可以任意去读、没有任何限制。

其中inputStream获取的锁一般都是共享锁。outputstream获取的锁一般都是独占锁。

上诉代码独占锁锁定了第2个到100字节。但是另外线程还是可以读取前两个字节的。

看下面的例子：

 例子2：

package nio;

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.nio.ByteBuffer;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.FileLock;

public class FileLockTest2 {
	public static void main(String[] args) throws Exception{
		//读文件
		FileInputStream in = new FileInputStream("F:\\1.txt");
		FileChannel inChannel = in.getChannel();
		FileLock inFileLock = inChannel.tryLock(0,in.available(),true);//获取共享锁
		ByteBuffer buffer = ByteBuffer.allocate(1);//只开辟一个缓冲，用于检测FileLockTest中的独占锁的作用
		int temp=0;
		while((temp=inChannel.read(buffer))!=-1){
			buffer.flip();
			printInfo(buffer);
			buffer.clear();
		}
		inFileLock.release();//共享锁释放
		inChannel.close();
		in.close();
	}
	
	private static void printInfo(ByteBuffer buffer) {
		while(buffer.hasRemaining()) {
			System.out.print((char)buffer.get()+"、");
		}
		System.out.println();
	}
}

 运行结果：