建设网站能自学吗,网站外链,网络公司网站模版,电子商务网站系统的开发设计一、说明
TM就是事务管理#xff1a;实现对于事务的新增#xff08;active#xff09;、事务的状态修改#xff08;commit、abort#xff09;、事务的状态判断 二、事务管理
2.1创建xid文件/打开xid文件
创建xid、写一个空的 XID 文件头并创建TM public static Transac…一、说明
TM就是事务管理实现对于事务的新增active、事务的状态修改commit、abort、事务的状态判断 二、事务管理
2.1创建xid文件/打开xid文件
创建xid、写一个空的 XID 文件头并创建TM public static TransactionManagerImpl create(String path) {//创建文件.xidFile f new File(pathTransactionManagerImpl.XID_SUFFIX);try {if(!f.createNewFile()) {Panic.panic(Error.FileExistsException);}} catch (Exception e) {Panic.panic(e);}if(!f.canRead() || !f.canWrite()) {Panic.panic(Error.FileCannotRWException);}//用于高效地处理文件的读取和写入操作FileChannel fc null;//任意读文件RandomAccessFile raf null;try {raf new RandomAccessFile(f, rw);fc raf.getChannel();} catch (FileNotFoundException e) {Panic.panic(e);}// 写空XID文件头ByteBuffer buf ByteBuffer.wrap(new byte[TransactionManagerImpl.LEN_XID_HEADER_LENGTH]);try {//定位到指定位置fc.position(0);//进行写入fc.write(buf);} catch (IOException e) {Panic.panic(e);}return new TransactionManagerImpl(raf, fc);}
2.2 打开xid文件并创建TM
public static TransactionManagerImpl open(String path) {File f new File(pathTransactionManagerImpl.XID_SUFFIX);if(!f.exists()) {Panic.panic(Error.FileNotExistsException);}if(!f.canRead() || !f.canWrite()) {Panic.panic(Error.FileCannotRWException);}FileChannel fc null;RandomAccessFile raf null;try {raf new RandomAccessFile(f, rw);fc raf.getChannel();} catch (FileNotFoundException e) {Panic.panic(e);}return new TransactionManagerImpl(raf, fc);} 2.2 基于TM进行相关的事务处理
0. 检查文件是否合法 :利用 RandomAccessFile 文件长度 和 new io 的一个类 FileChannel
1、新增事务
新增字节、修改事务总数
2、修改事务状态
通过 updateXID()实现 updateXid是对指定位置写 如果没有直接写 如果有会覆盖
3、事务的状态判断 2.3 注意事项
这里的所有文件操作在执行后都需要立刻刷入文件中防止在崩溃后文件丢失数据fileChannel 的 force() 方法强制同步缓存内容到文件中类似于 BIO 中的 flush() 方法。force 方法的参数是一个布尔表示是否同步文件的元数据例如最后修改时间等。
每次写完会try force() 方法。
