Communication method and device for converting synchronization to asynchronization in on-line system

Abstract

The invention provides a communication method for converting synchronization to asynchronization in an on-line system. According to the method, after a JMS message is constructed, whether a connection, a session and a producer are generated in a cache is judged based on a thread number corresponding to the JMS message; if yes, the connection, the session and the producer are multiplexed; and otherwise, a new connection, a new session and a new producer are created according to the thread number corresponding to the JMS message. In this way, the situation that a connection, a session and a producer need to be created again every time a message is sent is avoided, message sending time is shortened, and message sending efficiency is improved. Meanwhile, a correlation identifier of each message comprises a universally unique identifier (UUID) shared by threads and a self-increasing serial number; after the JMS message sent to a target MQ request queue is processed and returned to a return queue, a return message containing the UUID exclusive to an instance is screened coarsely, and therefore the same instance can only receive the message corresponding thereto; and then the return messages are screened finely through the self-increasing serial numbers, and therefore it is guaranteed that the return messages obtained through polling within preset time are correct return messages.

Description

technical field [0001] The present invention relates to the technical field of communication, and more specifically, to a communication method and device for converting synchronous to asynchronous in an online system. Background technique [0002] Most transactions between banks and financial systems are communicated through synchronous messages. In order to meet the requirements of large transaction volume, fast real-time delivery, and accurate message return, it is often necessary to convert synchronous messages to asynchronous processing. [0003] Although the existing technology can realize the synchronous to asynchronous communication mode, when a single message is sent to the shared queue by the main thread, it takes a long time to create a sending object every time, which cannot meet the requirements of fast and real-time return of messages. Message processing low efficiency. At the same time, when multiple instances are deployed, they may be received and discarded b...

AI Technical Summary

Problems solved by technology

[0004] In view of this, the present invention provides a synchronous-to-asynchronous communication method in an online system, which shortens the message sending time through the cache mechanism and the coarse-grained two-level screening message mechanism, and solves the problem that the returned message is blocked by other instances when the system is deployed with multiple instances. Consumption processing, resulting in the problem that the message cannot be returned to the normal instance

Images