數(shù)據(jù)庫(kù)表

create table if not exists yw_lock
(
    lock_field varchar(50) not null,
    lock_table varchar(50) not null,
    constraint pk_yw_lock
        primary key (lock_field, lock_table)
);

comment on table yw_lock is '分布式鎖';

comment on column yw_lock.lock_field is '業(yè)務(wù)鎖';

create index if not exists index_yw_lock_all
    on yw_lock (lock_field, lock_table);

lock實(shí)體類(lèi)

@Data
@EqualsAndHashCode
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "yw_lock")
public class YwLock implements Serializable {

    /**
     * 業(yè)務(wù)鎖
     */
    private String lockField;

    /**
     * 業(yè)務(wù)表
     */
    private String lockTable;

}

public interface YwLockMapper {
    int lock(YwLock ywLock);
    int unLock(YwLock ywLock);
}

<insert id="lock" parameterType="YwLock">
     INSERT INTO yw_lock (
        lock_field,
        lock_table
      ) VALUES (
        #{lockField},
        #{lockTable}
     );
</insert>

<delete id="unLock" parameterType="YwLock">
    DELETE
    FROM yw_lock
    WHERE lock_field = #{lockField} and lock_table = #{lockTable}
</delete>

Service層實(shí)現(xiàn)

public interface IYwLockService {
    /**
     * 加鎖
     */
    boolean lock(YwLock ywLock);

    /**
     * 解鎖
     */
    boolean unLock(YwLock ywLock);
}

implements實(shí)現(xiàn)

@Service
public class YwLockServiceImpl implements IYwLockService {

    @Resource
    private YwLockMapper lockMapper;

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public boolean lock(YwLock ywLock) {
        return lockMapper.lock(ywLock) > 0;
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public boolean unLock(YwLock ywLock) {
        return lockMapper.unLock(ywLock) > 0;
    }
}

通過(guò)service獲取到lock返回為true：表示拿到鎖，可以做業(yè)務(wù)操作，反知道不能做業(yè)務(wù)操作