mysql 프로토콜의 오류 패키지 및 분석에 대한 자세한 소개

git

https://github.com/sea-boat/mysql-protocol

개요

mysql 클라이언트와 mysql 서버 간의 상호 작용 중에 서버에 오류가 발생하여 클라이언트에 이를 알려야 하는 경우 오류 패킷을 반환합니다.

mysql 통신 메시지 구조

유형	이름	설명 th >
int	페이로드 길이	는 최하위 바이트부터 3단어로 저장됩니다. 스탠자의 페이로드와 1바이트 시퀀스 번호는 메시지 헤더로 결합됩니다.
int	일련 번호

类型	名字	描述
int5bdf4c78156c7953567bb5a0aef2fc53	payload长度	按照the least significant byte first存储，3个字节的payload和1个字节的序列号组合成报文头
intf35d6e602fd7d0f0edfa6f7d103c1b57	序列号
string	payload	报文体，长度即为前面指定的payload长度

string payload 메시지 본문, 길이는 이전에 지정된 페이로드 길이입니다. tr>

오류 패키지

페이로드

오류 코드 tr> table>자세한 내용: http://dev.mysql.com/doc/internals/en/packet-ERR_Packet.html

1. 패킷 작업 오류

오류 패키지 클래스

1. /**
    * 
    * @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>mysql error packet.</p>
    */public class ErrorPacket extends MySQLPacket {
       public static final byte header = (byte) 0xff;    
       private static final byte SQLSTATE_MARKER = (byte) &#39;#&#39;;    
       private static final byte[] DEFAULT_SQLSTATE = "HY000".getBytes();    
       public int errno;    
       public byte mark = SQLSTATE_MARKER;    
       public byte[] sqlState = DEFAULT_SQLSTATE;    
       public byte[] message;    
       public void read(byte[] data) {
           MySQLMessage mm = new MySQLMessage(data);
           packetLength = mm.readUB3();
           packetId = mm.read();
           mm.read();
           errno = mm.readUB2();        
           if (mm.hasRemaining() && (mm.read(mm.position()) == SQLSTATE_MARKER)) {
               mm.read();
               sqlState = mm.readBytes(5);
           }
           message = mm.readBytes();
       }    
       public void write(ByteBuffer buffer) {        
       int size = calcPacketSize();
           BufferUtil.writeUB3(buffer, size);
           buffer.put(packetId);
           buffer.put(header);
           BufferUtil.writeUB2(buffer, errno);
           buffer.put(mark);
           buffer.put(sqlState);
           buffer.put(message);
       }    @Override
       public int calcPacketSize() {        
       int size = 9;// 1 + 2 + 1 + 5
           if (message != null) {
               size += message.length;
           }        
           return size;
       }    
       @Override
       protected String getPacketInfo() {        
       return "MySQL Error Packet";
       }
   
   }

16진수 변환 도구

1. /**
    * 
    * @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>hex transform util.</p>
    */public class HexUtil {
       private final static byte[] hex = "0123456789ABCDEF".getBytes();    
       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();
       }
   }

오류 패키지 생성 테스트

/**
 * 
 * @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 auth packet.</p>
 */public class ErrorPacketTest {
    @Test
    public void produce() {
        ErrorPacket err = new ErrorPacket();
        err.packetId = 1;
        err.errno = 32322;
        err.message = "sorry".getBytes();
        ByteBuffer buffer = ByteBuffer.allocate(256);
        err.write(buffer);
        buffer.flip();        byte[] bytes = new byte[buffer.remaining()];
        buffer.get(bytes, 0, bytes.length);
        String result = HexUtil.Bytes2HexString(bytes);
        System.out.println(result);
        assertTrue(Integer.valueOf(result.substring(0, 2), 16) == result
                .length() / 2 - 4);

        ErrorPacket err2 = new ErrorPacket();
        err2.read(bytes);
        assertTrue(err2.errno == 32322);
        assertTrue(err2.message.length == "sorry".getBytes().length);
    }

}

위 내용은 mysql 프로토콜의 에러 패킷과 분석에 대한 자세한 소개이며, 보다 자세한 내용은 PHP 중국어 홈페이지(www.php.cn)를 참고하시기 바랍니다. !

유형

이름

설명

int td>

헤더

[ff] ERR 패킷의 헤더

int2cc198a1d5eb0d3eb508d858c9f5cbdb

error_code

Type	Name	Description
intf35d6e602fd7d0f0edfa6f7d103c1b57	header	[ff] header of the ERR packet
int2cc198a1d5eb0d3eb508d858c9f5cbdb	error_code	error-code
	if capabilities & CLIENT_PROTOCOL_41 {
string[1]	sql_state_marker	marker of the SQL State
string[5]	sql_state	SQL State
	}
string	error_message	human readable error message

기능 및 CLIENT_PROTOCOL_41 {

string[1]

sql_state_marker

SQL 상태 마커

string[ 5]

sql_state

SQL 상태

}

문자열

error_message

사람이 읽을 수 있는 오류 메시지