CN112463167B - Bank account dynamic account notification service system - Google Patents
Bank account dynamic account notification service system Download PDFInfo
- Publication number
- CN112463167B CN112463167B CN202011258020.0A CN202011258020A CN112463167B CN 112463167 B CN112463167 B CN 112463167B CN 202011258020 A CN202011258020 A CN 202011258020A CN 112463167 B CN112463167 B CN 112463167B
- Authority
- CN
- China
- Prior art keywords
- account
- message
- dynamic
- bank account
- dynamic account
- 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.)
- Active
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/60—Software deployment
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3003—Monitoring arrangements specially adapted to the computing system or computing system component being monitored
- G06F11/302—Monitoring arrangements specially adapted to the computing system or computing system component being monitored where the computing system component is a software system
-
- 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/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5011—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resources being hardware resources other than CPUs, Servers and Terminals
- G06F9/5016—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resources being hardware resources other than CPUs, Servers and Terminals the resource being the memory
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/02—Banking, e.g. interest calculation or account maintenance
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Business, Economics & Management (AREA)
- Accounting & Taxation (AREA)
- Computing Systems (AREA)
- Finance (AREA)
- Quality & Reliability (AREA)
- Mathematical Physics (AREA)
- Development Economics (AREA)
- Economics (AREA)
- Marketing (AREA)
- Strategic Management (AREA)
- Technology Law (AREA)
- General Business, Economics & Management (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Abstract
The invention relates to a bank account dynamic account notification service system, which is used for notifying a client of dynamic account information when the amount of a single receipt and payment transaction of a bank account reaches a preset condition; the dynamic account notification service system is provided with a message producer program module and a message consumption equation sequence module; the message producer program module is used for collecting bank account dynamic account data and comprises a plurality of threads for collecting bank account dynamic account data; any one of the task threads for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and falls to the ground; the message consumption equation sequence module is used for sending bank account dynamic account data and comprises a plurality of threads for sending the bank account dynamic account data; any one of the above-mentioned task threads for sending the accounting data period is used for sending the accounting notification message of the bank account. The method has the advantages that the layering code is clear in layering code according to a 'producer-consumer' model, the execution cost is low, and the resource utilization rate is high.
Description
[ field of technology ]
The invention relates to the technical field of bank informatization, in particular to a bank account dynamic account notification service system.
[ background Art ]
The system of bank account information service (account moving notification) can inform the customer of account moving information in time through an electronic channel or a mobile phone short message and the like when the bill collection and payment transaction amount of a customer settlement account reaches a preset condition according to customer agreement. For example: the credit card consumes a certain amount of money and notifies the credit card holder with a short message. Some banks are 300 yuan, and some banks are self-setting, if the setting is 1 yuan, that is to say, 0.9 yuan of card swiping is not notified, and if the setting exceeds 1 yuan, notification is performed. Both element 300 and element 1 are here account-movement notification credit. Of course, some banks for this service are free and some are charged.
An existing bank account dynamic account notification service system comprises: 1. the program deployment is single-machine deployment, so that the risk of program abnormality caused by downtime exists, and the reliability is poor; 2. the concurrent realization adopts a fork sub-process group calling mode, so that the resource consumption is high; 3. on the function integration, a set of programs are required to be independently arranged for each consumer business system, and a common module is not extracted, so that the subsequent code optimization is inconvenient; 4. reading a configuration file when the program is started on the program automation, wherein the parameter modification cannot automatically update the cache and can take effect only by restarting the process; 5. only the system log is simply added, and the log needs to be cleaned periodically manually to ensure that the space of the operating system is available.
The process is the minimum unit of resource allocation, and the thread is the minimum unit of program execution. The two are fundamentally different: a process is the basic unit of operating system resource allocation, while a thread is the basic unit of task scheduling and execution. Multiple processes (programs) can be run simultaneously in an operating system; while multiple threads execute simultaneously in the same process (program) (only one thread per time slice is executing by CPU scheduling). Memory allocation aspects: when the system operates, different memory spaces are allocated for each process; for threads, other than the CPU, the system does not allocate memory for the threads (the resources used by the threads come from the resources of the process to which the threads belong), and only the resources can be shared among the thread groups.
The copy (english: fork, and translation of a derivative, branch) is a forking function in UNIX or UNIX-like, which breaks the running program into 2 (almost) identical processes, each of which starts a thread that starts execution from the same location in the code. The fork system call is used to create a new process, called a child process, that runs simultaneously with a process (a process called a system call fork), called a parent process. After creating a new sub-process, both processes will execute the next instruction after the fork system call. The child process uses the same pc (program counter), the same CPU registers, the same open file used in the parent process.
Thread pool (english: thread pool): a thread usage pattern. Too many threads can cause scheduling overhead, thereby affecting cache locality and overall performance. While the thread pool maintains multiple threads waiting for the supervisory manager to allocate tasks that can be concurrently executed. This avoids the cost of creating and destroying threads while processing short-time tasks. The thread pool not only can ensure full utilization of the kernel, but also can prevent excessive scheduling. The newscheduledThreadpool of the JAVA language supports timing and periodic task execution, so that the execution time of the task can be delayed, or a periodic time can be set to enable the task to be repeatedly executed, and the thread pool has the following two delay methods, namely scheduleAtFixRate and scheduleWithFixDelay.
Java has the characteristics of simplicity, object-oriented, distributed, robustness, security, platform independence and portability, multithreading, dynamics and the like. GC (Garbage Collection): JAVA/. NET. Air may call Java programs remotely or locally. The log is simple to configure and easy to get up.
Aiming at the deployment of the 1 st machine and the single machine, the system risk is high; 2. the functions are not integrated, and the module coupling degree is high; 3. the method has no automatic configuration capability and has certain operation and maintenance cost; these prior art drawbacks utilize the above-described processes and threading techniques to improve the bank account accounting notification service method and system.
[ invention ]
The invention aims to provide a bank account dynamic account notification service system with clear layering code layers according to a producer-consumer model, small execution cost and high resource utilization rate.
In order to achieve the purpose, the technical scheme adopted by the invention is that the bank account dynamic account notification service system is used for notifying a client of dynamic account information when the single receipt and payment transaction amount of the bank account reaches a preset condition; the dynamic account notification service system is provided with a message producer program module and a message consumption equation sequence module; the message producer program module is used for collecting bank account dynamic account data and comprises a plurality of threads for collecting bank account dynamic account data; any one of the task threads for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and falls to the ground; the message consumption equation sequence module is used for sending bank account dynamic account data and comprises a plurality of threads for sending the bank account dynamic account data; any one of the above-mentioned task threads for sending the accounting data period is used for sending the accounting notification message of the bank account.
Further preferably, the message producer program module is configured to collect account data of a bank account and execute the following steps:
the method comprises the steps that C1, a bank account dynamic account information producer process is initialized;
c2, initializing process memory configuration of a bank account dynamic account message producer;
c3, the bank account dynamic account information producer process establishes a task thread pool for collecting dynamic account data period;
c4, circularly reading database configuration by a bank account dynamic account message producer process;
c5, judging database configuration consistency by a bank account dynamic account message producer process;
if the database configuration is inconsistent, refreshing the process memory configuration of the bank account dynamic account information producer, restarting/closing the task thread for collecting dynamic account data period according to the acquired database configuration, and executing the step C4 in a jumping manner;
c7, if the database configuration is consistent, the process of the bank account dynamic account information producer blocks and waits for a period, and the step C4 is executed in a jumping manner;
any of the task threads for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and executing the following steps in a floor mode:
c31, acquiring business parameters by reading a database by a task thread of a dynamic account data acquisition period;
c32, acquiring dynamic account data period task threads according to the inquiry details and the analysis details of the host computers on the bank accounts;
c33, if the detail queried by the upper host computer has follow-up, acquiring a dynamic account data period task thread to record a dynamic account notification, landing the detail table, and jumping to execute the step C31;
c34, if the details of the upper host computer query are not follow-up, the task thread of the collecting dynamic account data period updates the query condition of the fine powder pen, and the task thread of the collecting dynamic account data period is exited;
the message consumption equation sequence module is used for sending the bank account data to execute the following steps:
f1, initializing a bank account dynamic account message consumer process;
f2, initializing the process memory configuration of the bank account dynamic account message consumer;
f3, the bank account dynamic account message consumer process establishes a task thread pool for sending dynamic account data period;
f4, circularly reading the database configuration by the bank account dynamic account message consumer process;
f5, judging database configuration consistency by the bank account dynamic account message consumer process;
f6, if the database configuration is inconsistent, refreshing the process memory configuration of the bank account dynamic account message consumer, restarting/closing the task thread for transmitting dynamic account data period according to the acquired database configuration, and executing the step F4 in a jumping manner;
f7, if the database configuration is consistent, the bank account moving information consumer process is blocked and waits for a period, and the step F4 is executed in a jumping manner;
any one of the task threads for sending the dynamic account data period is used for sending the dynamic account notification message of the bank account to execute the following steps:
f31, sending a dynamic account data period task thread to read a database to obtain service parameters;
f32, reading a record of the unsent account notification by the task thread of the period of sending the account data according to the bank account, and sending the account notification to each consumer system;
and F33, exiting the task thread for transmitting the dynamic account data period.
Further preferably, the dynamic account notification service system further deploys a dynamic account notification public program module; the dynamic account notification public program module comprises a synchronous memory object attribute program sub-module, a timing task scheduling program sub-module and a dynamic account inquiring program sub-module; and C2, F2, C3, F32 and C32, respectively, calling a synchronous memory object attribute program sub-module to initialize memory configuration, and calling a timing task scheduling program sub-module to process periodic task thread business, wherein the host computer inquires details on a dynamic account inquiring program sub-module.
Preferably, the step C33 detail table landing refers to a medium log service message collection landing, a last period service message collection landing and a social security service message collection landing; the step F32 of sending the account moving notification refers to the transmission of the log-in business message, the transmission of the last period business message and the transmission of the social security business message.
Preferably, the sub-module of the dynamic account query program of the bank account dynamic account notification service system is divided into a sub-module of a private dynamic account query program and a sub-module of a public dynamic account query program according to the characteristics of banking.
Preferably, in the step C32 of the foregoing system for notifying account of bank account, the host query details on the sub-module of the query program of public account is called according to the query date, log number, timestamp, sequence number and entry sequence number of the last statement of bank account; and when the service type is the center, the step C32 calls the host on the private account inquiry program submodule to inquire and acquire the annex information when the private party is the debit card.
Further preferably, the dynamic account notification service system is further provided with a real-time monitoring equation sequence module, and an internal monitoring program sub-module is arranged in the message producer program module and the message consumption equation sequence module; the real-time monitoring program module and the internal monitoring program sub-module are matched to monitor and alarm abnormal conditions of the message producer program module and the message consumption equation sequence module in real time.
Preferably, the real-time monitoring program module comprises an external program monitoring sub-module, a message acquisition monitoring sub-module and a message transmission monitoring sub-module; the external program monitoring submodule judges whether the bank account dynamic account information producer process and the bank account dynamic account information consumer process normally carry out monitoring alarm or not according to the external program monitoring log information and whether the log grows; the message collection and monitoring sub-module monitors and alarms the abnormality encountered in the process of message collection of the bank account dynamic account message producer; the message sending monitoring sub-module carries out monitoring alarm on refused or overtime message sending of the bank account accounting message consumer process.
Preferably, the log adopts log back log management configuration, and the log can be automatically cleaned.
Preferably, the bank account accounting notification service system is programmed and deployed by adopting Java programming language, and the periodic task thread pool is a thread pool established by using a newScheduleThreadPool thread pool framework.
The invention has the following beneficial effects: 1) The invention analyzes the basic function points of each bank account dynamic account notification service, and layers according to a 'producer-consumer' model, and the related modules are independently output, so that the code layers are clearer; 2) The invention adopts a newScheduleThreadpool thread pool framework, has small execution cost and high resource utilization rate, and has manageability; 3) The method reads the database in each polling period, and dynamically refreshes configuration such as program execution time period, polling frequency, holiday parameters, concurrency number, sending targets, message types and the like, and takes effect immediately; 4) The invention is cluster deployment, high availability and expandable performance; 5) The log is configured by log management, and the log can be automatically cleaned.
[ description of the drawings ]
Fig. 1 is a schematic diagram of a logical architecture of a bank account accounting notification service system.
FIG. 2 is a flow chart of a message production equation sequence module for a bank account accounting notification service system.
FIG. 3 is a flow chart of a message consumption equation sequence module of a bank account dynamic account notification service system.
Fig. 4 is a schematic diagram of a public program module architecture of a dynamic account notification service system of a bank account.
[ detailed description ] of the invention
The invention is further described below with reference to examples and with reference to the accompanying drawings.
In the present invention, a server is a computer or device that provides, manages, and manages network resources over a network, and a terminal may refer to various types of devices including, but not limited to, wireless telephones, cellular telephones, laptops, multimedia wireless devices, wireless communication Personal Computer (PC) cards, personal Digital Assistants (PDAs), external or internal modems, etc. A client device, i.e. a terminal, may be any data means that communicates with the server via a wireless channel and/or via a wired channel (e.g. optical fiber or coaxial cable). Terminals may have a variety of names such as mobile station, mobile device, mobile unit, mobile phone, remote station, remote terminal, remote unit, user device, user equipment, handheld device, etc. Different terminals may be incorporated into one system. Terminals may be mobile or fixed and may be dispersed throughout a communication network.
Example 1
The embodiment realizes a bank account dynamic account notification service system.
FIG. 1 is a schematic diagram of a logical architecture of a bank account accounting notification service system. As shown in fig. 1, the present embodiment is a system for notifying a customer of account information when a single account of a bank is received and a payment transaction amount reaches a preset condition; the dynamic account notification service system is provided with a message producer program module and a message consumption equation sequence module; the message producer program module is used for collecting bank account dynamic account data and comprises a plurality of threads for collecting bank account dynamic account data; any one of the task threads for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and falls to the ground; the message consumption equation sequence module is used for sending bank account dynamic account data and comprises a plurality of threads for sending the bank account dynamic account data; any one of the above-mentioned task threads for sending the accounting data period is used for sending the accounting notification message of the bank account.
Fig. 2 is a flow chart of a message production equation sequence module of the bank account dynamic account notification service system. As shown in fig. 2, the message producer program module is configured to collect bank account accounting data and perform the following steps:
the method comprises the steps that C1, a bank account dynamic account information producer process is initialized;
c2, initializing process memory configuration of a bank account dynamic account message producer;
c3, the bank account dynamic account information producer process establishes a task thread pool for collecting dynamic account data period;
c4, circularly reading database configuration by a bank account dynamic account message producer process;
c5, judging database configuration consistency by a bank account dynamic account message producer process;
if the database configuration is inconsistent, refreshing the process memory configuration of the bank account dynamic account information producer, restarting/closing the task thread for collecting dynamic account data period according to the acquired database configuration, and executing the step C4 in a jumping manner;
and C7, if the database configuration is consistent, the process of the bank account accounting information producer blocks and waits for a period, and the step C4 is executed in a jumping manner.
Any of the task threads for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and executing the following steps in a floor mode:
c31, acquiring business parameters by reading a database by a task thread of a dynamic account data acquisition period;
c32, acquiring dynamic account data period task threads according to the inquiry details and the analysis details of the host computers on the bank accounts;
c33, if the detail queried by the upper host computer has follow-up, acquiring a dynamic account data period task thread to record a dynamic account notification, landing the detail table, and jumping to execute the step C31;
and C34, if the details of the upper host computer query are not follow-up, the task thread of the collecting dynamic account data period updates the query condition of the fine powder pen, and the task thread of the collecting dynamic account data period is exited.
FIG. 3 is a flow chart of a message consumption equation sequence module of the bank account dynamic account notification service system. As shown in fig. 3, the message consumer program module is configured to send bank account accounting data to perform the following steps:
f1, initializing a bank account dynamic account message consumer process;
f2, initializing the process memory configuration of the bank account dynamic account message consumer;
f3, the bank account dynamic account message consumer process establishes a task thread pool for sending dynamic account data period;
f4, circularly reading the database configuration by the bank account dynamic account message consumer process;
f5, judging database configuration consistency by the bank account dynamic account message consumer process;
f6, if the database configuration is inconsistent, refreshing the process memory configuration of the bank account dynamic account message consumer, restarting/closing the task thread for transmitting dynamic account data period according to the acquired database configuration, and executing the step F4 in a jumping manner;
and F7, if the database configuration is consistent, the bank account moving information consumer process blocks and waits for a period, and the step F4 is executed in a jumping manner.
Any one of the task threads for sending the dynamic account data period is used for sending the dynamic account notification message of the bank account to execute the following steps:
f31, sending a dynamic account data period task thread to read a database to obtain service parameters;
f32, reading a record of the unsent account notification by the task thread of the period of sending the account data according to the bank account, and sending the account notification to each consumer system;
and F33, exiting the task thread for transmitting the dynamic account data period.
FIG. 4 is a flow chart of a message consumption equation sequence module of the bank account dynamic account notification service system. As shown in fig. 4, in a further preferred technical solution, the accounting notification service system further deploys an accounting notification public program module; the dynamic account notification public program module comprises a synchronous memory object attribute program sub-module, a timing task scheduling program sub-module and a dynamic account inquiring program sub-module; and C2, F2, C3, F32 and C32, respectively, calling a synchronous memory object attribute program sub-module to initialize memory configuration, and calling a timing task scheduling program sub-module to process periodic task thread business, wherein the host computer inquires details on a dynamic account inquiring program sub-module.
Preferably, the step C33 detail table landing refers to a medium log service message collection landing, a last period service message collection landing and a social security service message collection landing; the step F32 of sending the account moving notification refers to the transmission of the log-in business message, the transmission of the last period business message and the transmission of the social security business message.
Preferably, the sub-module of the dynamic account query program of the bank account dynamic account notification service system is divided into a sub-module of a private dynamic account query program and a sub-module of a public dynamic account query program according to the characteristics of banking.
Preferably, in the step C32 of the foregoing system for notifying account of bank account, the host query details on the sub-module of the query program of public account is called according to the query date, log number, timestamp, sequence number and entry sequence number of the last statement of bank account; and when the service type is the center, the step C32 calls the host on the private account inquiry program submodule to inquire and acquire the annex information when the private party is the debit card.
Further preferably, the dynamic account notification service system is further provided with a real-time monitoring equation sequence module, and an internal monitoring program sub-module is arranged in the message producer program module and the message consumption equation sequence module; the real-time monitoring program module and the internal monitoring program sub-module are matched to monitor and alarm abnormal conditions of the message producer program module and the message consumption equation sequence module in real time.
Preferably, the real-time monitoring program module comprises an external program monitoring sub-module, a message acquisition monitoring sub-module and a message transmission monitoring sub-module; the external program monitoring submodule judges whether the bank account dynamic account information producer process and the bank account dynamic account information consumer process normally carry out monitoring alarm or not according to the external program monitoring log information and whether the log grows; the message collection and monitoring sub-module monitors and alarms the abnormality encountered in the process of message collection of the bank account dynamic account message producer; the message sending monitoring sub-module carries out monitoring alarm on refused or overtime message sending of the bank account accounting message consumer process.
Preferably, the log adopts log back log management configuration, and the log can be automatically cleaned.
Preferably, the bank account accounting notification service system is programmed and deployed by adopting Java programming language, and the periodic task thread pool is a thread pool established by using a newScheduleThreadPool thread pool framework.
Example 2
The embodiment realizes a bank account dynamic account notification service system. This embodiment is specifically implemented on the basis of embodiment 1.
The embodiment realizes that the bank account dynamic account notification service system polls the account details according to the configuration driving wheel and sends the consumer system notification dynamic account information in real time. The bank account dynamic account notification service system supports real-time polling detail query of the foreign currency on a plurality of account types such as a public account, a multi-level account book, a debit card, an NRA account and the like. And polling and sending the account moving notification message according to different message formats and different communication modes is supported, and a monitoring and alarming mechanism is provided for the abnormality of the consumer system. A logical architecture diagram of a bank account dynamic account notification service system according to this embodiment is shown in FIG. 1.
The bank account dynamic account notification service system mainly comprises the following modules:
1. the MsgCommon public module is divided into the following sub-modules:
(1) memSync reads the database synchronization memory object attribute module: creating database connection, and inquiring a UT_MSG_SYS dynamic account notification system table and a UT_MSG_HOLIDAY dynamic account notification node false daily table according to the service type to obtain the following member attributes: system switch, producer/consumer thread pool size, producer/consumer polling period, polling start time, polling stop time, holiday, etc., and if not consistent with parameters in the memory, the memory is updated.
(2) A scheduleServer timing task scheduling module: when the following conditions are satisfied: the method comprises the steps of (1) starting a system, (2) enabling the system as a task on the same day, and (3) creating a periodic task thread pool framework scheduledThreadpool within a scheduling time range, wherein a throwing thread polls a task through a schedule WithFixedDelay (command, delay, unit) at a fixed time, and the thread performs business processing of message acquisition/transmission. When the memory parameters change, the system shutdown, the non-starting day of the task, the inconsistent scheduling time and the like are met, and the timed scheduling thread pool is closed (waiting for the task to finish, not exceeding one period). The periodic tasks are restarted automatically when the thread number configuration changes.
(3) And the host pair private inquiry module.
(4) And the host computer is used for inquiring the module.
2. The msg producer moves account message collection, as the message producer, can call the 4 big submodules of the public module, the data flow is detailed in a message production equation sequence module flow chart of a bank account moves account notification service system of figure 2, and the message production equation sequence module flow chart is divided into the following submodules according to the target party:
(1) Message collection floor-center boarding;
(2) Message collection floor-upper phase place;
(3) Message collection floor-social security.
3. The MsgConsumer message is sent and used as a message consumer, a public module (4 big submodule) is called, the data flow is detailed in a message consumption equation sequence module flow chart of a bank account accounting notification service system shown in fig. 3, and the message consumption equation sequence module flow chart is divided into the following submodules according to a target party:
(1) Message sending-middle log;
(2) Message sending-upper period institute;
(3) Messaging-social security.
4. The Msgmonitor system monitors in real time and is divided into the following submodules:
(1) External program monitoring: and judging whether the process is normal or not by monitoring the information content of the log and whether the log grows through an external program, and performing monitoring alarm.
(2) And (3) message collection and monitoring: and if the abnormal condition is met in the process of collecting the information each time, such as abnormal database connection, abnormal AIR host communication and the like, a UDP packet is sent to a bank branch monitoring platform.
(3) Message sending monitoring: and similarly, when the sending is refused or overtime is encountered, the UDP packet is sent to the bank branch monitoring platform.
The technical scheme is that the bank account dynamic account notification service system is as follows:
1) The system performance and stability are improved, and the systematic risk is reduced;
2) The module has clear level, and is easy to be managed in a handover way and maintained in a later code;
3) The business is extensible, and the concurrency performance is extensible;
4) The system has high automation degree and low operation and maintenance cost.
The data acquisition module of the bank account dynamic account notification service system in this embodiment is shown in a flow chart of a message production equation sequence module of the bank account dynamic account notification service system in fig. 2. The main flow is as follows:
1. firstly, reading a configuration loading database driver;
2. acquiring the service types of the input parameters, and instantiating the object through a construction method MsgProducer (String type);
3. the main process calls a public module to carry out memory synchronization and thread scheduling; the same service allows parallel inquiry of different accounts, but the same account can only be inquired by one thread sequence;
4. message collection service implementation:
1) The method comprises the steps of connecting a database, reading a dynamic account notification account acquisition control table according to service TYPEs, inquiring whether an enabling state is Y-enabling or 0-capable of inquiring, adding a row-level lock when reading an account record (containing currency) with a latest polling timestamp before a polling period, updating the row to set the inquiring synchronous state as 1-being inquired, and instantiating MySyncTask_ [ TYPE ] objects to perform detail inquiry;
2) Calling public account information and acquiring dynamic account information through a public detail query interface in an AIR mode according to query date, log number, time stamp, sequence number, entry sequence number and the like of the last pen detail of the current account;
3) When the business type is the middle login, except calling details of public inquiry, a debit card inquiry interface is required to be called for acquiring the statement information under the condition that a private party is a debit card; if the debit card detail data does not exist after the public detail query is met, blocking one period for rechecking again, and if the debit card detail data is not queried for the second time, continuing the next step;
4) Analyzing the message according to the current service type and recording a detail table in a floor mode; if there is a successor, continuing to inquire until there is no successor, judging whether the interpolation fails because the key value is repeated, if yes, continuing, otherwise, sending an alarm UDP, interrupting service processing, and jumping to the step 6);
5) Updating the last detailed query condition of the account number in the acquisition control table as an initial query condition of the next period;
6) To prevent memory leaks, the object heap space needs to be dereferenced so that it can be reclaimed by the GC; and finally, changing the polling time stamp in the dynamic account notification account acquisition control table into a current time stamp, and recovering the synchronous state to 0-unoccupied.
The data transmission module of the bank account dynamic account notification service system in this embodiment, the data flow is shown in a flow chart of a message consumption equation sequence module of the bank account dynamic account notification service system in fig. 3. The main flow is as follows:
1. firstly, reading a configuration loading database driver;
2. acquiring the service types of the input parameters, and instantiating the object through a construction method MsgConsumer (String type);
3. the main process calls a public module to carry out memory synchronization and thread scheduling;
4. message sending service processing:
1) The connection database is used for obtaining a sending IP and a port in a system table according to the service type; reading a message transmission control table, inquiring an account record with an enabling state of Y-enabling and a transmission synchronization state of 0-capable of being transmitted, adding a row-level lock during reading, updating the row to set the transmission synchronization state to 1-in transmission, and instantiating sendask_ [ TYPE ] to transmit the message;
2) Inquiring the unsent record in the detail table according to the service type, the customer account number and the currency, assembling the message, and converting the XML message for the specific service;
3) TCP sends message to consumer system; if the transmission is refused or overtime is encountered, the pen detail needs to be retransmitted; if the retransmission fails, the transmission flow is exited; the updated list sending state returned successfully is 1-sent;
4) The update message transmission control table polls the time stamp for the current time, and the transmission synchronization status is 0-transmittable.
Those skilled in the art will appreciate that all or part of the processes implementing the methods of the above embodiments may be implemented by a computer program for instructing relevant hardware, where the program may be stored in a computer readable storage medium, and where the program may include processes implementing the embodiments of the methods described above. The storage medium may be a magnetic disk, an optical disk, a Read-Only Memory (ROM), a random access Memory (Random Acess Memory, RAM), or the like.
The foregoing is merely a preferred embodiment of the present invention and it should be noted that modifications and additions to the present invention may be made by those skilled in the art without departing from the principles of the present invention and such modifications and additions are to be considered as well as within the scope of the present invention.
Claims (9)
1. The utility model provides a bank account moves account and notifies service system for bank account single receipt, when payment transaction amount reaches preset condition, with moving account information notification customer, its characterized in that: the dynamic account notification service system is provided with a message producer program module and a message consumption equation sequence module; the message producer program module is used for collecting bank account dynamic account data, including a bank account dynamic account data collection thread; the task thread for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and falls to the ground; the message consumer program module is used for sending the bank account dynamic account data, including sending a bank account dynamic account data thread; the task thread of the data period of the sending dynamic account is used for sending a notification message of the dynamic account of the bank account;
the message producer program module is used for collecting bank account dynamic account data and executing the following steps:
the method comprises the steps that C1, a bank account dynamic account information producer process is initialized;
c2, initializing process memory configuration of a bank account dynamic account message producer;
c3, the bank account dynamic account information producer process establishes a task thread pool for collecting dynamic account data period;
c4, circularly reading database configuration by a bank account dynamic account message producer process;
c5, judging database configuration consistency by a bank account dynamic account message producer process;
if the database configuration is inconsistent, refreshing the process memory configuration of the bank account dynamic account information producer, restarting/closing the task thread for collecting dynamic account data period according to the acquired database configuration, and executing the step C4 in a jumping manner;
c7, if the database configuration is consistent, the process of the bank account dynamic account information producer blocks and waits for a period, and the step C4 is executed in a jumping manner;
any task thread for acquiring the dynamic account data period is used for acquiring the dynamic account notification message of the bank account and performing the following steps:
c31, acquiring business parameters by reading a database by a task thread of a dynamic account data acquisition period;
c32, acquiring dynamic account data period task threads according to the inquiry details and the analysis details of the host computers on the bank accounts;
c33, if the detail queried by the upper host computer has follow-up, acquiring a dynamic account data period task thread to record a dynamic account notification, landing the detail table, and jumping to execute the step C31;
c34, if the details of the upper host computer query are not follow-up, the task thread of the collecting dynamic account data period updates the query condition of the fine powder pen, and the task thread of the collecting dynamic account data period is exited;
the message consumer program module is used for sending bank account data to execute the following steps:
f1, initializing a bank account dynamic account message consumer process;
f2, initializing the process memory configuration of the bank account dynamic account message consumer;
f3, the bank account dynamic account message consumer process establishes a task thread pool for sending dynamic account data period;
f4, circularly reading the database configuration by the bank account dynamic account message consumer process;
f5, judging database configuration consistency by the bank account dynamic account message consumer process;
f6, if the database configuration is inconsistent, refreshing the process memory configuration of the bank account dynamic account message consumer, restarting/closing the task thread for transmitting dynamic account data period according to the acquired database configuration, and executing the step F4 in a jumping manner;
f7, if the database configuration is consistent, the bank account moving information consumer process is blocked and waits for a period, and the step F4 is executed in a jumping manner;
any one of the task threads for sending the dynamic account data period is used for sending the dynamic account notification message of the bank account to execute the following steps:
f31, sending a dynamic account data period task thread to read a database to obtain service parameters;
f32, reading a record of the unsent account notification by the task thread of the period of sending the account data according to the bank account, and sending the account notification to each consumer system;
and F33, exiting the task thread for transmitting the dynamic account data period.
2. The bank account accounting notification service system according to claim 1, wherein: the dynamic account notification service system is further provided with a dynamic account notification public program module; the dynamic account notification public program module comprises a synchronous memory object attribute program sub-module, a timing task scheduling program sub-module and a dynamic account inquiring program sub-module; and C2, F2, calling a synchronous memory object attribute program sub-module to initialize memory configuration, C3, F3, calling a timing task scheduler sub-module to process periodic task thread business, and C32, calling a host query detail on a dynamic account query program sub-module.
3. The bank account accounting notification service system according to claim 2, wherein: the step C33 detail list landing refers to the middle log service message collection landing, the last service message collection landing and the social security service message collection landing; the step F32 of sending the account moving notification refers to the transmission of the log-in business message, the transmission of the last period business message and the transmission of the social security business message.
4. A bank account accounting notification service system according to claim 3, wherein: the dynamic account inquiry program submodule is divided into a private dynamic account inquiry program submodule and a public dynamic account inquiry program submodule according to banking business characteristics.
5. The bank account accounting notification service system of claim 4, wherein: step C32 calls the host computer query details and the analysis details on the public account query program submodule according to the query date, the log number, the timestamp, the sequence number and the entry sequence number of the last statement details of the bank account; and when the service type is the center, the step C32 calls the host on the private account inquiry program submodule to inquire and acquire the annex information when the private party is the debit card.
6. The bank account accounting notification service system according to claim 1, wherein: the dynamic account notification service system is further provided with a real-time monitoring equation sequence module, and an internal monitoring program sub-module is arranged in the message producer program module and the message consumption equation sequence module; the real-time monitoring program module and the internal monitoring program sub-module are matched to monitor and alarm abnormal conditions of the message producer program module and the message consumption equation sequence module in real time.
7. The bank account accounting notification service system of claim 6, wherein: the real-time monitoring program module comprises an external program monitoring sub-module, a message acquisition monitoring sub-module and a message transmission monitoring sub-module; the external program monitoring submodule judges whether the bank account dynamic account information producer process and the bank account dynamic account information consumer process normally carry out monitoring alarm or not according to the external program monitoring log information and whether the log grows; the message collection and monitoring sub-module monitors and alarms the abnormality encountered in the process of message collection of the bank account dynamic account message producer; and the message sending monitoring sub-module carries out monitoring alarm on refused or overtime message sending of the bank account accounting message consumer process.
8. The bank account accounting notification service system of claim 7, wherein: and the log adopts log back log management configuration, and the log is automatically cleaned.
9. A bank account accounting notification service system according to any of claims 1 to 8, wherein: the dynamic account notification service system is programmed and deployed by adopting Java programming language, and the periodic task thread pool is a thread pool established by using a newScheduedThreadpool thread pool framework.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011258020.0A CN112463167B (en) | 2020-11-11 | 2020-11-11 | Bank account dynamic account notification service system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011258020.0A CN112463167B (en) | 2020-11-11 | 2020-11-11 | Bank account dynamic account notification service system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112463167A CN112463167A (en) | 2021-03-09 |
| CN112463167B true CN112463167B (en) | 2024-04-05 |
Family
ID=74825493
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011258020.0A Active CN112463167B (en) | 2020-11-11 | 2020-11-11 | Bank account dynamic account notification service system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112463167B (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114372800B (en) * | 2022-01-10 | 2025-04-11 | 中国工商银行股份有限公司 | Transaction processing methods, devices, equipment, media and products |
| CN114741178B (en) * | 2022-05-20 | 2022-08-23 | 北京宇信科技集团股份有限公司 | Credit application processing method and device, electronic equipment and storage medium |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20050055296A1 (en) * | 2003-09-08 | 2005-03-10 | Michael Hattersley | Method and system for underwriting and servicing financial accounts |
| CN101604436A (en) * | 2009-07-29 | 2009-12-16 | 中国建设银行股份有限公司 | The method of bank short message financial operations |
| CN106254214A (en) * | 2016-08-04 | 2016-12-21 | 武汉聚风天下科技有限公司 | The proactive notification system of a kind of banking information and proactive notification method |
| CN108712325A (en) * | 2018-05-28 | 2018-10-26 | 招商银行股份有限公司 | Dynamic account notification method, equipment and computer readable storage medium |
| CN109064161A (en) * | 2018-07-20 | 2018-12-21 | 诚泰信息科技（天津）有限公司 | A kind of bank account transaction journal intelligent management and device based on short message |
-
2020
- 2020-11-11 CN CN202011258020.0A patent/CN112463167B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20050055296A1 (en) * | 2003-09-08 | 2005-03-10 | Michael Hattersley | Method and system for underwriting and servicing financial accounts |
| CN101604436A (en) * | 2009-07-29 | 2009-12-16 | 中国建设银行股份有限公司 | The method of bank short message financial operations |
| CN106254214A (en) * | 2016-08-04 | 2016-12-21 | 武汉聚风天下科技有限公司 | The proactive notification system of a kind of banking information and proactive notification method |
| CN108712325A (en) * | 2018-05-28 | 2018-10-26 | 招商银行股份有限公司 | Dynamic account notification method, equipment and computer readable storage medium |
| CN109064161A (en) * | 2018-07-20 | 2018-12-21 | 诚泰信息科技（天津）有限公司 | A kind of bank account transaction journal intelligent management and device based on short message |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112463167A (en) | 2021-03-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112667362B (en) | Method and system for deploying Kubernetes virtual machine cluster on Kubernetes | |
| CN101707399B (en) | Method and system for acquiring electric energy information | |
| CN111930355B (en) | Web back-end development framework and construction method thereof | |
| CN101799751B (en) | Method for building monitoring agent software of host machine | |
| CN107506240B (en) | Background application program control method, device, storage medium and electronic device | |
| CN112463167B (en) | Bank account dynamic account notification service system | |
| CN104639374A (en) | Application program deployment management system | |
| CN102880503A (en) | Data analysis system and data analysis method | |
| CN101719852B (en) | Method and device for monitoring performance of middleware | |
| CN114244894B (en) | Method, system, computer storage medium and electronic device for processing shutdown and resumption of computer services | |
| CN103475677A (en) | Method, device and system for virtual node management in PaaS cloud platform | |
| CN105635298A (en) | Service isolation principle based data acquisition equipment unified access system | |
| CN106161644A (en) | Distributed system for data processing and data processing method thereof | |
| CN112100034A (en) | Service monitoring method and device | |
| CN103309705A (en) | Terminal application program activation method and system | |
| CN109885612A (en) | The synchronization take-effective method and device of block chain intelligence contract | |
| CN109117609A (en) | A kind of request hold-up interception method and device | |
| CN111984505A (en) | Operation and maintenance data acquisition engine and acquisition method | |
| CN109669979A (en) | The processing method and processing device of data, storage medium | |
| CN108121730B (en) | Device and method for quickly synchronizing data update to service system | |
| CN110324208A (en) | A kind of data loss processing method, intelligent terminal and storage medium | |
| CN111176959B (en) | Early warning method, system and storage medium of cross-domain application server | |
| CN113743879B (en) | Automatic rule processing method, system and related equipment | |
| CN116483890A (en) | Data processing method, apparatus, electronic device, medium, and program product | |
| CN112508710B (en) | Account checking system and corresponding computer equipment |
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 | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |