Detailed introduction to the server handshake package of the mysql protocol and its analysis-Mysql Tutorial-php.cn

Table of Contents

mysql communication message structure

Home

Database

Mysql Tutorial

Detailed introduction to the server handshake package of the mysql protocol and its analysis

黄舟

May 12, 2018 pm 04:41 PM

Overview

Mysql client logging in to the mysql server requires an interactive process. Here we first look at the initial handshake packet sent by the server to the client. As shown below, after the client connects to the port specified by the server through the socket, the server will send an initial handshake packet to the client. The server will return different initialization handshake packets according to different service versions and different configurations.

client              
server   
|------connect---- >|
   |                   |
   |<----handshake-----|
   |                   |
   |                   |
   |                   |

Copy after login

mysql communication message structure

## stringpayloadMessage body, the length is the previously specified payload length

Type	Name	Description
int<3>	payload length	Stored according to the least significant byte first, 3-byte payload and 1-byte sequence number Combined into a message header
int<1>	sequence number

Initial handshake packet

HandshakeV10 protocol is as follows

1              [0a] protocol version
string[NUL]    server version
4              connection id
string[8]      auth-plugin-data-part-1
1              [00] filler
2              capability flags (lower 2 bytes)
  if more data in the packet:
1              character set
2              status flags
2              capability flags (upper 2 bytes)
  if capabilities & CLIENT_PLUGIN_AUTH {
1              length of auth-plugin-data
  } else {
1              [00]
  }
string[10]     reserved (all [00])
  if capabilities & CLIENT_SECURE_CONNECTION {
string[$len]   auth-plugin-data-part-2 ($len=MAX(13, length of auth-plugin-data - 8))
  if capabilities & CLIENT_PLUGIN_AUTH {
    if version >= (5.5.7 and < 5.5.10) or (>= 5.6.0 and < 5.6.2) {
string[EOF]    auth-plugin name
    } elseif version >= 5.5.10 or >= 5.6.2 {
string[NUL]    auth-plugin name
    }
  }

Copy after login

Generate initial handshake packet

Definition version

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

<b>blog: </b>http://www.php.cn/;/pre>
 * <p>proxy&#39;s version.</p>
 */public interface Versions {

    byte PROTOCOL_VERSION = 10;    byte[] SERVER_VERSION = "5.6.0-snapshot".getBytes();
}

Copy after login

Random number tool

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

<b>blog: </b>http://www.php.cn/;/pre>
 * <p>a random util .</p>
 */public class RandomUtil {
    private static final byte[] bytes = { &#39;1&#39;, &#39;2&#39;, &#39;3&#39;, &#39;4&#39;, &#39;5&#39;, &#39;6&#39;, &#39;7&#39;,            
    &#39;8&#39;, &#39;9&#39;, &#39;0&#39;, &#39;q&#39;, &#39;w&#39;, &#39;e&#39;, &#39;r&#39;, &#39;t&#39;, &#39;y&#39;, &#39;u&#39;, &#39;i&#39;, &#39;o&#39;, &#39;p&#39;,            
    &#39;a&#39;, &#39;s&#39;, &#39;d&#39;, &#39;f&#39;, &#39;g&#39;, &#39;h&#39;, &#39;j&#39;, &#39;k&#39;, &#39;l&#39;, &#39;z&#39;, &#39;x&#39;, &#39;c&#39;, &#39;v&#39;,            
    &#39;b&#39;, &#39;n&#39;, &#39;m&#39;, &#39;Q&#39;, &#39;W&#39;, &#39;E&#39;, &#39;R&#39;, &#39;T&#39;, &#39;Y&#39;, &#39;U&#39;, &#39;I&#39;, &#39;O&#39;, &#39;P&#39;,            
    &#39;A&#39;, &#39;S&#39;, &#39;D&#39;, &#39;F&#39;, &#39;G&#39;, &#39;H&#39;, &#39;J&#39;, &#39;K&#39;, &#39;L&#39;, &#39;Z&#39;, &#39;X&#39;, &#39;C&#39;, &#39;V&#39;,            
    &#39;B&#39;, &#39;N&#39;, &#39;M&#39; };    
    private static final long multiplier = 0x5DEECE66DL;    
    private static final long addend = 0xBL;    
    private static final long mask = (1L << 48) - 1;    
    private static final long integerMask = (1L << 33) - 1;    
    private static final long seedUniquifier = 8682522807148012L;    
    private static long seed;    
    static {        
    long s = seedUniquifier + System.nanoTime();
        s = (s ^ multiplier) & mask;
        seed = s;
    }    public static final byte[] randomBytes(int size) {        
    byte[] bb = bytes;        
    byte[] ab = new byte[size];        
    for (int i = 0; i < size; i++) {
            ab[i] = randomByte(bb);
        }        return ab;
    }    private static byte randomByte(byte[] b) {        
    int ran = (int) ((next() & integerMask) >>> 16);        
    return b[ran % b.length];
    }    private static long next() {        
    long oldSeed = seed;        
    long nextSeed = 0L;
        do {
            nextSeed = (oldSeed * multiplier + addend) & mask;
        } 
        while (oldSeed == nextSeed);
        seed = nextSeed;        
        return nextSeed;
    }

}

Copy after login

mysql package base class

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

<b>blog: </b>http://www.php.cn/;/pre>
 * <p>MySQLPacket is mysql&#39;s basic packet.</p>
 */public abstract class MySQLPacket {
    /**
     * none, this is an internal thread state
     */
    public static final byte COM_SLEEP = 0;    /**
     * mysql_close
     */
    public static final byte COM_QUIT = 1;    /**
     * mysql_select_db
     */
    public static final byte COM_INIT_DB = 2;    /**
     * mysql_real_query
     */
    public static final byte COM_QUERY = 3;    /**
     * mysql_list_fields
     */
    public static final byte COM_FIELD_LIST = 4;    /**
     * mysql_create_db (deprecated)
     */
    public static final byte COM_CREATE_DB = 5;    /**
     * mysql_drop_db (deprecated)
     */
    public static final byte COM_DROP_DB = 6;    /**
     * mysql_refresh
     */
    public static final byte COM_REFRESH = 7;    /**
     * mysql_shutdown
     */
    public static final byte COM_SHUTDOWN = 8;    /**
     * mysql_stat
     */
    public static final byte COM_STATISTICS = 9;    /**
     * mysql_list_processes
     */
    public static final byte COM_PROCESS_INFO = 10;    /**
     * none, this is an internal thread state
     */
    public static final byte COM_CONNECT = 11;    /**
     * mysql_kill
     */
    public static final byte COM_PROCESS_KILL = 12;    /**
     * mysql_dump_debug_info
     */
    public static final byte COM_DEBUG = 13;    /**
     * mysql_ping
     */
    public static final byte COM_PING = 14;    /**
     * none, this is an internal thread state
     */
    public static final byte COM_TIME = 15;    /**
     * none, this is an internal thread state
     */
    public static final byte COM_DELAYED_INSERT = 16;    /**
     * mysql_change_user
     */
    public static final byte COM_CHANGE_USER = 17;    /**
     * used by slave server mysqlbinlog
     */
    public static final byte COM_BINLOG_DUMP = 18;    /**
     * used by slave server to get master table
     */
    public static final byte COM_TABLE_DUMP = 19;    /**
     * used by slave to log connection to master
     */
    public static final byte COM_CONNECT_OUT = 20;    /**
     * used by slave to register to master
     */
    public static final byte COM_REGISTER_SLAVE = 21;    /**
     * mysql_stmt_prepare
     */
    public static final byte COM_STMT_PREPARE = 22;    /**
     * mysql_stmt_execute
     */
    public static final byte COM_STMT_EXECUTE = 23;    /**
     * mysql_stmt_send_long_data
     */
    public static final byte COM_STMT_SEND_LONG_DATA = 24;    /**
     * mysql_stmt_close
     */
    public static final byte COM_STMT_CLOSE = 25;    /**
     * mysql_stmt_reset
     */
    public static final byte COM_STMT_RESET = 26;    /**
     * mysql_set_server_option
     */
    public static final byte COM_SET_OPTION = 27;    /**
     * mysql_stmt_fetch
     */
    public static final byte COM_STMT_FETCH = 28;    /**
     * mysql packet length
     */
    public int packetLength;    /**
     * mysql packet id
     */
    public byte packetId;    /**
     * calculate mysql packet length
     */
    public abstract int calcPacketSize();    /**
     * mysql packet info
     */
    protected abstract String getPacketInfo();    @Override
    public String toString() {        return new StringBuilder().append(getPacketInfo()).append("{length=")
                .append(packetLength).append(",id=").append(packetId)
                .append(&#39;}&#39;).toString();
    }

}

Copy after login

Handshake package class

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

<b>blog: </b>http://www.php.cn/;/pre>
 * <p>AuthPacket means mysql initial handshake packet .</p>
 */public class HandshakePacket extends MySQLPacket {
    private static final byte[] FILLER_13 = new byte[] { 0, 0, 0, 0, 0, 0, 0,            
    0, 0, 0, 0, 0, 0 };    
    public byte protocolVersion;    
    public byte[] serverVersion;    
    public long threadId;    
    public byte[] seed;    
    public int serverCapabilities;    
    public byte serverCharsetIndex;    
    public int serverStatus;    
    public byte[] restOfScrambleBuff;    
    public void read(byte[] data) {
        MySQLMessage mm = new MySQLMessage(data);
        packetLength = mm.readUB3();
        packetId = mm.read();
        protocolVersion = mm.read();
        serverVersion = mm.readBytesWithNull();
        threadId = mm.readUB4();
        seed = mm.readBytesWithNull();
        serverCapabilities = mm.readUB2();
        serverCharsetIndex = mm.read();
        serverStatus = mm.readUB2();
        mm.move(13);
        restOfScrambleBuff = mm.readBytesWithNull();
    }    @Override
    public int calcPacketSize() {        int size = 1;
        size += serverVersion.length;// n
        size += 5;// 1+4
        size += seed.length;// 8
        size += 19;// 1+2+1+2+13
        size += restOfScrambleBuff.length;// 12
        size += 1;// 1
        return size;
    }    public void write(ByteBuffer buffer) {
        BufferUtil.writeUB3(buffer, calcPacketSize());
        buffer.put(packetId);
        buffer.put(protocolVersion);
        BufferUtil.writeWithNull(buffer, serverVersion);
        BufferUtil.writeUB4(buffer, threadId);
        BufferUtil.writeWithNull(buffer, seed);
        BufferUtil.writeUB2(buffer, serverCapabilities);
        buffer.put(serverCharsetIndex);
        BufferUtil.writeUB2(buffer, serverStatus);
        buffer.put(FILLER_13);
        BufferUtil.writeWithNull(buffer, restOfScrambleBuff);
    }    @Override
    protected String getPacketInfo() {        
    return "MySQL Handshake Packet";
    }

}

Copy after login

Server capability class

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

<b>blog: </b>http://www.php.cn/;/pre>
 * <p>server capabilities .</p>
 */public interface Capabilities {

    // new more secure passwords
    int CLIENT_LONG_PASSWORD = 1;    // Found instead of affected rows
    int CLIENT_FOUND_ROWS = 2;    // Get all column flags
    int CLIENT_LONG_FLAG = 4;    // One can specify db on connect
    int CLIENT_CONNECT_WITH_DB = 8;    // Don&#39;t allow database.table.column
    int CLIENT_NO_SCHEMA = 16;    // Can use compression protocol
    int CLIENT_COMPRESS = 32;    // Odbc client
    int CLIENT_ODBC = 64;    // Can use LOAD DATA LOCAL
    int CLIENT_LOCAL_FILES = 128;    // Ignore spaces before &#39;(&#39;
    int CLIENT_IGNORE_SPACE = 256;    // New 4.1 protocol This is an interactive client
    int CLIENT_PROTOCOL_41 = 512;    // This is an interactive client
    int CLIENT_INTERACTIVE = 1024;    // Switch to SSL after handshake
    int CLIENT_SSL = 2048;    // IGNORE sigpipes
    int CLIENT_IGNORE_SIGPIPE = 4096;    // Client knows about transactions
    int CLIENT_TRANSACTIONS = 8192;    // Old flag for 4.1 protocol
    int CLIENT_RESERVED = 16384;    // New 4.1 authentication
    int CLIENT_SECURE_CONNECTION = 32768;    // Enable/disable multi-stmt support
    int CLIENT_MULTI_STATEMENTS = 65536;    // Enable/disable multi-results
    int CLIENT_MULTI_RESULTS = 131072;

}

Copy after login

Test class

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

<b>blog: </b>http://www.php.cn/;/pre>
 * <p>test handshake packet.</p>
 */public class HandshakePacketTest {
    private final static byte[] hex = "0123456789ABCDEF".getBytes();    @Test
    public void produce() {        
    byte[] rand1 = RandomUtil.randomBytes(8);        
    byte[] rand2 = RandomUtil.randomBytes(12);        
    byte[] seed = new byte[rand1.length + rand2.length];
        System.arraycopy(rand1, 0, seed, 0, rand1.length);
        System.arraycopy(rand2, 0, seed, rand1.length, rand2.length);
        HandshakePacket hs = new HandshakePacket();
        hs.packetId = 0;
        hs.protocolVersion = Versions.PROTOCOL_VERSION;
        hs.serverVersion = Versions.SERVER_VERSION;
        hs.threadId = 1000;
        hs.seed = rand1;
        hs.serverCapabilities = getServerCapabilities();
        hs.serverCharsetIndex = (byte) (CharsetUtil.getIndex("utf8") & 0xff);
        hs.serverStatus = 2;
        hs.restOfScrambleBuff = rand2;

        ByteBuffer buffer = ByteBuffer.allocate(256);
        hs.write(buffer);
        buffer.flip();        
        byte[] bytes = new byte[buffer.remaining()];
        buffer.get(bytes, 0, bytes.length);
        String result = Bytes2HexString(bytes);
        assertTrue(Integer.valueOf(result.substring(0,2),16)==result.length()/2-4);
    }    public static String Bytes2HexString(byte[] b) {        
    byte[] buff = new byte[2 * b.length];        
    for (int i = 0; i < b.length; i++) {
            buff[2 * i] = hex[(b[i] >> 4) & 0x0f];
            buff[2 * i + 1] = hex[b[i] & 0x0f];
        }        return new String(buff);
    }    public static String str2HexStr(String str) {        
    char[] chars = "0123456789ABCDEF".toCharArray();
        StringBuilder sb = new StringBuilder("");        
        byte[] bs = str.getBytes();        
        int bit;        
        for (int i = 0; i < bs.length; i++) {
            bit = (bs[i] & 0x0f0) >> 4;
            sb.append(chars[bit]);
            bit = bs[i] & 0x0f;
            sb.append(chars[bit]);
        }        return sb.toString();
    }    protected int getServerCapabilities() {        
    int flag = 0;
        flag |= Capabilities.CLIENT_LONG_PASSWORD;
        flag |= Capabilities.CLIENT_FOUND_ROWS;
        flag |= Capabilities.CLIENT_LONG_FLAG;
        flag |= Capabilities.CLIENT_CONNECT_WITH_DB;
        flag |= Capabilities.CLIENT_ODBC;
        flag |= Capabilities.CLIENT_IGNORE_SPACE;
        flag |= Capabilities.CLIENT_PROTOCOL_41;
        flag |= Capabilities.CLIENT_INTERACTIVE;
        flag |= Capabilities.CLIENT_IGNORE_SIGPIPE;
        flag |= Capabilities.CLIENT_TRANSACTIONS;
        flag |= Capabilities.CLIENT_SECURE_CONNECTION;        
        return flag;
    }

}

Copy after login

The above is the detailed content of Detailed introduction to the server handshake package of the mysql protocol and its analysis. For more information, please follow other related articles on the PHP Chinese website!

Statement of this Website

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress images for free

Clothoff.io

AI clothes remover

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

Assassin's Creed Shadows: Seashell Riddle Solution

3 weeks ago By DDD

What's New in Windows 11 KB5054979 & How to Fix Update Issues

2 weeks ago By DDD

Where to find the Crane Control Keycard in Atomfall

3 weeks ago By DDD

Saving in R.E.P.O. Explained (And Save Files)

1 months ago By 尊渡假赌尊渡假赌尊渡假赌

Assassin's Creed Shadows - How To Find The Blacksmith And Unlock Weapon And Armour Customisation

4 weeks ago By DDD

Hot Tools

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

God-level code editing software (SublimeText3)

Hot Topics

Where is the login entrance for gmail email?

7564

CakePHP Tutorial

1386

What is the format of the account name of steam

win11 activation key permanent

nyt connections hints and answers

Related knowledge

MySQL: Simple Concepts for Easy Learning Apr 10, 2025 am 09:29 AM

MySQL is an open source relational database management system. 1) Create database and tables: Use the CREATEDATABASE and CREATETABLE commands. 2) Basic operations: INSERT, UPDATE, DELETE and SELECT. 3) Advanced operations: JOIN, subquery and transaction processing. 4) Debugging skills: Check syntax, data type and permissions. 5) Optimization suggestions: Use indexes, avoid SELECT* and use transactions.

How to open phpmyadmin Apr 10, 2025 pm 10:51 PM

You can open phpMyAdmin through the following steps: 1. Log in to the website control panel; 2. Find and click the phpMyAdmin icon; 3. Enter MySQL credentials; 4. Click "Login".

MySQL: An Introduction to the World's Most Popular Database Apr 12, 2025 am 12:18 AM

MySQL is an open source relational database management system, mainly used to store and retrieve data quickly and reliably. Its working principle includes client requests, query resolution, execution of queries and return results. Examples of usage include creating tables, inserting and querying data, and advanced features such as JOIN operations. Common errors involve SQL syntax, data types, and permissions, and optimization suggestions include the use of indexes, optimized queries, and partitioning of tables.

Why Use MySQL? Benefits and Advantages Apr 12, 2025 am 12:17 AM

MySQL is chosen for its performance, reliability, ease of use, and community support. 1.MySQL provides efficient data storage and retrieval functions, supporting multiple data types and advanced query operations. 2. Adopt client-server architecture and multiple storage engines to support transaction and query optimization. 3. Easy to use, supports a variety of operating systems and programming languages. 4. Have strong community support and provide rich resources and solutions.

How to use single threaded redis Apr 10, 2025 pm 07:12 PM

Redis uses a single threaded architecture to provide high performance, simplicity, and consistency. It utilizes I/O multiplexing, event loops, non-blocking I/O, and shared memory to improve concurrency, but with limitations of concurrency limitations, single point of failure, and unsuitable for write-intensive workloads.

MySQL and SQL: Essential Skills for Developers Apr 10, 2025 am 09:30 AM

MySQL and SQL are essential skills for developers. 1.MySQL is an open source relational database management system, and SQL is the standard language used to manage and operate databases. 2.MySQL supports multiple storage engines through efficient data storage and retrieval functions, and SQL completes complex data operations through simple statements. 3. Examples of usage include basic queries and advanced queries, such as filtering and sorting by condition. 4. Common errors include syntax errors and performance issues, which can be optimized by checking SQL statements and using EXPLAIN commands. 5. Performance optimization techniques include using indexes, avoiding full table scanning, optimizing JOIN operations and improving code readability.

MySQL's Place: Databases and Programming Apr 13, 2025 am 12:18 AM

MySQL's position in databases and programming is very important. It is an open source relational database management system that is widely used in various application scenarios. 1) MySQL provides efficient data storage, organization and retrieval functions, supporting Web, mobile and enterprise-level systems. 2) It uses a client-server architecture, supports multiple storage engines and index optimization. 3) Basic usages include creating tables and inserting data, and advanced usages involve multi-table JOINs and complex queries. 4) Frequently asked questions such as SQL syntax errors and performance issues can be debugged through the EXPLAIN command and slow query log. 5) Performance optimization methods include rational use of indexes, optimized query and use of caches. Best practices include using transactions and PreparedStatemen

How to build a SQL database Apr 09, 2025 pm 04:24 PM

Building an SQL database involves 10 steps: selecting DBMS; installing DBMS; creating a database; creating a table; inserting data; retrieving data; updating data; deleting data; managing users; backing up the database.

See all articles