logo好方法网

数据处理方法和装置、电子设备及存储介质


技术摘要:
本申请提供的数据处理方法和装置、电子设备及存储介质,涉及数据处理技术领域。在本申请中,首先,通过预设的目标交换机获取终端设备发送的待处理数据,其中,该目标交换机为广播类的交换机。其次,通过目标交换机将待处理数据广播至,预先建立有绑定关系的每个请求队  全部
背景技术:
为了使得数据处理的效率更高,在现有技术中,一般会通过部署有多个服务端的 集群进行处理。例如,客户端可以将待处理数据分别发送给多个服务端,使得每个服务端可 以分别对该待处理数据进行处理。 经发明人研究发现,在现有技术中,由于客户端在发送待处理数据时,需要确定集 群中的全部服务端,然后,才能进行有效地的数据发送。如此,将会导致客户端与服务端之 间的耦合性较高,使得在对服务端进行动态调整(如扩展或收缩)之后,也需要对客户端进 行调整,从而导致对服务端的动态调整因受限于客户端而存在不便的问题。
技术实现要素:
有鉴于此,本申请的目的在于提供一种数据处理方法和装置、电子设备及存储介 质,以改善现有技术中对服务端的动态调整存在不便的问题。 为实现上述目的,本申请实施例采用如下技术方案: 一种数据处理方法,应用于代理服务器,该方法包括: 通过预设的目标交换机获取终端设备发送的待处理数据,其中,该目标交换机为 广播类的交换机; 通过所述目标交换机将所述待处理数据广播至,预先建立有绑定关系的每个请求 队列,其中,每个所述请求队列对应有至少一个目标服务端,用于对对应请求队列中的待处 理数据进行处理,得到目标数据; 通过预设的响应队列获取每个所述目标服务端得到的目标数据,以使所述终端设 备从该响应队列获取所述待处理数据对应的每个目标数据。 在本申请实施例较佳的选择中,在上述数据处理方法中,所述通过预设的目标交 换机获取终端设备发送的待处理数据的步骤,包括: 基于预先安装的消息代理软件和终端设备基于高级消息队列协议发送的第一连 接请求信息,与该终端设备建立通信连接; 基于所述终端设备发送的交换机声明信息,创建广播类的目标交换机; 通过所述目标交换机获取所述终端设备发送的待处理数据。 在本申请实施例较佳的选择中,在上述数据处理方法中,所述通过所述目标交换 机将所述待处理数据广播至,预先建立有绑定关系的每个请求队列的步骤,包括: 基于预先安装的消息代理软件和每个目标服务端基于高级消息队列协议发送的 第二连接请求信息,分别与每个所述目标服务端建立通信连接; 基于每个所述目标服务端发送的队列声明信息分别创建对应的请求队列,并将每 4 CN 111580993 A 说 明 书 2/11 页 个请求队列与目标交换机建立绑定关系; 通过所述目标交换机将所述待处理数据广播至,与该目标交换机具有绑定关系的 每个请求队列。 在本申请实施例较佳的选择中,在上述数据处理方法中,所述将每个请求队列与 目标交换机建立绑定关系的步骤,包括: 基于每个所述目标服务端发送的队列绑定信息,判断是否已经建立有与该目标服 务端的业务类型相对应的交换机; 若建立有与所述目标服务端的业务类型相对应的交换机,则将该交换机作为目标 交换机,与该目标服务端对应的请求队列建立绑定关系; 若未建立有与所述目标服务端的业务类型相对应的交换机,则基于该目标服务端 的业务类型创建目标交换机,并将该目标服务端对应的请求队列与该目标交换机建立绑定 关系。 本申请实施例还提供了另一种数据处理方法,应用于终端设备,该方法包括: 将待处理数据发送给代理服务器的目标交换机,其中,该目标交换机为预设的广 播类的交换机,用于将该待处理数据广播至预先建立有绑定关系的每个请求队列; 从预先创建的响应队列获取所述待处理数据对应的每个目标数据,其中,每个所 述请求队列对应有至少一个目标服务端,用于对对应请求队列中的待处理数据进行处理得 到目标数据,并将该目标数据发送给所述代理服务器的响应队列。 在本申请实施例较佳的选择中,在上述数据处理方法中,所述将待处理数据发送 给代理服务器的目标交换机的步骤,包括: 基于高级消息队列协议向代理服务器发送第一连接请求信息,其中,该代理服务 器预先安装有基于该高级消息队列协议形成的消息代理软件,用于基于该第一连接请求信 息与所述终端设备建立通信连接; 基于所述通信连接向所述代理服务器发送交换机声明信息,其中,该代理服务器 用于基于该交换机声明信息,创建广播类的目标交换机; 将待处理数据发送给所述代理服务器的目标交换机。 本申请实施例还提供了一种数据处理装置,应用于代理服务器,该装置包括: 第一数据获取模块,用于通过预设的目标交换机获取终端设备发送的待处理数 据,其中,该目标交换机为广播类的交换机; 数据广播模块,用于通过所述目标交换机将所述待处理数据广播至,预先建立有 绑定关系的每个请求队列,其中,每个所述请求队列对应有至少一个目标服务端,用于对对 应请求队列中的待处理数据进行处理,得到目标数据; 第二数据获取模块,用于通过预设的响应队列获取每个所述目标服务端得到的目 标数据,以使所述终端设备从该响应队列获取所述待处理数据对应的每个目标数据。 本申请实施例还提供了另一种数据处理装置,应用于终端设备,该装置包括: 待处理数据发送模块,用于将待处理数据发送给代理服务器的目标交换机,其中, 该目标交换机为预设的广播类的交换机,用于将该待处理数据广播至预先建立有绑定关系 的每个请求队列; 目标数据获取模块,用于从预先创建的响应队列获取所述待处理数据对应的每个 5 CN 111580993 A 说 明 书 3/11 页 目标数据,其中,每个所述请求队列对应有至少一个目标服务端,用于对对应请求队列中的 待处理数据进行处理得到目标数据,并将该目标数据发送给所述代理服务器的响应队列。 在上述基础上,本申请实施例还提供了一种电子设备,包括: 存储器,用于存储计算机程序; 与所述存储器连接的处理器,用于执行所述计算机程序; 其中,在所述电子设备作为代理服务器时,所述处理器执行所述计算机程序,以实 现上述应用于代理服务器的数据处理方法; 在所述电子设备作为终端设备时,所述处理器执行所述计算机程序,以实现上述 应用于终端设备的数据处理方法。 在上述基础上,本申请实施例还提供了一种计算机可读存储介质,其上存储有计 算机程序,该计算机程序被执行时,实现上述的数据处理方法。 本申请提供的数据处理方法和装置、电子设备及存储介质,通过将待处理数据发 送给代理服务器的目标交换机,而该目标交换机属于广播类,使得该待处理数据可以被广 播至绑定的所有请求队列,从而保证所有的目标服务端都可以从对应的请求队列中获得待 处理数据,以通过进行处理得到目标数据。如此,可以使得服务端在进行调整(如数量的扩 展或减少)之后,仅需要申请对应的请求队列并绑定至目标交换机即可,与终端设备的客户 端无任何直接关联,使得客户端与服务端之间的耦合性降低(即解耦),从而改善现有技术 中对服务端的动态调整因受限于客户端而存在不便的问题,尤其是在服务端部署较多、动 态调整频率较高的应用中,具有较好的应用效果,实用价值较高。 为使本申请的上述目的、特征和优点能更明显易懂,下文特举较佳实施例,并配合 所附附图,作详细说明如下。 附图说明 图1为本申请实施例提供的数据处理系统的系统交互示意图。 图2为本申请实施例提供的电子设备的结构框图。 图3为本申请实施例提供的数据处理方法(应用于代理服务器)包括的各步骤的流 程示意图。 图4为图3中步骤S110包括的各步骤的流程示意图。 图5为图3中步骤S120包括的各步骤的流程示意图。 图6为图4中步骤S122包括的各步骤的流程示意图。 图7为本申请实施例提供的数据处理方法(应用于终端设备)包括的各步骤的流程 示意图。 图8为图7中步骤S210包括的各步骤的流程示意图。 图9为本申请实施例提供的请求队列与响应队列的数据传输示意图。 图10为本申请实施例提供的第一数据处理装置包括的功能模块的方框示意图。 图11为本申请实施例提供的第二数据处理装置包括的功能模块的方框示意图。 图标:10-数据处理系统;20-电子设备;22-存储器;24-处理器;100-第一数据处理 装置;110-第一数据获取模块;120-数据广播模块;130-第二数据获取模块;200-第二数据 处理装置;210-待处理数据发送模块;220-目标数据获取模块。 6 CN 111580993 A 说 明 书 4/11 页
下载此资料需消耗2积分,
分享到:
收藏