买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉上海赛可出行科技服务有限公司申请的专利一种微服务线程队列堆积处理方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115658342B 。

龙图腾网通过国家知识产权局官网在2026-01-09发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202211302916.3，技术领域涉及：G06F9/54；该发明授权一种微服务线程队列堆积处理方法是由赵刚;庄菁雄设计研发完成，并于2022-10-24向国家知识产权局提交的专利申请。

本一种微服务线程队列堆积处理方法在说明书摘要公布了：本发明公开了一种微服务线程队列堆积处理方法，包括以下步骤：S1、建立微服务线程队列模型；S2、队列模型分配时间标志和汇总处理情况；S3、检测队列堆积的方法；S4、队列堆积的恢复方法；S5、队列堆积的溯源方法。本发明能够解决微服务中线程队列堆积识别困难、难以快速恢复以及难以准确溯源到导致问题的消息类型的问题；能够精准定位到当时发生问题的消息类型，提高问题排查效率，与现有的技术方法对比，能快速恢复队列并自动定位问题；综上，本发明能够解决微服务系统中线程队列堆积问题，同时可自动的对微服务进行恢复，提升了微服务的可用性，并自动定位到问题消息，简化了当前微服务群复杂的治理工。

本发明授权一种微服务线程队列堆积处理方法在权利要求书中公布了：1.一种微服务线程队列堆积处理方法，其特征在于，包括以下步骤： S1、建立微服务线程队列模型： 每一个微服务内部建立一个接收队列，该队列为有界队列，长度为a，a≥10000,启动b个消费者线程，b≥100,b个消费者线程公平的消费队列中的消息； S2、队列模型分配时间标志和汇总处理情况： a服务调用方调用服务提供方的消息发送方法： 具体为所发送的消息报文必须附带以下2个关键字段：timeout和msgType； a1等待响应超时时间timeout，该字段表示服务调用方在等待timeout秒后，未收到响应，则认为超时，不再继续等待； a2消息类型msgType，表示服务提供方惟一的消息类型，包括手机号登录、发送登录短信，服务提供者的消息类型集合记作Q； b服务提供方接收消息入队方法： 在服务提供方接收到服务调用方的请求报文后，从报文中获得timeout和msgType，并记录接收到报文请求的时间为入队时间enQueueTime，把请求内容,enQueueTime,timeout和msgType作为一个数据元素放入队列； c服务提供方到达次数周期汇总方法： 对每个msgType每分钟到达情况做一次到达汇总计算，计算消息类型的到达次数； 具体为，服务提供方接收到请求后，对每一个请求的msgType,累计1分钟内的msgType的个数，求得到达次数arriveCount，t时刻msgType为m的到达次数记作gm，t,同理t-1时刻msgType为m的到达次数记作gm，t-1； d服务提供方消费者数据元素出队方法，服务提供方有b个消费者线程，若队列不为空，某个消费者线程从队列中出队一个数据元素； e服务提供方对该数据元素的业务处理方法： e1某一数据元素出队后，记录当前时间作为该请求出队时间outQueueTime； e2对该数据元素中的消息内容进行业务处理，其处理时间记为handleTime； f服务提供方对处理效率的周期汇总方法： 对每个msgType每分钟处理情况做一次汇总计算，求平均处理时间avgHandleTime；公式如下： avgHandleTimemsgType＝handleTimemsgTypecountmsgType； countmsgType为1分钟内的处理的相同msgType的数据元素个数； ΣhandleTimemsgType为1分钟内的处理的相同msgType的数据元素的总处理时间之和，求得平均处理时间avgHandleTimemsgType； t时刻msgType为m的平均处理时间avgHandleTimemsgType，t简化记作fm，t； 同理，t-1时刻msgType为m的平均处理时间简化记作fm，t-1； S3、检测队列堆积的方法： 若发生下面2种情况，判定队列堆积： 1服务提供方接收到新消息，但此时队列长度已达a，则无法继续入队，因队列满队列堆积，此时丢弃该请求，记下首次堆积时刻为r，此时上个时刻未堆积，若上个时刻已堆积，则已在上个时刻检测到； 2从队列中出队后，计算outQueueTime,检查outQueueTime-enQueueTimetimeout,则因此请求调用方已不再等待其响应结果，没有必要继续处理，所以丢弃该请求；若连续累计有c条请求都需要丢弃，则判定队列已堆积，记下首次堆积时刻为r，此时上个时刻未堆积，若上个时刻已堆积，则已在上个时刻检测到； S4、队列堆积的恢复方法： 因服务提供方消息太多或处理速度低于服务调用方的发放速度，而服务调用方感知到超时后，又会不停重发请求给服务提供方；若不能及时恢复队列，则会发生链式传导，最终系统各服务均发生风险；具体恢复方法为： 1系统恢复，历史消息调用方已不再等待，没有必要处理失效的消息，先清空队列中的所有消息进行系统恢复； 2自动扩容，增加服务提供方的消费能力，具体为：检测若cpu30％,则线程数增大100％，若30％cpu50％,则线程数增大30％； S5、队列堆积的溯源方法： 在队列堆积的情况下，需找到哪些消息导致的堆积；具体方法为： 1对平均处理时间太长的消息类型溯源； 对于所有的消息类型msgType，m∈Q,若fm,rα*fm,r-1,则m放入集合E，E为处理时间长的堆积消息类型集合，α≥2，α为预设阈值； 2对到达速率太快的消息类型溯源； 对于所有的消息类型msgType，m∈Q,若gm,rα*gm,r-1,则m放入集合H，H为到达速率太快的堆积消息类型集合，β≥2，β为预设阈值； 最终在堆积时刻r，找到导致堆积的消息类型集合E和H。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人上海赛可出行科技服务有限公司，其通讯地址为：201805 上海市嘉定区安亭镇墨玉南路888号16层1603室-7；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。