CN111274047A - Information processing method, terminal, system, computer device and storage medium - Google Patents
Information processing method, terminal, system, computer device and storage mediumDownload PDFInfo
- Publication number
- CN111274047A CN111274047ACN202010049302.3ACN202010049302ACN111274047ACN 111274047 ACN111274047 ACN 111274047ACN 202010049302 ACN202010049302 ACN 202010049302ACN 111274047 ACN111274047 ACN 111274047A
- Authority
- CN
- China
- Prior art keywords
- information
- consumed
- identification number
- unique identification
- sending
- 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
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/544—Buffers; Shared memory; Pipes
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Telephonic Communication Services (AREA)
Abstract
Translated fromChinese
Description
Translated fromChinese技术领域technical field
本申请涉及信息交互技术领域，尤其涉及一种信息处理方法、终端、信息处理系统、计算机设备和计算机可读存储介质。The present application relates to the technical field of information interaction, and in particular, to an information processing method, a terminal, an information processing system, a computer device, and a computer-readable storage medium.
背景技术Background technique
目前，随着微服务的发展日益突出，随之兴起的消息队列的应用愈发普及，RabbitMQ是一款基于AMQP协议的消息中间件，它能够在应用之间提供可靠的消息传输。在易用性，扩展性，高可用性上表现优秀，应用广泛。At present, with the increasingly prominent development of microservices, the application of message queues has become more and more popular. RabbitMQ is a message middleware based on the AMQP protocol, which can provide reliable message transmission between applications. It has excellent performance in ease of use, scalability, and high availability, and is widely used.
但是，目前的RabbitMQ客户端是面向单个RabbitMQ服务器设计的，随着服务提供范围的扩大，现在已经可以部署RabbitMQ服务器集群来提高RabbitMQ服务的可用性，RabbitMQ客户端连接到集群中任意一台服务器都可以发送和接收消息。其中，RabbitMQ是一个在AMQP协议的基础上完成的、可复用的企业消息系统，其中，MQ(MessageQueue，消息队列)是一种应用程序对应用程序的通信方法。However, the current RabbitMQ client is designed for a single RabbitMQ server. With the expansion of the service offering, a cluster of RabbitMQ servers can now be deployed to improve the availability of the RabbitMQ service. The RabbitMQ client can connect to any server in the cluster. Send and receive messages. Among them, RabbitMQ is a reusable enterprise message system completed on the basis of the AMQP protocol, wherein, MQ (MessageQueue, message queue) is an application-to-application communication method.
其中，每个RabbitMQ客户端都是面向单个RabbitMQ服务器设计，即在初期都会为每台RabbitMQ客户端分配固定连接的一个RabbitMQ服务器，如果集群中的一台服务器宕机时，连接到这台服务器的所有RabbitMQ客户端都会断开连接。即虽然RabbitMQ服务器集群提供了高可用的服务，但是每台RabbitMQ客户端还是仅与其中的一个RabbitMQ服务器建立固定的连接，一旦出现单节点故障还是出现与原先一样的RabbitMQ服务中断的情况。Among them, each RabbitMQ client is designed for a single RabbitMQ server, that is, a RabbitMQ server with a fixed connection will be allocated to each RabbitMQ client in the initial stage. All RabbitMQ clients are disconnected. That is, although the RabbitMQ server cluster provides highly available services, each RabbitMQ client only establishes a fixed connection with one of the RabbitMQ servers. Once a single node fails, the same RabbitMQ service interruption will occur.
在主业务服务中如果直接应用RabbitMQ消息队列会由于网络不稳定等多方面原因，出现主业务服务与RabbitMQ服务连接中断，造成假死的现象，甚至导致服务崩溃。If the RabbitMQ message queue is directly used in the main business service, the connection between the main business service and the RabbitMQ service will be interrupted due to various reasons such as network instability, resulting in suspended animation and even service crashes.
因此，RabbitMQ在使用到企业内部的消息服务、邮件、APP推送或一般的异步任务时，由于上述一种或多种原因，会导致在企业内部无法进行顺畅通讯，影响用户使用，甚至会带来不可预见的损失，给用户带来诸多不便。Therefore, when RabbitMQ uses the message service, email, APP push or general asynchronous tasks within the enterprise, due to one or more of the above reasons, smooth communication within the enterprise will not be possible, affecting the use of users, and even bringing Unforeseen losses bring a lot of inconvenience to users.
发明内容SUMMARY OF THE INVENTION
本申请提供了一种信息处理方法、终端、信息处理系统、计算机设备和存储介质，以有效地解决上述技术问题。The present application provides an information processing method, terminal, information processing system, computer equipment and storage medium to effectively solve the above technical problems.
第一方面，本申请提供了一种信息处理方法，包括：In a first aspect, the present application provides an information processing method, including:
生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号；generating information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number for identifying the information to be consumed and the confirmation information;
将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存；Sending the information to be consumed and the corresponding unique identification number to a preliminary information queue for buffering;
发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。Send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component releases the information to be consumed corresponding to the unique identification number in the preliminary information queue to the first target terminal for consumption.
第二方面，本申请还提供一种终端，所述终端包括：In a second aspect, the present application further provides a terminal, where the terminal includes:
信息生成模块，用于生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号；an information generation module for generating information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number for identifying the information to be consumed and the confirmation information;
信息发送模块，用于将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存；an information sending module, configured to send the information to be consumed and the corresponding unique identification number to a preliminary information queue for buffering;
确认发送模块，用于发送具备所述唯一识别号的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。A confirmation sending module, configured to send the confirmation information with the unique identification number to the RocketMQ service component, so that the RocketMQ service component sends the information to be consumed corresponding to the unique identification number in the preliminary information queue Released to the first target terminal for consumption.
第三方面，本申请还提供一种信息处理系统，所述信息处理系统包括若干个如第二方面所述的终端。In a third aspect, the present application further provides an information processing system, where the information processing system includes several terminals according to the second aspect.
第四方面，本申请还提供一种计算机设备，所述计算机设备包括存储器和处理器；In a fourth aspect, the present application further provides a computer device, the computer device comprising a memory and a processor;
所述存储器用于存储计算机程序；the memory is used to store computer programs;
所述处理器，用于执行所述计算机程序并在执行所述计算机程序时实现如上述的信息处理方法。The processor is configured to execute the computer program and implement the above-mentioned information processing method when executing the computer program.
第五方面，本申请还提供一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时使所述处理器实现如上述的信息处理方法。In a fifth aspect, the present application further provides a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, and when the computer program is executed by a processor, the processor implements the above-mentioned information processing method.
本申请公开了一种信息处理方法、终端、信息处理系统、计算机设备和存储介质，本申请通过生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号；然后将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存，最终发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将缓存的与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。本申请采用RocketMQ进行系统通讯，并采用一全局唯一识别号，做到绝对不可能出现id重复造成消息发送失败的情况，本申请可以适用于消息服务、邮件、APP推送或一般的异步任务等。The present application discloses an information processing method, terminal, information processing system, computer equipment and storage medium. The present application generates to-be-consumed information, confirmation information corresponding to the to-be-consumed information, and uses for identifying the to-be-consumed information and The unique identification number of the confirmation information; then send the to-be-consumed information and the corresponding unique identification number to the preliminary information queue for buffering, and finally send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component releases the cached information to be consumed corresponding to the unique identification number to the first target terminal for consumption. This application uses RocketMQ for system communication, and uses a global unique identification number, so that it is absolutely impossible for the repeated id to cause the failure of message sending. This application can be applied to message services, emails, APP push or general asynchronous tasks.
附图说明Description of drawings
为了更清楚地说明本申请实施例技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本申请的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。In order to explain the technical solutions of the embodiments of the present application more clearly, the following briefly introduces the accompanying drawings used in the description of the embodiments. For those of ordinary skill, other drawings can also be obtained from these drawings without any creative effort.
图1是本申请实施例提供的一种信息处理系统的示意性框图；1 is a schematic block diagram of an information processing system provided by an embodiment of the present application;
图2是本申请实施例提供的信息处理方法的步骤示意流程图；2 is a schematic flowchart of steps of an information processing method provided by an embodiment of the present application;
图3是本申请实施例提供的另一信息处理方法的步骤示意流程图；3 is a schematic flowchart of steps of another information processing method provided by an embodiment of the present application;
图4是本申请的实施例还提供一种终端的示意性框图；4 is a schematic block diagram of a terminal further provided by an embodiment of the present application;
图5是本申请实施例提供的一种计算机设备的结构示意性框图。FIG. 5 is a schematic structural block diagram of a computer device provided by an embodiment of the present application.
具体实施方式Detailed ways
下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本申请保护的范围。The technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the accompanying drawings in the embodiments of the present application. Obviously, the described embodiments are part of the embodiments of the present application, not all of the embodiments. Based on the embodiments in the present application, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present application.
附图中所示的流程图仅是示例说明，不是必须包括所有的内容和操作/步骤，也不是必须按所描述的顺序执行。例如，有的操作/步骤还可以分解、组合或部分合并，因此实际执行的顺序有可能根据实际情况改变。The flowcharts shown in the figures are for illustration only, and do not necessarily include all contents and operations/steps, nor do they have to be performed in the order described. For example, some operations/steps can also be decomposed, combined or partially combined, so the actual execution order may be changed according to the actual situation.
下面结合附图，对本申请的一些实施方式作详细说明。在不冲突的情况下，下述的实施例及实施例中的特征可以相互组合。Some embodiments of the present application will be described in detail below with reference to the accompanying drawings. The embodiments described below and features in the embodiments may be combined with each other without conflict.
请参阅图1，图1是本申请实施例提供的一种信息处理系统的示意性框图。本申请所提供的信息处理方法，可应用于该信息处理系统。Please refer to FIG. 1. FIG. 1 is a schematic block diagram of an information processing system provided by an embodiment of the present application. The information processing method provided in this application can be applied to the information processing system.
如图1所示，该信息处理系统100包括发送终端101、目标终端102和RocketMQ服务组件103。发送终端101、RocketMQ服务组件103和目标终端102依次连接。但需要说明的是，该信息处理系统还可以包括两个以上的终端，本申请对于该信息处理系统中的终端数量在此不做限定。As shown in FIG. 1 , the
发送终端101用于生成待消费信息、与待消费信息对应的确认信息以及用于识别待消费信息和确认信息的唯一识别号。The sending
发送终端101上还连接有Zookeeper组件104，并且，发送终端101将生成的待消费信息和所述待消费信息对应的唯一识别号发送至Zookeeper组件104的预备信息队列中进行缓存。The
发送终端101发送与唯一识别号对应的确认信息至RocketMQ服务组件103，使RocketMQ服务组件103协调Zookeeper组件104将缓存在预备信息队列中与唯一识别号对应的所述待消费信息释放至目标终端102进行消费。The
发送终端101发送消息至RocketMQ服务组件103，若消息发送成功，则由RocketMQ服务组件103发送确认信息(ACK)至目标终端102，目标终端102接收到确认信息后执行本地任务；若消息发送失败，则通知RocketMQ服务组件103回调发送终端101，判断是进行消息回滚还是重新发送一次确认信息。The sending
在一些实施例中，该信息处理系统还可以包括第一数据库105和第二数据库106，第一数据库用于储存发送终端生成的与消费信息对应的确认信息，第二数据库用于储存目标终端产生的序列指示信息。In some embodiments, the information processing system may further include a
以下将基于所述信息处理系统对本申请提供的信息处理方法进行详细介绍。The information processing method provided by the present application will be described in detail below based on the information processing system.
请参阅图2，图2是本申请实施例提供的信息处理方法的步骤示意流程图，本申请的信息处理方法可以应用到短信、邮件、APP信息推送、第三方支付平台业务来往以及各种网络在线交互系统的异步交互任务等，具体包括步骤S201至步骤S203。Please refer to FIG. 2. FIG. 2 is a schematic flowchart of the steps of the information processing method provided by the embodiment of the present application. The information processing method of the present application can be applied to short messages, emails, APP information push, third-party payment platform business transactions, and various network The asynchronous interaction tasks of the online interaction system, etc., specifically include steps S201 to S203.
S201、生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号。S201. Generate information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number for identifying the information to be consumed and the confirmation information.
具体地，确认信息是指用于由第一目标终端对某待消费信息进行消费的信息。Specifically, the confirmation information refers to information used for consuming certain information to be consumed by the first target terminal.
其中，确认信息与待消费信息一一对应，也即每一个待消费信息都对应的有一个确认信息，并且待消费信息和其对应的确认信息共同具有一个相同的唯一识别号。在具体实施过程中，可以将唯一识别号可以标记为Message ID，并且在生成唯一识别号时，可以使用分布式锁的方式生成唯一识别号，以避免存在重复的ID，进而避免造成消息发送失败的情况。The confirmation information is in one-to-one correspondence with the information to be consumed, that is, each information to be consumed has a corresponding confirmation information, and the information to be consumed and the corresponding confirmation information share the same unique identification number. In the specific implementation process, the unique identification number can be marked as Message ID, and when generating the unique identification number, a distributed lock can be used to generate the unique identification number to avoid duplicate IDs and thus avoid message sending failures Case.
在一些实施例中，发送终端上可以连接有第一数据库，将发送终端生成的确认信息存储在与发送终端连接的第一数据库内，并在条件到达时，自动从所述第一数据库内读取所述确认信息，然后发送给RocketMQ服务组件。通过这种方式，可以避免系统重启或者网络异常而导致发送终端的确认信息丢失的情况，保证所述待消费信息能够对应被消费。In some embodiments, a first database may be connected to the sending terminal, the confirmation information generated by the sending terminal is stored in the first database connected to the sending terminal, and when a condition is reached, it is automatically read from the first database Get the confirmation information and send it to the RocketMQ service component. In this way, the situation that the confirmation information of the sending terminal is lost due to system restart or network abnormality can be avoided, and it is ensured that the information to be consumed can be consumed accordingly.
值得一提的是，在将确认信息存储在第一数据库内时，可以采用顺序写的方式，这样可以避免磁盘随机读写的寻址开销，本申请磁盘顺序读写的性能极高，有效保证了效率。It is worth mentioning that when the confirmation information is stored in the first database, a sequential write method can be used, which can avoid the addressing overhead of random read and write on the disk. efficiency.
S202、将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存。S202. Send the to-be-consumed information and the corresponding unique identification number to a preparatory information queue for buffering.
具体地，预备信息队列是指Zookeeper组件的预备信息队列，Zookeeper组件亦为ZK组件或ZK，Zookeeper组件可以实现分布式系统之间的协调工作，比如发送终端发送请求之后可以在Zookeeper组件上对某个节点的值注册个监听器，一旦第一目标终端处理完了就修改那个节点的值，发送终端能够马上收到通知反馈信息。Specifically, the preliminary information queue refers to the preliminary information queue of the Zookeeper component. The Zookeeper component is also the ZK component or ZK. The Zookeeper component can realize the coordination between distributed systems. The value of each node registers a listener, and once the first target terminal finishes processing, the value of that node is modified, and the sending terminal can immediately receive notification feedback information.
在一些实施例中，在步骤S202之后，还可以包括：In some embodiments, after step S202, it may further include:
设置所述待消费信息的存活时间；若所述待消费信息在所述存活时间内未被消费，则将所述待消费信息转发至另一预备信息队列。The survival time of the information to be consumed is set; if the information to be consumed is not consumed within the survival time, the information to be consumed is forwarded to another preliminary information queue.
具体地，可以利用RocketMQ的DLX(Dead Letter Exchanges)和消息的TTL(Time-To-Live Extensions)特性，首先发送待消费消息到缓存队列，然后设置一个存活时间TTL，在存活时间内如果没有被消费，设置这个待消费消息转发到其他缓存队列里面去；然后从这个其他队列里面消费执行该被转发的待消费信息的任务，从而达到一个消息延时消费的效果。Specifically, RocketMQ's DLX (Dead Letter Exchanges) and message TTL (Time-To-Live Extensions) features can be used to first send the message to be consumed to the cache queue, and then set a time-to-live TTL. Consumption, set this to-be-consumed message to be forwarded to other cache queues; then consume and execute the task of the forwarded to-be-consumed information from this other queue, so as to achieve the effect of delayed consumption of a message.
不难理解的是，通过这种方式，可以避免现有技术每分钟或者每小时，去跑一次取出需要处理的订单或其他数据进行处理的情况，提高效率，而且可以避免数据量大时扫库动作对数据库造成的极大压力，本申请时效性高，避免出现重复执行的结果，使得时效和轮询的频率得以平衡协调处理。It is not difficult to understand that in this way, the existing technology can avoid the situation of taking out orders or other data to be processed for processing every minute or every hour, improving efficiency, and avoiding the need to scan the database when the amount of data is large. Actions cause great pressure on the database, and the application has high timeliness to avoid repeated execution results, so that the timeliness and the frequency of polling can be balanced and coordinated.
S203、发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。S203. Send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component releases the information to be consumed corresponding to the unique identification number in the preliminary information queue to the first A target terminal for consumption.
具体地，发送终端将与唯一识别号对应的确认信息发送至RocketMQ服务组件，使RocketMQ服务组件协调Zookeeper组件将缓存在Zookeeper组件的预备信息队列中的与唯一识别号对应的待消费信息释放至第一目标终端进行消费。Specifically, the sending terminal sends the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component coordinates the Zookeeper component to release the to-be-consumed information corresponding to the unique identification number cached in the preliminary information queue of the Zookeeper component to the first A target terminal for consumption.
在具体实施过程中，第一目标终端需要保持与发送终端的幂等性。举例而言，发送终端先发送一个prepared消息到RocketMQ，如果这个prepared消息发送失败那么就直接取消操作不执行；如果消息发送成功，就执行本地任务，如果成功就告诉RocketMQ发送确认消息(ACK)，如果失败就通知RocketMQ回滚消息并发送NACK；如果发送了确认消息，那么此时第一目标终端会接收到确认消息，然后执行本地任务；RocketMQ自动定时轮询所有prepared消息回调接口，一般来说这里就可以查下数据库之前本地任务是否执行，如果回滚了，那么执行回滚；而如果第一目标终端消费失败，则自动不断重试直到成功，或可以执行回滚操作，同时发送终端也执行回滚操作，或者发送报警由人工来手动回滚和补偿。In a specific implementation process, the first target terminal needs to maintain idempotency with the sending terminal. For example, the sending terminal first sends a prepared message to RocketMQ. If the prepared message fails to be sent, it will cancel the operation and not execute it; if the message is sent successfully, it will execute the local task. If it is successful, it will tell RocketMQ to send an acknowledgment message (ACK). If it fails, it will notify RocketMQ to roll back the message and send NACK; if the confirmation message is sent, then the first target terminal will receive the confirmation message and then execute the local task; RocketMQ automatically polls all prepared message callback interfaces at regular intervals, generally speaking Here, you can check whether the local task was executed before the database. If it is rolled back, then execute the rollback; and if the consumption of the first target terminal fails, it will automatically retry until it succeeds, or the rollback operation can be performed, and the sending terminal also Perform rollback operations, or send alerts for manual rollback and compensation by humans.
本实施例提供的一种信息处理方法，通过生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号；然后将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存，最终发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将缓存的与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。采用RocketMQ进行系统通讯，并采用一全局唯一识别号，做到绝对不可能出现id重复造成消息发送失败的情况，本申请可以适用于消息服务、邮件、APP推送或一般的异步任务等。This embodiment provides an information processing method, by generating information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number used to identify the information to be consumed and the confirmation information; The information to be consumed and the corresponding unique identification number are sent to the preliminary information queue for buffering, and finally the confirmation information corresponding to the unique identification number is sent to the RocketMQ service component, so that the RocketMQ service component will cache the cached and The information to be consumed corresponding to the unique identification number is released to the first target terminal for consumption. Using RocketMQ for system communication and a global unique identification number, it is absolutely impossible for the repeated id to cause the failure of message sending. This application can be applied to message services, emails, APP push or general asynchronous tasks.
请参考图3，图3是本申请实施例提供的另一信息处理方法的步骤示意流程图。Please refer to FIG. 3 , which is a schematic flowchart of steps of another information processing method provided by an embodiment of the present application.
S301、生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号。S301. Generate information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number for identifying the information to be consumed and the confirmation information.
具体地，确认信息是指用于由第一目标终端对某待消费信息进行消费的信息。Specifically, the confirmation information refers to information used for consuming certain information to be consumed by the first target terminal.
其中，确认信息与待消费信息一一对应，也即每一个待消费信息都对应的有一个确认信息，并且待消费信息和其对应的确认信息共同具有一个相同的唯一识别号。在具体实施过程中，可以将唯一识别号可以标记为Message ID，并且在生成唯一识别号时，可以使用分布式锁的方式生成唯一识别号，以避免存在重复的ID，进而避免造成消息发送失败的情况。The confirmation information is in one-to-one correspondence with the information to be consumed, that is, each information to be consumed has a corresponding confirmation information, and the information to be consumed and the corresponding confirmation information share the same unique identification number. In the specific implementation process, the unique identification number can be marked as Message ID, and when generating the unique identification number, a distributed lock can be used to generate the unique identification number to avoid duplicate IDs and thus avoid message sending failures Case.
S302、将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存，并启动所述确认信息的发送倒计时。S302. Send the information to be consumed and the corresponding unique identification number to a preparatory information queue for buffering, and start a countdown for sending the confirmation information.
具体地，所述确认信息可以在发送终端将待消费信息和对应的所述唯一识别号发送至Zookeeper组件的预备信息队列中进行缓存时，就自动启动发送倒计时，以实现对所述待消费信息的定时消费。Specifically, the confirmation information may automatically start the sending countdown when the sending terminal sends the information to be consumed and the corresponding unique identification number to the preliminary information queue of the Zookeeper component for buffering, so as to realize the processing of the information to be consumed. time consumption.
S303、在所述确认信息的发送倒计时结束后，发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。S303. After the countdown for sending the confirmation information ends, send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component associates the preliminary information queue with the unique identification number. The information to be consumed corresponding to the number is released to the first target terminal for consumption.
具体地，在确认信息的发送倒计时结束后，发送终端会自动将与唯一识别号对应的确认信息发送至RocketMQ服务组件，使RocketMQ服务组件协调Zookeeper组件将缓存在Zookeeper组件的预备信息队列中的与唯一识别号对应的待消费信息释放至第一目标终端进行消费。第一目标终端需要保持与发送终端的幂等性。在确认信息的发送倒计时结束后，发送终端会自动将确认信息发送给RocketMQ服务组件，以便实现第一目标终端对待消费信息的定时消费。Specifically, after the countdown for sending the confirmation information ends, the sending terminal will automatically send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component coordinates the Zookeeper component to cache the corresponding data in the preliminary information queue of the Zookeeper component. The information to be consumed corresponding to the unique identification number is released to the first target terminal for consumption. The first target terminal needs to maintain idempotency with the sending terminal. After the countdown for sending the confirmation information ends, the sending terminal will automatically send the confirmation information to the RocketMQ service component, so as to realize the timing consumption of the information to be consumed by the first target terminal.
S304、获取所述待消费信息被释放时返回的序列指示信息。S304. Obtain the sequence indication information returned when the information to be consumed is released.
具体地，在待消费信息释放至第一目标终端后，第一目标终端会向发送终端返回一个序列指示信息，以提示发送终端该待消费信息已经消费完成。Specifically, after the information to be consumed is released to the first target terminal, the first target terminal will return a sequence indication information to the sending terminal to prompt the sending terminal that the consumption of the information to be consumed has been completed.
在一些实施例中，可以通过第二终端设置如何实现确认消费了待消费信息，比如，可以通过在Redis里记录一标识，表明已消费待消费信息，也可以在Zookeeper组件中创建一个node，代表该待消费信息已经被处理过，此时如果发送重复的待消费信息过来，创建Zookeeper组件的node会自动报错，避免重复消费某待消费信息。In some embodiments, how to confirm the consumption of the information to be consumed can be realized through the settings of the second terminal. For example, an identifier can be recorded in Redis to indicate that the information to be consumed has been consumed, or a node can be created in the Zookeeper component to represent the consumption of the information to be consumed. The to-be-consumed information has already been processed. If duplicate to-be-consumed information is sent, the node that created the Zookeeper component will automatically report an error to avoid repeated consumption of a to-be-consumed information.
当然，在第二终端的一侧，也可以设置第二数据库以进行数据存储。Of course, on the side of the second terminal, a second database may also be set for data storage.
不难理解的是，本申请通过记录一标识，只需要注册个监听器即可监听待消费信息是否已经被消费，优化系统性能。It is not difficult to understand that, by recording an identifier, the present application only needs to register a listener to monitor whether the information to be consumed has been consumed, thereby optimizing system performance.
S305、对所述序列指示信息进行解析以得到序列待消费信息的唯一识别号。S305. Parse the sequence indication information to obtain a unique identification number of the sequence information to be consumed.
其中，序列待消费信息是指在预备信息队列中进行排序等待消费的待消费信息，可以理解的是，序列待消费信息与待消费信息相同，都具有对应的确认信息以及用于识别的唯一识别号。具体地，发送终端接收到序列指示信息后，对序列指示信息进行解析，从而得到序列待消费信息的唯一标识号，也即下一个需要进行消费的待消费信息的唯一标识号。Among them, the sequence to-be-consumed information refers to the to-be-consumed information that is sorted in the prepared information queue for consumption. It can be understood that the sequence to-be-consumed information is the same as the to-be-consumed information, and both have corresponding confirmation information and a unique identification for identification. No. Specifically, after receiving the sequence indication information, the sending terminal parses the sequence indication information to obtain the unique identification number of the information to be consumed in the sequence, that is, the unique identification number of the information to be consumed next to be consumed.
S306、发送与所述唯一识别号对应的确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件从所述预备信息队列中获取与所述唯一识别号对应的所述序列待消费信息，并将所述序列待消费信息释放至第二目标终端进行消费。S306. Send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component obtains the information to be consumed in the sequence corresponding to the unique identification number from the preliminary information queue, and sends The information to be consumed in the sequence is released to the second target terminal for consumption.
具体地，所述第一目标终端和第二目标终端可以为同一个终端，也可以为不同的终端，并且，待消费信息和序列待消费信息可以由同一个发送终端发送至Zookeeper组件的预备信息队列中进行缓存，也可以由不同的发送终端发送至Zookeeper组件的预备信息队列中进行缓存。Specifically, the first target terminal and the second target terminal may be the same terminal or different terminals, and the to-be-consumed information and the sequence to-be-consumed information may be sent by the same sending terminal to the preparatory information of the Zookeeper component It can be buffered in the queue, and can also be buffered in the preparatory information queue sent by different sending terminals to the Zookeeper component.
值得一提的是，通过步骤S304至步骤S306可以实现两种场景，具体如下：It is worth mentioning that two scenarios can be implemented through steps S304 to S306, as follows:
场景一，假设存在A、B、C三个待消费信息的任务，B任务需要等待A任务完成后才去执行，而C任务需要等待B任务完成才去执行，此时，A任务执行完了发送序列指示消息给B任务，B任务收到序列指示消息后顺序执行，依序C任务执行类似的方式，即C任务收到B任务返回的序列指示消息后执行，本场景以此实现了多个任务之间的通信并保证多个任务状态互通。Scenario 1, assuming that there are three tasks A, B, and C to consume information, task B needs to wait for task A to complete before executing, and task C needs to wait for task B to complete before executing. At this time, task A is completed and sent. The sequence instruction message is sent to task B, and task B executes sequentially after receiving the sequence instruction message. Task C executes in a similar manner in sequence, that is, task C executes after receiving the sequence instruction message returned by task B. In this scenario, multiple tasks are implemented. Communication between tasks and ensure the interworking of multiple task states.
场景二，很多业务内容涉及到关联方之间的相互回调。当对方系统处理完结果之后，本方系统只需要监听这个特定类型的topic，然后做自己系统的程序处理，而无需每次新增一个功能都加接口修改网关，有利于系统之间的解耦和扩展，比如用户系统和短信系统之间、支付网关和处理系统之间的解耦和扩展等。Scenario 2, many business contents involve mutual callbacks between related parties. When the other party's system processes the result, the local system only needs to monitor the topic of this specific type, and then process the program of its own system, without adding an interface to modify the gateway every time a function is added, which is conducive to the decoupling between systems and expansion, such as decoupling and expansion between the user system and the SMS system, between the payment gateway and the processing system, etc.
举例而言，针对支付网关会需要接入支付功能，比如微信或者支付宝，其通常会以回调的形式通知本方系统支付结果。For example, payment gateways need to access payment functions, such as WeChat or Alipay, which usually notify the local system of payment results in the form of callbacks.
此时，本申请可以将支付网关独立出来，通过MQ通知本方业务系统进行处理。At this time, the application can separate the payment gateway and notify its own business system through MQ for processing.
假设本方设置一积分系统，用户支付成功，给用户添加积分，此时只需要积分系统监听这个消息topic，并处理积分就好，无需修改网关层代码。Assuming that the local party sets up a point system, the user pays successfully and adds points to the user. At this time, only the point system needs to monitor this message topic and process the points, without modifying the gateway layer code.
值得注意的是，本申请还可以设置对上述推送信息、支付结果的转发规则，以保证每个感兴趣的队列能获取到推送信息、支付结果。It is worth noting that this application can also set forwarding rules for the above push information and payment results to ensure that each interested queue can obtain the push information and payment results.
在一些实施例中，为了保证发送终端与RocketMQ服务组件的有效连接，可以采用以下步骤对连接的有效性进行判断：In some embodiments, in order to ensure the effective connection between the sending terminal and the RocketMQ service component, the following steps can be used to judge the validity of the connection:
接收从已连接的所述RocketMQ服务组件的服务提供节点的节点返回信息；判断接收到相邻两次所述节点返回信息的时间间隔是否超过预设时长；若接收到相邻两次所述节点返回信息的时间间隔超过预设时长，则选择所述RocketMQ服务组件的另一服务提供节点建立连接。Receive the information returned from the node of the connected service provider node of the RocketMQ service component; determine whether the time interval between receiving the information returned by the node twice adjacently exceeds the preset duration; If the time interval of returning information exceeds the preset time length, another service provider node of the RocketMQ service component is selected to establish a connection.
其中，可用节点集中包括集群中所有可用RocketMQ服务组件的服务提供节点的节点身份信息和连接建立信息，且可用节点集预先存储于MQ客户端本地。The available node set includes the node identity information and connection establishment information of all service provider nodes of the available RocketMQ service components in the cluster, and the available node set is pre-stored locally in the MQ client.
此外，本申请还可以实现RocketMQ服务组件的自动化部署：首先制作服务安装包，比如服务中使用或依赖的组件的安装文件以及这些组件安装、初始化、启动、停止、重启、更新、伸缩以及监控的相关脚本和组件的配置文件；在定义服务安装包的过程中，使用shell、freemarker语言进行个性化处理；定义服务基本信息，在服务管理平台上进行服务的基本信息定义；定义服务规格，对服务集群的大小、集群中节点的角色以及节点的配置的信息进行定义，用户在申请服务实例时以规格为模板创建相应的虚拟机集群；对同一服务定义多种规格用于满足不同服务应用场景下的需求；若配置的服务基本信息需要改动，则将发布状态转为召回状态，再进行编辑，修改完毕后，重新发布服务信息；服务实例安装，用户在服务管理平台上，进行服务实例的安装，创建实例时对服务规格和接入网络进行选择，创建过程中随时对其进行删除，服务实例启动后，用户选择对其启动或停止或对其进行管理。In addition, this application can also realize the automatic deployment of RocketMQ service components: first, make a service installation package, such as the installation files of components used or depended on in the service and the installation, initialization, start, stop, restart, update, scaling and monitoring of these components. Configuration files of related scripts and components; in the process of defining service installation packages, use shell and freemarker languages for personalized processing; define basic service information, and define the basic information of services on the service management platform; The size of the cluster, the roles of the nodes in the cluster, and the configuration information of the nodes are defined. When applying for a service instance, the user uses the specifications as a template to create a corresponding virtual machine cluster; define multiple specifications for the same service to meet different service application scenarios. If the basic information of the configured service needs to be changed, the release state will be changed to the recall state, and then edited, and the service information will be re-released after the modification; service instance installation, the user installs the service instance on the service management platform , select the service specification and access network when creating an instance, delete it at any time during the creation process, and after the service instance is started, the user chooses to start or stop it or manage it.
本实施例提供的一种信息处理方法，通过生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号；然后将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存，再发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将缓存的与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费；随后获取所述待消费信息被释放时返回的序列指示信息；对所述序列指示信息进行解析以得到另一所述待消费信息的唯一识别号；最终发送与所述唯一识别号对应的确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件从所述预备信息队列中获取与所述唯一识别号对应的待消费信息，并将所述待消费信息释放至第二目标终端进行消费。采用RocketMQ进行系统通讯，并采用一全局唯一识别号，做到绝对不可能出现id重复造成消息发送失败的情况，能够实现多个任务之间的通信并保证多个任务状态的互通。This embodiment provides an information processing method, by generating information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number used to identify the information to be consumed and the confirmation information; The information to be consumed and the corresponding unique identification number are sent to the preliminary information queue for buffering, and then the confirmation information corresponding to the unique identification number is sent to the RocketMQ service component, so that the RocketMQ service component will cache the cached and The information to be consumed corresponding to the unique identification number is released to the first target terminal for consumption; then the sequence indication information returned when the information to be consumed is released is obtained; the sequence indication information is parsed to obtain another The unique identification number of the information to be consumed; finally send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component obtains the pending information corresponding to the unique identification number from the preliminary information queue. consume information, and release the to-be-consumed information to the second target terminal for consumption. Using RocketMQ for system communication and a global unique identification number, it is absolutely impossible for the repeated id to cause the failure of message sending. It can realize the communication between multiple tasks and ensure the interoperability of multiple task states.
请参考图4，图4是本申请的实施例还提供一种终端的示意性框图，该终端用于执行前述的信息处理方法。其中，该终端可以配置于服务器或终端中。Please refer to FIG. 4 , which is a schematic block diagram of a terminal further provided by an embodiment of the present application, where the terminal is configured to execute the foregoing information processing method. The terminal may be configured in a server or a terminal.
其中，服务器可以为独立的服务器，也可以为服务器集群。该终端可以是手机、平板电脑、笔记本电脑、台式电脑、个人数字助理和穿戴式设备等电子设备。The server may be an independent server or a server cluster. The terminal may be an electronic device such as a mobile phone, a tablet computer, a notebook computer, a desktop computer, a personal digital assistant and a wearable device.
如图4所示，终端400包括：信息生成模块401、信息发送模块402和确认发送模块403。As shown in FIG. 4 , the terminal 400 includes: an
信息生成模块401，用于生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号。The
信息发送模块402，用于将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存。The
确认发送模块403，用于发送具备所述唯一识别号的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。
请参考图5，图5是本申请实施例提供的一种计算机设备的结构示意性框图。该计算机设备可以是服务器或终端。Please refer to FIG. 5 , which is a schematic structural block diagram of a computer device provided by an embodiment of the present application. The computer device can be a server or a terminal.
参阅图5，该计算机设备包括通过系统总线连接的处理器、存储器和网络接口，其中，存储器可以包括非易失性存储介质和内存储器。Referring to FIG. 5, the computer device includes a processor, a memory, and a network interface connected by a system bus, wherein the memory may include a non-volatile storage medium and an internal memory.
非易失性存储介质可存储操作系统和计算机程序。该计算机程序包括程序指令，该程序指令被执行时，可使得处理器执行任意一种信息处理方法。The nonvolatile storage medium can store operating systems and computer programs. The computer program includes program instructions that, when executed, can cause the processor to execute any information processing method.
处理器用于提供计算和控制能力，支撑整个计算机设备的运行。The processor is used to provide computing and control capabilities to support the operation of the entire computer equipment.
内存储器为非易失性存储介质中的计算机程序的运行提供环境，该计算机程序被处理器执行时，可使得处理器执行任意一种信息处理方法。The internal memory provides an environment for running the computer program in the non-volatile storage medium, and when the computer program is executed by the processor, the processor can execute any information processing method.
该网络接口用于进行网络通信，如发送分配的任务等。本领域技术人员可以理解，图5中示出的结构，仅仅是与本申请方案相关的部分结构的框图，并不构成对本申请方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。The network interface is used for network communication, such as sending assigned tasks. Those skilled in the art can understand that the structure shown in FIG. 5 is only a block diagram of a part of the structure related to the solution of the present application, and does not constitute a limitation on the computer equipment to which the solution of the present application is applied. Include more or fewer components than shown in the figures, or combine certain components, or have a different arrangement of components.
应当理解的是，处理器可以是中央处理单元(Central Processing Unit，CPU)，该处理器还可以是其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现场可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。其中，通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。It should be understood that the processor may be a central processing unit (Central Processing Unit, CPU), and the processor may also be other general-purpose processors, digital signal processors (Digital Signal Processors, DSP), application specific integrated circuits (Application Specific Integrated Circuits) Circuit, ASIC), Field-Programmable Gate Array (Field-Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, and the like. Wherein, the general-purpose processor can be a microprocessor or the processor can also be any conventional processor or the like.
其中，在一个实施例中，所述处理器用于运行存储在存储器中的计算机程序，以实现如下步骤：Wherein, in one embodiment, the processor is configured to run a computer program stored in the memory to implement the following steps:
生成待消费信息、与所述待消费信息对应的确认信息以及用于识别所述待消费信息和所述确认信息的唯一识别号；将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存；发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。generating information to be consumed, confirmation information corresponding to the information to be consumed, and a unique identification number for identifying the information to be consumed and the confirmation information; sending the information to be consumed and the corresponding unique identification number to Cache in the preliminary information queue; send the confirmation information corresponding to the unique identification number to the RocketMQ service component, so that the RocketMQ service component will store the pending information corresponding to the unique identification number in the preliminary information queue. The consumption information is released to the first target terminal for consumption.
在一个实施例中，所述处理器在实现所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费之后，还用于实现：In one embodiment, after the RocketMQ service component releases the information to be consumed corresponding to the unique identification number in the preliminary information queue to the first target terminal for consumption, the processor is further configured to: accomplish:
获取所述待消费信息被释放时返回的序列指示信息；对所述序列指示信息进行解析以得到序列待消费信息的唯一识别号；发送与所述唯一识别号对应的确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件从所述预备信息队列中获取与所述唯一识别号对应的序列待消费信息，并将所述序列待消费信息释放至第二目标终端进行消费。Obtain the sequence indication information returned when the information to be consumed is released; parse the sequence indication information to obtain the unique identification number of the information to be consumed in the sequence; send confirmation information corresponding to the unique identification number to the RocketMQ service component, So that the RocketMQ service component acquires the sequence to be consumed information corresponding to the unique identification number from the preliminary information queue, and releases the sequence to be consumed information to the second target terminal for consumption.
在一个实施例中，所述处理器在实现所述生成用于识别所述待消费信息和所述确认信息的唯一识别号时，用于实现：In one embodiment, when implementing the generating of the unique identification number for identifying the information to be consumed and the confirmation information, the processor is configured to implement:
采用分布式锁生成用于识别所述待消费信息和所述确认信息的唯一识别号。A unique identification number for identifying the information to be consumed and the confirmation information is generated by using a distributed lock.
在一个实施例中，所述处理器在实现所述生成用于识别所述待消费信息和所述确认信息的唯一识别号时，用于实现：In one embodiment, when implementing the generating of the unique identification number for identifying the information to be consumed and the confirmation information, the processor is configured to implement:
将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存，并启动所述确认信息的发送倒计时；Send the to-be-consumed information and the corresponding unique identification number to the preliminary information queue for buffering, and start the countdown for sending the confirmation information;
所述处理器在实现发送具备所述唯一识别号的确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费时，用于实现：The processor is implementing to send the confirmation information with the unique identification number to the RocketMQ service component, so that the RocketMQ service component releases the information to be consumed corresponding to the unique identification number in the preliminary information queue to the RocketMQ service component. When the first target terminal consumes, it is used to achieve:
在所述确认信息的发送倒计时结束后，发送具备所述唯一识别号的确认信息至RocketMQ服务组件，以使所述RocketMQ服务组件将所述预备信息队列中与所述唯一识别号对应的所述待消费信息释放至第一目标终端进行消费。After the countdown for sending the confirmation information ends, send the confirmation information with the unique identification number to the RocketMQ service component, so that the RocketMQ service component sends the confirmation information corresponding to the unique identification number in the preliminary information queue The information to be consumed is released to the first target terminal for consumption.
在一个实施例中，所述处理器在实现所述将所述待消费信息和对应的所述唯一识别号发送至预备信息队列中进行缓存之后，还用于实现：In one embodiment, after implementing the sending of the information to be consumed and the corresponding unique identification number to the prepared information queue for caching, the processor is further configured to implement:
设置所述待消费信息的存活时间；若所述待消费信息在所述存活时间内未被消费，则将所述待消费信息转发至其他预备信息队列。The survival time of the information to be consumed is set; if the information to be consumed is not consumed within the survival time, the information to be consumed is forwarded to other prepared information queues.
在一个实施例中，所述处理器在实现所述发送与所述唯一识别号对应的所述确认信息至RocketMQ服务组件之后，还用于实现：In one embodiment, after implementing the sending the confirmation information corresponding to the unique identification number to the RocketMQ service component, the processor is further configured to implement:
接收从已连接的所述RocketMQ服务组件的服务提供节点的节点返回信息；判断接收到相邻两次所述节点返回信息的时间间隔是否超过预设时长；若接收到相邻两次所述节点返回信息的时间间隔超过预设时长，则选择所述RocketMQ服务组件的其他服务提供节点建立连接。Receive the information returned from the node of the connected service provider node of the RocketMQ service component; determine whether the time interval between receiving the information returned by the node twice adjacently exceeds the preset duration; If the time interval for returning information exceeds the preset time length, other service providing nodes of the RocketMQ service component are selected to establish a connection.
本申请的实施例中还提供一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序中包括程序指令，所述处理器执行所述程序指令，实现本申请实施例提供的任一项信息处理方法。The embodiments of the present application further provide a computer-readable storage medium, where the computer-readable storage medium stores a computer program, the computer program includes program instructions, and the processor executes the program instructions to implement the present application Any one of the information processing methods provided in the embodiments.
其中，所述计算机可读存储介质可以是前述实施例所述的计算机设备的内部存储单元，例如所述计算机设备的硬盘或内存。所述计算机可读存储介质也可以是所述计算机设备的外部存储设备，例如所述计算机设备上配备的插接式硬盘，智能存储卡(SmartMedia Card，SMC)，安全数字(Secure Digital，SD)卡，闪存卡(Flash Card)等。The computer-readable storage medium may be an internal storage unit of the computer device described in the foregoing embodiments, such as a hard disk or a memory of the computer device. The computer-readable storage medium may also be an external storage device of the computer device, such as a plug-in hard disk, a smart memory card (SmartMedia Card, SMC), a secure digital (Secure Digital, SD) equipped on the computer device card, flash card (Flash Card) and so on.
以上所述，仅为本申请的具体实施方式，但本申请的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本申请揭露的技术范围内，可轻易想到各种等效的修改或替换，这些修改或替换都应涵盖在本申请的保护范围之内。因此，本申请的保护范围应以权利要求的保护范围为准。The above are only specific embodiments of the present application, but the protection scope of the present application is not limited thereto. Any person skilled in the art can easily think of various equivalents within the technical scope disclosed in the present application. Modifications or substitutions shall be covered by the protection scope of this application. Therefore, the protection scope of the present application shall be subject to the protection scope of the claims.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010049302.3ACN111274047A (en) | 2020-01-16 | 2020-01-16 | Information processing method, terminal, system, computer device and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010049302.3ACN111274047A (en) | 2020-01-16 | 2020-01-16 | Information processing method, terminal, system, computer device and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111274047Atrue CN111274047A (en) | 2020-06-12 |
Family
ID=70997326
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010049302.3APendingCN111274047A (en) | 2020-01-16 | 2020-01-16 | Information processing method, terminal, system, computer device and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111274047A (en) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111901224A (en)* | 2020-07-24 | 2020-11-06 | 中国平安财产保险股份有限公司 | Method, device and equipment for loading delayed messages and computer readable storage medium |
| CN112187903A (en)* | 2020-09-22 | 2021-01-05 | 华云数据控股集团有限公司 | Message pushing method and device and message service system |
| CN114860473A (en)* | 2022-04-08 | 2022-08-05 | 天工信创(广州)信息科技有限公司 | A message processing method, processor and storage medium |
| CN116633891A (en)* | 2023-05-23 | 2023-08-22 | 中国工商银行股份有限公司 | Message processing method, device, computer equipment and storage medium |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103179193A (en)* | 2013-02-21 | 2013-06-26 | 用友软件股份有限公司 | Data transmission system and data transmission method used for distributed application system |
| GB201313775D0 (en)* | 2013-08-01 | 2013-09-18 | Ibm | Consuming ordered streams of messages in a message oriented middleware |
| CN108134830A (en)* | 2017-12-20 | 2018-06-08 | 马上消费金融股份有限公司 | Load balancing method, system, device and storage medium based on message queue |
- 2020
- 2020-01-16CNCN202010049302.3Apatent/CN111274047A/enactivePending
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103179193A (en)* | 2013-02-21 | 2013-06-26 | 用友软件股份有限公司 | Data transmission system and data transmission method used for distributed application system |
| GB201313775D0 (en)* | 2013-08-01 | 2013-09-18 | Ibm | Consuming ordered streams of messages in a message oriented middleware |
| CN108134830A (en)* | 2017-12-20 | 2018-06-08 | 马上消费金融股份有限公司 | Load balancing method, system, device and storage medium based on message queue |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111901224A (en)* | 2020-07-24 | 2020-11-06 | 中国平安财产保险股份有限公司 | Method, device and equipment for loading delayed messages and computer readable storage medium |
| CN112187903A (en)* | 2020-09-22 | 2021-01-05 | 华云数据控股集团有限公司 | Message pushing method and device and message service system |
| CN114860473A (en)* | 2022-04-08 | 2022-08-05 | 天工信创(广州)信息科技有限公司 | A message processing method, processor and storage medium |
| CN116633891A (en)* | 2023-05-23 | 2023-08-22 | 中国工商银行股份有限公司 | Message processing method, device, computer equipment and storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112867988B (en) | Compliance settings are implemented by mobile devices to follow configuration scenarios | |
| CN111274047A (en) | Information processing method, terminal, system, computer device and storage medium | |
| CN114338650B (en) | File transmission method, device, electronic equipment and readable storage medium | |
| US20130318512A1 (en) | Hot Pluggable Extensions for Access Management System | |
| CN112099935B (en) | Task processing method and device | |
| US8484281B2 (en) | System and method for callbacks based on web service addressing | |
| CN111064626B (en) | Configuration updating method, device, server and readable storage medium | |
| CN113590354B (en) | Block chain based information pushing method, device, equipment, medium and program product | |
| CN114900449B (en) | Resource information management method, system and device | |
| WO2019205555A1 (en) | Method and apparatus for pushing message | |
| CN114860473A (en) | A message processing method, processor and storage medium | |
| US9026839B2 (en) | Client based high availability method for message delivery | |
| CN113961330A (en) | Distributed timing task execution method, device, equipment and computer readable medium | |
| WO2024103943A1 (en) | Service processing method and apparatus, storage medium, and device | |
| CN111240760B (en) | Application publishing method, system, storage medium and equipment based on registry | |
| CN113947434B (en) | A business processing method and device for a multi-business component combination scenario | |
| CN113645260A (en) | Service retry method, device, storage medium and electronic equipment | |
| CN112187916B (en) | A cross-system data synchronization method and device | |
| CN113535439A (en) | Service request processing method, device, device and storage medium | |
| CN110119269B (en) | Method, device, server and storage medium for controlling task object | |
| CN110740151B (en) | Micro-service adjusting method, device, server and computer storage medium | |
| CN117592931A (en) | Verification methods, devices and storage media | |
| CN111459819A (en) | Software testing method and device, electronic equipment and computer readable medium | |
| CN113760693B (en) | Method and device for local debugging of microservice system | |
| CN113342540B (en) | Terminal user fee-paying starting method, system, computer equipment and storage medium |
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 |