Transmission method and device of data

Abstract

The invention discloses a transmission method and device of data, relates to the field of internet technology, and mainly aims to solve problems that in the prior art, a Flume system collects log data, and if MemoryChannel is adopted for storing the data, an overflow anomaly exists when speed of writing of the received log data is greater than speed of removing log data and overstocked data in theMemoryChannel are too much; and if FileChannel is adopted for storing the data, performance of log-data writing or removing is lower. The technical solution of the invention includes: monitoring writing speed of data in preset storage space and removing speed of data; respectively transferring data in the preset storage space to first storage space and second storage space if the writing speed ofthe data is greater than the removing speed of the data and data occupancy space in the preset storage space exceeds an overflow risk threshold value; and transmitting the data in the first storage space to an external memory, and transmitting the same to the second storage space by the external memory.

Description

technical field [0001] The invention relates to the technical field of the Internet, in particular to a data transmission method and device. Background technique [0002] With the rapid development of Internet technology, more and more users are more inclined to use the Internet for daily life. For example: the user plays a video through a video player or directly uses a web page, and so on. At present, during the video playing process, the video player or the webpage will record the real-time data of the currently playing video, and send the generated real-time log data to the server, so that the server can analyze the currently playing video in real time according to the real-time log data. Due to the large and scattered data volume of real-time log data, in specific applications, the server often collects real-time log data through Flume, among which Flume is a highly available, highly reliable, distributed massive log collection, aggregation and transmission platform s...

AI Technical Summary

Problems solved by technology

The second type, FileChannel, is a channel established in the external storage of Flume; since the channel of the FileChannel type is located in the external storage, it has a large storage space and stores a large amount of real-time log data.

[0004] In the process of implementing the above invention, the inventor found that when using Flume in the prior art, in order to maintain the high efficiency of Flume transmission performance, the first type of MemoryChannel above can be used to process real-time log data; however, due to the limited server memory The number of real-time log data stored in MemoryChannel is limited. When the speed of receiving real-time log data is faster than the speed of moving out real-time log data in MemoryChannel, memory overflow exceptions are likely to occur

In order to ensure that the Flume system does not experience memory overflow exceptions, the second type above can be used to process real-time log data using FileChannel. FileChannel is built on an external memory and has a large capacity for storing real-time log data; however, due to the external memory The reading and writing efficiency of the system is lower than that of the memory, which reduces the speed of writing or removing real-time log data in the FileChannel in the external storage, which reduces the performance of the entire Flume system in processing real-time log data.

Images