分布式序号获取方法、装置、设备、存储介质和程序产品与流程

1.本公开涉及云计算技术领域，具体的涉及分布式技术领域，更具体地涉及一种分布式序号采集方法、装置、设备、存储介质和程序产品。


背景技术：

2.为了支持大规模并发，分布式系统一般采用双号段分片序号库做高可用部署。当序号库分段序号被消耗时，序号库会更新当前序号值，当序号库号段耗尽后会循环，且序号存储在多个业务集群内存内，多台服务器共用同一种序号类型，当某台服务器一直没有业务消耗本地序号时，当其它服务器并发量较大导致号段循环后，会导致不同业务集群内存在相同序列，导致生成的业务id相同。
3.需要说明的是，在上述背景技术部分公开的信息仅用于加强对本公开的背景的理解，因此可以包括不构成对本领域普通技术人员已知的现有技术的信息。


技术实现要素：

4.鉴于上述问题，本公开提供了一种分布式序号获取方法、装置、设备、存储介质和程序产品。
5.根据本公开的第一个方面，提供了一种分布式序号获取方法，应用于业务节点，所述业务节点部署多个业务容器，所述方法包括：
6.接收序号库发送的新增序号信息，其中，所述新增序号信息包括新增号段和版本号；
7.根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应；
8.若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。
9.根据本公开的实施例，所述方法还包括：
10.当所述业务容器重启后，根据所述业务容器的标识消费消息队列的存量号段。
11.根据本公开的实施例，所述根据所述版本号对所述新增号段和存量号段进行版本一致性检验包括：
12.根据业务容器标识获取存量号段的版本号；
13.将所述存量号段的版本号与所述新增号段的版本号进行比对；以及
14.根据比对结果确定版本一致性检验结果。
15.根据本公开的实施例，所述方法还包括：
16.接收所述序号库返回的标识位；以及
17.根据所述标识位确定获取号段的序号库。
18.根据本公开的实施例，所述根据所述标识位确定获取号段的序号库包括：
19.根据所述标识位确定序号库号段剩余状态；
20.当确定所述序号库号段用尽后，向序号监听器发送一级监控报警；
21.从对端序号库获取号段直至消息队列补充至预设数量，其中，所述对端序号库为所述序号库的备用库；以及
22.当确定所述对端序号库号段达到预设阈值时，向序号监听器发送二级监控报警，其中所述二级监控报警用于指示序号库进行号段循环以生成新号段。
23.根据本公开的实施例，所述方法还包括：
24.当确定消息队列发生故障时，通过降级读取序号库获取预设数量的号段存储于本地内存。
25.根据本公开的实施例，所述方法还包括：
26.若版本一致性检验不通过，根据业务容器标识删除消息队列中的存量号段；以及
27.重新向序号库发送请求补充预设数量的号段至消息队列中。
28.本公开的第二方面提供了一种分布式序号获取方法，应用于序号监听器，所述方法包括：
29.响应于业务容器发送的报警信号，确定报警等级和报警序号类别；
30.根据所述报警等级触发序号库对所述报警序号类别进行号段循环，以生成新号段；
31.将当前时间戳作为所述新号段的版本号。
32.根据本公开的实施例，还包括：
33.定时扫描序号库每种序号的使用率；以及
34.根据所述每种序号的使用率对序号容量进行调整。
35.本公开的第三方面提供了一种分布式序号获取装置，应用于业务节点，所述业务节点部署多个业务容器，所述装置包括：
36.序号信息接收模块，用于接收序号库发送的新增序号信息，其中，所述新增序号信息包括新增号段和版本号；
37.版本检验模块，用于根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应；以及
38.存储模块，用于若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。
39.根据本公开的实施例，所述装置还包括：存量序号消费模块。
40.存量序号消费模块，用于当所述业务容器重启后，根据所述业务容器的标识消费消息队列的存量号段。
41.根据本公开的实施例，所述版本检验模块包括第一获取子模块、比对子模块和第一确定子模块。
42.第一获取子模块，用于根据业务容器标识获取存量号段的版本号；
43.比对子模块，用于将所述存量号段的版本号与所述新增号段的版本号进行比对；以及
44.第一确定子模块，用于根据比对结果确定版本一致性检验结果。
45.根据本公开的实施例，所述装置还包括：标识位接收模块和第一确定模块。
46.标识位接收模块，用于接收所述序号库返回的标识位；以及
47.第一确定模块，用于根据所述标识位确定获取号段的序号库。
48.根据本公开的实施例，所述第一确定模块包括：第一确定子模块、第一发送子模块、第二获取子模块和第二发送子模块。
49.第一确定子模块，用于根据所述标识位确定序号库号段剩余状态；
50.第一发送子模块，用于当确定所述序号库号段用尽后，向序号监听器发送一级监控报警；
51.第二获取子模块，用于从对端序号库获取号段直至消息队列补充至预设数量，其中，所述对端序号库为所述序号库的备用库；以及
52.第二发送子模块，用于当确定所述对端序号库号段达到预设阈值时，向序号监听器发送二级监控报警，其中所述二级监控报警用于指示序号库进行号段循环以生成新号段。
53.根据本公开的实施例，所述装置还包括：第二确定模块。
54.第二确定模块，用于当确定消息队列发生故障时，通过降级读取序号库获取预设数量的号段存储于本地内存。
55.根据本公开的实施例，所述装置还包括：删除模块和发送模块。
56.删除模块，用于若版本一致性检验不通过，根据业务容器标识删除消息队列中的存量号段；以及
57.发送模块，用于重新向序号库发送请求补充预设数量的号段至消息队列中。
58.本公开的第四方面提供了一种分布式序号获取装置，应用于序号监听器，所述装置包括：
59.确定模块，用于响应于业务容器发送的报警信号，确定报警等级和报警序号类别；
60.号段生成模块，用于根据所述报警等级触发序号库对所述报警序号类别进行号段循环，以生成新号段；
61.版本号生成模块，用于将当前时间戳作为所述新号段的版本号。
62.根据本公开的实施例，所述装置还包括：扫描模块和调整模块。
63.扫描模块，用于定时扫描序号库每种序号的使用率；
64.调整模块，用于根据所述每种序号的使用率对序号容量进行调整。
65.本公开的第五方面提供了一种电子设备，包括：一个或多个处理器；存储器，用于存储一个或多个程序，其中，当所述一个或多个程序被所述一个或多个处理器执行时，使得一个或多个处理器执行上述分布式序号获取方法。
66.本公开的第六方面还提供了一种计算机可读存储介质，其上存储有可执行指令，该指令被处理器执行时使处理器执行上述分布式序号获取方法。
67.本公开的第七方面还提供了一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现上述分布式序号获取方法。
68.通过本公开的实施例提供的一种分布式序号获取方法，当接收序号库发送的新增序号信息时，根据所述版本号对新增号段和存量号段进行版本一致性检验；在确定版本一致性检验通过后，根据所述业务容器的标识将新增号段推送至消息队列中。由于每一业务容器对应消息队列中的主题，业务节点将从序号库获取到的序号存储至消息队列中，相较
应包括但不限于单独具有a、单独具有b、单独具有c、具有a和b、具有a和c、具有b和c、和/或具有a、b、c的系统等)。
84.首先对本公开实施例出现的术语进行解释：
85.分布式序号：分布式系统涉及不同业务类型节点的分片、交互和高并发场景时，为了对大量数据和消息进行唯一标识，系统生成的跨集群的全网唯一递增序列号。
86.号段：按一定步长从序号库获取的递增序号集合。
87.基于上述技术问题，本公开的实施例提供了一种分布式序号获取方法，应用于业务节点，所述业务节点部署多个业务容器，所述方法包括：接收序号库发送的新增序号信息，其中，所述新增序号信息包括新增号段和版本号；根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应；若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。
88.图1示意性示出了根据本公开实施例的分布式序号获取装置的系统架构图。如图1所示，本公开实施例提供的系统包括：序号库a1、对端序号库a2、业务节点a3、消息中间件a4和序号监听节点a5。其中，序号库a1存储了事先设置的整形序列段，存在最大序列数和最小序列数，供业务节点中的容器取序号，为提高序号库的可用性，设置对端序号库a2，对端序号库a2为序号库a1的备用库，当序号库a1序号用尽时，业务节点切换至对端序号库a2进行号段的取用；消息中间件a4例如可以是kafka，用于未使用号段的提供和消费，同时作为号段获取的降级首层；业务节点a3用于提供各种业务，本地查询序号库a1获取序列段存储内存，生成业务唯一id标识。序号监控节点a5监控序号的使用详情，同时根据报警信息更新序号的版本号。业务节点向序号库发送序号请求，响应于业务节点的序号请求，序号库向业务节点返回序号号段和版本信息，业务节点中各业务容器对接收的序号号段进行版本一致性校验，保证新增号段和存储在消息中间件中的存量号段处于同一版本，从而保证业务id的唯一性。
89.图2示意性示出了根据本公开实施例的分布式序号获取方法、装置、设备、存储介质和程序产品的应用场景图。
90.如图2所示，根据该实施例的应用场景200可以包括分布式序号获取场景。网络204用以在终端设备201、202、203和服务器205之间提供通信链路的介质。网络204可以包括各种连接类型，例如有线、无线通信链路或者光纤电缆等等。
91.用户可以使用终端设备201、202、203通过网络204与服务器205交互，以接收或发送消息等。终端设备201、202、203上可以安装有各种通讯客户端应用，例如购物类应用、网页浏览器应用、搜索类应用、即时通信工具、邮箱客户端、社交平台软件等(仅为示例)。
92.终端设备201、202、203可以是具有显示屏并且支持网页浏览的各种电子设备，包括但不限于智能手机、平板电脑、膝上型便携计算机和台式计算机等等。
93.服务器205可以是业务节点服务器，该服务器用于对外提供不同业务，当接收到序号库发送的新增序号信息，对新增号段进行版本一致性检验，在版本一致性检验通过后，将新增号段推送至业务容器对应的消息队列中。
94.需要说明的是，本公开实施例所提供的分布式序号获取方法一般可以由服务器205执行。相应地，本公开实施例所提供的编译报错定位装置一般可以设置于服务器205中。
本公开实施例所提供的分布式序号获取方法也可以由不同于服务器205且能够与终端设备201、202、203和/或服务器205通信的服务器或服务器集群执行。相应地，本公开实施例所提供的分布式序号获取装置也可以设置于不同于服务器205且能够与终端设备201、202、203和/或服务器205通信的服务器或服务器集群中。
95.应该理解，图2中的终端设备、网络和服务器的数目仅仅是示意性的。根据实现需要，可以具有任意数目的终端设备、网络和服务器。
96.需要说明的是，本公开实施例确定的分布式序号获取方法和装置可用于云计算技术领域，也可用于金融技术领域，还可用于除金融领域之外的任意领域，本公开实施例确定的分布式序号获取方法和装置的应用领域不做限定。
97.以下将基于图1描述的系统架构和图2描述的应用场景，通过图3～图7对本公开实施例的分布式序号获取方法进行详细描述。
98.图3示意性示出了根据本公开一实施例提供的一种分布式序号获取方法的流程图。如图3所示，该实施例的分布式序号获取方法包括操作s210～操作s230，该方法可以由服务器或其他计算设备执行，例如由业务节点服务器执行，业务节点服务器中部署有多个业务容器。分布式场景下，为了保证事务一致性，当业务容器对外提供服务时，需要从序号库中取出序号生成业务id，该业务id为全局唯一。为了解决相关技术中业务容器重启导致存量号段丢失浪费的问题，本公开实施例采用消息中间件进行存量号段的存储
99.在操作s210，接收序号库发送的新增序号信息。
100.根据本公开的实施例，所述新增序号信息包括新增号段和版本号。
101.一个示例中，当业务节点启动时，会从序号库发送序号请求信息请求获取序号号段，序号请求信息包括请求获取的序号号段数量和种类等信息，接收序号库发送的新增序号信息，包括新增号段和版本号信息，将获取到的预设数量的号段序号存储于内存中，预设数量可以根据具体业务需求进行调整，例如可以是3个。
102.在操作s220，根据所述版本号对所述新增号段和存量号段进行版本一致性检验。
103.根据本公开的实施例，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应。
104.根据本公开的实施例，根据业务容器标识获取存量号段的版本号；将所述存量号段的版本号与所述新增号段的版本号进行比对；根据比对结果确定版本一致性检验结果。
105.一个示例中，由于序号库在序号用尽后会进行号段循环，重新生成新号段，此时新号段可能与未使用号段相同，导致业务id不唯一的问题，为了保证业务id的唯一性，在获取到新增号段后，对新增号段进行版本一致性检验，具体的，根据业务容器标识获取存量号段的版本号；将所述存量号段的版本号与所述新增号段的版本号进行比对；根据比对结果确定版本一致性检验结果。
106.在操作s230，若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。
107.根据本公开的实施例，若版本一致性检验不通过，根据业务容器标识删除消息队列中的存量号段；重新向序号库发送请求补充预设数量的号段至消息队列中。
108.一个示例中，若版本一致性检验通过，即新增号段与存量号段为同一版本，根据号段序号的大小，取首号段用于生成业务id，其余号段则推送至消息中间件的消息队列中，例
如可以发送至kafka中，即业务容器作为消息队列的生产者，将未使用号段存储至消息队列中，业务容器与消息队列中的主题topic一一对应，每一业务容器消费对应主题。当首号段用尽，需要消费未使用号段时，根据业务容器的标识即可定位到消息队列中对应的主题，进行剩余号段的消费。
109.一个示例中，当业务容器用尽一个号段后，继续向序号库发送序号请求获取新号段补充至消息队列中，保证业务容器与消息队列中的号段总数为预设数量值。
110.一个示例中，若版本一致性检验不通过，删除该业务容器中对应消息队列中的存量号段；重新向序号库发送请求补充预设数量的号段至消息队列中，保证用于生成业务id的号段版本号始终和序号库保持一致。
111.通过本公开的实施例提供的一种分布式序号获取方法，当接收序号库发送的新增序号信息时，根据所述版本号对新增号段和存量号段进行版本一致性检验；在确定版本一致性检验通过后，根据所述业务容器的标识将新增号段推送至消息队列中。由于每一业务容器对应消息队列中的主题，业务节点将从序号库获取到的序号存储至消息队列中，相较于相关技术，本公开实施例提供的分布式序号获取方法，能够避免号段资源的浪费，保证号段的唯一性，有效避免业务id不一致的问题。
112.图4示意性示出了根据本公开另一实施例提供的一种分布式序号获取方法的流程图。图5示意性示出了根据本公开又一实施例提供的一种分布式序号获取方法的流程图。如图4所示，包括操作310～操作s330。
113.在操作s310，当所述业务容器重启后，根据所述业务容器的标识消费消息队列的存量号段。
114.一个示例中，由于业务容器的序号号段都存储在对应消息队列中，当业务容器发生故障或网络抖动进行重启时，根据业务容器标识消费对应消息队列中的存量号段。
115.在操作s320，接收所述序号库返回的标识位。
116.一个示例中，当序号库中业务节点请求的某类号段用尽时，会向业务节点返回特定标识位，该标识位表征序号库中该类号段已经用尽。
117.在操作s330，根据所述标识位确定获取号段的序号库。
118.在操作s340，当确定消息队列发生故障时，通过降级读取序号库获取预设数量的号段存储于本地内存。
119.一个示例中，当消息队列发生故障时，业务节点可以通过降级读取序号库获取对应数量的号段存储于本地内存，提高系统稳定性。
120.如图5所示，操作s330包括操作s331～操作s334。
121.在操作s331，根据所述标识位确定序号库号段剩余状态。
122.在操作s332，当确定所述序号库号段用尽后，向序号监听器发送一级监控报警。
123.在操作s333，从对端序号库获取号段直至消息队列补充至预设数量。
124.根据本公开的实施例，所述对端序号库为所述序号库的备用库。
125.在操作s334，当确定所述对端序号库号段达到预设阈值时，向序号监听器发送二级监控报警。
126.根据本公开的实施例，二级监控报警用于指示序号库进行号段循环以生成新号段。
127.一个示例中，当确定序号库号段用尽后，向序号监听器发送一级监控报警，并降级读取对端序号库中的序号；当对端序号库的号段余量小于某预设阈值时，向业务节点返回标识位，业务节点确定所述对端序号库号段达到预设阈值时，向序号监听器发送二级监控报警。
128.本公开的实施例通过引入降级读取对端序号库的方法，尽量让两个序号库的序号被充分使用，避免当前序号库序号被使用完时，只循环当前连接序号库。同时当前序号库序号耗尽发送一级监控，对端序号库使用临近临界值发送二级监控。将序号库的循环由业务节点进行触发改为用序号库监听器收到某类序号二级监控进行触发，并且将触发时间存储到序号库作为当类序号的版本号，方便各业务节点获取序号时区分新旧序号从而清空内存和kafka旧序号，重新获取新版本序号，避免旧版本序号和新版本的相同值的号段存在不同的节点生成相同值的业务id，保证数据唯一性原则。
129.图6示意性示出了根据本公开一实施例提供的一种分布式序号获取方法的流程图，图7示意性示出了根据本公开另一实施例提供的一种分布式序号获取方法的流程图。如图6所示，包括操作s410～操作s430。本公开实施例中的分布式序号获取方法由新增设的序号监听器执行。
130.在操作s410，响应于业务容器发送的报警信号，确定报警等级和报警序号类别。
131.在操作s420，根据所述报警等级触发序号库对所述报警序号类别进行号段循环，以生成新号段。
132.在操作s430，将当前时间戳作为所述新号段的版本号。
133.一个示例中，为了更好的管理分布式序号的使用情况，本公开实施例中，接收业务容器发送的报警信号，确定报警信号的等级和报警序号类别，例如某类别a序号的报警信号等级为一级，则表征序号库a类序号的号段已用尽，进而等待接受a类序号的二级报警信息；若接收到a类序号的二级报警信息，则表征对端数据库中a类序号号段也即将用尽。此时触发序号库对a类序号号段进行号段循环，生成新的号段，同时将当前时间戳作为新的版本号更新序号库和对端序号库中的版本号。可以确定的是，序号库中的序号号段可以有多个类别，同一序号库可能存在多个版本号，每一类别号段均增设序号监听器，监听号段的使用情况。
134.如图7所示，还包括s440和操作s450。
135.在操作s440，定时扫描序号库每种序号的使用率。
136.在操作s450，根据所述每种序号的使用率对序号容量进行调整。
137.一个示例中，序号监听器定期扫描序号库每种序号固定周期的使用率，例如，可以是日终进行扫描一天各号段的使用情况，对于使用率较高的号段进行扩容处理，对使用率一直较低的号段进行缩容处理。
138.基于上述分布式序号获取方法，本公开还提供了一种分布式序号获取。以下将结合图8对该装置进行详细描述。
139.图8示意性示出了根据本公开实施例的一种分布式序号获取装置的结构框图。如图8所示，该实施例的分布式序号获取装置800包括序号信息接收模块810、版本检验模块820和存储模块830。
140.序号信息接收模块810用于接收序号库发送的新增序号信息，其中，所述新增序号
信息包括新增号段和版本号。在一实施例中，序号信息接收模块810可以用于执行前文描述的操作s210，在此不再赘述。
141.版本检验模块820用于根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应。在一实施例中，版本检验模块820可以用于执行前文描述的操作s220，在此不再赘述。
142.存储模块830用于若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。在一实施例中，存储模块830可以用于执行前文描述的操作s230，在此不再赘述。
143.根据本公开的实施例，所述装置还包括：存量序号消费模块。
144.存量序号消费模块用于当所述业务容器重启后，根据所述业务容器的标识消费消息队列的存量号段。在一实施例中，存量序号消费模块可以用于执行前文描述的操作s310，在此不再赘述。
145.根据本公开的实施例，所述版本检验模块包括第一获取子模块、比对子模块和第一确定子模块。
146.第一获取子模块，用于根据业务容器标识获取存量号段的版本号。在一实施例中，第一获取子模块可以用于执行前文描述的操作s220，在此不再赘述。
147.比对子模块，用于将所述存量号段的版本号与所述新增号段的版本号进行比对。在一实施例中，比对子模块可以用于执行前文描述的操作s220，在此不再赘述。
148.第一确定子模块，用于根据比对结果确定版本一致性检验结果。在一实施例中，第一确定子模块可以用于执行前文描述的操作s220，在此不再赘述。
149.根据本公开的实施例，所述装置还包括：标识位接收模块和第一确定模块。
150.标识位接收模块，用于接收所述序号库返回的标识位。在一实施例中，标识位接收模块可以用于执行前文描述的操作s320，在此不再赘述。
151.第一确定模块，用于根据所述标识位确定获取号段的序号库。在一实施例中，第一确定模块可以用于执行前文描述的操作s330，在此不再赘述。
152.根据本公开的实施例，所述第一确定模块包括：第一确定子模块、第一发送子模块、第二获取子模块和第二发送子模块。
153.第一确定子模块，用于根据所述标识位确定序号库号段剩余状态。在一实施例中，第一确定子模块可以用于执行前文描述的操作s331，在此不再赘述。
154.第一发送子模块，用于当确定所述序号库号段用尽后，向序号监听器发送一级监控报警。在一实施例中，第一发送子模块可以用于执行前文描述的操作s332，在此不再赘述。
155.第二获取子模块，用于从对端序号库获取号段直至消息队列补充至预设数量，其中，所述对端序号库为所述序号库的备用库。在一实施例中，第二获取子模块可以用于执行前文描述的操作s333，在此不再赘述。
156.第二发送子模块，用于当确定所述对端序号库号段达到预设阈值时，向序号监听器发送二级监控报警，其中所述二级监控报警用于指示序号库进行号段循环以生成新号段。在一实施例中，第二发送子模块可以用于执行前文描述的操作s334，在此不再赘述。
157.根据本公开的实施例，所述装置还包括：第二确定模块。
158.第二确定模块，用于当确定消息队列发生故障时，通过降级读取序号库获取预设数量的号段存储于本地内存。在一实施例中，第二确定模块可以用于执行前文描述的操作s340，在此不再赘述。
159.根据本公开的实施例，所述装置还包括：删除模块和发送模块。
160.删除模块，用于若版本一致性检验不通过，根据业务容器标识删除消息队列中的存量号段。在一实施例中，删除模块可以用于执行前文描述的操作s230，在此不再赘述。
161.发送模块，用于重新向序号库发送请求补充预设数量的号段至消息队列中。在一实施例中，发送模块可以用于执行前文描述的操作s230，在此不再赘述。
162.根据本公开的实施例，序号信息接收模块810、版本检验模块820和存储模块830中的任意多个模块可以合并在一个模块中实现，或者其中的任意一个模块可以被拆分成多个模块。或者，这些模块中的一个或多个模块的至少部分功能可以与其他模块的至少部分功能相结合，并在一个模块中实现。根据本公开的实施例，序号信息接收模块810、版本检验模块820和存储模块830中的至少一个可以至少被部分地实现为硬件电路，例如现场可编程门阵列(fpga)、可编程逻辑阵列(pla)、片上系统、基板上的系统、封装上的系统、专用集成电路(asic)，或可以通过对电路进行集成或封装的任何其他的合理方式等硬件或固件来实现，或以软件、硬件以及固件三种实现方式中任意一种或以其中任意几种的适当组合来实现。或者，序号信息接收模块810、版本检验模块820和存储模块830中的至少一个可以至少被部分地实现为计算机程序模块，当该计算机程序模块被运行时，可以执行相应的功能。
163.图9示意性示出了根据本公开实施例的另一种分布式序号获取装置的结构框图。如图9所示，该实施例的分布式序号获取装置900包括确定模块910、号段生成模块920和版本号生成模块930。
164.确定模块910用于响应于业务容器发送的报警信号，确定报警等级和报警序号类别。在一实施例中，确定模块910可以用于执行前文描述的操作s410，在此不再赘述。
165.号段生成模块920用于根据所述报警等级触发序号库对所述报警序号类别进行号段循环，以生成新号段。在一实施例中，号段生成模块920可以用于执行前文描述的操作s420，在此不再赘述。
166.版本号生成模块930用于将当前时间戳作为所述新号段的版本号。在一实施例中，版本号生成模块930-可以用于执行前文描述的操作s430，在此不再赘述。
167.根据本公开的实施例，所述装置还包括：扫描模块和调整模块。
168.扫描模块，用于定时扫描序号库每种序号的使用率。在一实施例中，扫描模块可以用于执行前文描述的操作s440，在此不再赘述。
169.调整模块，用于根据所述每种序号的使用率对序号容量进行调整。在一实施例中，调整模块可以用于执行前文描述的操作s450，在此不再赘述。
170.根据本公开的实施例，获取装置900包括确定模块910、号段生成模块920和版本号生成模块930中的任意多个模块可以合并在一个模块中实现，或者其中的任意一个模块可以被拆分成多个模块。或者，这些模块中的一个或多个模块的至少部分功能可以与其他模块的至少部分功能相结合，并在一个模块中实现。根据本公开的实施例，获取装置900包括确定模块910、号段生成模块920和版本号生成模块930中的至少一个可以至少被部分地实
现为硬件电路，例如现场可编程门阵列(fpga)、可编程逻辑阵列(pla)、片上系统、基板上的系统、封装上的系统、专用集成电路(asic)，或可以通过对电路进行集成或封装的任何其他的合理方式等硬件或固件来实现，或以软件、硬件以及固件三种实现方式中任意一种或以其中任意几种的适当组合来实现。或者，获取装置900包括确定模块910、号段生成模块920和版本号生成模块930中的至少一个可以至少被部分地实现为计算机程序模块，当该计算机程序模块被运行时，可以执行相应的功能。
171.图10示意性示出了根据本公开实施例的适于实现分布式序号获取方法的电子设备的方框图。
172.如图10所示，根据本公开实施例的电子设备1000包括处理器1001，其可以根据存储在只读存储器(rom)1002中的程序或者从存储部分1008加载到随机访问存储器(ram)1003中的程序而执行各种适当的动作和处理。处理器1001例如可以包括通用微处理器(例如cpu)、指令集处理器和/或相关芯片组和/或专用微处理器(例如，专用集成电路(asic))等等。处理器1001还可以包括用于缓存用途的板载存储器。处理器1001可以包括用于执行根据本公开实施例的方法流程的不同动作的单一处理单元或者是多个处理单元。
173.在ram 1003中，存储有电子设备1000操作所需的各种程序和数据。处理器1001、rom 1002以及ram 1003通过总线1004彼此相连。处理器1001通过执行rom 1002和/或ram 1003中的程序来执行根据本公开实施例的方法流程的各种操作。需要注意，所述程序也可以存储在除rom 1002和ram 1003以外的一个或多个存储器中。处理器1001也可以通过执行存储在所述一个或多个存储器中的程序来执行根据本公开实施例的方法流程的各种操作。
174.根据本公开的实施例，电子设备1000还可以包括输入/输出(i/o)接口1005，输入/输出(i/o)接口1005也连接至总线1004。电子设备1000还可以包括连接至i/o接口1005的以下部件中的一项或多项：包括键盘、鼠标等的输入部分1006；包括诸如阴极射线管(crt)、液晶显示器(lcd)等以及扬声器等的输出部分1007；包括硬盘等的存储部分1008；以及包括诸如lan卡、调制解调器等的网络接口卡的通信部分1009。通信部分1009经由诸如因特网的网络执行通信处理。驱动器1010也根据需要连接至i/o接口1005。可拆卸介质1011，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器1010上，以便于从其上读出的计算机程序根据需要被安装入存储部分1008。
175.本公开还提供了一种计算机可读存储介质，该计算机可读存储介质可以是上述实施例中描述的设备/装置/系统中所包含的；也可以是单独存在，而未装配入该设备/装置/系统中。上述计算机可读存储介质承载有一个或者多个程序，当上述一个或者多个程序被执行时，实现根据本公开实施例的分布式序号获取方法。
176.根据本公开的实施例，计算机可读存储介质可以是非易失性的计算机可读存储介质，例如可以包括但不限于：便携式计算机磁盘、硬盘、随机访问存储器(ram)、只读存储器(rom)、可擦式可编程只读存储器(eprom或闪存)、便携式紧凑磁盘只读存储器(cd-rom)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本公开中，计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。例如，根据本公开的实施例，计算机可读存储介质可以包括上文描述的rom 1002和/或ram 1003和/或rom 1002和ram 1003以外的一个或多个存储器。
177.本公开的实施例还包括一种计算机程序产品，其包括计算机程序，该计算机程序
包含用于执行流程图所示的方法的程序代码。当计算机程序产品在计算机系统中运行时，该程序代码用于使计算机系统实现本公开实施例所提供的分布式序号获取方法。
178.在该计算机程序被处理器1001执行时执行本公开实施例的系统/装置中限定的上述功能。根据本公开的实施例，上文描述的系统、装置、模块、单元等可以通过计算机程序模块来实现。
179.在一种实施例中，该计算机程序可以依托于光存储器件、磁存储器件等有形存储介质。在另一种实施例中，该计算机程序也可以在网络介质上以信号的形式进行传输、分发，并通过通信部分1009被下载和安装，和/或从可拆卸介质1011被安装。该计算机程序包含的程序代码可以用任何适当的网络介质传输，包括但不限于：无线、有线等等，或者上述的任意合适的组合。
180.在这样的实施例中，该计算机程序可以通过通信部分1009从网络上被下载和安装，和/或从可拆卸介质1011被安装。在该计算机程序被处理器1001执行时，执行本公开实施例的系统中限定的上述功能。根据本公开的实施例，上文描述的系统、设备、装置、模块、单元等可以通过计算机程序模块来实现。
181.根据本公开的实施例，可以以一种或多种程序设计语言的任意组合来编写用于执行本公开实施例提供的计算机程序的程序代码，具体地，可以利用高级过程和/或面向对象的编程语言、和/或汇编/机器语言来实施这些计算程序。程序设计语言包括但不限于诸如java，c++，python，“c”语言或类似的程序设计语言。程序代码可以完全地在用户计算设备上执行、部分地在用户设备上执行、部分在远程计算设备上执行、或者完全在远程计算设备或服务器上执行。在涉及远程计算设备的情形中，远程计算设备可以通过任意种类的网络，包括局域网(lan)或广域网(wan)，连接到用户计算设备，或者，可以连接到外部计算设备(例如利用因特网服务提供商来通过因特网连接)。
182.附图中的流程图和框图，图示了按照本公开各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，上述模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图或流程图中的每个方框、以及框图或流程图中的方框的组合，可以用执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。
183.本领域技术人员可以理解，本公开的各个实施例和/或权利要求中记载的特征可以进行多种组合或/或结合，即使这样的组合或结合没有明确记载于本公开中。特别地，在不脱离本公开精神和教导的情况下，本公开的各个实施例和/或权利要求中记载的特征可以进行多种组合和/或结合。所有这些组合和/或结合均落入本公开的范围。
184.以上对本公开的实施例进行了描述。但是，这些实施例仅仅是为了说明的目的，而并非为了限制本公开的范围。尽管在以上分别描述了各实施例，但是这并不意味着各个实施例中的措施不能有利地结合使用。本公开的范围由所附权利要求及其等同物限定。不脱离本公开的范围，本领域技术人员可以做出多种替代和修改，这些替代和修改都应落在本
公开的范围之内。

技术特征：
1.一种分布式序号获取方法，应用于业务节点，所述业务节点部署多个业务容器，其特征在于，所述方法包括：接收序号库发送的新增序号信息，其中，所述新增序号信息包括新增号段和版本号；根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应；以及若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。2.根据权利要求1所述的方法，其特征在于，所述方法还包括：当所述业务容器重启后，根据所述业务容器的标识消费消息队列的存量号段。3.根据权利要求2所述的方法，其特征在于，所述根据所述版本号对所述新增号段和存量号段进行版本一致性检验包括：根据业务容器标识获取存量号段的版本号；将所述存量号段的版本号与所述新增号段的版本号进行比对；以及根据比对结果确定版本一致性检验结果。4.根据权利要求1所述的方法，其特征在于，所述方法还包括：接收所述序号库返回的标识位；以及根据所述标识位确定获取号段的序号库。5.根据权利要求4所述的方法，其特征在于，所述根据所述标识位确定获取号段的序号库包括：根据所述标识位确定序号库号段剩余状态；当确定所述序号库号段用尽后，向序号监听器发送一级监控报警；从对端序号库获取号段直至消息队列补充至预设数量，其中，所述对端序号库为所述序号库的备用库；以及当确定所述对端序号库号段达到预设阈值时，向序号监听器发送二级监控报警，其中所述二级监控报警用于指示序号库进行号段循环以生成新号段。6.根据权利要求1至5中任一项所述的方法，其特征在于，所述方法还包括：当确定消息队列发生故障时，通过降级读取序号库获取预设数量的号段存储于本地内存。7.根据权利要求6所述的方法，其特征在于，所述方法还包括：若版本一致性检验不通过，根据业务容器标识删除消息队列中的存量号段；以及重新向序号库发送请求补充预设数量的号段至消息队列中。8.一种分布式序号获取方法，应用于序号监听器，其特征在于，所述方法包括：响应于业务容器发送的报警信号，确定报警等级和报警序号类别；根据所述报警等级触发序号库对所述报警序号类别进行号段循环，以生成新号段；将当前时间戳作为所述新号段的版本号。9.根据权利要求8所述的方法，其特征在于，还包括：定时扫描序号库每种序号的使用率；以及根据所述每种序号的使用率对序号容量进行调整。10.一种分布式序号获取装置，应用于业务节点，所述业务节点部署多个业务容器，其
特征在于，所述装置包括：序号信息接收模块，用于接收序号库发送的新增序号信息，其中，所述新增序号信息包括新增号段和版本号；版本检验模块，用于根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应；以及存储模块，用于若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。11.一种分布式序号获取装置，应用于序号监听器，其特征在于，所述装置包括：确定模块，用于响应于业务容器发送的报警信号，确定报警等级和报警序号类别；号段生成模块，用于根据所述报警等级触发序号库对所述报警序号类别进行号段循环，以生成新号段；版本号生成模块，用于将当前时间戳作为所述新号段的版本号。12.一种电子设备，包括：一个或多个处理器；存储装置，用于存储一个或多个程序，其中，当所述一个或多个程序被所述一个或多个处理器执行时，使得所述一个或多个处理器执行根据权利要求1～9中任一项所述的分布式序号获取方法。13.一种计算机可读存储介质，其上存储有可执行指令，该指令被处理器执行时使处理器执行根据权利要求1～9中任一项所述的分布式序号获取方法。14.一种计算机程序产品，包括计算机程序，所述计算机程序被处理器执行时实现根据权利要求1～9中任一项所述的分布式序号获取方法。

技术总结
本公开提供了一种分布式序号获取方法，涉及云计算技术领域，可以应用于金融技术领域。所述方法应用于业务节点，所述业务节点部署多个业务容器，包括：接收序号库发送的新增序号信息，其中，所述新增序号信息包括新增号段和版本号；根据所述版本号对所述新增号段和存量号段进行版本一致性检验，其中，所述存量号段存储于消息队列中，每一所述业务容器与所述消息队列的主题唯一对应；若版本一致性检验通过，根据所述业务容器的标识将所述新增号段推送至消息队列中。本公开还提供了一种分布式序号获取装置、设备、存储介质和程序产品。存储介质和程序产品。存储介质和程序产品。


技术研发人员：邓华丰 魏普 廖宸 曾雷
受保护的技术使用者：中国工商银行股份有限公司
技术研发日：2023.07.10
技术公布日：2023/10/5