DBLE Network Module Source Code Analysis: How DBLE Handles MySQL Packets

This article continues the series on DBLE by examining the network module from a source‑code perspective. It explains how DBLE processes MySQL packets, implements I/O multiplexing with Java Selector , and handles requests asynchronously to achieve high performance.

1. Handling client connect – The client connection is accepted in public void run() of NIOAcceptor , where the selector polls for accept events and calls accept() . The accept() method creates a FrontendConnection , registers it with a NIOReactor , and posts the registration.

public void run() { ... }

private void accept() { ... }

2. Server sends handshake packet – After registration, NIOReactor#postRegister enqueues the connection and wakes up the selector. The RW#register method registers the channel with the selector and invokes AbstractConnection#register , which eventually calls MySQLFrontAuthService#register . The greeting() method builds a MySQL handshake packet and writes it to the client.

void postRegister(AbstractConnection c) { ... }

private void greeting() { ... hs.write(connection); }

3. Processing client handshake reply – Incoming data is read in RW#run , which selects readable keys and calls con.asyncRead() . NIOSocketWR#asyncRead reads bytes into a buffer and forwards them to AbstractConnection#onReadData , which eventually reaches AbstractService#handle . The handler parses the packet, creates a task, and queues it for asynchronous processing.

public void run() { ... keys = finalSelector.selectedKeys(); ... executeKeys(keys); }

public void asyncRead() throws IOException { ... int got = channel.read(theBuffer); con.onReadData(got); }

4. Asynchronous task execution and OK packet – The task is processed by AbstractService#execute , which calls handleData . For the handshake reply, MySQLFrontAuthService#handleAuthPacket reads the AuthPacket , validates credentials, and finally sends an OK packet via OkPacket .

public void execute(ServiceTask task) { task.increasePriority(); handleData(task); }

private void handleAuthPacket(byte[] data) { AuthPacket auth = new AuthPacket(); auth.read(data); auth(); }

The article concludes that DBLE’s high‑performance network I/O relies on Java NIO selectors for multiplexing and a task‑based asynchronous model to process MySQL protocol packets efficiently.