Patents
Literature
Hiro is an intelligent assistant for R&D personnel, combined with Patent DNA, to facilitate innovative research.
Hiro

141results about How to "Guaranteed timing" patented technology

Satellite universal automatic testing platform and data interaction method thereof

The invention relates to a satellite universal automatic testing platform and a data interaction method thereof, aims to solve the technical problem that existing satellite test equipment has poor universality and a low automation degree, and belongs to the technical field of satellite testing. The satellite universal automatic testing platform provided by the invention consists of a peripheral equipment layer, an intermediate service layer and a user terminal layer, wherein the peripheral equipment layer comprises measurement and control system automatic testing equipment, control system automatic testing equipment, CAN (Controller Area Network) monitoring equipment, plug-failure signal monitoring equipment and solar cell array simulating equipment, and is used for making a response to aremote control command of a comprehensive testing server, uploading the remote control command to a satellite, finishing signal collection of the satellite data simultaneously, transmitting a collected signal to the comprehensive testing server to perform signal processing and data storage. According to the testing platform and a data interaction way thereof, the rapid testing demand at each stageof the satellite is met; a system of satellite distribution test control and comprehensive integration management is formed, and universal and automatic satellite testing is realized. The satellite universal automatic testing platform has the advantages of high universality and high automation degree.
Owner:CHANGGUANG SATELLITE TECH CO LTD

Method and device for transmitting and acquiring uplink HARQ feedback information

The invention provides a method and a device for transmitting and acquiring uplink HARQ feedback information, wherein the method comprises the steps of acquiring a service priority sequence list of downlink subframes; according to the service priority sequence list, multiplexing the HARQ feedback information of the downlink subframes according to a sequence that the service priorities reduce from highest to lowest, and obtaining to-be-transmitted HARQ feedback information; successively assigning uplink subframes to the to-be-transmitted HARQ feedback information, and transmitting the to-be-transmitted HARQ feedback information to a base station. According to the method for transmitting the uplink HARQ feedback information, user equipment can preferably transmit the HARQ feedback information of the subframes with low time delay requirement. When the base station acquires a transmission error of time-delay-sensitive service data, the downlink subframes which carry the time-delay-sensitive service data can be preferably retransmitted, thereby shortening transmission time of the time-delay-sensitive service data.
Owner:BEIJING XIAOMI MOBILE SOFTWARE CO LTD

High-reliability file synchronization method based on log change

The invention discloses a high-reliability file synchronization method based on log changes. The method comprises the steps of: judging whether a file requested to be operated is locked after a customer request is received by a file server, and waiting for unlocking to perform relevant operations if the file is locked; recording the operational type and the operational file of every modification through the file server in a log format; performing real-time scanning of the log file through the file server, and synchronizing all files to other nodes when the number of operational logs reaches the threshold value; and when the number of operational logs is smaller than the threshold value, sequentially processing every log file according to a sequence of generation time of the log files. For every log file, additional files are synchronized to other nodes according to contents of the operational log, and the operational log is deleted if synchronization is successful; and otherwise, the operational log is maintained. The target node is locked when files are synchronized, and the problem of file inconsistency caused by sudden switching of a host and a spare unit during file synchronization can be solved effectively.
Owner:NARI TECH CO LTD

Method for processing multiprogress message and method for processing multiprogress talk ticket

This invention relates to a multi-process information process method and a multi-process ticket process method, in which the ticket process method used in parallel process to tickets in the charge system includes 1, setting up a shared memory for every process, 2, the process fetches the tickets for processing in the shared memory block, 3, distributing the tickets and storing them in the shared memory according to the preset load balance rule based on the current occupation situation of the memory block and storing the tickets with the same charged numbers in a same shared memory.
Owner:DATANG SOFTWARE TECH

Reliable and real-time industrial wireless local area network transmission method

An industrial wireless local area network is widely applied to various industrial fields, data transmission is often interfered due to the special environments of industrial sites, the types of the data needed to the transmitted in the industrial sites are diversified, the data includes state data, control instructions, images and the like, and the transmission performance requirements of the data are different. The invention discloses a reliable and real-time industrial wireless local area network transmission method. The method adopts classified transmission for various types of data, that is to say, important data is transmitted first to guarantee the time sequence requirements. A double confirmation mechanism is adopted to guarantee data accuracy. A data transmission timer timing self-adaptation adjusting method based on network communication state is provided for fully utilizing network bandwidth. By the transmission method, instantaneity and reliability of industrial wireless local area network data transmission can be effectively increased, and application of the industrial local area network to severe industrial environments is promoted.
Owner:SOUTHEAST UNIV

Real-time control method for asynchronous messages of 1553B bus

The invention discloses a real-time control method for asynchronous messages of a 1553B bus. An IP core (intellectual property core) of hardware is used for realizing transmission control over the asynchronous messages of the 1553B bus, including transmission of non-periodic messages and zero clearing of a service request bit and a vector character of each RT (remote terminal), and the real-time response to a service request of each RT and timely zero clearing of a status bit and the vector character of each RT are ensured. Compared with a method for realizing asynchronous communication through an upper computer, the real-time control method has the advantages that the transmission of the non-periodic messages is realized through condition messages of a BC (bus controller), the condition messages are only executed in a very short time, the real-time transmission of the non-periodic messages can be realized, and the transmission time sequence of the non-periodic messages on the bus can be ensured. The service request bit of a status word and the vector character are realized through a hardware zero-clearing function of each RT, the real-time property is good, the service request bit and the vector character can be timely cleared, and repeated processing of the same service request of each RT is avoided. According to the control method, the whole process is controlled in the hardware, and the architecture design of a system can be simplified.
Owner:北京石竹科技股份有限公司

Miniature semi-active folding flapping wing

The invention discloses a miniature semi-active folding flapping wing, which consists of a front beam, an inclined beam, wing ribs and covers. The front beam and the inclined beam are respectively divided into two sections from an middle part; the inner section and the outer section of the front beam are respectively fixed to a folding base and a folding head; a rocker arm of the folding head is connected with a soft steel wire rope; the soft steel wire rope penetrates through the inner section of the front beam and is fixedly connected with a frame of a flapping wing driving mechanism; and a root part of the inner section of the front beam is connected with an output rocker arm of the flapping wing driving mechanism in an inserting manner. In a process that the flapping wing downwardly flaps, the flapping wing keeps flat and straight, and in an upwardly flapping process, the outer section of the flapping wing is downwardly bent to a certain angle due to the action of aerodynamic forces, and further, gradually becomes flat and straight along with the straining of the steel wire rope. According to the miniature semi-active folding flapping wing, the asymmetric upward / downward flapping of the flapping wing is realized through a simple and reliable manner, a resultant force of the aerodynamic lifting forces in a flapping cycle is increased, the aerodynamic efficiency of the flapping wing is increased, and thus, the miniature semi-active folding flapping wing is applicable to a miniature flapping wing flying vehicle.
Owner:NORTHWESTERN POLYTECHNICAL UNIV

Light source output control method and system, and laser projection device

The invention discloses a light source output control method, comprising: non-coaxially arranging a first color wheel and a second color wheel which are respectively provided with a first mark and a second mark, and synchronizing the first color wheel and the second color wheel according to an obtained first set of induction signals of a first synchronous mark and a second synchronous mark; and obtaining second induction signals from the output light path of the second color wheel, and synchronizing the first color wheel and the second color wheel again according to the second induction signals, wherein the second induction signals are voltage waveform signals corresponding to different colors, and sequentially output three primary colors when passing the second color wheel. Accordingly, the method can synchronize the two color wheels accurately, eliminate color mixing in outputting the second color wheel, improve the homogeneous light purity and brightness of the three primary colors, and provide a high quality lighting light source. The invention also provides a control system corresponding to the light source output control method, and a laser projection device using the control system and method.
Owner:QINGDAO HISENSE LASER DISPLAY CO LTD

Automatic online mark spraying machine for steel plates

The invention discloses an automatic online mark spraying machine for steel plates. The automatic online mark spraying machine for steel plates comprises an equipment foundation rack, a three-dimensional coordinate positioning mechanism is installed on the equipment foundation rack and provided with an alternating current servo device connected with a computer, the computer controls the alternating current servo device to achieve three-dimensional movement positioning of the three-dimensional coordinate positioning mechanism, and the three-dimensional coordinate positioning mechanism is provided with a flow restraining device. Compared with the prior art, the automatic online mark spraying machine for steel plates can solve the problems that existing mark spraying equipment is huge and large in occupied space, specific temperature requirements are provided when the surfaces of steel plates are marked, the spray printing quality is poor, the existing mark spraying equipment is incompatible with existing enterprise equipment, the cost is high as the whole set of equipment needs to be imported, a spraying mechanism is not provided with a flow restraining device, and the environment of working sites is poor.
Owner:LIUZHOU IRON & STEEL

Control method for electronic brake-force distribution of automobile

ActiveCN103661334AGuaranteed timingIncreased braking potentialBraking systemsControl systemInlet valve
The invention relates to a control method for electronic brake-force distribution of an automobile. The control method includes the first step of setting an EBD subsystem in a general ABS control system, wherein the EBD subsystem comprises an EBD activation trigger and judgment module, an EBD and ABS coordination control module and an EBD control logic module, the second step of determining whether functions of the EBD subsystem need to be activated in the EBD activation trigger and judgment module, the third step of determining the best trigger time of movement of an EBD after the functions are activated, the fourth step of controlling the EBD subsystem to execute corresponding movement according to ABS conditions, detected by the EBD and ABS coordination control module, of front wheels and rear wheels after the movement of the EBD is triggered, and the fifth step of determining whether to enter the EBD control logic module, wherein the EBD control logic module sets the threshold value of critical slip ratio difference values to control the rear wheels to achieve circulating brake control over switching of pressurization, pressure maintenance and pressure reduction through the adoption of a logic threshold value control method based on slip ratio control, and controls brake force over the rear wheels through the adoption of the method combining time constant control and liquid inlet valve opening control. The control method for electronic brake-force distribution of the automobile can be widely applied to the automobile braking process.
Owner:BEIJING WONDER CAREWAY AUTOMOTIVE TECH

Detection device for engine oil performance of engine

The invention provides a detection device for engine oil performance of an engine, belonging to the technical field of measurement and solving the problems of single physical and chemical parameter and incapability of scientifically and rationally judging the quality of the engine oil existing in the conventional engine oil detection method. The detection device for the engine oil performance of the engine comprises a capacitive sensor for detecting capacitance of the engine oil, an infrared sensor for detecting clarity of the engine oil, a display unit for displaying a result and a processor, wherein the processor is electrically connected with all the capacitive sensor, the infrared sensor and the display unit and can be used for analyzing signals input by the capacitive sensor and the infrared sensor and transmitting an analysis and processing result to the display unit. The physical and chemical parameters such as viscosity of the engine oil, moisture, open flash point, acid value, iron content and n-pentane insoluble substance are effectively and comprehensively evaluated by the capacitive sensor and the infrared sensor of the detection device for the engine oil performance of the engine, so that the detection device has the advantages of complete detection parameters, scientific and rational method and accurate result.
Owner:HANGZHOU BRANCH ZHEJIANG GEELY AUTOMOBILE RES INST +2

Adaptive local feeder automation fault processing method independent of network topology

InactiveCN106300285AGuaranteed timingAchieving localization and isolationEmergency protective circuit arrangementsSelf adaptiveElectricity
The invention discloses an adaptive local feeder automation fault processing method independent of a network topology. The method comprises the following processes of unified constant value setting of section switches; adaptive adjustment of constant values of the section switches: tripping a power distribution line after a fault, de-energizing and opening all section switches, adding adjustment time [delta]t to the power-on closing time of the section switches through which no fault current passes on the basis of unified constant values and ensuring a power-on closing time sequence of the section switches; fault isolation: reclosing the power distribution line, sequentially closing the section switches, when the section switch nearest to a fault point is in the fault, generating a short-circuit fault and tripping again, and locking the section switch nearest to the fault point due to the fact that the time from power-on closing to voltage-loss opening again is shorter than fault confirming time and achieving isolation of the fault point; and non-fault section power supply restoration: reclosing the power distribution line for the second time, sequentially powering on and closing the section switches which are not locked on the power distribution line and restoring non-fault section power supply of the power distribution line.
Owner:STATE GRID SHANDONG ELECTRIC POWER +1

Time-of-flight mass spectrometer electronics reading method based on pulse front edge time measurement and amplitude correction algorithm

The invention discloses a time-of-flight mass spectrometer electronics reading method which can improve time resolution and a quantitative performance of a time-of-flight mass spectrometer at the same time and is different from an electronics reading scheme of a traditional time-of-flight mass spectrometer by an ADC (Analog to Digital Converter) waveform sampling or a TDC (Time to Digital Converter) pulse time measuring. The pulse front edge time measurement and a pulse forming sampling scheme are combined; the front edge time measured by the TDC is corrected by amplitude information obtained by a middle and low speed ADC for sampling a formed pulse, so that a time resolution effect is obviously improved, and the quantitative performance of an apparatus is improved. According to the reading method, an expensive high-speed ADC (over 1G SPS (samples per second) ) chip is replaced by a pulse forming circuit and the middle and low-speed ADC (about 100M of SPS); a constant fraction discriminator (CFD) circuit in a traditional time-of-flight mass spectrometer reading electronics is replaced by utilizing direct pulse front edge screening, and apparatus cost is reduced when a performance is improved.
Owner:ANHUI USTC JIANCHENG HAISHENG TECH

Process data acquisition method, device and system

The invention provides a process data acquisition method, device and system, and aims to solve the problem that the single data acquirement and transmission adopted in the prior art lower the acquirement efficiency. The method comprises the steps as follows: receiving a batch data acquirement request; obtaining a data acquirement list corresponding to data acquirement list identification information in the request, wherein the data acquirement list includes a plurality of process data type identification information; carrying out traversal on each process data type identification information in the data acquirement list, acquiring process data corresponding to each process data type identification information one by one, and storing; and returning all of process data in batch after process data corresponding to all of process data type identification information is acquired and stored. The technical scheme provided by the invention reduces the cost of communication between a lower computer control system and a data acquirement control system, and improves the data acquirement efficiency.
Owner:BEIJING NAURA MICROELECTRONICS EQUIP CO LTD

Data caching method and device, electronic equipment and storage medium

The embodiment of the invention discloses a data caching method and device, electronic equipment and a storage medium. The data caching method comprises the steps ofwhen a data change event of a localdatabase is detected, acquiring log information generated by the local database; and analyzing the log information, and updating a local cache according to an analysis result. According to the technical scheme of the embodiment of the invention, by analyzing log information generated when a data change event of a local database occurs, the local cache is updated according to the analysis result due to the fact that the log information records the data information and the data operation information of the local database. Thetechnical problem that the user experience is poor due to the fact that the local cache is not updated in time is solved, timely updating of the local cache can be guaranteed, and the consistency of the local cache and the local data is kept.
Owner:BEIJING BYTEDANCE NETWORK TECH CO LTD

Text sentiment classification model training method and device, computer equipment and medium

The invention relates to the technical field of artificial intelligence, and provides a text sentiment classification model training method and device, computer equipment and a medium. The method comprises the following steps: obtaining a plurality of long texts, and segmenting each long text to obtain a plurality of text statements; calculating a TextRank value of each text statement in each longtext, and generating a text abstract for each long text according to the TextRank value; calculating an emotion score of each text statement in each text abstract; sorting a plurality of text statements in each text abstract according to the emotion scores, and generating a text data set according to the sorted text statements; and training a plurality of text data sets based on the pre-trainingmodel to obtain a text sentiment classification model. The sentiments of the long texts can be accurately classified, and the position information, the time sequence information and the semantic information of the original long texts are not lost.
Owner:深圳赛安特技术服务有限公司

High-speed bridge device for AHB (advanced high-performance bus) accessing on-chip SRAM (static random access memory) and operating method of high-speed bridge device

The invention discloses a high-speed bridge device for an AHB (advanced high-performance bus) accessing an on-chip SRAM (static random access memory), which comprises a register and a plus one counter; during write operation, an SRAM address, i.e. an AHB address of the previous clock cycle, which is obtained after an AHB address is stored by the register for a beat is accessed; during read operation, at the beat of returning read operation data, a predicted address which is obtained after the plus one counter adds one to the AHB address is accessed, and at the beat of incomplete read operation data transmission, the AHB address is the SRAM address, i.e., the current AHB address is accessed. The invention also discloses an operating method of the high-speed bridge device for the AHB accessing the on-chip SRAM. The invention uses the buss bridge with an address prediction mechanism to accelerate the read-write access of the high-capacity SRAM, thus increasing the operating efficiency of the whole system.
Owner:SHANDONG SINOCHIP SEMICON

Data reorganization method capable of reserving time sequence and video structuring system

The invention discloses a data reorganization method capable of reserving time sequence and a video structuring system. The data reorganization method comprises a data extraction process and a data merging process, wherein the data extraction process comprises the step of respectively extracting data related to objects in the same group from original data; and the data merging process comprises the steps of ordering and merging the data related to the objects in the same group according to the time sequence to form reorganized data with the original time sequence being reserved. Since the complexity of the algorithm provided by the invention is low, the consumed computation resources are fewer and the processing time is linearly and positively correlated to the number of input data, the algorithm is very easy to realize on software or hardware. Since the input and output results of group data have FIFO (first in first out) characteristics, the reorganized data maintains the input time sequence to a certain extent and the data reorganization method is suitable for a real-time system.
Owner:深圳市华尊科技股份有限公司

Space-time credible block chain generation method and device

The invention discloses a space-time credible block chain generation method, which comprises the following steps that: a node sends an authentication request to a CA (Certificate Authentication) center, the CA center authenticates the time and space of the node respectively, and the node after successful authentication of the time and space can be added into a block chain system; when the node generates block chain transaction information, time and position information of the node is added into the transaction information; wherein the transaction information is included in a transaction blockof a current accounting period; and the accounting node calculates the transaction information in the transaction block, and takes the time information of the accounting node as a timestamp and takesthe position information as a position stamp to be added into the transaction block. Unified time and space references are provided for a block chain system, time information and position informationof each transaction are recorded in transaction information as necessary attributes, and time information and position information of an accounting node are recorded in a transaction block as a timestamp and a position stamp respectively.
Owner:ANHUI SUN CREATE ELECTRONICS

Sampling rate conversion filter and sampling rate conversion achieving method

The invention discloses a sampling rate conversion filter and a sampling rate conversion achieving method. The filter comprises a filtering module used for conducting filtering processing on input signals, a first in first out (FIFO) module, a control module and a delay processing module. The FIFO module is used for writing signal data of each stage under control of the control module and conducting rate and clock domain conversion. The control module is used for controlling the delay processing module to read converted signal data of each stage and generating delay parameter. The delay processing module is used for reading converted signal data of each stage, adding the signal data of each stage and signal data of the previous stage subjected to position-cutting processing, multiplying the obtained sum with the delay parameter, conducting position-cutting processing on signal data obtained by multiplying and then transmitting the signal data to the next stage. Output signals are obtained till the last stage of signal data is processed. The filter reduces data processing amount through the position-cutting processing, reduces system resource occupation quantity, ensures time sequence through the FIFO unit and improves processing performance of the filter.
Owner:SANECHIPS TECH CO LTD

Method and apparatus for transmitting and acquiring uplink HARQ feedback information

The invention provides a method and apparatus for transmitting and acquiring uplink HARQ feedback information. The method includes the following steps: acquiring a business priority list; based on the business priority list, binding the HARQ feedback information of a downlink sub-frame from highest priority to lowest priority, generating to-be-transmitted HARQ feedback information; and successively designating an uplink sub-frame to the to-be-transmitted HARQ feedback information, and transmitting the to-be-transmitted HARQ feedback information to a base station. The method of transmitting uplink HARQ feedback information enables a user device to prioritize the transmission of HARQ feedback information of sub-frames having low time-delay requirements to the base station, and when the base station is informed of errors in the transmission of delay-sensitive business, enables the prioritization of re-transmission of downlink sub-frames which carry delay-sensitive business data, thus shortening the delivery of the delay-sensitive business data.
Owner:BEIJING XIAOMI MOBILE SOFTWARE CO LTD

Memory subsystem and its method for generating latch clock

ActiveCN1838310AGuaranteed timingGood for reading and writingDigital storageData signalComputer science
Methods and systems for generating a latch clock in memory reading. Data with a first logic level and with a second logic level are stored into a first address and a second address of a memory, respectively. A read data signal is generated by issuing continuous read commands for repeated retrieval of the data at the first and the second addresses of the memory. A divided frequency signal is generated by dividing a frequency of the internal clock. A phase of the divided frequency signal is adjusted according to a delay parameter by varying the delay parameter until at least an edge of the divided frequency signal is aligned with any edge of the read data signal. Finally, the latch clock is generated according to the delay parameter and the internal clock.
Owner:MEDIATEK INC

Information real-time sharing system

The invention relates to information technology and provides an information real-time sharing system, which aims to solve problems of time difference between information input and saving and inaccuracy thereof in occasions like multi-people meetings and teaching classes. According to the technical scheme, the information real-time sharing system comprises an information input display unit and at least one sharing device. The information input display unit establishes a wireless connection with each sharing device. The information input display unit is used for inputting and displaying information and transmitting currently displayed content to the sharing device in wireless connection with the information input display unit in real time. The sharing device is used for receiving the currently displayed content transmitted from the information input display unit in wireless connection with the sharing device, and displaying the content. The information real-time sharing system has the beneficial effects of guaranteeing the timeliness and accuracy of the information, improving the efficiency and being applicable to information sharing.
Owner:SICHUAN CHANGHONG EDUCATION TECH

Service message processing method and device based on service agent and electronic equipment

The embodiment of the invention provides a service message processing method based on a service agent, and relates to the field of computer networks, and the method comprises the steps: obtaining service configuration information set by a remote configuration module; monitoring the backlog state of the service message of the current message-oriented middleware and the operation load of data processing of the streaming processing framework; according to the backlog state and the operation load, constructing a capacity expansion and shrinkage operation and a new message theme of the message middleware corresponding to the capacity expansion and shrinkage operation; and sending a new service message to a new message theme of the message-oriented middleware, and performing aggregation processing on the service message according to the service configuration information by utilizing the capacity expansion and shrinkage operation corresponding to the new message theme. According to the technical scheme, the job with larger resource quantity is constructed for processing when the service message is overstocked, and the job with less resource quantity is constructed for processing when theservice message is less, so that reasonable utilization of resources in the service agent system is achieved, the service message overstocked and resource waste are avoided, and meanwhile, the resource utilization rate is improved.
Owner:GUANGZHOU HUYA TECH CO LTD

Identifier generation method, system and device based on distributed system and medium

The invention provides an identifier generation method, system and device based on a distributed system and a medium, and the method comprises the steps: obtaining one or more identifier generation requests, and enabling the identifier generation requests to comprise a business KEY value; detecting whether the number of the remaining identifiers in the current cache meets the requirements of the identifier generation request or not; when the number of the remaining identifiers in the cache meets the requirement of an identifier generation request, returning the identifiers to a requester; whenthe number of the remaining identifiers in the cache does not meet the requirement of an identifier generation request, calling a Redis INCR instruction to generate an identifier, and returning the identifier to the cache to meet the identifier generation request; and obtaining the maximum value of the sequence by utilizing the Redis INCR, reversely calculating the initial values to be sequentially increased or decreased to generate identifiers, and determining the generation quantity of the identifiers according to the quantity of the remaining identifiers in the cache and the requirements of identifier generation requests. According to the invention, the identifier generation efficiency is improved; the ID repetition phenomenon is avoided through the sequence IDs generated in sequence,and subsequent capacity expansion is facilitated.
Owner:重庆紫光华山智安科技有限公司

Rodent depression model construction device and experiment system

The invention relates to a rodent depression model construction device and an experiment system, and relates to the technical field of animal experiment methods and equipment. The rodent depression model construction device comprises a cage frame and a control mechanism, wherein a plurality of cage positions are arranged in the cage frame; a cage body used for containing an experiment animal is fixedly connected in each cage position; a vibration motor is arranged under the cage frame; the top of the vibration motor is connected with the bottom of the cage frame through vibration springs; an electric telescopic rod is also arranged at the upper part of the back surface of the cage frame; the fixed end of the electric telescopic rod is hinged to a wall; the telescopic end of a lead screw ishinged to the back surface of the cage frame; an electric control cabinet is arranged in the control mechanism; and the electric telescopic rod and the vibration motor are electrically connected withthe electric control cabinet. The consistency, the synchronism and the timing performance of experiment operation can be ensured; the operation steps of experimenters can be reduced to the maximum extent; the work efficiency is greatly improved; and the experiment quality is improved, so that the depression molding is efficiently and smoothly completed.
Owner:SHANDONG UNIV OF TRADITIONAL CHINESE MEDICINE

Message processing method and device and storage medium

The invention relates to a message processing method and device and a storage medium, and the method comprises the steps: receiving a first request message which comprises the serial number of the first request message; judging whether the serial number of the first request message and the serial number of the previous received first request message are continuous and are increased progressively or not; and if the serial number of the first request message and the serial number of the last received first request message are continuous and are increased progressively, responding to the first request message. A message processing link is prevented from being established between the message sending end and the message receiving end to guarantee the time sequence of the first request message,the complexity of an algorithm is reduced, and therefore the message processing efficiency is improved while the time sequence of the message is guaranteed.
Owner:BEIJING DAJIA INTERNET INFORMATION TECH CO LTD

Message queue processing method, medium, equipment and system

The invention provides a message queue processing method, medium, equipment and system, and the method comprises the steps: obtaining a value of a write segment index according to a partition name sent by a message production end; querying from the Hash of the write segment index according to the partition name to obtain a segment number, and splicing the partition name and the segment number to obtain a storage key name; writing the message content according to the storage key name, and determining a message time serial number entryId corresponding to the message content; writing a mark into the message content, wherein the mark is used for indicating that the message content is not synchronized between the master node and the slave node of the message queue; enabling the message queue to comprise a master node and slave nodes; judging whether the number of the written message contents reaches the preset length of the segment or not; when the number of the written message contents reaches the preset length of the segment, adding 1 to the value of the write segment index; acquiring a main node replication offset of the message queue; and returning the entryId and the main node replication offset of the message queue to the message production end. According to the technical scheme, the time sequence of message processing is ensured.
Owner:北京宇信科技集团股份有限公司
Who we serve
  • R&D Engineer
  • R&D Manager
  • IP Professional
Why Patsnap Eureka
  • Industry Leading Data Capabilities
  • Powerful AI technology
  • Patent DNA Extraction
Social media
Patsnap Eureka Blog
Learn More
PatSnap group products