fix协议封装挑战-DbFail

xiaoxiao2021-02-28  110

package cs.mina.client.handler; import java.io.Serializable; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import cs.mina.codec.msg.BaseMsg; import cs.util.FileOPUtil; /* *@author(huangxiaoping) *@date 2014-1-11 */ public class DbFail implements Serializable{ private int id; private BaseMsg msg; private static int idGen; private static Lock lock=new ReentrantLock(); static{ idGen=FileOPUtil.readDbFailId(); if(idGen<0){ idGen=0; } } public DbFail(){ lock.lock(); try{ idGen++; setId(idGen); }finally{ lock.unlock(); } } public int getId() { return id; } public void setId(int id) { this.id = id; } public BaseMsg getMsg() { return msg; } public void setMsg(BaseMsg msg) { this.msg = msg; } }
转载请注明原文地址: https://www.6miu.com/read-49949.html

最新回复(0)