CN117768429A - Store software timely communication system and method - Google Patents
Store software timely communication system and method Download PDFInfo
- Publication number
- CN117768429A CN117768429A CN202311836164.3A CN202311836164A CN117768429A CN 117768429 A CN117768429 A CN 117768429A CN 202311836164 A CN202311836164 A CN 202311836164A CN 117768429 A CN117768429 A CN 117768429A
- Authority
- CN
- China
- Prior art keywords
- module
- task
- equipment
- software
- socket
- 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
- 238000004891 communication Methods 0.000 title claims abstract description 39
- 238000000034 method Methods 0.000 title claims abstract description 20
- 238000012544 monitoring process Methods 0.000 claims abstract description 28
- 230000007246 mechanism Effects 0.000 claims abstract description 17
- 230000005856 abnormality Effects 0.000 claims description 13
- 238000001514 detection method Methods 0.000 claims description 8
- 230000002159 abnormal effect Effects 0.000 claims description 6
- 230000008569 process Effects 0.000 claims description 6
- 230000004044 response Effects 0.000 claims description 5
- 230000002093 peripheral effect Effects 0.000 claims description 3
- 238000007619 statistical method Methods 0.000 claims description 3
- 238000012300 Sequence Analysis Methods 0.000 claims description 2
- 230000009286 beneficial effect Effects 0.000 abstract description 2
- 238000007405 data analysis Methods 0.000 description 2
- 206010033799 Paralysis Diseases 0.000 description 1
- 230000004075 alteration Effects 0.000 description 1
- 230000002860 competitive effect Effects 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 238000012731 temporal analysis Methods 0.000 description 1
- 238000000700 time series analysis Methods 0.000 description 1
Landscapes
- Computer And Data Communications (AREA)
Abstract
The invention discloses a store software timely communication system and method, comprising an application layer, a multicast service discovery module, a Socket communication module, a task scheduling module, a heartbeat mechanism module and a monitoring alarm module, wherein the cooperative work of the modules realizes the instant communication and the cooperative work among the store software and simultaneously monitors and alarms each module in real time; the application layer comprises cashing software, order circulation software and a number calling screen; the multicast service discovery module is used for broadcasting equipment IP, equipment name and equipment type information for other equipment discovery; the beneficial effects of the invention are as follows: through the cooperative work of the multicast service discovery module, the Socket communication module, the task scheduling module, the heartbeat mechanism module and the monitoring alarm module, the instant messaging and the cooperative work among store software are realized, and the store work efficiency is improved; the heartbeat mechanism module keeps long connection, so that the equipment connection state is detected in time, and the communication stability is improved.
Description
Technical Field
The invention belongs to the technical field of software communication, and particularly relates to a store software timely communication system and method.
Background
The intelligent store management software brings high effectiveness to enterprises, improves the working efficiency of the enterprises, reduces the human capital of the enterprises, and can be completed by more than ten people; especially for some linked stores, the traditional management mode needs to send a person to each store to patrol the store, the remote day on the way can only run 2 to 3 stores, and now if intelligent store management software is provided, one mobile phone can check the operation condition of each store, and the operation of all the ten linked stores can be checked in one day, or even more; the traditional store management is a problem for data analysis, and every month, even half year and year are the most vexation time of store management staff, and sales, commodity inventory and other information are frequently checked from the early to the late, because the data are complicated, and the data loss, data omission and other conditions often occur; the industry is competitive, the data analysis of the traditional store management system cannot solve the sales problem, and the essence of the intelligent store management software is to make marketing more accurate.
As the number of linked stores continues to increase and the scale expands, the quality of communication requirements between multiple device software within a store becomes more critical; to meet this requirement, we define more complex api at the server to implement software-to-server-to-software communication; however, once the server fails, store software may be paralyzed to cause the software to fail to operate normally; meanwhile, the complex network environment can also generate interference on the coordination work among store system software.
Disclosure of Invention
The invention aims to provide a store software timely communication system and method, which improve the work efficiency and user experience of stores.
In order to achieve the above purpose, the present invention provides the following technical solutions: the system comprises an application layer, a multicast service discovery module, a Socket communication module, a task scheduling module, a heartbeat mechanism module and a monitoring alarm module, wherein the cooperative work of the modules realizes the instant messaging and cooperative work among the store software and simultaneously monitors and alarms each module in real time;
the application layer comprises cashing software, order circulation software and a number calling screen;
the multicast service discovery module is used for broadcasting equipment IP, equipment name and equipment type information for other equipment discovery;
the Socket communication module is used for enabling the device to serve as a server to start Socket, waiting for connection of other peripheral devices and transmitting data;
the task scheduling module is used for starting to distribute tasks among different devices according to the queues after communication connection and coordinating the work among the devices;
the heartbeat mechanism module is used for maintaining long connection, detecting whether equipment connection is normal or not, and attempting reconnection if failure occurs;
the monitoring alarm module is responsible for monitoring the running state of each module in real time, and immediately sends out an alarm prompt once abnormality or error is found.
As a preferred technical scheme of the invention, during communication, cashing software, a number calling screen and order circulation software execute ping/pong operation, long connection is kept, and no response is made to attempt reconnection after time-out.
As a preferable technical scheme of the invention, the monitoring alarm module monitors in real time by the following modes, and immediately sends out an alarm prompt when abnormality or error is found:
and (3) real-time data acquisition: the monitoring alarm module can collect the operation data of each module at regular time or in real time, compare the data with a preset normal range, and immediately send out an alarm prompt once abnormal data are found;
anomaly detection algorithm: the monitoring alarm module adopts an abnormality detection algorithm to monitor the running state of each module in real time, and immediately sends out an alarm prompt once abnormality or deviation from a normal trend is found;
event triggering mechanism: the monitoring alarm module sets a specific event triggering mechanism, and when the error number of a certain module exceeds a certain threshold value or the response time exceeds a preset maximum value, an alarm prompt is immediately sent out.
As a preferable embodiment of the present invention, the anomaly detection algorithm includes a statistical method and a time-series analysis.
As a preferable technical scheme of the invention, the operation data of each module comprises CPU utilization rate, memory occupancy rate and network bandwidth.
As a preferable technical scheme of the invention, in the task scheduling module, the specific method for distributing tasks among different devices and coordinating the work among the devices according to the queues is as follows:
establishment of a task queue: the task scheduling module maintains a task queue, and the tasks in the queue are ordered according to the priority and time conditions;
task allocation: when a new task is added into the queue, the task scheduling module distributes the task to proper equipment according to a preset distribution strategy;
task coordination: in the task allocation process, the task scheduling module needs to consider cooperative work among devices;
task monitoring and adjustment: in the task execution process, a task scheduling module monitors the progress of the task and the performance of the equipment in real time, and if the equipment is found to have an excessively high load or abnormal condition, the task scheduling module adjusts the task allocation so as to ensure the load balance of the equipment and the smooth progress of the task;
task completion and feedback: and after the task is completed, the task scheduling module collects the completion condition of the task and feeds the information back to other modules of the system for optimizing the task allocation and the equipment scheduling.
As a preferred technical solution of the present invention, the allocation policy is set according to the performance, load and availability factors of the device.
The invention also discloses a store software timely communication method, which comprises the following steps:
order circulation software starts mdns broadcasting, and provides IP information, equipment name and equipment type information to be found and identified;
the order circulation software starts Socket service and waits for other software to join in connection;
the cashing software sends an mdns discovery request, acquires equipment information, analyzes the information, stores the information locally, and sends a Socket connection request to Socket service;
the number calling screen sends an mdns discovery request, acquires equipment information, analyzes the information, stores the information locally, and sends a Socket connection request to Socket service;
the Task scheduling module starts working after successful connection;
the number calling screen sends order data to Socket service, and the Socket service informs the number calling screen to refresh an interface, reminds to take articles and sets a store;
the Socket service issues article data, and the number calling screen plays article animation and article number taking voice;
the Socket service issues order list data, notifies a number calling screen to refresh an interface, and reminds to take articles;
and the Socket service issues new order data and notifies the cashing software to start printing the receipt.
Compared with the prior art, the invention has the beneficial effects that:
through the cooperative work of the multicast service discovery module, the Socket communication module, the task scheduling module, the heartbeat mechanism module and the monitoring alarm module, the instant messaging and the cooperative work among store software are realized, and the store work efficiency is improved;
the heartbeat mechanism module keeps long connection, so that the equipment connection state is detected in time, and the communication stability is improved;
the monitoring alarm module is added, so that the system can monitor the running state of each module in real time, and timely find and solve the abnormality or error, thereby improving the reliability and stability of the system;
can be widely applied to the operation management of various stores, and has wide market prospect and application value.
Drawings
FIG. 1 is a partial system frame diagram of the present invention;
fig. 2 is a flow chart of a communication method of the present invention.
Detailed Description
The following description of the embodiments of the present invention will be made clearly and completely with reference to the accompanying drawings, in which it is apparent that the embodiments described are only some embodiments of the present invention, but not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments of the invention without making any inventive effort, are intended to be within the scope of the invention.
Example 1
Referring to fig. 1, a store software timely communication system is provided in a first embodiment of the present invention, which includes an application layer, a multicast service discovery module, a Socket communication module, a task scheduling module, a heartbeat mechanism module, and a monitoring alarm module, wherein by the cooperative work of the modules, the instant messaging and the cooperative work between store software are realized, and simultaneously, each module is monitored and alarmed in real time;
the application layer comprises cashing software, order circulation software and a number calling screen;
the multicast service discovery module is used for broadcasting equipment IP, equipment name and equipment type information for other equipment discovery;
the Socket communication module is used for enabling the device to serve as a server to start Socket, waiting for connection of other peripheral devices and transmitting data;
the task scheduling module is used for starting to distribute tasks among different devices according to the queues after communication connection, and coordinating the work among the devices;
the heartbeat mechanism module is used for maintaining long connection, detecting whether the equipment connection is normal or not, and attempting reconnection if failure occurs;
the monitoring alarm module is responsible for monitoring the running state of each module in real time, and immediately sends out an alarm prompt once abnormality or error is found.
In this embodiment, preferably, during communication, the cashing software, the number calling screen and the order circulation software perform ping/pong operations, maintain long connection, and timeout does not respond to attempt to reconnect.
In this embodiment, preferably, the monitoring alarm module monitors in real time by the following modes, and immediately sends out an alarm prompt when an abnormality or error is found:
and (3) real-time data acquisition: the monitoring alarm module can collect the operation data of each module in a timing or real-time manner, such as CPU utilization rate, memory occupancy rate and network bandwidth, compare the data with a preset normal range, and immediately send an alarm prompt once abnormal data is found;
anomaly detection algorithm: the monitoring alarm module can adopt an abnormality detection algorithm, such as a statistical method and time sequence analysis, to monitor the running state of each module in real time, and immediately send an alarm prompt once abnormality or deviation from a normal trend is found;
event triggering mechanism: the monitoring alarm module may set a specific event triggering mechanism, such as immediately sending an alarm prompt when the number of errors of a certain module exceeds a certain threshold or the response time exceeds a preset maximum value.
In this embodiment, preferably, in the task scheduling module, the specific method for distributing tasks among different devices and coordinating the work among the devices according to the queues is as follows:
establishment of a task queue: the task scheduling module maintains a task queue, and the tasks in the queue are ordered according to the priority and time conditions;
task allocation: when a new task is added into the queue, the task scheduling module distributes the task to proper equipment according to a preset distribution strategy; the allocation policy can be set according to the performance, load and availability factors of the equipment;
task coordination: in the task allocation process, the task scheduling module also needs to consider the cooperative work among devices; for example, some tasks may require multiple devices to complete together, and at this time, the task scheduling module needs to coordinate the workflow of each device to ensure that the tasks can be completed smoothly;
task monitoring and adjustment: in the task execution process, the task scheduling module can monitor the progress of the task and the performance of the equipment in real time, and if the equipment is found to have an excessively high load or abnormal condition, the task scheduling module can adjust the allocation of the task so as to ensure the load balance of the equipment and the smooth progress of the task;
task completion and feedback: after the task is completed, the task scheduling module can collect the completion condition of the task, including the execution time and success or failure information of the task, and feed back the information to other modules of the system for optimizing the task allocation and the equipment scheduling;
by the method, the task scheduling module can effectively distribute tasks among different devices according to the queues, coordinate the work among the devices and improve the overall efficiency and stability of the system.
Example 2
Referring to fig. 2, a second embodiment of the present invention provides a store software timely communication method, which includes the following steps:
order circulation software starts mdns broadcasting, and provides IP information, equipment name and equipment type information to be found and identified;
the order circulation software starts Socket service and waits for other software to join in connection;
the cashing software sends an mdns discovery request, acquires equipment information, analyzes the information, stores the information locally, and sends a Socket connection request to Socket service;
the number calling screen sends an mdns discovery request, acquires equipment information, analyzes the information, stores the information locally, and sends a Socket connection request to Socket service;
the Task scheduling module starts working after successful connection;
the number calling screen sends order data to Socket service, and the Socket service informs the number calling screen to refresh an interface, reminds to take articles and sets a store;
the Socket service issues article data, and the number calling screen plays article animation and article number taking voice;
the Socket service issues order list data, notifies a number calling screen to refresh an interface, and reminds to take articles;
and the Socket service issues new order data and notifies the cashing software to start printing the receipt.
While embodiments of the present invention have been shown and described in detail with reference to the foregoing detailed description, it will be understood by those skilled in the art that various changes, modifications, substitutions and alterations may be made therein without departing from the principles and spirit of the invention, the scope of which is defined in the appended claims and their equivalents.
Claims (8)
1. A store software timely communication system, characterized by: the system comprises an application layer, a multicast service discovery module, a Socket communication module, a task scheduling module, a heartbeat mechanism module and a monitoring alarm module, wherein the cooperative work of the modules realizes instant communication and cooperative work among store software and simultaneously monitors and alarms each module in real time;
the application layer comprises cashing software, order circulation software and a number calling screen;
the multicast service discovery module is used for broadcasting equipment IP, equipment name and equipment type information for other equipment discovery;
the Socket communication module is used for enabling the device to serve as a server to start Socket, waiting for connection of other peripheral devices and transmitting data;
the task scheduling module is used for starting to distribute tasks among different devices according to the queues after communication connection and coordinating the work among the devices;
the heartbeat mechanism module is used for maintaining long connection, detecting whether equipment connection is normal or not, and attempting reconnection if failure occurs;
the monitoring alarm module is responsible for monitoring the running state of each module in real time, and immediately sends out an alarm prompt once abnormality or error is found.
2. The store software just-in-time communication system according to claim 1, wherein: during communication, cashing software, a number calling screen and order circulation software execute ping/pong operation, long connection is kept, and no response is made to attempt reconnection after time-out.
3. The store software just-in-time communication system according to claim 1, wherein: the monitoring alarm module monitors in real time in the following modes, and immediately sends out an alarm prompt when abnormality or error is found:
and (3) real-time data acquisition: the monitoring alarm module can collect the operation data of each module at regular time or in real time, compare the data with a preset normal range, and immediately send out an alarm prompt once abnormal data are found;
anomaly detection algorithm: the monitoring alarm module adopts an abnormality detection algorithm to monitor the running state of each module in real time, and immediately sends out an alarm prompt once abnormality or deviation from a normal trend is found;
event triggering mechanism: the monitoring alarm module sets a specific event triggering mechanism, and when the error number of a certain module exceeds a certain threshold value or the response time exceeds a preset maximum value, an alarm prompt is immediately sent out.
4. A store software timely communication system according to claim 3, characterized in that: the anomaly detection algorithm comprises a statistical method and time sequence analysis.
5. A store software timely communication system according to claim 3, characterized in that: the operation data of each module comprises CPU utilization rate, memory occupancy rate and network bandwidth.
6. The store software just-in-time communication system according to claim 1, wherein: in the task scheduling module, the specific method for distributing tasks among different devices and coordinating the work among the devices according to the queues is as follows:
establishment of a task queue: the task scheduling module maintains a task queue, and the tasks in the queue are ordered according to the priority and time conditions;
task allocation: when a new task is added into the queue, the task scheduling module distributes the task to proper equipment according to a preset distribution strategy;
task coordination: in the task allocation process, the task scheduling module needs to consider cooperative work among devices;
task monitoring and adjustment: in the task execution process, a task scheduling module monitors the progress of the task and the performance of the equipment in real time, and if the equipment is found to have an excessively high load or abnormal condition, the task scheduling module adjusts the task allocation so as to ensure the load balance of the equipment and the smooth progress of the task;
task completion and feedback: and after the task is completed, the task scheduling module collects the completion condition of the task and feeds the information back to other modules of the system for optimizing the task allocation and the equipment scheduling.
7. The store software just-in-time communication system according to claim 6, wherein: the allocation policy is set according to the performance, load and availability factors of the equipment.
8. A store software timely communication method is characterized in that: order circulation software in a communication system according to any of claims 1-7, said communication method comprising:
order circulation software starts mdns broadcasting, and provides IP information, equipment name and equipment type information to be found and identified;
the order circulation software starts Socket service and waits for other software to join in connection;
the cashing software sends an mdns discovery request, acquires equipment information, analyzes the information, stores the information locally, and sends a Socket connection request to Socket service;
the number calling screen sends an mdns discovery request, acquires equipment information, analyzes the information, stores the information locally, and sends a Socket connection request to Socket service;
the Task scheduling module starts working after successful connection;
the number calling screen sends order data to Socket service, and the Socket service informs the number calling screen to refresh an interface, reminds to take articles and sets a store;
the Socket service issues article data, and the number calling screen plays article animation and article number taking voice;
the Socket service issues order list data, notifies a number calling screen to refresh an interface, and reminds to take articles;
and the Socket service issues new order data and notifies the cashing software to start printing the receipt.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202311836164.3A CN117768429A (en) | 2023-12-28 | 2023-12-28 | Store software timely communication system and method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202311836164.3A CN117768429A (en) | 2023-12-28 | 2023-12-28 | Store software timely communication system and method |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN117768429A true CN117768429A (en) | 2024-03-26 |
Family
ID=90318152
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202311836164.3A Pending CN117768429A (en) | 2023-12-28 | 2023-12-28 | Store software timely communication system and method |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN117768429A (en) |
-
2023
- 2023-12-28 CN CN202311836164.3A patent/CN117768429A/en active Pending
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US7777777B2 (en) | System and method for active call monitoring | |
| CN110213371A (en) | Information consumption method, apparatus, equipment and computer storage medium | |
| CN113742066A (en) | A load balancing system and method for server cluster | |
| US7539755B2 (en) | Real-time heartbeat frequency regulation system and method utilizing user-requested frequency | |
| CN103259832A (en) | Cluster resource control method for achieving dynamic load balance, fault diagnosis and failover | |
| WO2016188282A1 (en) | Message processing method, device and system | |
| CN114742487B (en) | Production task management and control method and system based on industrial Internet of things | |
| Ju et al. | A high-reliability edge-side mobile terminal shared computing architecture based on task triple-stage full-cycle monitoring | |
| CN107070744A (en) | Server monitoring method | |
| CN117560700B (en) | Control method and system for monitoring network data based on intelligent equipment | |
| CN108459941A (en) | A kind of method and system of distributed data acquisition and software supervision | |
| CN104270452B (en) | A kind of tele-medicine data management system and its wireless network communication method | |
| CN117768429A (en) | Store software timely communication system and method | |
| CN114844809B (en) | Multi-factor arbitration method and device based on network heartbeat and kernel disk heartbeat | |
| CN103326880B (en) | Genesys calling system high availability cloud computing monitoring system and method | |
| CN118863488B (en) | A management method, system and storage medium for after-sales maintenance products | |
| CN111782364B (en) | Service calling method, device, electronic equipment and storage medium | |
| CN111654401B (en) | Network segment switching method, device, terminal and storage medium of monitoring system | |
| CN110601914B (en) | Method and system for monitoring server survival status | |
| CN116032932B (en) | Cluster management method, system, equipment and medium for edge server | |
| CN114900558B (en) | Universal equipment management protocol control method and device | |
| CN112087341B (en) | Communication methods, systems, electronic devices and storage media based on multi-channel compensation | |
| CN117424935A (en) | Batch task management method, device, equipment and storage medium | |
| CN117201506A (en) | Distributed scheduling management method, device, terminal equipment and storage medium | |
| CN114444733A (en) | Self-service equipment fault processing method, terminal 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 |