溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
小編給大家分享一下java如何使用預分配法生成唯一ID，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！
在項目中經常有生成唯一ID的業務需求。作為唯一標識方便后續查找和追蹤。網上也有很多實現方案。比如：數據庫自增主鍵，數據庫批量生成ID，UUID，時間戳方法，zookeeper生成ID，redis生成唯一ID，snowflake算法等等。這些解決方案各有優缺點。我在游戲項目常用的解決方案是：預分配法生成唯一ID。其原理簡單，利于擴展，具有較強的適用性。
預分配法生成唯一ID原理：數據庫中存儲每種類型最后的預分配dbUniqueId值。數據庫實體對象上增加當前分配的
useDbUniqueId。預分配步長DBUNIQUEID_M可根據類型和業務量自定義。當useDbUniqueId大于等于dbUniqueId時就預分配出DBUNIQUEID_M個唯一ID。
角色ID生成：要求7位連續的唯一ID。則DBUNIQUEID_M=1。1000000+dbUniqueId格式化成7位數字。
本服唯一ID：則DBUNIQUEID_M=10000。(1000000+dbUniqueId)*10000+serverId格式化而成。其中serverId游戲服ID定義為4位
全局唯一ID：則DBUNIQUEID_M=10000。((100000000000L+dbUniqueId)100+gameCode10000+workerId;格式化而成。其中gameCode游戲編碼定義為2位。
具體實現請參閱代碼。非常方便的移植到項目工程中。
IdWorkerEnum.java
package com.game.common.db;
import java.util.List;
import com.core.enums.LLIndexedEnum;
/**
* ID枚舉類型
* @author Thinker
*/
public enum IdWorkerEnum implements LLIndexedEnum
{
/** 角色ID */
IDWORKER_HUMANID(1,"角色ID"),
/** 數據庫ID */
IDWORKER_DBID(2,"數據庫ID"),
/** 工會ID */
IDWORKER_CLUBID(3,"工會ID"),
/** 收集ID */
IDWORKER_COLLECTID(4,"收集ID"),;
/** 枚舉的索引 */
public final int index;
/** 名稱的key */
private final String nameKey;
/** 按索引順序存放的枚舉數組 */
private static final List<IdWorkerEnum> indexes=LLIndexedEnum.IndexedEnumUtil.toIndexes(IdWorkerEnum.values());
private IdWorkerEnum(int index,String nameKey)
{
this.index=index;
this.nameKey=nameKey;
}
/**
* 獲取索引
*/
@Override
public int getIndex()
{
return index;
}
/**
* 取得名稱key
*/
public String getNameKey()
{
return this.nameKey;
}
/**
* 根據指定的索引獲取枚舉的定義
*/
public static IdWorkerEnum valueOf(final int index)
{
return LLIndexedEnum.IndexedEnumUtil.valueOf(indexes,index);
}
}DbUniqueIdEntity.java
package com.game.common.db;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import org.eclipse.persistence.annotations.HashPartitioning;
import org.eclipse.persistence.annotations.Partitioned;
import com.game.common.db.dao.BaseDbBean;
/**
* 數據庫唯一KEY實體類
* @author Thinker
*/
@Entity(name="t_dbUniqueId")
@HashPartitioning(name="HashPartitionByDbUniqueCacheId",partitionColumn=@Column(name="dbUniqueCacheId"))
@Partitioned("HashPartitionByDbUniqueCacheId")
public class DbUniqueIdEntity extends BaseDbBean
{
/** 數據庫唯一緩存ID **/
@Id
@Column(length=20)
private long dbUniqueCacheId;
/** 數據庫唯一ID **/
@Column(length=20)
private long dbUniqueId;
/** 最后更新的時間 **/
@Column(length=20)
private long createTime;
// ////////////////內部數據//////////////////
/** 已經使用過的數據庫唯一ID(唯一ID) */
@Column(length=20)
private long useDbUniqueId;
@Override
public long getId()
{
return dbUniqueCacheId;
}
@Override
public void setId(long id)
{
}
public long getDbUniqueCacheId()
{
return dbUniqueCacheId;
}
public void setDbUniqueCacheId(long dbUniqueCacheId)
{
this.dbUniqueCacheId=dbUniqueCacheId;
}
public long getDbUniqueId()
{
return dbUniqueId;
}
public void setDbUniqueId(long dbUniqueId)
{
this.dbUniqueId=dbUniqueId;
}
public long getCreateTime()
{
return createTime;
}
public void setCreateTime(long createTime)
{
this.createTime=createTime;
}
public long getUseDbUniqueId()
{
return useDbUniqueId;
}
public void setUseDbUniqueId(long useDbUniqueId)
{
this.useDbUniqueId=useDbUniqueId;
}
}IdWorker.java
package com.game.common.db;
import com.game.common.Globals;
import com.game.common.entityProxy.EntityProxy;
import com.game.core.appConfig.AppConfigServ;
import com.game.core.utils.LoggerUtils;
/**
* 唯一ID生成器
*
* @author Thinker
*/
public class IdWorker
{
public final static IdWorker OBJ=new IdWorker(AppConfigServ.OBJ.getAppConfigBean().getServerNo());
private int DBUNIQUEID_M=2000;
private final long workerId;
/** 數據庫連接池 */
private DbUniqueIdEntity[] szDbUniqueIdEntity=new DbUniqueIdEntity[5];
public IdWorker(long workerId)
{
this.workerId=workerId;
}
/**
* 生成系統唯一ID:采用隱性鎖方式
*/
public synchronized long nextId()
{
IdWorkerEnum idWorkerEnum=IdWorkerEnum.IDWORKER_DBID;
int dbUniqueCacheId=idWorkerEnum.getIndex();
loadDbUniqueId(idWorkerEnum);
DbUniqueIdEntity dbUniqueIdEntity=szDbUniqueIdEntity[dbUniqueCacheId];
long dbUniqueId=0;
// 需要重新分配Id:每次分配 M個
if(dbUniqueIdEntity.getUseDbUniqueId()>=dbUniqueIdEntity.getDbUniqueId())
{
dbUniqueIdEntity.setDbUniqueId(dbUniqueIdEntity.getDbUniqueId()+DBUNIQUEID_M);
EntityProxy.OBJ.update((long) dbUniqueCacheId,dbUniqueIdEntity);
LoggerUtils.serverLogger.info("IdWorker DbId:update dbUniqueId="+dbUniqueIdEntity.getDbUniqueId());
}
dbUniqueId=dbUniqueIdEntity.getUseDbUniqueId()+1;
dbUniqueIdEntity.setUseDbUniqueId(dbUniqueId);
// 11位UUID
return (1000000+dbUniqueId)*10000+workerId;
}
/**
* 生成系統唯一HumanID:采用隱性鎖方式
*/
public synchronized long nextHumanId()
{
IdWorkerEnum idWorkerEnum=IdWorkerEnum.IDWORKER_HUMANID;
int dbUniqueCacheId=idWorkerEnum.getIndex();
loadDbUniqueId(idWorkerEnum);
DbUniqueIdEntity dbUniqueIdEntity=szDbUniqueIdEntity[dbUniqueCacheId];
long dbUniqueId=0;
// 需要重新分配Id:每次分配 M個
if(dbUniqueIdEntity.getUseDbUniqueId()>=dbUniqueIdEntity.getDbUniqueId())
{
dbUniqueIdEntity.setDbUniqueId(dbUniqueIdEntity.getDbUniqueId()+1);
EntityProxy.OBJ.update((long) dbUniqueCacheId,dbUniqueIdEntity);
LoggerUtils.serverLogger.info("IdWorker HumanId:update dbUniqueId="+dbUniqueIdEntity.getDbUniqueId());
}
dbUniqueId=dbUniqueIdEntity.getUseDbUniqueId()+1;
dbUniqueIdEntity.setUseDbUniqueId(dbUniqueId);
// 7位UUID
return (1000000+dbUniqueId);
}
/**
* 生成系統唯一ClubID:采用隱性鎖方式
*/
public synchronized long nextClubId()
{
IdWorkerEnum idWorkerEnum=IdWorkerEnum.IDWORKER_CLUBID;
int dbUniqueCacheId=idWorkerEnum.getIndex();
loadDbUniqueId(idWorkerEnum);
DbUniqueIdEntity dbUniqueIdEntity=szDbUniqueIdEntity[dbUniqueCacheId];
long dbUniqueId=0;
// 需要重新分配Id:每次分配 M個
if(dbUniqueIdEntity.getUseDbUniqueId()>=dbUniqueIdEntity.getDbUniqueId())
{
dbUniqueIdEntity.setDbUniqueId(dbUniqueIdEntity.getDbUniqueId()+1);
EntityProxy.OBJ.update((long) dbUniqueCacheId,dbUniqueIdEntity);
LoggerUtils.serverLogger.info("IdWorker clubId:update dbUniqueId="+dbUniqueIdEntity.getDbUniqueId());
}
dbUniqueId=dbUniqueIdEntity.getUseDbUniqueId()+1;
dbUniqueIdEntity.setUseDbUniqueId(dbUniqueId);
// 5位UUID
return (10000+dbUniqueId);
}
/**
* 生成系統唯一ID:采用隱性鎖方式
*/
public synchronized long nextCollectId()
{
IdWorkerEnum idWorkerEnum=IdWorkerEnum.IDWORKER_COLLECTID;
int dbUniqueCacheId=idWorkerEnum.getIndex();
loadDbUniqueId(idWorkerEnum);
DbUniqueIdEntity dbUniqueIdEntity=szDbUniqueIdEntity[dbUniqueCacheId];
long dbUniqueId=0;
// 需要重新分配Id:每次分配 M個
if(dbUniqueIdEntity.getUseDbUniqueId()>=dbUniqueIdEntity.getDbUniqueId())
{
dbUniqueIdEntity.setDbUniqueId(dbUniqueIdEntity.getDbUniqueId()+DBUNIQUEID_M);
EntityProxy.OBJ.update((long) dbUniqueCacheId,dbUniqueIdEntity);
LoggerUtils.serverLogger.info("IdWorker DbId:update dbUniqueId="+dbUniqueIdEntity.getDbUniqueId());
}
dbUniqueId=dbUniqueIdEntity.getUseDbUniqueId()+1;
dbUniqueIdEntity.setUseDbUniqueId(dbUniqueId);
// 18位UUID:游戲ID+服務器ID。確保支持多游戲不重復的ID。便于兼容統計
return ((100000000000L+dbUniqueId)*100+AppConfigServ.OBJ.getAppConfigBean().getGameCode())*10000+workerId;
}
/**
* 加載唯一ID
*/
public void loadDbUniqueId(IdWorkerEnum idWorkerEnum)
{
int dbUniqueCacheId=idWorkerEnum.getIndex();
if(szDbUniqueIdEntity[dbUniqueCacheId]!=null) return;
DbUniqueIdEntity dbUniqueIdEntity=EntityProxy.OBJ.get((long) dbUniqueCacheId,(long) dbUniqueCacheId,DbUniqueIdEntity.class);
if(dbUniqueIdEntity==null)
{
dbUniqueIdEntity=new DbUniqueIdEntity();
dbUniqueIdEntity.setDbUniqueCacheId(dbUniqueCacheId);
dbUniqueIdEntity.setDbUniqueId(0);
dbUniqueIdEntity.setCreateTime(Globals.getTimeService().now());
dbUniqueIdEntity.setUseDbUniqueId(0);
EntityProxy.OBJ.insert((long) dbUniqueCacheId,dbUniqueIdEntity);
}
dbUniqueIdEntity.setUseDbUniqueId(dbUniqueIdEntity.getDbUniqueId());
szDbUniqueIdEntity[dbUniqueCacheId]=dbUniqueIdEntity;
LoggerUtils.serverLogger.info("IdWorker:load dbUniqueId="+dbUniqueIdEntity.getDbUniqueId());
}
}以上是“java如何使用預分配法生成唯一ID”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
