34results about How to "Solve concurrency issues" patented technology

The invention provides a framework system applied to the field of intelligent wear and based on an MEAN framework so as to solve the problem of interconnection of intelligent wear equipment, a mobile phone APP and a cloud server. Meanwhile, the invention provides an application framework applied to the field of child bracelet equipment and based on a tracking planned and triggered bracelet capable of preventing children from being lost so as to solve the problems that consumption of equipment batteries is increased and the tracking requirements of different scenes can not be met due to the fact that a child bracelet reports aimlessly in real time.

The present invention relates to the field of cloud computing, in particular, to an SaaS service system for achieving large scale of users to log in at the same time and a method thereof. The present invention system consists of a single sign-on concurrent cluster, a public library, an application server cluster, a service application server cluster and a database cluster; the deployment of the application server cluster is achieved through balancing loading and distributing technology; and the deployment of the database cluster through reading writing separating technology and database independent branch library. The present invention solves the problem of large scale of users logging in, accessing, storing server data at the same time; and can be used in concurrent processing in the SaaS service mode.

The present invention discloses a system for realizing order management and control, a method for realizing order management and control, a scheduling server and a processing server system. The method includes the following steps that: when a scheduling system determines that order tasks need to be issued, the order tasks are issued, and the number of the issued order tasks is counted through a first counter; and when the scheduling system learns that the issued order tasks have been successfully processed, the number of the order tasks that have been successfully processed is counted through a second counter. According to system for realizing order management and control, the method for realizing order management and control, and the scheduling server and the processing server of the invention, when a scheduling decision in the scheduling system determines that the orders can be issued, pre-counting is performed for once, namely, the value of the first counter adds one, and therefore, management and control on the issuing of the orders by the total scheduling of the system is realized really; and therefore, when the scheduling system makes scheduling decisions on other orders subsequently, the scheduling system can refer to the value of the first counter so as to determine whether the number of orders issued to warehouses exceeds the capacity of the warehouses timely, and therefore, precise control on order issuance on the basis of a distributed system can be ensured, and the problem of inaccurate control caused by asynchronous time difference can be avoided.

The invention relates to the big data transmission technology, and provides a data transmission method based on interface asynchronous call, a server and a computer readable storage medium. The methodcomprises the following steps: receiving an interface call request sent by a client, wherein the interface call request comprises primary key information, a data operation type and operation timestamp information; generating an asynchronous call task according to the interface call request, and storing the asynchronous call task in an asynchronous task table; and executing the asynchronous call task in the asynchronous task table, reading data returned by an interface, and transmitting the data to the client. By adoption of the data transmission method provided by the invention, the problem of call thread obstruction during high concurrency is solved by establishing the asynchronous task table, repeated call is avoided by using the primary key information, reverse call is prevented by using the operation timestamp information, the data transmission quality is improved, and the response speed of a server is improved.

The invention provides a shared storage-based MPP database data redistribution system. The shared storage-based MPP database data redistribution system includes a shared storage system, an MPP cluster management node and MPP cluster distributed computation nodes. The shared storage-based MPP database data redistribution system is used for solving the performance problem of the redistribution of data in the existing MPP databases. Through the shared storage-based MPP database data redistribution system, the redistribution of the data can be rapidly realized by the MPP databases according to a distributed storage system when computation node undergoes expansion, so that the performance problem and the business concurrence problem of the redistribution of the existing MPP system data are avoided and the online businesses are hardly influenced.

The invention provides a file configuration method and device based on distributed file edge nodes, and relates to the technical field of file configuration. The method comprises the steps of: obtaining a change event broadcasted by a central node; comparing a label, a version number and a timestamp corresponding to a newly generated configuration file with the configurations of an edge node, andjudging whether the configuration of the newly generated configuration file is illegal or not; if not, discarding the change event; and otherwise, loading the change event and pulling the newly generated configuration file, so as to enable a client to pull the newly generated configuration file into a shared memory of the client when monitoring the change event and the version number change of theconfiguration of the edge node to finish the hot update of the configuration file of the client. According to the file configuration method and device, configuration files are simultaneously distributed at different edge nodes, and therefore, the diversified adaptation problem that different servers, middleware and service codes read configurations on different edge nodes is solved.

The invention provides a method and equipment for matching network game clients. According to the invention, the candidate server information can be obtained according to a received first game connection request. After that, the target game server information is obtained according to the server connection information and the game room information in the candidate server information. Then, the target game server information is returned to a client. Therefore, the newly accessed client is allocated according to the game room information while the load balancing requirement of the server is met.The problems of server resource waste caused by continuous occupation of server resources by an unfilled game room on the initial server, poor user experience caused by continuous waiting of a clientin the game room and the like are avoided. The resources of the server are fully utilized. The game experience of a user is improved. Meanwhile, the game server which is low in coupling, high in connection efficiency, simple in structure and easy to maintain is achieved through a brand-new method, and the maintenance cost of developers is reduced.

The invention provides a data processing system. A cloud computing platform, a big data platform and an intelligent contract body are used to construct a more efficient decentralized data analysis platform, front-end display, a cloud computing platform technology and a big data platform technology are combined, therefore, the application layer, the algorithm layer and the data layer are separated;and through scheduling of a centralized intelligent contract body, the efficiency and precision of estimating the workload of the calculation task are improved, the workload load of the multi-cloud platform is balanced, the problem of big data concurrency is solved, the resource utilization efficiency, the calculation retrieval efficiency and the rear-end service development expansibility are improved, and the method can be applied to social security big data processing and improve the working efficiency.

The invention relates to a method that web page dynamically displays larger external data without refreshment, the method comprises the following steps: (1) the one-to-one corresponding relation between a car-mounted terminal and a GPS terminal is created in a WEB system; (2) the GPS terminal collects the current data of the car-mounted terminal and saves the data to a data base through a satellite, a basic public communication network and the corresponding gateway-program technology; (3) a data fetching and conversing server fetches the data collected by the GPS terminal in the data base and converts the data into corresponding uniform data source; (4) a WEB server accesses the uniform data source and can display a larger amount of information reported by the GPS car-mounted terminal dynamically and in real time. Compared with the prior art, the invention has the advantages that the web page can dynamically, quickly, and reliably display larger external data without refreshment, and the like.

The invention relates to an intelligent contract execution optimization method based on a multi-core architecture. The method comprises two stages: 1) a parallel mining stage; 2) parallel verificationstage. According to the invention, aiming at two stages of intelligent contract execution, parallel mining and parallel verification strategies are respectively designed and implemented. In the parallel mining stage, the problems of frequent context switching of threads and blockage of read-write locks are solved by introducing Spinlock and MVCC; meanwhile, in the parallel verification stage, conflict transactions are grouped, and parallelization of the transactions is achieved through a double-end queue; the intelligent contract parallelization strategy provided by the invention provides a new solution for execution of the intelligent contract, also explores the restorability of the task execution sequence in a multi-thread environment, and has certain theoretical value and research significance for effectively solving the concurrency problem.

The invention is suitable for the technical field of satellite positioning, and provides an allocation method and system of a network RTK (Real Time Kinematic) service, a cloud server and a memory. The method comprises the following steps: connecting base stations distributed throughout the country into a network structure, wherein the network structure comprises a geometric element combination, and the geometric element combination at least includes triangular elements; dividing the network RTK service into corresponding sub-tasks based on the geometric element combination; and calculating computing resources needing to be consumed by the corresponding sub-tasks, and performing service allocation based on a computing result. In the allocation method, all the base stations throughout the country are connected into the network structure, service allocation is performed on the basis of the network structure, and one big task is allocated to a plurality of computers, so that the problem of concurrence of a large scale of network RTK services is solved.

The invention discloses a resource access control method and device, electronic equipment and a storage medium, and relates to the field of server management. The specific implementation scheme is asfollows: the method comprises the steps of when a current sampling period arrives, obtaining a first accessed flow of a limited flow resource in a master DC and a second accessed flow of the limited flow resource in each slave DC in a previous sampling period; determining sub-page view thresholds corresponding to the master DC and the slave DCs respectively according to the first accessed traffic,the second accessed traffic and the total page view threshold of the limited traffic resources; and performing access control on the limited flow resource according to the sub-page view threshold corresponding to the master DC, and sending the sub-page view threshold corresponding to each slave DC to the corresponding slave DC, so that each slave DC performs access control on the limited flow resource according to the received sub-page view threshold. Therefore, the sub-page view threshold of each DC is calculated based on the actual page view of the limited flow resource in each DC in the previous sampling period, and the concurrency problem caused by resource deployment in a plurality of data centers is solved.

The embodiment of the invention discloses a method and device for managing a mirror image warehouse, electronic equipment and a readable storage medium. The method for managing the mirror image warehouse comprises the steps of receiving one or more uploading mirror image layers; storing the uploaded mirror image layer in the mirror image warehouse in a first storage mode; determining a to-be-cleaned mirror image layer in one or more original mirror image layers stored in the mirror image warehouse in a second storage mode, wherein the first storage mode is different from the second storage mode; and cleaning the mirror image layer to be cleaned. According to the technical scheme, the newly uploaded mirror image layer and the original mirror image layer are stored in the mirror image warehouse in the first storage mode and the second storage mode respectively, so that the mirror image layer in the mirror image uploading operation is separated from the mirror image layer in the garbage cleaning operation, and garbage cleaning is possible to be executed while the mirror image uploading operation is carried out; concurrent problems are avoided, and under the condition that other databases or middleware is not introduced, the garbage cleaning problem of the mirror image warehouse is solved.

The invention provides a simulation method for hardware equipment, which can be applied to the technical field of finance or other technical fields. The simulation method comprises the following steps: acquiring information of hardware equipment, and storing the information of the hardware equipment into an equipment information table; collecting interaction data of the hardware equipment and the terminal, and storing the collected interaction data in a data information table, wherein a mapping relation is formed between the interaction data and information of the hardware equipment; actively modifying the interaction data to obtain virtual data; and sending the virtual data and the information of the hardware equipment to the terminal to realize analog communication. According to the simulation method disclosed by the invention, the real interaction data between the hardware equipment and the terminal is replaced by the virtual data in a mode of actively modifying the interaction data, so that the simulation communication with the terminal is realized, and the condition of concurrent conflicts in the process of simultaneously using a plurality of pieces of hardware equipment is avoided. The invention further provides a simulator, electronic equipment, a storage medium and a computer program product.

The invention relates to a container edge proxy-based data message conversion self-description protocol MQTT method, which comprises the following steps of: S1, receiving a plurality of service requests by a middleware layer, and judging a processing sequence of the service requests; s2, performing an authentication process on a protocol message carried by the service request to obtain effective message content; s3, the effective message content is sent to an analysis unit for a message analysis process; and S4, the service request returns a response or reports a state, and state information is updated. The processing pressure of the Internet of Things management platform can be reduced, the communication delay is avoided, and the system response time is shortened.

The invention discloses a method and an apparatus for preventing database concurrence. The method comprises the steps of receiving a database access request; according to an access data identifier in the data access request, querying corresponding data from a database and reading a version number of the corresponding data; before the corresponding data in the database is operated according to an operation instruction in the data access request, judging whether the version number of the corresponding data is the same as the read version number or not; and if the version number of the corresponding data is the same as the read version number, then performing corresponding operation on the corresponding data in the database according to the operation instruction and modifying the version number of the corresponding data. According to the technical scheme, through a method for adding the version number to the data in the database, the problem of database concurrence is effectively solved and the fluency of data access is improved.

The embodiment of the invention provides a model calling method based on HTTP. The method comprises the following steps: receiving a plurality of HTTP requests provided by one or more client terminals; configuring a plurality of processes for the plurality of HTTP requests; executing the following operations through each process: generating a corresponding processing request according to the corresponding HTTP request, and transmitting the processing request to a corresponding target model, so that the target model feeds back a corresponding processing result based on the corresponding processing request; and receiving the processing result and sending the processing result to a client terminal. According to the embodiment of the invention, the corresponding processes are allocated to theplurality of HTTP requests, and the HTTP requests are processed by calling the corresponding target models, so the calculation processing speed when the HTTP requests are dense and the processing efficiency when the HTTP requests are concurrent are improved.

The invention discloses a data processing method and device. The data processing method comprises the steps of obtaining information of a first buffer area; acquiring a first cache data block corresponding to the first buffer area according to the information of the first buffer area and a mapping relationship between the buffer area and the cache data block; setting a writing state of the first cache data block to forbid a reading operation for the first cache data block; obtaining a version number of the first cache data block; judging whether the obtained version number of the first cache data block is the same as the current version number of the first cache data block or not; If yes, writing data to be written into the first cache data block, and clearing a writing state of the firstcache data block to allow a reading operation for the first cache data block. By adopting the data processing method provided by the invention, the problem of concurrence of cache data reading and writing of a single producer and multiple consumers is solved.

The invention discloses a method for saving online inquiry records. The method comprises the following steps: inquiry contents between an inquiring party and an inquired party are recorded, and online inquiry record data is generated and saved in a server; a first storage identifier is received and saved; dumping requests are generated according to the first storage identifier and sent to a scheduling queue; the scheduling queue acquires the online inquiry record data corresponding to the selected dumping requests from the server according to the selected dumping requests, and saves the data in a data storage device; and a second storage identifier used for searching for the online inquiry record data in the data storage device is received, the record data is acquired from the data storage device according to the second storage identifier, and feedback of the data is carried out. The method provided by the invention has the advantages that the pressure on an online medical platform server is greatly reduced, and the processing efficiency of the server is improved.

The invention discloses an artificial intelligence call center record quality inspection method and system, and the method comprises the steps: adding an initial inspection task, setting a task name,task effective time and task failure time, inputting a screening condition for extracting a record from the task effective time to the task failure time, obtaining a monitored seat meeting the screening condition, and generating an initial inspection task list; entering the initial inspection task list, selecting a monitored seat for quality inspection, and setting an initial inspection task allocation rule; and starting the initial inspection task when the task is valid, extracting the record data of the monitored seat according to the allocation rule, allocating the record data to related quality inspectors to start quality inspection scoring, and ending the initial inspection task when the task is invalid. The method can solve the problem of difficulty in quality inspection of massive call records of the existing call center, increases the number of concurrent users, and improves the execution capability of the system.

The invention discloses an application data processing method and device and electronic equipment. The method comprises the following steps: acquiring original application data of a current login userfrom a server, and caching the acquired original application data into a local database corresponding to the user on the mobile terminal; and querying the local database according to the applicationlist display request, obtaining original application data from the local database, performing grouping processing on the original application data, and adding the processed application data to an application list page to display the application list page. According to the embodiment of the invention, the data is managed in a database manner, the transaction of the database avoids the concurrency problem, and each login user corresponds to one database, so that the independent storage of the data is realized, the wrong display is avoided, and the requirements are met.

The invention relates to a communication method of a process control system for an aluminum plate and strip rolling technology. Concurrent and associative access by name is supported by the communication method. Aiming at the concurrence problem and the problem that the type and the size of communication data are uncertain during the cross-process and cross-host communication process of the process control system of an aluminum rolling mill, the invention provides a solution. According to the communication method, the concurrence problem is efficiently solved by adopting a reactor server framework; the associative access is realized by combining a MAP container; a mode of random and concurrent processing access by communication variable name is finally realized; flexible and expanded associative communication is provided, and multi-process concurrent cross-host access and the random access by name of the communication data are supported, and therefore, the flexibility and the efficiency of data communication are greatly improved, the instant communication performance, the flexibility and the expansibility of the process control system of the aluminum rolling mill are effectively improved, and the expansion complexity of the system is reduced.

The invention provides a smiling face finance intelligent recommendation resource rapid matching pool division algorithm. Target selling process, the object and object pool weight can be adjusted through the background, the object selling sequence is controlled, a timing task is started every minute to check the object and order state, the system fault-tolerant rate is increased, the object id, the amount of money, the state and other factors are used for conducting comprehensive idempotent verification rules, and the problem that the object places an order repeatedly is solved; According to the method, an existing recommendation algorithm is enhanced and improved, so that the recommendation algorithm better conforms to a company system, the pressure problem of the system is solved, the concurrency of users is increased, and the experience degree of the users is improved.

The invention discloses a distributed unique ID generation method. The method comprises the following steps that distributed data ID self-increasing is achieved in a MySql primary key self-increasing mode, MySql multi-instance primary key self-increasing is used, a database request is sent when the ID is obtained every time, and the obtained ID is an ID interval section. According to the invention, a reliable solution is provided for the generation of the distributed system ID, and different scenes, requirements and performance requirements are adapted; the self-increasing problem of the database is perfectly solved, the readability is high, the query efficiency is high, the availability delay is low, and the ID generation response is fast; a single-point problem does not exist, and it is ensured that the ID is a globally unique basic requirement; the invention is high in availability, low in delay and fast in ID generation response, does not become a business bottleneck, and is infinitely close to 100% in availability; the problem of concurrence during ID acquisition is solved by using a distributed lock; the trend increases progressively, and various specific business scenes are met.

The invention discloses an improvement method and device for a Redis distributed lock based on a Mysql database, and the method comprises the steps: setting a value and expiration time for a business key by using a SetNX command of Redis before a thread 1 carries out an A operation, and if the setting fails, enabling the thread 1 to terminate the operation; if the setting is successful, entering the next step; enabling the thread 1 to update the state of corresponding data t in a table data table a related to the operation A in the Mysql database into an 'in-operation' state, if an updating result returns to 1, determining that no thread carries out the operation related to the data t at the moment, and the next step is carried out; if the update result returns to 0, enabling the thread 1 to terminate the operation; enabling the thread 1 to execute the operation A; wherein no matter whether the thread 1 executes the operation A successfully or not, the state of the data t of the table a is updated to be 'non-operation', and the corresponding Redis key in the first step is deleted. The method has the beneficial effect that the concurrency problem generated when multiple threads simultaneously obtain the Redis distributed lock under the high concurrency condition is solved.

The present invention relates to a message sending method, device, computer equipment and storage medium based on RabbitMQ. The method includes the steps of: receiving a message and a queue identifier sent by a production end, and then determining a message corresponding to the queue identifier from a plurality of pre-declared message queues. The corresponding message queue can then deliver the message that the producer needs to send to the message queue, and send the message to a consumer bound to the message queue through the message queue, so that the consumer can process the message sent by the producer message, so that the producer can set the corresponding queue ID according to the actual needs and send the message to a specific consumer for processing, so that all operations of the producer can hit the specified consumer, avoiding the message of the producer from being polled and sent to Processing by multiple consumer ends improves the flexibility of message sending, and only needs to shackle messages on one consumer end to avoid concurrency problems and improve concurrency performance.

The invention discloses a map display system. The system includes: a network transmission device used for NIO frame adaptation, data reception and transmission, and data decoding; a map protocol device connected to the network transmission device for processing Protocol analysis and assembly, protocol distribution, protocol logic processing, and key value generation; distributed cache device, connected to the map protocol device, is used to store map data cache groups, cache partitions, cache backup, and cache restoration. By adapting the existing NIO framework, the present invention speeds up the network transmission speed and solves the problem of network concurrency, and provides scalability for the system; by implementing a custom protocol, the request / response data packets are simplified and the request response is faster Speed: make full use of the characteristics of the cache, the data storage structure is based on the cache, and all data is placed in the distributed cache, thereby speeding up the response time of processing requests.

The invention discloses an abnormal temperature data diagnosis method. The method comprises the following steps of receiving a temperature acquisition instruction issued by a server, acquiring temperature data of field equipment through a temperature sensor, analyzing and processing the temperature data, and judging whether the temperature data is abnormal temperature data or not, and uploading the abnormal temperature data to the server if so. According to the invention, the temperature data collected by a large number of temperature sensors installed in a power transmission line is moved forward to an abnormal temperature data diagnosis device for processing and storage, then the abnormal temperature data is uploaded to the server after being processed, an intermediate transmission process is reduced, the problems of concurrence caused by excessive temperature data and overhigh occupied transmission bandwidth are solved, the temperature data processing capability is more real-time and faster, and the rapid response to the temperature sensors of an Internet of Things transmission line is realized. The invention further provides an abnormal temperature data diagnosis device and equipment and a readable storage medium with the above advantages.

The invention discloses a method and an apparatus for preventing database concurrence. The method comprises the steps of receiving a database access request; according to an access data identifier in the data access request, querying corresponding data from a database and reading a version number of the corresponding data; before the corresponding data in the database is operated according to an operation instruction in the data access request, judging whether the version number of the corresponding data is the same as the read version number or not; and if the version number of the corresponding data is the same as the read version number, then performing corresponding operation on the corresponding data in the database according to the operation instruction and modifying the version number of the corresponding data. According to the technical scheme, through a method for adding the version number to the data in the database, the problem of database concurrence is effectively solved and the fluency of data access is improved.