当前位置：首页 > news >正文

【分布式系统】唯一性ID的实现

news 2025/8/3 19:08:37

1、UUID（通用唯一标识符）

1、UUID本身
一种用于标识信息的标准化方法。一个128位的数字，常表示为32个十六进制数字，以连字符分隔成五组：8-4-4-4-12。

版本： UUID有不同的版本，最常见的是基于时间戳和随机数生成的版本1和版本4。
唯一性：由于UUID的长度和生成机制，可以保证在大多数情况下生成的UUID是唯一的。
应用：在各种系统中广泛应用，用于唯一标识实体、会话、交易等。

2、设计方法：
时间戳：将当前时间戳作为UUID的一部分，以确保在同一时刻生成的UUID是唯一的。

节点标识：在分布式系统中，将每个节点的唯一标识符（如机器ID）纳入UUID的生成过程，以防止在不同节点上生成相同的UUID。

随机数生成器：将随机数作为UUID的一部分，以增加唯一性，但在分布式系统中要确保随机数生成器是足够随机的。

考虑时钟回拨问题：如果使用时间戳作为UUID的一部分，需要考虑时钟回拨可能导致的重复UUID问题。可以采用一些机制来解决时钟回拨带来的潜在问题，比如使用递增序列号。

一致性哈希算法：基于节点信息和数据内容计算哈希值，然后将哈希值转换为UUID。这样可以确保相同的数据在不同节点上生成的UUID是一致的。

时钟回拨问题：
指在分布式系统中，当某个节点的系统时间发生回拨（即向过去跳跃）时可能导致的一系列问题。
引起的原因：手动调整时间；网络时间协议（NTP）校准；系统重启或故障；虚拟机迁移；
解决方向：使用逻辑时钟；增加容错机制；使用稳定的时钟；时间校正算法；设计时避免依赖绝对时间；

package mainimport ("fmt""github.com/google/uuid"
)func main() {// 生成一个新的 UUIDnewUUID := uuid.New()fmt.Printf("Generated UUID: %s\n", newUUID)
}

2、数据库序列（自增ID）

简单，工作方式：基于中央数据库的序列生成器，如自增ID，每次请求时递增序列值。顺序性：保证了生成ID的顺序性和唯一性。

package mainimport ("database/sql""fmt"_ "github.com/mattn/go-sqlite3"
)func main() {// 连接到 SQLite 数据库db, err := sql.Open("sqlite3", "test.db")if err != nil {fmt.Println(err)return}defer db.Close()// 创建一个包含自增ID的表_, err = db.Exec("CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT)")if err != nil {fmt.Println(err)return}fmt.Println("Table created successfully")
}
//连接到 SQLite 数据库，并创建了一个名为 users 的表，该表包含一个自增的整数类型的ID列和一个文本类型的 name 列。
//不同的数据库（如 MySQL、PostgreSQL 等）可能有不同的语法和方式来实现自动递增的ID列

3、雪花算法（Twitter Snowflake）

Twitter开发的一种生成64位ID的服务，基于时间戳、机器ID和序列号。

时间戳（41位）：用于表示ID生成的时间戳，通常精确到毫秒级。
机器ID（10位）：标识生成ID的机器的唯一标识，通常使用数据中心ID与机器ID的组合。
序列号（12位）：在同一毫秒内，通过累加的方式生成序列号，确保在同一节点上生成的ID是唯一的。

雪花算法的优点包括高性能、高可用性和ID趋势递增。在实际应用中，可根据需求调整时间戳的位数、机器ID的位数和序列号的位数来适应不同的场景。
一般用于替代传统自增ID的方式。

package mainimport ("fmt""sync""time"
)const (epoch time.Duration = 1609459200000 // 2021-01-01 的时间戳，用于生成时间戳部分workerIDBits       = 5               // 机器 ID 的位数sequenceBits       = 12              // 序列号的位数maxWorkerID        = -1 ^ (-1 << workerIDBits)maxSequence        = -1 ^ (-1 << sequenceBits)
)type Snowflake struct {mu         sync.MutexlastTime   int64workerID   uintsequence   uint
}func NewSnowflake(workerID uint) *Snowflake {if workerID > maxWorkerID {panic("worker ID 超出范围")}return &Snowflake{lastTime: 0,workerID: workerID,sequence: 0,}
}func (s *Snowflake) GenerateID() uint64 {s.mu.Lock()defer s.mu.Unlock()currentTime := time.Now().UnixNano() / 1e6 // 获取当前时间的毫秒数if s.lastTime == currentTime {s.sequence = (s.sequence + 1) & maxSequenceif s.sequence == 0 {for currentTime <= s.lastTime {currentTime = time.Now().UnixNano() / 1e6}}} else {s.sequence = 0}s.lastTime = currentTimeid := uint64((currentTime-epoch)<<22 | int64(s.workerID)<<17 | int64(s.sequence))return id
}func main() {sf := NewSnowflake(1) // 设定一个机器 IDid := sf.GenerateID()fmt.Println(id)
}

4、使用Redis实现分布式ID生成

Redis是一个高性能的键值数据库，它可以用于生成分布式唯一标识符。
不同Redis实例通过配置不同的起始步长来区分。
这个的实现原理利用了Redis的原子操作。

package mainimport ("fmt""github.com/go-redis/redis/v8""log""time"
)var redisClient *redis.Clientfunc init() {redisClient = redis.NewClient(&redis.Options{Addr:     "localhost:6379", // Redis 服务器地址Password: "",               // Redis 密码，如果有的话DB:       0,                // 选择使用的数据库})
}func generateID(key string) (int64, error) {val, err := redisClient.Incr(key).Result()if err != nil {return 0, err}return val, nil
}func main() {key := "distributed_id_generator" // Redis 中的键名// 生成 5 个分布式 IDfor i := 0; i < 5; i++ {id, err := generateID(key)if err != nil {log.Fatalf("Failed to generate ID: %v", err)}fmt.Printf("Generated ID: %d\n", id)time.Sleep(time.Millisecond) // 可选的延迟，以避免生成相同的 ID}
}

package mainimport ("fmt""github.com/go-redis/redis/v8""log""time"
)var redisClients map[string]*redis.Clientfunc init() {redisClients = make(map[string]*redis.Client)redisClients["instance1"] = redis.NewClient(&redis.Options{Addr:     "localhost:6379", // Redis 实例1的地址Password: "",               // Redis 密码，如果有的话DB:       0,                // 选择使用的数据库})redisClients["instance2"] = redis.NewClient(&redis.Options{Addr:     "localhost:6380", // Redis 实例2的地址Password: "",               // Redis 密码，如果有的话DB:       0,                // 选择使用的数据库})
}func generateID(key string, start int64) (int64, error) {val, err := redisClients[key].IncrBy(key, start).Result()if err != nil {return 0, err}return val, nil
}func main() {key1 := "distributed_id_generator_instance1" // Redis 实例1中的键名key2 := "distributed_id_generator_instance2" // Redis 实例2中的键名// 生成 5 个分布式 IDfor i := 0; i < 5; i++ {id1, err := generateID(key1, 1000) // 指定实例1的起始步长为1000if err != nil {log.Fatalf("Failed to generate ID: %v", err)}fmt.Printf("Instance 1 - Generated ID: %d\n", id1)id2, err := generateID(key2, 2000) // 指定实例2的起始步长为2000if err != nil {log.Fatalf("Failed to generate ID: %v", err)}fmt.Printf("Instance 2 - Generated ID: %d\n", id2)time.Sleep(time.Millisecond) // 可选的延迟，以避免生成相同的 ID}
}