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

bwmarrin/snowflake生成ID重复问题排查记录

现象

某日,运营反馈,在某个时间区间丢失了一段日志,让看看是什么问题。

排查

  1. 查看项目日志有无错误
    发现项目日志有报错信息Error 1062 Duplicate entry '149059529550598144' for key 'PRIMARY',很显然,问题在此,数据库主键冲突,无法插入数据,导致这部分数据被丢弃。那么问题来了,我们使用的雪花算法,为什么会生成重复的ID呢?

进一步排查

  1. 猜想可能早成该问题的原因,可能有两个
    1. 两个项目用了同样的MachineId,然而并没有,我们是单体应用
    2. 时钟回拨,存疑,需进一步确定,大概率是这个问题

  2. 进一步查看代码,bwmarrin/snowflake库的生成方法

// Generate creates and returns a unique snowflake ID
// To help guarantee uniqueness
// - Make sure your system is keeping accurate system time
// - Make sure you never have multiple nodes running with the same node ID
func (n *Node) Generate() ID {n.mu.Lock()now := time.Since(n.epoch).Nanoseconds() / 1000000if now == n.time {n.step = (n.step + 1) & n.stepMaskif n.step == 0 {for now <= n.time {now = time.Since(n.epoch).Nanoseconds() / 1000000}}} else {n.step = 0}n.time = nowr := ID((now)<<n.timeShift |(n.node << n.nodeShift) |(n.step),)n.mu.Unlock()return r
}

可以看出确实没对 now <n.time做判定,而且方法的注释中有说明Make sure your system is keeping accurate system time要自己保障系统时间的准确性。
3. 进一步找运营确认情况,运营老哥说问题是自两天前才有的,想想两天前我对服务器做了什么。两天前我把项目的容器内编译,改为了本地编译,采用挂载时区的方式来设置时区。

FROM golang:1.16 as builder
ENV GO111MODULE=on \CGO_ENABLED=0 \GOOS=linux \GOARCH=amd64 \GOPROXY=https://goproxy.cn,direct
WORKDIR /go/release
COPY go.mod .
COPY go.sum .
RUN go mod download
RUN go build -ldflags="-s -w" -installsuffix cgo -o serve .
FROM scratch as prod
COPY --from=builder /usr/share/zoneinfo /usr/share/zoneinfo
ENV TZ=Asia/Shanghai
COPY --from=builder /go/release/* ./
CMD ["/serve"]//以上每次部署需要3分钟左右,我觉得太慢,改为宿主机执行go build 然后直接把二进制镜像丢给scratch镜像
FROM scratch
ENV TZ=Asia/Shanghai
COPY . /
CMD ["/serve"]
//启动容器时挂载时区
docker run -p 8080:8080 -v /usr/share/zoneinfo:/usr/share/zoneinfo:ro -d test:v1.0.0

但是我没想到的是,宿主机会通过NTP对时间进行矫正,每次矫正,都会造成时钟回拨,生成的ID重复。

解决方案

让容器读自己的时区信息

FROM alpine:latest as base
RUN echo "https://mirrors.aliyun.com/alpine/v3.8/main/" > /etc/apk/repositories \&& echo "https://mirrors.aliyun.com/alpine/v3.8/community/" >> /etc/apk/repositories \&& apk add --no-cache tzdata \&& cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime  \&& echo Asia/Shanghai > /etc/timezone
FROM scratch
COPY --from=base /usr/share/zoneinfo /usr/share/zoneinfo
ENV TZ=Asia/Shanghai
COPY . /
CMD ["/serve"]
http://www.lryc.cn/news/10977.html

相关文章:

  • 操作系统题目收录(十)
  • IOS 自动化测试环境搭建
  • 系统设计原则
  • 推荐130个网站,非常实用,比涨工资都重要
  • 手机棋牌游戏开发的流程是怎样的?
  • 浅谈C++函数重载
  • 数据分析spss应急考试
  • Handler postDelayed的实现原理
  • 【数据结构】平衡二叉树
  • Minecraft服务端配置
  • yunUI组件库解析:图片上传与排序组件yImgPro
  • Java基础:回调函数
  • Springboot多环境配置
  • Java Number Math 类,超详细整理,适合新手入门
  • 俯瞰·明统系列·落霞与孤鹜齐飞、南征与北伐并举
  • Nodejs环境搭建和配置
  • MybatisPlus------条件构造器Wrapper以及QueryWrapper用法(七)
  • NetSuite Intercompany Framework 101
  • 限时活动|凭徽章领披萨大奖,玩转Moonbeam治理论坛
  • Golang中struct{}和struct{}{}的区别你知道吗?
  • 网络安全-信息收集- 谷歌浏览器插件收集信息,谷歌hacking搜索语法-带你玩不一样的搜索引擎
  • 基础篇—一文掌握css的边框属性
  • 05服务发现:引入etcd服务注册中心
  • Pdfium.Net SDK 4.78.2704 完美Crack/Ptach
  • 再学C语言38:指针操作
  • 【论文Word排版】使用多级列表设置论文序号
  • 分支管理方案
  • Allegro走线时如何自动关闭其它网络飞线显示操作指导
  • Linux中常用命令汇总二
  • 【数据结构】排序算法