How to start Receiver

This article mainly explains "how to start Receiver". The content in the article is simple and clear, easy to learn and understand. Please follow the editor's train of thought to study and learn "how to start Receiver".

Receiver is started through the start method of ReceiverSupervisor:

The onStart () method of ReceiverSupervisor is called first

RegisteredBlockGenerators is assigned when ReceiverSupervisor is instantiated:

Call the start method of BlockGenerator

BlockIntervalTimer is a timer, and the updateCurrentBuffer function is called when the time comes.

The timer will keep calling this method.

By default, the changed thread will run every 200 milliseconds.

TriggerActionForNextInterval will call the following callback method:

The data received during the current time period will be subpackaged as a block and added to the queue.

Let's take another look.

You can see that the pushBlocak method is called every 10 milliseconds

This method is called to the listener

The data will be sent to receivedBlockHandler for storage, and the metadata information of the saved data will be reported to receiverTracker.

ReceivedBlockHandler has two ways to save data, one is to pre-write the log, and the other is to store it directly.

Thank you for your reading, the above is the content of "how to start Receiver". After the study of this article, I believe you have a deeper understanding of how to start Receiver, and the specific use needs to be verified in practice. Here is, the editor will push for you more related knowledge points of the article, welcome to follow!