lxm_library_java/SnowFlake-IdGenerator
1
0
Fork 0
mirror of synced 2026-04-18 14:28:43 +08:00
Code Issues Projects Releases Wiki Activity

!10 PHP扩展增加参数校验。统一参数描述

Browse Source
This commit is contained in:
微希夷
2021-04-13 11:17:09 +08:00
committed by yitter
parent 694c4712d5
commit e74f2fba2a
5 changed files with 116 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
PHP/README.md
View File

@@ -23,14 +23,14 @@ make install
**配置文件配置参数**：
```shell
//snowdrift.ini
snowdrift.Method=1 //1 漂移算法 2 传统算法
snowdrift.BaseTime=1582136402000
snowdrift.WorkerId=1 //默认workerid，支持参数传递改变实际使用的值，范围1~(-1L << snowdrift.WorkerIdBitLength) ^ -1L
snowdrift.WorkerIdBitLength=6 //WorkerId位数，默认6。
snowdrift.SeqBitLength=6 //自增序号位数
snowdrift.MaxSeqNumber=0 //默认值为0，0时自动计算=(-1L << snowdrift.SeqBitLength) ^ -1L，需大于MinSeqNumber
snowdrift.MinSeqNumber=5 //默认值为5，当配置了MaxSeqNumber时，需小于MaxSeqNumber
snowdrift.TopOverCostCount=2000 //最大漂移次数
snowdrift.Method=1 // 雪花计算方法,（1-漂移算法|2-传统算法），默认1
snowdrift.BaseTime=1582136402000 //基础时间（ms单位），不能超过当前系统时间
snowdrift.WorkerId=1 //机器码，必须由外部设定，最大值 2^WorkerIdBitLength-1
snowdrift.WorkerIdBitLength=6 //机器码位长，默认值6，取值范围 [1, 15]（要求：序列数位长+机器码位长不超过22）
snowdrift.SeqBitLength=6 //序列数位长，默认值6，取值范围 [3, 21]（要求：序列数位长+机器码位长不超过22）
snowdrift.MaxSeqNumber=0 //最大序列数（含），设置范围 [MinSeqNumber, 2^SeqBitLength-1]，默认值0，表示最大序列数取最大值（2^SeqBitLength-1]
snowdrift.MinSeqNumber=5 //最小序列数（含），默认值5，取值范围 [5, MaxSeqNumber]，每毫秒的前5个序列数对应编号0-4是保留位，其中1-4是时间回拨相应预留位，0是手工新值预留位
snowdrift.TopOverCostCount=2000 //最大漂移次数（含），默认2000，推荐范围 500-20000（与计算能力有关）
```
**函数签名**：

2
PHP/snowdrift.c
View File

@@ -99,8 +99,6 @@ PHP_METHOD(snowdrift, NextId)
RETURN_LONG(NextId(flake));
}
/** 这种方式性能比不上PHP直接循环调用NextId快
*/
PHP_METHOD(snowdrift, NextNumId)
{
zend_long num = 1;

125
PHP/src/snowflake/snowflake.c
View File

@@ -9,12 +9,13 @@
#endif
static void EndOverCostAction(uint64_t useTimeTick, snowflake *flake);
static uint64_t NextOverCostId(snowflake *flake);
static uint64_t NextNormalId(snowflake *flake);
static uint64_t GetCurrentTimeTick(snowflake *flake);
static uint64_t GetNextTimeTick(snowflake *flake);
static uint64_t CalcId(snowflake *flake);
static uint64_t CalcTurnBackId(snowflake *flake);
static inline uint64_t NextOverCostId(snowflake *flake);
static inline uint64_t NextNormalId(snowflake *flake);
static inline uint64_t GetCurrentTimeTick(snowflake *flake);
static inline uint64_t GetNextTimeTick(snowflake *flake);
static inline uint64_t CalcId(snowflake *flake);
static inline uint64_t CalcTurnBackId(snowflake *flake);
static inline uint64_t GetCurrentTime();
int ncpu;
uint16_t spin = 2048;
@@ -37,19 +38,90 @@ void Config(snowflake *flake)
ncpu = 1;
}
}
flake->WorkerIdBitLength = flake->WorkerIdBitLength == 0 ? 6 : flake->WorkerIdBitLength;
flake->SeqBitLength = flake->SeqBitLength == 0 ? 6 : flake->SeqBitLength;
flake->MaxSeqNumber = flake->MaxSeqNumber > 0 ? flake->MaxSeqNumber : (-1L << flake->SeqBitLength) ^ -1L;
flake->BaseTime = flake->BaseTime != 0 ? flake->BaseTime : 1577808000000;
flake->_TimestampShift = (uint8_t)(flake->WorkerIdBitLength + flake->SeqBitLength);
flake->_CurrentSeqNumber = flake->MinSeqNumber;
if (flake->MaxSeqNumber <= flake->MinSeqNumber)
if (flake->BaseTime == 0)
{
flake->MinSeqNumber = 0;
flake->BaseTime = 1582136402000;
}
else if (flake->BaseTime < 631123200000 || flake->BaseTime > GetCurrentTime())
{
perror("BaseTime error.");
return 0;
}
// 2.WorkerIdBitLength
if (flake->WorkerIdBitLength <= 0)
{
perror("WorkerIdBitLength error.(range:[1, 21])");
exit(1);
}
if (flake->SeqBitLength + flake->WorkerIdBitLength > 22)
{
perror("error：WorkerIdBitLength + SeqBitLength <= 22");
exit(1);
}
else
{
flake->WorkerIdBitLength = flake->WorkerIdBitLength <= 0 ? 6 : flake->WorkerIdBitLength;
}
// 3.WorkerId
uint32_t maxWorkerIdNumber = (1 << flake->WorkerIdBitLength) - 1;
if (maxWorkerIdNumber == 0)
{
maxWorkerIdNumber = 63;
}
if (flake->WorkerId < 0 || flake->WorkerId > maxWorkerIdNumber)
{
perror("WorkerId error. (range:[0, {2^WorkerIdBitLength-1]}");
exit(1);
}
// 4.SeqBitLength
if (flake->SeqBitLength < 2 || flake->SeqBitLength > 21)
{
perror("SeqBitLength error. (range:[2, 21])");
exit(1);
}
else
{
flake->SeqBitLength = flake->SeqBitLength <= 0 ? 6 : flake->SeqBitLength;
}
// 5.MaxSeqNumber
uint32_t maxSeqNumber = (1 << flake->SeqBitLength) - 1;
if (maxSeqNumber == 0)
{
maxSeqNumber = 63;
}
if (flake->MaxSeqNumber > maxSeqNumber)
{
perror("MaxSeqNumber error. (range:[1, {2^SeqBitLength-1}]");
exit(1);
}
else
{
flake->MaxSeqNumber = flake->MaxSeqNumber <= 0 ? maxSeqNumber : flake->MaxSeqNumber;
}
// 6.MinSeqNumber
if (flake->MinSeqNumber < 5 || flake->MinSeqNumber > maxSeqNumber)
{
perror("MinSeqNumber error. (range:[5, {MinSeqNumber}]");
exit(1);
}
else
{
flake->MinSeqNumber = flake->MinSeqNumber <= 0 ? 5 : flake->MinSeqNumber;
}
// 7.Others
flake->TopOverCostCount = flake->TopOverCostCount <= 0 ? 2000 : flake->TopOverCostCount;
flake->_TimestampShift = flake->WorkerIdBitLength + flake->SeqBitLength;
flake->_CurrentSeqNumber = flake->MinSeqNumber;
flake->Method = flake->Method;
}
void inline EndOverCostAction(uint64_t useTimeTick, snowflake *flake)
static inline void EndOverCostAction(uint64_t useTimeTick, snowflake *flake)
{
if (flake->_TermIndex > 10000)
{
@@ -57,7 +129,7 @@ void inline EndOverCostAction(uint64_t useTimeTick, snowflake *flake)
}
}
uint64_t inline NextOverCostId(snowflake *flake)
static inline uint64_t NextOverCostId(snowflake *flake)
{
uint64_t currentTimeTick = GetCurrentTimeTick(flake);
if (currentTimeTick > flake->_LastTimeTick)
@@ -94,7 +166,7 @@ uint64_t inline NextOverCostId(snowflake *flake)
return CalcId(flake);
}
uint64_t inline NextNormalId(snowflake *flake)
static inline uint64_t NextNormalId(snowflake *flake)
{
uint64_t currentTimeTick = GetCurrentTimeTick(flake);
if (currentTimeTick < flake->_LastTimeTick)
@@ -133,14 +205,19 @@ uint64_t inline NextNormalId(snowflake *flake)
return CalcId(flake);
}
uint64_t inline GetCurrentTimeTick(snowflake *flake)
static inline uint64_t GetCurrentTime()
{
struct timeval t;
gettimeofday(&t, NULL);
return (uint64_t)((t.tv_sec * 1000 + t.tv_usec / 1000) - flake->BaseTime);
return (uint64_t)(t.tv_sec * 1000 + t.tv_usec / 1000);
}
uint64_t inline GetNextTimeTick(snowflake *flake)
static inline uint64_t GetCurrentTimeTick(snowflake *flake)
{
return GetCurrentTime() - flake->BaseTime;
}
static inline uint64_t GetNextTimeTick(snowflake *flake)
{
uint64_t tempTimeTicker = GetCurrentTimeTick(flake);
while (tempTimeTicker <= flake->_LastTimeTick)
@@ -150,21 +227,21 @@ uint64_t inline GetNextTimeTick(snowflake *flake)
return tempTimeTicker;
}
uint64_t inline CalcId(snowflake *flake)
static inline uint64_t CalcId(snowflake *flake)
{
uint64_t result = (flake->_LastTimeTick << flake->_TimestampShift) + (flake->WorkerId << flake->SeqBitLength) + (flake->_CurrentSeqNumber);
flake->_CurrentSeqNumber++;
return result;
}
uint64_t inline CalcTurnBackId(snowflake *flake)
static inline uint64_t CalcTurnBackId(snowflake *flake)
{
uint64_t result = (flake->_LastTimeTick << flake->_TimestampShift) + (flake->WorkerId << flake->SeqBitLength) + (flake->_TurnBackTimeTick);
flake->_TurnBackTimeTick--;
return result;
}
uint64_t inline NextSonwId(snowflake *flake)
static inline uint64_t NextSonwId(snowflake *flake)
{
uint64_t currentTimeTick = GetCurrentTimeTick(flake);
if (flake->_LastTimeTick == currentTimeTick)
@@ -184,7 +261,7 @@ uint64_t inline NextSonwId(snowflake *flake)
return (uint64_t)((currentTimeTick << flake->_TimestampShift) | (flake->WorkerId << flake->SeqBitLength) | flake->_CurrentSeqNumber);
}
uint64_t inline GetId(snowflake *flake)
static inline uint64_t GetId(snowflake *flake)
{
return flake->Method == 1 ? (flake->_IsOverCost != 0 ? NextOverCostId(flake) : NextNormalId(flake)) : NextSonwId(flake);
}

2
PHP/src/test.c
View File

@@ -12,7 +12,7 @@
#define THREAD 2
#define TOTAL 50000
static snowflake snowf = {1, 0, 1, 6, 6, 0, 0, 2000};
static snowflake snowf = {1, 0, 1, 6, 12, 0, 5, 2000};
static snowflake *flake = &snowf;
uint64_t arr[TOTAL];

12
zzz-OtherLanguages/V/source/contract/IdGeneratorOptions.v
View File

@@ -4,10 +4,10 @@ pub struct IdGeneratorOptions {
pub mut:
method u16 = 1 // 雪花计算方法,（1-漂移算法|2-传统算法），默认1
base_time i64 = 1582136402000 // 基础时间，不能超过当前系统时间
worker_id u16 = 1 // 机器码，与 workerid_bitlength 有关系
workerid_bitlength byte = 6 // 机器码位长，范围：1-21（要求：序列数位长+机器码位长不超过22）
seq_bitlength byte = 6 // 序列数位长，范围：2-21（要求：序列数位长+机器码位长不超过22）
max_seqnumber u32 = 0 // 最大序列数（含），（由seq_bitlength计算的最大值）
min_seqnumber u32 = 5 // 最小序列数（含），默认5，不小于1，不大于max_seqnumber
top_over_cost_count u32 = 2000 // 最大漂移次数（含），默认2000，推荐范围500-10000（与计算能力有关）
worker_id u16 = 1 // 机器码，必须由外部设定，最大值 2^WorkerIdBitLength-1
workerid_bitlength byte = 6 // 机器码位长，默认值6，取值范围 [1, 15]（要求：序列数位长+机器码位长不超过22）
seq_bitlength byte = 6 // 序列数位长，默认值6，取值范围 [3, 21]（要求：序列数位长+机器码位长不超过22）
max_seqnumber u32 = 0 // 最大序列数（含），设置范围 [MinSeqNumber, 2^SeqBitLength-1]，默认值0，表示最大序列数取最大值（2^SeqBitLength-1]）
min_seqnumber u32 = 5 // 最小序列数（含），默认值5，取值范围 [5, MaxSeqNumber]，每毫秒的前5个序列数对应编号0-4是保留位，其中1-4是时间回拨相应预留位，0是手工新值预留位
top_over_cost_count u32 = 2000 // 最大漂移次数（含），默认2000，推荐范围 500-20000（与计算能力有关）
}