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

git

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

개요

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

mysql 통신 메시지 구조

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

类型	名字	描述
int<3>	payload长度	按照the least significant byte first存储，3个字节的payload和1个字节的序列号组合成报文头
int<1>	序列号
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 패킷의 헤더

int<2>

error_code

Type	Name	Description
int<1>	header	[ff] header of the ERR packet
int<2>	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

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