概况
mysql客户端登陆到mysql服务端需要一个交互的过程,这里先看服务端给客户端发送的初始握手包。如下,client通过socket连接到server指定的端口后,server将往client发送初始握手包。服务端会根据不同的服务版本和不同的配置返回不同的初始化握手包。
client server |------connect---- >| | | |<----handshake-----| | | | | | |
mysql通信报文结构
类型 | 名字 | 描述 |
---|---|---|
int<3> | payload长度 | 按照the least significant byte first存储,3个字节的payload和1个字节的序列号组合成报文头 |
int<1> | 序列号 | |
string | payload | 报文体,长度即为前面指定的payload长度 |
初始握手包
HandshakeV10协议如下
1 [0a] protocol versionstring[NUL] server version4 connection idstring[8] auth-plugin-data-part-11 [00] filler2 capability flags (lower 2 bytes) if more data in the packet:1 character set2 status flags2 capability flags (upper 2 bytes) if capabilities & CLIENT_PLUGIN_AUTH {1 length of <mark>本文来源gaodaimacom搞#^代%!码&网(</mark>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 } }
生成初始握手包
-
定义版
/** * * @author seaboat * @date 2016-09-25 * @version 1.0 * <pre><b>email: </b>[email protected]</pre> * <pre><b>blog: </b>http://www.gaodaima.com/;/pre> * <p>proxy's version.</p> */public interface Versions { byte PROTOCOL_VERSION = 10; byte[] SERVER_VERSION = "5.6.0-snapshot".getBytes();}
-
随机数工具
/** * * @author seaboat * @date 2016-09-25 * @version 1.0 * <pre><b>email: </b>[email protected]</pre> * <pre><b>blog: </b>http://www.gaodaima.com/;/pre> * <p>a random util .</p> */public class RandomUtil { private static final byte[] bytes = { '1', '2', '3', '4', '5', '6', '7', '8', '9', '0', 'q', 'w', 'e', 'r', 't', 'y', 'u', 'i', 'o', 'p', 'a', 's', 'd', 'f', 'g', 'h', 'j', 'k', 'l', 'z', 'x', 'c', 'v', 'b', 'n', 'm', 'Q', 'W', 'E', 'R', 'T', 'Y', 'U', 'I', 'O', 'P', 'A', 'S', 'D', 'F', 'G', 'H', 'J', 'K', 'L', 'Z', 'X', 'C', 'V', 'B', 'N', 'M' }; 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; }}