47 results about "Epoll" patented technology

The invention relates to a LoRa core network system and a realization method. According to functions of designed gateway, network management server, application management server, data distribution server and database server, a task of operating and managing a LoRa network can be finished. The designed application management server based on Nginx, TCP connection is taken over by Nginx, and parameters of request service are borne by a body in an HTTP message. A service request module is docked with an Nginx module. The realization complexity resulting from managing the TCP connection by an Epoll model is avoided, the system expansibility is improved, and the maintainability is relatively high. A request preprocessing mode accesses the rapid processing and blacklist filtering LoRa network based on a UDP, requests are rapidly transmitted to the data distribution server through the UDP, through blacklist filtering, illegal requests are prevented from entering the application management server through the data distribution server, and the system security and reliability are ensured.

The invention discloses a TCP channel management method suitable for high-concurrency scenes. The method comprises an access gateway, message middleware, a data analysis service and a TSP business service, wherein the access gateway is connected with a plurality of clients; the access gateway s connected with the message middleware; the message middleware is connected with each of the data analysis service and the TSP business service; and the access gateway is used for providing services such as client access, link validity verification and overtime management. According to the method, an epoll asynchronous communication model is adopted, a task pool, link table management and a link detector are imported, and a task queue pool and a multi-thread technology are combined, and a communication link is decoupled. The method is suitable for high-concurrency application scene characteristics and network communication technology background, and sufficiently considers the advantages and disadvantages of various technologies so as to adopt the advantages and avoid the disadvantages.

The invention relates to the technical field of heartbeat packet control and especially relates to a heartbeat packet asynchronous control method and apparatus. The heartbeat packet asynchronous control method comprises the following steps: step A, performing server socket communication parameter initialization and server communication model initialization, and establishing a monitoring socket descriptor; step B, establishing and initializing a server dynamic list; step C, initializing and starting a system timer controlling a heartbeat packet; and step D, invoking a monitoring function, determining whether a client communication event is triggered, if so, a server main program exiting from the monitoring function, and the server traversing and processing the communication event, and if not, continuously waiting until the client communication event is triggered. According to the invention, by use of an Epoll server model of a linux system, the method and apparatus are simple, reliable and highly efficient, the problems of multithread programming and protocol complexity are overcome, system memory resources are fully utilized, heartbeat packet data is efficiently processed.

The invention belongs to the network communication field and provides a network communication method and a system. The method comprises the following steps that: a network data transceiving thread and an interception interface are associated, and the interception interface is added to an epoll array; the interception interface intercepts events in the epoll array, and when the interception interface intercepts an event needing transceiving data, different events are processed and the network data transceiving threads associated with the different events are notified to transmit and receive data; and the network data transceiving thread transmits and receives network data according to notification of the interception interface. In the embodiment of the invention, the interception interface is established in the system kernel to intercept the events in the epoll array, to notify the network data transceiving thread to export a socket-associated function symbol table, and to transmit and receive the data by using a standard system call corresponding to the function symbol table in the kernel, so that the transceiving of the data in the kernel process is realized.

The invention discloses a communication method, a device and a server for Internet of things. The method comprises the following steps: setting a plurality of first selectors so as to receive a connection request from a connection queue in a multithreads manner; determining one first selector to receive the connection request which is currently positioned at the utmost front end of the connection queue according to the amount of data received by the first selectors; establishing the connection to the side of equipment according to the connection request. According to the embodiment of the invention, the plurality of selectors are arranged, the selectors can receive the connection request from the connection queue in a multithreads manner, and further multiple connection requests are processed in parallel, so that the processing speed of the server is higher, and the problems that select and epoll models based on a single thread cannot satisfy the socket read and write requirements of the system, and the professional work thread of the server is blocked as packages are frequently transmitted by the equipment in the prior art are solved.

The invention provides a method and device for testing pressure. The method comprises the steps that initialization is firstly conducted, wherein a reading connection pool and a writing connection pool of the epoll are initialized, application for a data area cache is conducted according to preset user customized parameters, and a data package is loaded to the cache from a pressure file; with regard to connection established with a module to be tested, data are read and written in a level triggered mode and trigger events of data reading and data writing are arranged and the connection is added to the reading connection pool and the writing connection pool; the pressure condition is counted at regular time through a counting thread and transmission of pressure data is stimulated at regular time through effective global variables which are continuously transmitted through set identification; after the trigger event of data writing is monitored through a pressure transmission thread, if the global variables are effective, the pressure data in the cache are transmitted to the module to be tested in a polling mode until the pressure number of the transmission period is achieved, and then the global variables are set ineffective. According to the method and device for testing the pressure, the high pressure testing requirement can be satisfied and the phenomenon that the tested pressure reaches the limit of a physical network card becomes possible.

The invention provides a write data monitoring method and system based on EPOLL. The method comprises the following steps: the Epoll server-side accepting the connection of a client; after the connection is successful, a socket data dictionary saving a socket object; creating an independent monitoring thread to monitor each socket object in the socket data dictionary at fixed time; checking the size of unsent cache area in the socket object at limited time intervals, if the size of the unsent cache exceeds a threshold value, processing the corresponding client. The invention further provides a write data monitoring system based on EPOLL. The system is used for monitoring the server source and immediately adjusting the server source.

The invention belongs to the network communication field and relates to a system for supporting multiple platform network communication processing and a method thereof. The system comprises a network database module which is connected with an upper application system. The network database module is provided with the following modules: a channel create module, which is used to request the network database module to create a new channel and execute creating the new channel; a channel closing module, which is used to request the network database module to close the channel and execute closing the channel; a set user data and callback function module, which is used to arrange and store the user data and a callback function pointer and execute calling the callback function; a network event processing module, which is provided with a thread pool and an epoll module and is used to process an epollin event, wherein the thread pool and the epoll module are connected with each other. The channel create module, the channel closing module and the set user data and callback function module are respectively connected with the network event processing module. The set user data and callback function module is connected with the upper application system. By using the system and the method, TCP and UDP can be integrated and portability is strong.

The invention provides a data processing method based on a distributed file system. The method comprises the steps of performing connection with at least one initiator; starting an epoll network model, and when detecting transmitted network data, processing the data in response to corresponding threads, wherein multiple threads correspond to one initiator; starting the corresponding threads to receive a request message sent by the initiator and packaging the request message into SCSI command words; processing the received request message and storing metadata corresponding to the processed request message into a data memory pool. The invention also provides a data processing device based on a distributed file system. The method and the device combine multiple threads with iSCSIs, so that each thread is corresponding to one or more initators and the processing properties of a distributed file system block device is improved.

The invention discloses a platform for automatically realizing video format conversion processing, which is characterized in that a set of high-performance streaming media service framework is constructed, and multiple streaming media protocols of rtmp/rtsp/hls/http-flv are supported. Linux, macos, windows, ios and an android platform are supported, and the supported coding formats comprise H264, AAC and H265; an adopted model is multi-thread IO multiplexing non-blocking programming (epoll is adopted under linux, and select is adopted by other platforms); the framework is developed based on C++11, use of a bare pointer is avoided, memory copying is reduced, codes are simple and reliable, concurrency performance is excellent, and under a linux platform, the advantages of a multi-core CPU can be fully utilized by a single process; the CPU and network card performance can be maximized; and the performance limit of the 10-gigabit network card can be easily and meanwhile, extremely low time delay can be achieved while high performance is achieved, and a picture is opened in seconds.

The invention discloses a multithreading high-performance http agency realizing method and system. According to the scheme, an epoll event notification mechanism and the multithreading technology are combined to be used, through reasonable modeling and design, the concurrent processing capacity of http agency is greatly improved, and the problem that an existing http agency realizing scheme can not effectively process especially-large concurrent requests is effectively solved.