怎么用數(shù)據(jù)庫(kù)的悲觀鎖來(lái)實(shí)現(xiàn)一個(gè)分布式的鎖

public class XttblogLock {
 
    private DataSource dataSource;
 
    private static final String cmd = "select * from xttblog_lock where id = 1 for update";
 
    public XttblogLock(DataSource ds) {
        this.dataSource = ds;
    }
 
    public static interface CallBack{
        public void doAction();
    }
    public void lock(CallBack callBack)  {
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
 
        try {
            //try get lock
            System.out.println(Thread.currentThread().getName() + " begin try lock");
            conn = dataSource.getConnection();
            conn.setAutoCommit(false);
            stmt = conn.prepareStatement(cmd);
            rs = stmt.executeQuery();
           
            //do business thing
            callBack.doAction();
             
            //release lock
            conn.commit();
            System.out.println(Thread.currentThread().getName() + " release lock");
 
        } catch (SQLException e) {
            e.printStackTrace();
 
        } finally {
             
            if (null != conn) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
 
        }
    }
}

final XttblogLock xttblogLock = new XttblogLock(dataSource);
xttblogLock.lock(new CallBack() {
                         
    @Override
    public void doAction() {
        System.out.println(Thread.currentThread().getName() + "beging do somthing");
        try {
            System.out.println("業(yè)余草：www.xttblog.com 歡迎你！");
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "end do somthing");
 
    }
});