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

C#进阶-基于雪花算法的订单号设计与实现

在现代电商系统和分布式系统中,高效地生成全局唯一的订单号是一个关键需求。订单号不仅需要唯一性,还需要具备一定的趋势递增性,以满足数据库索引和排序的需求。本文将介绍如何在C#中使用雪花算法(Snowflake)设计和实现高性能的订单号生成器。

在这里插入图片描述


一、雪花算法的定义

雪花算法最初由Twitter开发,是一种用于生成全局唯一ID的高性能算法。其核心思想是结合当前时间戳机器ID序列号,生成一个64位的整数ID,确保在分布式环境下的唯一性趋势递增性

雪花算法的结构:

雪花算法生成的ID通常由以下几个部分组成:

部分位数说明
符号位1位始终为0,不参与实际运算。
时间戳41位记录当前时间戳,可以使用69年。
机器ID10位标识不同的机器或节点。
序列号12位同一毫秒内的序列号,支持每个节点每毫秒生成4096个ID。

二、使用雪花算法生成订单号

1. 实现前需要考虑的点

在订单号的设计中,我们需要考虑以下几点:

特性说明
唯一性订单号必须全局唯一,不能重复。
有序性订单号应具备趋势递增性,方便数据库索引和排序。
性能生成订单号的过程应高效,支持高并发环境。

基于上述需求,雪花算法是一个理想的选择。下面我们将基于提供的参考代码,详细解释如何在C#中实现雪花算法。


2. 创建含雪花算法的ID生成类

定义 ID生成类 IdWorker.cs:

public class IdWorker
{// 机器IDprivate static long workerId;// 起始时间戳(可以自行设置,不要大于当前时间戳)private static long twepoch = 687888001020L;// 序列号private static long sequence = 0L;// 机器ID所占的位数private static int workerIdBits = 4;// 最大机器IDpublic static long maxWorkerId = -1L ^ -1L << workerIdBits;// 序列号所占的位数private static int sequenceBits = 10;// 机器ID左移位数private static int workerIdShift = sequenceBits;// 时间戳左移位数private static int timestampLeftShift = sequenceBits + workerIdBits;// 序列号的掩码public static long sequenceMask = -1L ^ -1L << sequenceBits;// 上次生成ID的时间戳private long lastTimestamp = -1L;// 构造函数,初始化机器IDpublic IdWorker(long workerId){if (workerId > maxWorkerId || workerId < 0)throw new Exception($"Worker ID can't be greater than {maxWorkerId} or less than 0");IdWorker.workerId = workerId;}// 生成下一个IDpublic long NextId(){lock (this){long timestamp = TimeGen();if (lastTimestamp == timestamp){// 同一毫秒内,序列号自增sequence = (sequence + 1) & sequenceMask;if (sequence == 0){// 序列号达到上限,等待下一毫秒timestamp = TilNextMillis(lastTimestamp);}}else{// 不同毫秒内,序列号归零sequence = 0;}if (timestamp < lastTimestamp){throw new Exception($"Clock moved backwards. Refusing to generate id for {lastTimestamp - timestamp} milliseconds");}lastTimestamp = timestamp;// 按位或运算,组合生成唯一IDlong nextId = ((timestamp - twepoch) << timestampLeftShift)| (workerId << workerIdShift)| sequence;return nextId;}}// 等待下一毫秒private long TilNextMillis(long lastTimestamp){long timestamp = TimeGen();while (timestamp <= lastTimestamp){timestamp = TimeGen();}return timestamp;}// 获取当前时间戳private long TimeGen(){return (long)(DateTime.UtcNow - new DateTime(1970, 1, 1)).TotalMilliseconds;}
}

关键点解析:

  • 时间戳的处理:使用Unix时间戳(毫秒级)减去自定义的起始时间戳twepoch,确保生成的ID较小,且可用时间更长。
  • 序列号的控制:在同一毫秒内,通过自增序列号确保ID的唯一性,当序列号达到上限时,等待下一毫秒。
  • 线程安全:使用lock关键字确保在多线程环境下生成的ID仍然唯一。
  • 位移操作:通过位移和按位或运算,将时间戳、机器ID和序列号组合成一个64位的唯一ID。

3. 订单号工具类的调用

下面,我们使用刚刚创建的工具类来生成订单号。

调用示例:

class Program
{static void Main(string[] args){IdWorker idWorker = new IdWorker(1);for (int i = 0; i < 10; i++){long id = idWorker.NextId();Console.WriteLine($"生成的订单号:{id}");}}
}

输出示例

生成的订单号:2656420150056961
生成的订单号:2656420150056962
生成的订单号:2656420150056963
...

4. 注意事项

① 机器ID的分配:在分布式环境下,需要为每个节点分配唯一的workerId,以避免ID冲突。
② 时间同步:服务器的系统时间需要同步,避免因时间回拨导致ID重复或生成失败。
③ 起始时间戳twepoch:应设置为一个固定的过去时间,以确保ID的有效性和可读性。


三、雪花算法总结

通过雪花算法,我们可以在C#中高效地生成全局唯一且趋势递增的订单号。该算法简单可靠,适用于高并发和分布式系统。雪花算法的设计巧妙地结合了时间戳、机器ID和序列号,确保了在分布式环境下的ID生成既快速又不重复。由于其基于时间的特性,生成的订单号具备天然的有序性,这对于数据库的索引优化和查询性能提升具有显著的优势。

在实际应用中,雪花算法不仅限于订单号的生成,还可以广泛应用于其他需要唯一标识的场景,如用户ID、会话ID以及日志追踪等。其高效的生成能力使其能够支持大规模的并发请求,而不成为系统性能的瓶颈。同时,雪花算法的可扩展性也非常强,通过调整机器ID的位数和序列号的长度,可以灵活地适应不同规模的分布式系统需求。

此外,雪花算法在实现时需要注意时间同步问题,确保各个节点的系统时间保持一致,以避免因时间回拨或偏差导致的ID冲突或生成错误。采用网络时间协议(NTP)等时间同步机制,可以有效缓解这一问题。另一个需要关注的点是机器ID的分配,确保每个节点拥有唯一的机器ID,这是保证ID全局唯一性的关键。

总的来说,雪花算法以其高效、可靠和可扩展的特点,成为分布式系统中生成唯一标识符的首选方案。在C#中实现雪花算法,不仅能够满足当前系统对订单号的需求,还为未来系统的扩展和优化打下了坚实的基础。希望本文的介绍能够帮助您在实际项目中应用雪花算法,实现高性能、高可靠性的订单号生成,提升系统整体的稳定性和用户体验。

在这里插入图片描述

http://www.lryc.cn/news/443425.html

相关文章:

  • 低版本SqlSugar的where条件中使用可空类型报语法错误
  • 跨游戏引擎的H5渲染解决方案(腾讯)
  • docker构建java镜像,运行镜像出现日志 no main manifest attribute, in /xxx.jar
  • react + antDesignPro 企业微信扫码登录
  • Go-知识-定时器
  • 【alluxio编译报错】Some files do not have the expected license header
  • 基于SpringBoot+Vue的商城积分系统
  • docker-compose up 报错:KeyError: ‘ContainerConfig‘
  • 股票行情接口,量化金融交易在未来会被广泛应用吗
  • [SDX35+WCN6856]SDX35 开启class/gpio子系统配置操作说明
  • react:React Hook函数
  • 算法学习2
  • vue循环渲染动态展示内容案例(“更多”按钮功能)
  • 好用的工具网址
  • 【Temporal】方法规范
  • Python实现图形学曲线和曲面的Bezier曲线算法
  • Unity数据持久化4——2进制
  • 经典sql题(八)SQL 查询详细指南总结一
  • 用Python实现时间序列模型实战——Day 30: 学习总结与未来规划
  • ChatGPT居然主动勾引用户,OpenAI又测试新功能? 一文教你学会订阅
  • 基于SpringBoot+Vue的考研百科网站系统
  • 深度之眼(三十)——pytorch(一)--深入浅出pytorch(附安装流程)
  • 麒麟银河桌面版,成功安装cuda12.6,mysql
  • CentOS 7 YUM源不可用
  • Java反序列化利用链篇 | URLDNS链
  • Android 短信验证码自动填充
  • 数据库 MySQL 是否需要容器化?
  • Kettle的安装及简单使用
  • Golang | Leetcode Golang题解之第420题强密码检验器
  • 面试金典题3