CN116095139A - 一种会话处理方法、系统、装置及存储介质 - Google Patents
一种会话处理方法、系统、装置及存储介质 Download PDFInfo
- Publication number
- CN116095139A CN116095139A CN202211703585.4A CN202211703585A CN116095139A CN 116095139 A CN116095139 A CN 116095139A CN 202211703585 A CN202211703585 A CN 202211703585A CN 116095139 A CN116095139 A CN 116095139A
- Authority
- CN
- China
- Prior art keywords
- session
- computing node
- computing
- processing method
- processing
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/14—Session management
- H04L67/141—Setup of application sessions
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/14—Session management
- H04L67/142—Managing session states for stateless protocols; Signalling session states; State transitions; Keeping-state mechanisms
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/14—Session management
- H04L67/146—Markers for unambiguous identification of a particular session, e.g. session cookie or URL-encoding
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer And Data Communications (AREA)
Abstract
本申请公开了一种会话处理方法、系统、装置及存储介质。该方法包括:响应于第一设备发出的第一会话请求,分配第一计算节点处理所述第一会话请求;所述第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片;所述第一分片用于存储所述第一设备的会话信息;根据所述第一分片中存储的所述第一设备对应的会话状态数据,建立所述第一设备的会话进程,并更新所述会话状态数据。本申请实施例能够实现计算节点的扩容,提升海量设备的会话处理能力,提升处理效率。本方法可以广泛的应用于计算机技术领域。
Description
技术领域
本申请涉及计算机技术领域,尤其是一种会话处理方法、系统、装置及存储介质。
背景技术
随着物联网技术的快速发展,相关设备数量出现阶梯式增长。而海量的设备接入统一的物联网平台,平台侧需要维护每个设备的在线会话,当设备数量达到亿级时,设备的会话维护将面临诸多挑战。相关技术中,处理节点同时承担计算与存储功能,节点间依赖性强,无法水平扩容;处理效率低下。
发明内容
本申请的目的在于至少一定程度上解决现有技术中存在的技术问题之一。
为此,本发明的目的在于提供一种高效、可支持多设备的会话处理方法、系统、装置及存储介质。
为了达到上述技术目的,本申请实施例所采取的技术方案包括:
一方面,本申请实施例提供了一种会话处理方法,包括以下步骤:
本申请实施例的会话处理方法,该方法包括:响应于第一设备发出的第一会话请求,分配第一计算节点处理所述第一会话请求;所述第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片;所述第一分片用于存储所述第一设备的会话信息;根据所述第一分片中存储的所述第一设备对应的会话状态数据,建立所述第一设备的会话进程,并更新所述会话状态数据。本申请实施例通过计算节点进行查询处理操作,通过分片进行存储操作,将存储和节点分离部署,能够实现计算节点的扩容,提升海量设备的会话处理能力,提升处理效率。
另外,根据本申请上述实施例的会话处理方法,还可以具有以下附加的技术特征:
进一步地,本申请实施例的会话处理方法,所述方法还包括:
获取所述第一分片中存储的所述第一设备对应的计算节点,确定为第二计算节点;
若所述第二计算节点与所述第一计算节点不同,删除第二计算节点对应的本地会话进程。
进一步地,在本申请的一个实施例中,所述第一会话请求包括第一业务数据,所述方法还包括:
所述第一计算节点将所述第一业务数据发送至第一应用。
进一步地,在本申请的一个实施例中,分片中存储有关系路由表,所述关系路由表用于表征设备与计算节点的对应关系,所述方法还包括以下步骤:
响应于第二应用发出的第二会话请求,分配第三计算节点处理所述第二会话请求;其中,所述第二会话请求中包括所述第二应用的会话对象,所述会话对象为第二设备;
所述第三计算节点根据所述第二设备的预设标识,查询所述第二设备对应的第二分片;所述第二分片用于存储所述第二设备的会话信息;
查询所述第二分片中的关系路由表,确定所述第二设备对应的第四计算节点;
若所述第三计算节点与所述第四计算节点不同,所述第三计算节点将所述第二会话请求路由至所述第四计算节点。
进一步地,在本申请的一个实施例中,所述方法还包括:
构建会话处理构架,所述会话处理构架包括计算集群和存储集群;
所述计算集群包括若干计算节点,所述计算节点用于接收并处理会话请求;所述存储集群包括若干存储节点,每个所述存储节点包括若干分片;所述分片用于存储会话信息。
进一步地,在本申请的一个实施例中,所述方法还包括:
若所述计算节点对应的会话请求数均大于预设阈值,对所述计算集群进行扩容处理,向所述计算集群中增加新的计算节点。
进一步地,在本申请的一个实施例中,所述第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片,包括:
第一计算节点对所述第一设备的IMEI号进行哈希、取模处理,确定所述第一设备对应的第一分片。
另一方面,本申请实施例提出了一种会话处理系统,包括:
第一模块,用于响应于第一设备发出的第一会话请求,分配第一计算节点处理所述第一会话请求;
第二模块,用于使第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片;所述第一分片用于存储所述第一设备的会话信息;
第三模块,用于根据所述第一分片中存储的所述第一设备对应的会话状态数据,建立所述第一设备的会话进程,并更新所述会话状态数据。
另一方面,本申请实施例提供了一种会话处理装置,包括:
至少一个处理器;
至少一个存储器,用于存储至少一个程序;
当所述至少一个程序被所述至少一个处理器执行时,使得所述至少一个处理器实现上述的任一种会话处理方法。
另一方面,本申请实施例提供了一种存储介质,其中存储有处理器可执行的程序,所述处理器可执行的程序在由处理器执行时用于实现上述的任一种会话处理方法。
本申请实施例通过计算节点进行查询处理操作,通过分片进行存储操作,将存储和节点分离部署,能够实现计算节点的扩容,提升海量设备的会话处理能力,提升处理效率。
附图说明
为了更清楚地说明本申请实施例或者现有技术中的技术方案,下面对本申请实施例或者现有技术中的相关技术方案附图作以下介绍,应当理解的是,下面介绍中的附图仅仅为了方便清晰表述本申请的技术方案中的部分实施例,对于本领域的技术人员来说,在无需付出创造性劳动的前提下,还可以根据这些附图获取到其他附图。
图1为相关技术中会话处理方法的一种实施例的流程示意图;
图2为相关技术中会话处理方法的另一种实施例的流程示意图;
图3为本申请提供的会话处理方法的一种实施例的流程示意图;
图4为本申请提供的设备会话请求的一种实施例的流程示意图;
图5为本申请提供的应用会话请求的一种实施例的流程示意图;
图6为本申请提供的会话处理框架的一种实施例的结构示意图;
图7为本申请提供的会话处理系统的一种实施例的结构示意图;
图8为本申请提供的会话处理装置的一种实施例的结构示意图。
具体实施方式
下面详细描述本申请的实施例,实施例的示例在附图中示出,其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。下面通过参考附图描述的实施例是示例性的,仅用于解释本申请,而不能理解为对本申请的限制。对于以下实施例中的步骤编号,其仅为了便于阐述说明而设置,对步骤之间的顺序不做任何限定,实施例中的各步骤的执行顺序均可根据本领域技术人员的理解来进行适应性调整。
随着物联网技术的快速发展,相关设备数量出现阶梯式增长。而海量的设备接入统一的物联网平台,平台侧需要维护每个设备的在线会话,当设备数量达到亿级时,设备的会话维护将面临诸多挑战。相关技术中,参见图1所示的一种实施例,采用计算存储混合方式进行设备的会话处理。处理节点同时承担计算和存储功能,为了节点间的进程重建与指令消息的正确路由,每个处理节点(示例性地,如图中的处理节点11、处理节点12、处理节点13和处理节点14)需存储全量路由信息。因此,处理节点可扩容数较少,系统整体容量受限于单个节点可存储全量路由信息的上限。参见图2所示的一种实施例,实现了计算与存储分离,存储节点主备方式进行设备的会话处理;处理节点只需要进行会话的处理操作(示例性地,如图中的处理节点21和处理节点22)。增加存储节点的主机配置,可提升计算节点的扩容数。但是,仍存在如下问题:计算节点扩容数中等,系统整体容量受限于存储节点可存储全量信息的上限。
基于NB-IoT窄带蜂窝网络的特点:终端数量大,速率低;传统物联网平台接入NB-IoT设备,存在以下不足:接入层不具备扩展性,无法满足海量设备接入需求;程序处理模块间耦合性强,可扩展性弱;设备会话管理对会话的无缝迁移支持能力不足,对终端业务的影响较大。因此,本申请提供一种会话处理方法,将计算和存储分离,结合计算集群与存储集群的分片协同处理,实现平台接入层的可弹性扩展,最终实现平台具备亿级NB-IoT设备接入的能力。
下面参照附图详细描述根据本申请实施例提出的会话处理方法和系统,首先将参照附图描述根据本申请实施例提出的会话处理方法。
参照图3,本申请实施例中提供一种会话处理方法,本申请实施例中的会话处理方法,可应用于终端中,也可应用于服务器中,还可以是运行于终端或服务器中的软件等。终端可以是平板电脑、笔记本电脑、台式计算机等,但并不局限于此。服务器可以是独立的物理服务器,也可以是多个物理服务器构成的服务器集群或者分布式系统,还可以是提供云服务、云数据库、云计算、云函数、云存储、网络服务、云通信、中间件服务、域名服务、安全服务、CDN、以及大数据和人工智能平台等基础云计算服务的云服务器。本申请实施例中的会话处理方法主要包括以下步骤:
S100:响应于第一设备发出的第一会话请求,分配第一计算节点处理第一会话请求;
本步骤中,基于设备与应用之间的会话,若设备需要发送业务数据至应用,则通过负载均衡模块根据各个计算节点的负载量,分配第一计算节点对第一会话请求进行处理。第一计算节点接收到第一会话请求,进行相应的会话处理。通过负载均衡模块,实现计算节点之间的负载均衡,提升会话处理效率。
S200:第一计算节点根据第一设备的预设标识,查询第一设备对应的第一分片;第一分片用于存储第一设备的会话信息;
本步骤中,通过计算节点根据第一设备的预设标识,查询对应的第一分片。可以理解的是,第一分片属于存储单元或存储集群;存储集群中包括若干个分片,每个分片可以存储若干个设备的会话信息。通过设备的预设标识,进行分类存储,便于会话信息的搜索,提升查询速度和准确度。需要说明的是,预设标识,可以是设备的任意可区分标识;通过预设标识可以确定该设备的唯一分片号。通过将计算节点和存储进行分离,实现了计算节点和存储节点的任意弹性扩容,能够实现海量设备的会话处理。
S300:根据第一分片中存储的第一设备对应的会话状态数据,建立第一设备的会话进程,并更新会话状态数据。
本步骤中,第一计算节点根据第一分片中的第一设备对应的会话状态数据,建立第一设备的会话进程,更新会话状态数据。可以理解的是,第一分片中存储有第一设备的关系路由表,记录了第一设备与对应的处理计算节点的关系。而当前时刻的第一设备的会话,通过第一计算节点进行处理。综上可知,本申请提供的实施例实现了计算集群(无状态)和存储集群(有状态)分离;上下行消息通过负载均衡分发至多个计算节点。计算节点维护设备会话进程,承担协议解析及业务流程的处理作业,节点间无直接的相互依赖,可水平任意扩容。
综上,本申请提供一种方法,将计算和存储分离,结合计算集群与存储集群的分片协同处理,实现平台接入层的可弹性扩容,最终使得系统具备接入亿级NB-IoT设备能力。同时,能够实现终端上行业务对会话迁移的无感,下行业务的准确路由。
可选地,本申请实施例的会话处理方法,方法还包括以下步骤:
获取第一分片中存储的第一设备对应的计算节点,确定为第二计算节点;
若第二计算节点与第一计算节点不同,删除第二计算节点对应的本地会话进程。
本步骤中,参见图4所示的一种实施例,将设备向应用之间的数据传输视为上行,本申请实施例可以基于LwM2M协议上实施,该协议基于底层UDP协议的短连接构建,负载均衡模块转发上行报文选择后端计算节点具有随机性,通过存储节点的路由中介作用,可实现会话在计算节点间的无缝迁移。可以理解的是,第一分片中存储有第一设备的上一次会话对应的计算节点,若上一次的计算节点不同于本次会话的计算节点,即第二计算节点不同于第一计算节点,则将第二计算节点中的本地会话进程销毁。同时,更新关系路由表。示例性地,上行会话处理的具体过程可以是:
步骤41、第一计算节点接收到第一设备/终端上报的第一会话请求,第一会话请求中包括第一业务数据及第一业务数据的发送对象,即第一应用。
步骤42、第一计算节点根据第一设备的IMEI号确定分片号,进而向分片对应存储节点获取会话状态数据,同时获取到第一设备对应的上一次会话归属的老节点,记为第二计算节点。
步骤43、第一计算节点根据步骤42中获取的会话状态数据构建设备会话进程,并更新会话状态数据至存储节点。具体地,将第一计算节点与第一设备的会话的关联关系,写入存储节点。
步骤44、第一计算节点通知第二计算节点销毁本地会话进程。
步骤45、第一计算节点将第一业务数据转发至北向第一应用。
可选地,在本申请的一个实施例中,第一会话请求包括第一业务数据,方法还包括:
第一计算节点将第一业务数据发送至第一应用。
本步骤中,第一计算节点基于会话进程和第一会话请求,将第一业务数据发送至第一应用,完成终端向应用的会话需求。
可选地,在本申请的一个实施例中,分片中存储有关系路由表,关系路由表用于表征设备与计算节点的对应关系,方法还包括以下步骤:
响应于第二应用发出的第二会话请求,分配第三计算节点处理第二会话请求;其中,第二会话请求中包括第二应用的会话对象,会话对象为第二设备;
第三计算节点根据第二设备的预设标识,查询第二设备对应的第二分片;第二分片用于存储第二设备的会话信息;
查询第二分片中的关系路由表,确定第二设备对应的第四计算节点;
若第三计算节点与第四计算节点不同,第三计算节点将第二会话请求路由至第四计算节点。
本步骤中给出了应用向终端发送响应数据的下行过程,具体地,应用发起的下行指令同样随机发送至某个计算节点,计算节点通过分片的计算和数据查询确定路由目的,将指令路由给对应计算节点,完成指令下发设备。如图5所示的一种实施例,下行会话过程如下所示:
步骤51、第二应用有数据进行下行传输时,通过负载均衡模块分配计算节点处理,示例性地,通过第三计算节点进行处理,第三计算节点接收到第二应用下发的第二会话请求。
步骤52、第三计算节点根据第二设备的IMEI号确定第二设备相应的存储分片,进而向分片对应存储节点查询到第二设备的会话所归属的计算节点为第四计算节点。
步骤53、将第二会话请求路由到第四计算节点进行处理。具体地,第三计算节点将指令路由至第四计算节点。
步骤54、第四计算节点将指令下发给第二终端/设备。即本申请还包括步骤:第二会话请求包括第二业务数据,第三计算节点将第二业务数据发送至第二设备。
可选地,在本申请的一个实施例中,方法还包括:
构建会话处理构架,会话处理构架包括计算集群和存储集群;
计算集群包括若干计算节点,计算节点用于接收并处理会话请求;存储集群包括若干存储节点,每个存储节点包括若干分片;分片用于存储会话信息。
本步骤中,构建计算节点和存储节点的网状访问架构,单个节点只负责有限数量的会话处理或存储,通过分片协同实现计算集群和存储集群节点数量的任意弹性扩容,使得系统具备接入亿级NB-IoT设备能力。可以理解的是,平台接入层承接设备上行数据并推送给应用,同时接收应用下发的指令并下发给设备。本申请实施例中,平台接入层提供计算集群和存储集群两类服务,计算集群负责维护会话进程处理数据转发,存储集群负责会话状态数据存储。
参见图6所示的实施例,具体处理过程如下:
步骤61、系统以设备唯一标识(示例性地,如LwM2M协议中的设备IMEI号)计算hash值,再与分片数(示例性地,如有128个分片)取模确定分片编号。可以理解的是,图6中的分片数量属于示例性举例,本申请并不限制具体的分片数。
步骤62、负载均衡模块负责将设备上行流量和应用下行流量均分至计算节点。
步骤63、计算节点完成协议层流程处理及设备会话的建立与维护,同时根据设备IMEI号确定设备归属分片,并将会话状态数据存储于分片对应的存储节点。
可以理解的是,本申请中计算节点和存储节点的网状访问架构,单个计算节点和存储节点只负责有限数量的设备会话处理与存储,从而实现计算集群和存储集群中节点数量的任意弹性扩容,使得系统具备接入NB-IoT设备量超过亿级能力。
可选地,在本申请的一个实施例中,方法还包括:
若计算节点对应的会话请求数均大于预设阈值,对计算集群进行扩容处理,向计算集群中增加新的计算节点。
本步骤中,通过上述构架能够实现无限扩容。具体地,若每个计算节点的会话请求数均处于高位,可以在计算集群中新增计算节点。当然,也可以根据实际需求,增加新的计算集群,处理大量的设备请求。通过计算集群和存储集群的架构设计,实现了扩容,提升系统的处理效率。
可选地,在本申请的一个实施例中,第一计算节点根据第一设备的预设标识,查询第一设备对应的第一分片,包括:
第一计算节点对第一设备的IMEI号进行哈希、取模处理,确定第一设备对应的第一分片。
本步骤中,可以根据设备的IMEI号确定设备归属的分片编号,分片算法全局统一。单个存储节点只负责一个或多个数据分片的存储,存储节点与分片的归属关系信息全局同步,存储节点个数可可根据实际需求进行设置。
需要说明的是,通过实施本申请的技术方案,通过相关产品的应用,已表明,在相关物联网开放平台实施,能够接入的终端数超过四千万。鉴于窄带蜂窝网络的特点以及本申请中对海量NB-IoT设备接入平台的技术建议,可将方案推广至通用的物联网行业场景。具体地,本申请提供的方法,可以用于下列场景中:
1、智慧城市:智能停车、消防栓、水/气表、智能垃圾箱、路灯、烟雾报警等。
2、个人生活:可穿戴设备、物品追踪等。
3、工业&农业:气体探测、灌溉控制、牲畜管控等。
4、智能家居:智能门锁、家电监控等。
其次,参照附图7描述根据本申请实施例提出的一种会话处理系统。
图7是本申请一个实施例的会话处理系统结构示意图,系统具体包括:
第一模块710,用于响应于第一设备发出的第一会话请求,分配第一计算节点处理第一会话请求;
第二模块720,用于使第一计算节点根据第一设备的预设标识,查询第一设备对应的第一分片;第一分片用于存储第一设备的会话信息;
第三模块730,用于根据第一分片中存储的第一设备对应的会话状态数据,建立第一设备的会话进程,并更新会话状态数据。
可见,上述方法实施例中的内容均适用于本系统实施例中,本系统实施例所具体实现的功能与上述方法实施例相同,并且达到的有益效果与上述方法实施例所达到的有益效果也相同。
参照图8,本申请实施例提供了一种会话处理装置,包括:
至少一个处理器810;
至少一个存储器820,用于存储至少一个程序;
当至少一个程序被至少一个处理器810执行时,使得至少一个处理器810实现的会话处理方法。
同理,上述方法实施例中的内容均适用于本装置实施例中,本装置实施例所具体实现的功能与上述方法实施例相同,并且达到的有益效果与上述方法实施例所达到的有益效果也相同。
本申请实施例还提供了一种计算机可读存储介质,其中存储有处理器810可执行的程序,处理器810可执行的程序在由处理器810执行时用于执行上述的会话处理方法。
同理,上述方法实施例中的内容均适用于本存储介质实施例中,本存储介质实施例所具体实现的功能与上述方法实施例相同,并且达到的有益效果与上述方法实施例所达到的有益效果也相同。
在一些可选择的实施例中,在方框图中提到的功能/操作可以不按照操作示图提到的顺序发生。例如,取决于所涉及的功能/操作,连续示出的两个方框实际上可以被大体上同时地执行或所述方框有时能以相反顺序被执行。此外,在本申请的流程图中所呈现和描述的实施例以示例的方式被提供,目的在于提供对技术更全面的理解。所公开的方法不限于本文所呈现的操作和逻辑流程。可选择的实施例是可预期的,其中各种操作的顺序被改变以及其中被描述为较大操作的一部分的子操作被独立地执行。
此外,虽然在功能性模块的背景下描述了本申请,但应当理解的是,除非另有相反说明,功能和/或特征中的一个或多个可以被集成在单个物理装置和/或软件模块中,或者一个或多个功能和/或特征可以在单独的物理装置或软件模块中被实现。还可以理解的是,有关每个模块的实际实现的详细讨论对于理解本申请是不必要的。更确切地说,考虑到在本文中公开的装置中各种功能模块的属性、功能和内部关系的情况下,在工程师的常规技术内将会了解该模块的实际实现。因此,本领域技术人员运用普通技术就能够在无需过度试验的情况下实现在权利要求书中所阐明的本申请。还可以理解的是,所公开的特定概念仅仅是说明性的,并不意在限制本申请的范围,本申请的范围由所附权利要求书及其等同方案的全部范围来决定。
所述功能如果以软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本申请的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干程序用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本申请各个实施例所述方法的全部或部分步骤。而前述的存储介质包括:U盘、移动硬盘、只读存储器(ROM,Read-Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。
在流程图中表示或在此以其他方式描述的逻辑和/或步骤,例如,可以被认为是用于实现逻辑功能的可执行程序的定序列表,可以具体实现在任何计算机可读介质中,以供程序执行系统、装置或设备(如基于计算机的系统、包括处理器的系统或其他可以从程序执行系统、装置或设备取程序并执行程序的系统)使用,或结合这些程序执行系统、装置或设备而使用。就本说明书而言,“计算机可读介质”可以是任何可以包含、存储、通信、传播或传输程序以供程序执行系统、装置或设备或结合这些程序执行系统、装置或设备而使用的装置。
计算机可读介质的更具体的示例(非穷尽性列表)包括以下:具有一个或多个布线的电连接部(电子装置),便携式计算机盘盒(磁装置),随机存取存储器(RAM),只读存储器(ROM),可擦除可编辑只读存储器(EPROM或闪速存储器),光纤装置,以及便携式光盘只读存储器(CDROM)。另外,计算机可读介质甚至可以是可在其上打印所述程序的纸或其他合适的介质,因为可以例如通过对纸或其他介质进行光学扫描,接着进行编辑、解译或必要时以其他合适方式进行处理来以电子方式获得所述程序,然后将其存储在计算机存储器中。
应当理解,本申请的各部分可以用硬件、软件、固件或它们的组合来实现。在上述实施方式中,多个步骤或方法可以用存储在存储器中且由合适的程序执行系统执行的软件或固件来实现。例如,如果用硬件来实现,和在另一实施方式中一样,可用本领域公知的下列技术中的任一项或他们的组合来实现:具有用于对数据信号实现逻辑功能的逻辑门电路的离散逻辑电路,具有合适的组合逻辑门电路的专用集成电路,可编程门阵列(PGA),现场可编程门阵列(FPGA)等。
在本说明书的上述描述中,参考术语“一个实施方式/实施例”、“另一实施方式/实施例”或“某些实施方式/实施例”等的描述意指结合实施方式或示例描述的具体特征、结构、材料或者特点包含于本申请的至少一个实施方式或示例中。在本说明书中,对上述术语的示意性表述不一定指的是相同的实施方式或示例。而且,描述的具体特征、结构、材料或者特点可以在任何的一个或多个实施方式或示例中以合适的方式结合。
尽管已经示出和描述了本申请的实施方式,本领域的普通技术人员可以理解:在不脱离本申请的原理和宗旨的情况下可以对这些实施方式进行多种变化、修改、替换和变型,本申请的范围由权利要求及其等同物限定。
以上是对本申请的较佳实施进行了具体说明,但本申请并不限于所述实施例,熟悉本领域的技术人员在不违背本申请精神的前提下还可做作出种种的等同变形或替换,这些等同的变形或替换均包含在本申请权利要求所限定的范围内。
Claims (10)
1.一种会话处理方法,其特征在于,包括以下步骤:
响应于第一设备发出的第一会话请求,分配第一计算节点处理所述第一会话请求;
所述第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片;所述第一分片用于存储所述第一设备的会话信息;
根据所述第一分片中存储的所述第一设备对应的会话状态数据,建立所述第一设备的会话进程,并更新所述会话状态数据。
2.根据权利要求1所述的会话处理方法,其特征在于,所述方法还包括:
获取所述第一分片中存储的所述第一设备对应的计算节点,确定为第二计算节点;
若所述第二计算节点与所述第一计算节点不同,删除第二计算节点对应的本地会话进程。
3.根据权利要求1所述的会话处理方法,其特征在于,所述第一会话请求包括第一业务数据,所述方法还包括:
所述第一计算节点将所述第一业务数据发送至第一应用。
4.根据权利要求1所述的会话处理方法,其特征在于,分片中存储有关系路由表,所述关系路由表用于表征设备与计算节点的对应关系,所述方法还包括以下步骤:
响应于第二应用发出的第二会话请求,分配第三计算节点处理所述第二会话请求;其中,所述第二会话请求中包括所述第二应用的会话对象,所述会话对象为第二设备;
所述第三计算节点根据所述第二设备的预设标识,查询所述第二设备对应的第二分片;所述第二分片用于存储所述第二设备的会话信息;
查询所述第二分片中的关系路由表,确定所述第二设备对应的第四计算节点;
若所述第三计算节点与所述第四计算节点不同,所述第三计算节点将所述第二会话请求路由至所述第四计算节点。
5.根据权利要求1所述的会话处理方法,其特征在于,所述方法还包括:
构建会话处理构架,所述会话处理构架包括计算集群和存储集群;
所述计算集群包括若干计算节点,所述计算节点用于接收并处理会话请求;所述存储集群包括若干存储节点,每个所述存储节点包括若干分片;所述分片用于存储会话信息。
6.根据权利要求5所述的会话处理方法,其特征在于,所述方法还包括:
若所述计算节点对应的会话请求数均大于预设阈值,对所述计算集群进行扩容处理,向所述计算集群中增加新的计算节点。
7.根据权利要求1所述的会话处理方法,其特征在于,所述第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片,包括:
第一计算节点对所述第一设备的IMEI号进行哈希、取模处理,确定所述第一设备对应的第一分片。
8.一种会话处理系统,其特征在于,包括:
第一模块,用于响应于第一设备发出的第一会话请求,分配第一计算节点处理所述第一会话请求;
第二模块,用于使第一计算节点根据所述第一设备的预设标识,查询所述第一设备对应的第一分片;所述第一分片用于存储所述第一设备的会话信息;
第三模块,用于根据所述第一分片中存储的所述第一设备对应的会话状态数据,建立所述第一设备的会话进程,并更新所述会话状态数据。
9.一种会话处理装置,其特征在于,包括:
至少一个处理器;
至少一个存储器,用于存储至少一个程序;
当所述至少一个程序被所述至少一个处理器执行,使得所述至少一个处理器实现如权利要求1至7中任一项所述的会话处理方法。
10.一种计算机可读存储介质,其中存储有处理器可执行的程序,其特征在于:所述处理器可执行的程序在由处理器执行时用于实现如权利要求1至7中任一项所述的会话处理方法。
Priority Applications (2)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211703585.4A CN116095139A (zh) | 2022-12-29 | 2022-12-29 | 一种会话处理方法、系统、装置及存储介质 |
| PCT/CN2023/142002 WO2024140698A1 (zh) | 2022-12-29 | 2023-12-26 | 一种会话处理方法、系统、装置及存储介质 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211703585.4A CN116095139A (zh) | 2022-12-29 | 2022-12-29 | 一种会话处理方法、系统、装置及存储介质 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN116095139A true CN116095139A (zh) | 2023-05-09 |
Family
ID=86198532
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202211703585.4A Pending CN116095139A (zh) | 2022-12-29 | 2022-12-29 | 一种会话处理方法、系统、装置及存储介质 |
Country Status (2)
| Country | Link |
|---|---|
| CN (1) | CN116095139A (zh) |
| WO (1) | WO2024140698A1 (zh) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2024140698A1 (zh) * | 2022-12-29 | 2024-07-04 | 天翼物联科技有限公司 | 一种会话处理方法、系统、装置及存储介质 |
Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20140115176A1 (en) * | 2012-10-22 | 2014-04-24 | Cassidian Communications, Inc. | Clustered session management |
| US20150200973A1 (en) * | 2014-01-13 | 2015-07-16 | Comcast Cable Communication, Llc | Systems And Methods For Dynamic Connection Management |
| WO2015123876A1 (zh) * | 2014-02-21 | 2015-08-27 | 华为技术有限公司 | 通信数据处理方法、装置和系统 |
| CN105579960A (zh) * | 2013-06-26 | 2016-05-11 | 亚马逊技术有限公司 | 计算会话的管理 |
| CN113645261A (zh) * | 2020-04-27 | 2021-11-12 | 中国移动通信集团江西有限公司 | 一种会话数据处理方法、装置、存储介质和计算机设备 |
| CN114827093A (zh) * | 2021-01-18 | 2022-07-29 | 阿里巴巴集团控股有限公司 | 一种通信方法、设备、系统及存储介质 |
| CN114866596A (zh) * | 2022-05-25 | 2022-08-05 | 上海浦东发展银行股份有限公司 | 会话处理方法、装置、服务器及存储介质 |
| CN115422129A (zh) * | 2022-09-19 | 2022-12-02 | 青岛中科曙光科技服务有限公司 | 一种会话处理方法、装置、电子设备及存储介质 |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9888064B2 (en) * | 2015-02-11 | 2018-02-06 | International Business Machines Corporation | Load-balancing input/output requests in clustered storage systems |
| CN113452737A (zh) * | 2020-03-27 | 2021-09-28 | 华为技术有限公司 | 一种传输会话请求的方法、装置和电子设备 |
| CN116095139A (zh) * | 2022-12-29 | 2023-05-09 | 天翼物联科技有限公司 | 一种会话处理方法、系统、装置及存储介质 |
-
2022
- 2022-12-29 CN CN202211703585.4A patent/CN116095139A/zh active Pending
-
2023
- 2023-12-26 WO PCT/CN2023/142002 patent/WO2024140698A1/zh not_active Ceased
Patent Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20140115176A1 (en) * | 2012-10-22 | 2014-04-24 | Cassidian Communications, Inc. | Clustered session management |
| CN105579960A (zh) * | 2013-06-26 | 2016-05-11 | 亚马逊技术有限公司 | 计算会话的管理 |
| US20150200973A1 (en) * | 2014-01-13 | 2015-07-16 | Comcast Cable Communication, Llc | Systems And Methods For Dynamic Connection Management |
| WO2015123876A1 (zh) * | 2014-02-21 | 2015-08-27 | 华为技术有限公司 | 通信数据处理方法、装置和系统 |
| CN113645261A (zh) * | 2020-04-27 | 2021-11-12 | 中国移动通信集团江西有限公司 | 一种会话数据处理方法、装置、存储介质和计算机设备 |
| CN114827093A (zh) * | 2021-01-18 | 2022-07-29 | 阿里巴巴集团控股有限公司 | 一种通信方法、设备、系统及存储介质 |
| CN114866596A (zh) * | 2022-05-25 | 2022-08-05 | 上海浦东发展银行股份有限公司 | 会话处理方法、装置、服务器及存储介质 |
| CN115422129A (zh) * | 2022-09-19 | 2022-12-02 | 青岛中科曙光科技服务有限公司 | 一种会话处理方法、装置、电子设备及存储介质 |
Non-Patent Citations (1)
| Title |
|---|
| 邓世昆: "计算机网络工程", vol. 978, 31 August 2021, 北京理工大学出版社, pages: 222 - 223 * |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2024140698A1 (zh) * | 2022-12-29 | 2024-07-04 | 天翼物联科技有限公司 | 一种会话处理方法、系统、装置及存储介质 |
Also Published As
| Publication number | Publication date |
|---|---|
| WO2024140698A1 (zh) | 2024-07-04 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US10635649B2 (en) | Systems, methods, and media for managing an in-memory NoSQL database | |
| CN101133622B (zh) | 划分节点的工作负荷 | |
| CN101645922B (zh) | 基于地理位置信息编码的cdn网络系统及分发处理方法 | |
| US20200358848A1 (en) | Methods, systems, and media for providing distributed database access during a network split | |
| CN101753610B (zh) | 分布式网络构造方法、装置和系统以及任务处理方法 | |
| CN104135539B (zh) | 数据存储方法、sdn控制器和分布式网络存储系统 | |
| CN103516755B (zh) | 虚拟存储方法及设备 | |
| WO2018000993A1 (zh) | 一种分布式存储的方法和系统 | |
| WO2017097059A1 (zh) | 分布式数据库系统及其自适应方法 | |
| CN101697526A (zh) | 分布式文件系统中元数据管理的负载均衡方法及其系统 | |
| CN103095727B (zh) | P2p资源定位方法 | |
| CN102708165A (zh) | 分布式文件系统中的文件处理方法及装置 | |
| CN115878046B (zh) | 数据处理方法、系统、装置、存储介质及电子设备 | |
| US20150120787A1 (en) | Systems, methods, and media for managing ram resources for in-memory nosql databases | |
| CN101116312B (zh) | 在覆盖网络中路由业务查询的方法和信息业务节点 | |
| CN112121413A (zh) | 功能服务的响应方法、系统、装置、终端及介质 | |
| CN111526208A (zh) | 一种基于微服务的高并发云平台文件传输优化方法 | |
| WO2025113567A1 (zh) | 一种基于sdwan的跨境传输优化方法 | |
| CN116095139A (zh) | 一种会话处理方法、系统、装置及存储介质 | |
| CN103246716B (zh) | 基于对象集群文件系统的对象副本高效管理方法及系统 | |
| CN101820434B (zh) | 对等网络媒体传输方法、系统和对等节点 | |
| CN100559758C (zh) | 基于组合式建造p2p系统的方法 | |
| CN105808788B (zh) | 大数据系统的数据搜索方法 | |
| CN104753873A (zh) | 一种提供内容服务的方法、装置和系统 | |
| Lebre¹ et al. | at the Edge |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20230509 |