首页 / MYSQL / mysql 通信协议 -- 创建连接

mysql 通信协议 -- 创建连接

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了mysql 通信协议 -- 创建连接，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含10749字，纯文字阅读大概需要16分钟。

内容图文

该文章内容根据mysql官方文档内容进行整理、验证（所有图片都摘自官网）

mysql通信协连接阶段主要内容包括：

交换客户端和服务端的信息
如果客户端设置了SSL，设置SSL通信通道
服务端根据客户端返回的数据进行用户验证

客户端开始连接服务端时，服务端可以发送ERR_Packet完成握手或发送客户端初始握手需要的数据包，在该阶段客户端还可以请求SSL连接，在身份验证之前建立SSL通信通道。

在初次握手时服务端会发送用于验证的方法，客户端根据收到的信息进行数据包组装返回，整个连接过程直到服务端返回ERR_Packet或OK_Packet结束，整个过程见下图(摘自官网)：

mysql 通信协议 -- 创建连接 - 文章图片

初次握手：

初次握手从服务器发送Protocol::Handshake数据包开始，在此之后，客户端可以请求使用Protocol::SSLRequest包建立SSL连接，或者客户端直接发送Protocol::HandshakeResponse包，下面分别介绍两种连接方式的情况

ssl 连接：

- 服务端发送Protocol::Handshake数据包
- 客户端回复Protocol::SSLRequest包
- 服务端设置ssl通道
- 客户端发送Protocol::HandshakeResponse数据包

mysql 通信协议 -- 创建连接 - 文章图片

普通连接：

- 服务端发送Protocol::Handshake数据包
- 客户端发送Protocol::HandshakeResponse数据包

握手时当然不可能都是一帆风顺的，在这途中会有各种情况发生，比如身份验证失败、密码验证方法不符合、客服端未按要求返回验证方法等，这里只介绍密码验证方法错误的情况，想详细了解见官网文档：

- 客户端连接到服务端
- 服务端发送Protocol::Handshake
- 客户端返回Protocol::HandshakeResponse
- 服务端发送Protocol::AuthSwitchRequest 告诉客户端它需要切换到新的身份验证方法。
- 客户端和服务端可能根据客户端进行身份验证的方法，要求交换更多数据包。
- 服务端发送OK_Packet或ERR_Packet数据包

mysql 通信协议 -- 创建连接 - 文章图片

可以看出该情况比一步完成连接的情况多了Protocol::AuthSwitchRequest和客户端重新回复包的两步，当然在这其中也可能继续发生该异常或其他异常，需要继续交换数据包，下面来看下Protocol::Handshake和Protocol::HandshakeResponse两个数据包的组装情况，mysql通信协议中的所有包会有4bytes的head，前3bytes记录包的大小，第4位置的1byts记录数据包的顺序id，客户端和服务端的一次协议交互直到结束，这途中所有数据包的id都是顺序增长，所以下面介绍的结构都不包含这4bytes需要先明白：

Protocol::Handshake：

mysql 通信协议 -- 创建连接 - 文章图片

图中我们可以很清楚的看到包中包含有协议版本、mysql版本、当前连接的id、默认的字符集还有一些需要交换的信息，而密码验证方法的内容分成了两个部分，这可能是出于安全考虑吧.....

Protocol::HandshakeResponse：

mysql 通信协议 -- 创建连接 - 文章图片

Response包有Protocol::HandshakeResponse320和Protocol::HandshakeResponse41，因为Protocol::HandshakeResponse320是4.1以下版本的协议包，所以只关注了Protocol::HandshakeResponse41包的内容，毕竟现在mysql使用的主流都是5.7了，更多详细内容还是看官方文档吧，毕竟篇幅有限，这里主要说下密码的加密方式，8.0默认密码验证方式为caching_sha2_password，还没来得及认真研究，这里讲讲我们普遍使用的加密方式：mysql_navicat_password：

上面看到Protocol::Handshake有发送两部分的auth-plugin-data，这两部分数据起到加密用户密码的作用，加密方式如下：

SHA1( password ) XOR SHA1( "20-bytes random data from server" <concat> SHA1( SHA1( password ) ) )

假如服务端未发送auth-plugin-data数据将只使用SHA1(password) ,如果有发送该部分数据就将结合这部分数据对密码进行加密，这样可以让嗅探工具不能直接查看到密码，起到一定的安全作用

mysql协议中连接的建立大概内容基本就这些，还是需要自己动手来验证，下面写了一个小脚本，直接看代码吧，只做了常规的步骤，过程中的各种异常并未进行处理，仅供参考：

#!/usr/bin/env python
# -*- encoding: utf-8 -*-
'''
@author: xiao cai niao
'''
import struct,sys
from socket import *
from contextlib import closing
import hashlib,os
from functools import partial

sha1_new = partial(hashlib.new, 'sha1')
SHA1_HASH_SIZE = 20
MULTI_RESULTS = 1 << 17
SECURE_CONNECTION = 1 << 15
CLIENT_PLUGIN_AUTH = 1 << 19
CLIENT_CONNECT_ATTRS = 1<< 20
CLIENT_PROTOCOL_41 = 1 << 9
CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA = 1<<21
LONG_PASSWORD = 1
LONG_FLAG = 1 << 2
PROTOCOL_41 = 1 << 9
TRANSACTIONS = 1 << 13

CAPABILITIES = (
    LONG_PASSWORD | LONG_FLAG | PROTOCOL_41 | TRANSACTIONS
    | SECURE_CONNECTION | MULTI_RESULTS
    | CLIENT_PLUGIN_AUTH | CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA | CLIENT_CONNECT_ATTRS)


CLIENT_CONNECT_WITH_DB = 9
max_packet_size = 2 ** 24 - 1
charset_id = 45


class TcpClient:
    def __init__(self,host_content,user_name,password,databases):
        _host_content = host_content.split(':')
        self.user = user_name
        self.password = password
        self.database = databases
        HOST = _host_content[0]
        PORT = int(_host_content[1])
        self.BUFSIZ = 1024
        self.ADDR = (HOST, PORT)

        self.client=socket(AF_INET, SOCK_STREAM)
        self.client.connect(self.ADDR)
        self.client.settimeout(1)

        self.server_packet_info = {}

        self.packet = None
    def header(self):
        self.offset = 0
        self.payload_length = self.packet[2] << 16 | self.packet[1] << 8 | self.packet[0]
        self.sequence_id = self.packet[3]
        self.offset += 4

    def check_packet(self):
        self.header()
        packet_header = self.packet[self.offset]
        self.offset += 1
        if packet_header == 0x00:
            print('connection ok')
        elif packet_header in (0xfe,0xff):
            print(self.packet[self.offset:])

    def Send(self):
        self.packet=self.client.recv(self.BUFSIZ)
        self.header()
        self.__read_server_info()
        self.__handshakeresponsepacket()
        response_payload = len(self.response_packet)
        self.client.send(struct.pack('<I',response_payload)[:3] + struct.pack('!B',1) + self.response_packet)

        self.packet = self.client.recv(self.BUFSIZ)
        self.header()
        packet_header = self.packet[self.offset]
        self.offset += 1
        if packet_header == 0xff:
            error_code = struct.unpack('<H', self.packet[self.offset:self.offset + 2])
            self.offset+= 2
            print(error_code,self.packet[self.offset:])
        elif packet_header == 0xfe:
            """AuthSwitchRequest"""
            _data = self.__authswitchrequest()
            self.client.send(struct.pack('<I', len(_data))[:3] + struct.pack('!B', 3) + _data)
            self.packet = self.client.recv(self.BUFSIZ)
            self.check_packet()

        elif packet_header in (0x00,0xfe):
            if self.payload_length > 7:
                print('ok packet')
            elif self.payload_length < 9:
                print('error packet')

        print(self.server_packet_info)

        """在这里停留一段时间，在mysql查看连接是否正常"""
        import time
        time.sleep(1000)


    def __authswitchrequest(self):
        end_pos = self.packet.find(b'\0', self.offset)
        auth_name = self.packet[self.offset:end_pos].decode()

        self.offset = end_pos + 1

        auth_plugin_data = self.packet[self.offset:]
        if self.server_packet_info['capability_flags'] & CLIENT_PLUGIN_AUTH and auth_name:
            data = self.__sha1_password(auth_plugin_data)

        return data


    def __read_server_info(self):
        PLUGIN_AUTH = 1 << 19
        #数据包内容
        self.server_packet_info['packet_header'] = self.packet[self.offset]
        self.offset += 1

        _s_end = self.packet.find(b'\0', self.offset)
        self.server_packet_info['server_version'] = self.packet[self.offset:_s_end]
        self.offset = _s_end + 1
        self.server_packet_info['thread_id'] = struct.unpack('<I',self.packet[self.offset:self.offset+4])
        self.offset += 4
        self.server_packet_info['auth_plugin_data'] = self.packet[self.offset:self.offset+8]
        self.offset += 8 + 1
        self.server_packet_info['capability_flags'] = struct.unpack('<H',self.packet[self.offset:self.offset+2])[0]
        self.offset += 2
        self.server_packet_info['character_set_id'],\
        self.server_packet_info['status_flags'],\
        capability_flags_2,auth_plugin_data_len = struct.unpack('<BHHB',self.packet[self.offset:self.offset+6])

        self.server_packet_info['capability_flags'] |= capability_flags_2 << 16
        self.offset += 6
        self.offset += 10
        auth_plugin_data_len = max(13,auth_plugin_data_len-8)
        if len(self.packet) - 4 >= self.offset + auth_plugin_data_len:
            # salt_len includes auth_plugin_data_part_1 and filler
            self.server_packet_info['auth_plugin_data'] += self.packet[self.offset:self.offset + auth_plugin_data_len]
            self.offset += auth_plugin_data_len

        if self.server_packet_info['capability_flags'] & PLUGIN_AUTH and len(self.packet) - 4 >= self.offset:
            _s_end = self.packet.find(b'\0',self.offset)
            self.server_packet_info['auth_plugin_name'] = self.packet[self.offset:_s_end]


    def __handshakeresponsepacket(self):
        client_flag = 0
        client_flag |= CAPABILITIES
        if self.database:
            client_flag |= CLIENT_CONNECT_WITH_DB
        server_version = (self.server_packet_info['server_version']).decode()
        if int(server_version.split('.', 1)[0]) >= 5:
            client_flag |= MULTI_RESULTS

        self.response_packet = struct.pack('<iIB23s',client_flag,max_packet_size,charset_id,b'')
        self.response_packet += self.user.encode() + b'\0'
        sha1_password = self.__sha1_password()

        if self.server_packet_info['capability_flags'] & CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA:
            self.response_packet += struct.pack('!B',len(sha1_password)) + sha1_password
        elif self.server_packet_info['capability_flags'] & SECURE_CONNECTION:
            self.response_packet += struct.pack('B',len(sha1_password)) + sha1_password
        else:
            self.response_packet += sha1_password + b'\0'

        if self.server_packet_info['capability_flags'] & CLIENT_CONNECT_WITH_DB:
            self.response_packet += self.database.encode() + b'\0'
        if self.server_packet_info['capability_flags'] & CLIENT_PLUGIN_AUTH:
            self.response_packet += b'' + b'\0'
        if self.server_packet_info['capability_flags'] & CLIENT_CONNECT_ATTRS:
            _connect_attrs = {
                '_client_name': 'pymysql',
                '_pid': str(os.getpid()),
                '_client_version': '3.6.5',
                'program_name' : sys.argv[0]
            }
            connect_attrs = b''
            for k, v in _connect_attrs.items():
                k = k.encode('utf8')
                connect_attrs += struct.pack('B', len(k)) + k
                v = v.encode('utf8')
                connect_attrs += struct.pack('B', len(v)) + v
            self.response_packet += struct.pack('B', len(connect_attrs)) + connect_attrs
    def __sha1_password(self,auth_plugin_data=None):
        _pass1 = sha1_new(self.password.encode()).digest()
        _pass2 = sha1_new(_pass1).digest()
        s = sha1_new()
        if auth_plugin_data is None:
            s.update(self.server_packet_info['auth_plugin_data'][:SHA1_HASH_SIZE])
        else:
            s.update(auth_plugin_data[:SHA1_HASH_SIZE])
        s.update(_pass2)
        t = bytearray(s.digest())
        for i in range(len(t)):
            t[i] ^= _pass1[i]

        return t

    def close(self):
        self.client.close()


with closing(TcpClient('192.168.10.12:3306','root','root','sys')) as tcpclient:
    tcpclient.Send()

技术交流Q群(479472450)及个人公众号会不定期分享学习成果：

mysql 通信协议 -- 创建连接 - 文章图片

内容总结

以上是互联网集市为您收集整理的mysql 通信协议 -- 创建连接全部内容，希望文章能够帮你解决mysql 通信协议 -- 创建连接所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/894288.html

来源：【匿名】

【上一篇】mysql01 【下一篇】用IE远程创建Mysql数据库的简易程序

更多 ►

【mysql 通信协议 -- 创建连接】教程文章相关的互联网学习教程文章

mysql创建定时任务

一、前言　　自 MySQL5.1.6起，增加了一个非常有特色的功能–事件调度器(Event Scheduler)，可以用做定时执行某些特定任务（例如：删除记录、对数据进行汇总等等），来取代原先只能由操作系统的计划任务来执行的工作。更值得一提的是MySQL的事件调度器可以精确到每秒钟执行一个任务，而操作系统的计划任务（如：Linux下的CRON或Windows下的任务计划）只能精确到每分钟执行一次。对于一些对数据实时性要求比较高的应用（例如：股票...

在mysql中创建 oracle scott 用户的四个表及插入初始化数据【代码】【图】

各表的字段的含义：（参考自：http://www.cnblogs.com/mchina/archive/2012/09/06/2649951.html） 1、部门表：dept № 名称类型描述 1 DEPTNO NUMBER(2) 表示部门编号，由两位数字所组成 2 DNAME VARCHAR2(14) 部门名称，最多由14个字符所组成 3 LOC VARCHAR2(13) 部门所在的位置 2、雇员表：emp № 名称类型描述 1 EMPNO NUMBER(4) 雇员的编号，由四位数字所组成 2 ENAME VARCHAR2(10) 雇...

MYSQL定时创建表分区【代码】

MYSQL定时创建表分区一.存储过程-表分区-----------------------------------------------------------------需求：每月创建一个分区分区名名称格式:p201201,p201202……------------------------------------------ 1CREATE DEFINER = `root`@`%` PROCEDURE `Auto_Create_Partition`(IN `databaseName` varchar(50),IN `tableName` varchar(50))2 L_END:BEGIN 3# 初始化变量4DECLARE MAX_PARTITION_DESCRIPTION VARCHAR(255) DE...

MySql分区后创建索引加速单表查询和连表查询【代码】【图】

版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。本文链接：https://blog.csdn.net/konkon2012/article/details/96482548为了加快查询，我们通常根据Where条件创建索引！那么分区后再创建索引，那就应该更快了！我们依据订单表和订单商品表举例，先创建表结构：CREATE TABLE `zstb_orders` ( `order_id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, `org_id` INT(10) UNSIGNED NOT NU...

mysql中外键的创建与删除【代码】【图】

外键的创建方法1：创建表的时候设置（外键名随机生成） 1.前提条件，必须要有一个主表，这里设为persons 2.主表中必须设置主键字段primary key，这里设为id_p//创建数据库database（test） create database if not exists test character set utf8;//创建主表（persons） create table if not exists persons(id_p int not null,lastName varchar(15) not null,firstName varchar(15) not null,address varchar(20) not nul...

mysql笔记02 创建高性能的索引

创建高性能的索引1. 索引(在MySQL中也叫做"键(key)")是存储引擎用于快速找到记录的一种数据结构。2. 索引可以包含一个或多个列的值。如果索引包含多个列，那么列的顺序也十分重要，因为MySQL只能高效低使用索引的最左前缀列。3. B-Tree索引：当人们谈论索引的时候，如果没有特别执行索引类型，那多半说是B-Tree索引，它使用B-Tree数据结构来存储数据。 1). 可以使用B-Tree索引的查询类型： a. 全职匹配：全值匹配指的是...

MySQL索引的创建、删除和查看

MySQL索引的创建、删除和查看此文转自http://blogold.chinaunix.net/u3/93470/showart_2001536.html1．索引作用在索引列上，除了上面提到的有序查找之外，数据库利用各种各样的快速定位技术，能够大大提高查询效率。特别是当数据量非常大，查询涉及多个表时，使用索引往往能使查询速度加快成千上万倍。例如，有3个未索引的表t1、t2、t3，分别只包含列c1、c2、c3，每个表分别含有1000行数据组成，指为1～1000的数值，查找对应...

PHP 创建 MySQL 表【代码】

CREATE TABLE 语句用于创建 MySQL 表。创建表前，我们需要使用 use myDB 来选择要操作的数据库：use myDB;我们将创建一个名为 "MyGuests" 的表，有 5 个列： "id", "firstname", "lastname", "email" 和 "reg_date":CREATE TABLE MyGuests (id INT(6) UNSIGNED AUTO_INCREMENT PRIMARY KEY,firstname VARCHAR(30) NOT NULL,lastname VARCHAR(30) NOT NULL,email VARCHAR(50),reg_date TIMESTAMP )上表中的注意事项:数据类型指定列可...

【mysql创建用户|删除用户|修改用户权限|常用命令】

原文链接：http://blog.csdn.net/leili0806/article/details/85736361. CREATE USER语法：CREATE USER ‘username‘@‘host‘ IDENTIFIED BY ‘password‘; 例子: CREATE USER ‘dog‘@‘localhost‘ IDENTIFIED BY ‘123456‘; CREATE USER ‘pig‘@‘192.168.1.101_‘ IDENDIFIED BY ‘123456‘; CREATE USER ‘pig‘@‘%‘ IDENTIFIED BY ‘123456‘; CREATE USER ‘pig‘@‘...

Python 使用 PyMysql、DBUtils 创建连接池，提升性能【代码】【图】

转自：https://blog.csdn.net/weixin_41287692/article/details/83413775Python 编程中可以使用 PyMysql 进行数据库的连接及诸如查询/插入/更新等操作，但是每次连接 MySQL 数据库请求时，都是独立的去请求访问，相当浪费资源，而且访问数量达到一定数量时，对 mysql 的性能会产生较大的影响。因此，实际使用中，通常会使用数据库的连接池技术，来访问数据库达到资源复用的目的。解决方案：DBUtilsDBUtils 是一套 Python 数据库连接...

mysql创建表，表中存在中文时乱码问题【图】

一、在表中操作字符编码1.创建库时指定编码：create database testdb default charset GBK2.修改库的编码： ALTER DATABASE 库名 DEFAULT CHARACTER SET utf8 COLLATE utf8_bin3.修改表的编码：ALTER TABLE 表名 DEFAULT CHARACTER SET utf8 COLLATE utf8_bin 44.修改字段的编码： ALTER TABLE 表名 CHANGE 旧字段名新字段名 VARCHAR( 45 ) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL5.查看数据库支持的所有字符集 show charac...

MySQL ODBC创建【图】

一. 创建MySQL ODBC：1. 开始菜单=>控制面板=>管理工具：注意：1). Data Source Name：就是以后代码访问ODBC的名字。具体使用参考以后分析。2). TCP/IP Server：如果有数据库服务器，请输入服务器IP，如果是本机请输入：127.0.0.13). Port：默认是3306(但是在安装MySQL的时候可能会有变化)4). User：root（My SQL的账号）5). Password：是登陆MySQL的密码6. DataBase: MySQL上面创建的数据库,如Test数据库二. 常见问题：如果您是6...

Mysql 创建权限较小的用户(只对特定数据库有操作权限)【代码】【图】

项目开发过程中，因为root的权限太大，可能对其他数据库造成修改。故创建一权限较小的用户，使其只能对特定的数据库操作，以保证数据安全。主要语句如下：createuser zang identified by‘123‘; # 设置用户 zang和密码 123grantallon bos19.*to zang; # 赋给zang用户操作bos19数据库的权限原文：http://www.cnblogs.com/zjfjava/p/6936287.html

查看mysql表结构和表创建语句的方法【代码】

首先展示一下创建数据库时的语句：mysql>create table worker( id char(11) primary key, name varchar(20), work varchar(20), part varchar(20), sex enum(‘男‘,‘女‘) not null, birth date );这是刚开始的时候创建的语句。以上为例介绍查看mysql中表结构：1.desc 表名例如：要查看worker数据表的表结构，先进入数据表所在的数据库，然后执行下面语句：mysql>desc worker;得到的结...

iReport连接Mysql创建图表报表【代码】【图】

列举一下需要的资源：1、mySql数据库安装好的2、iReport+jasperreport配置好3、我用的是Myeclipse，MySQL的驱动jar包不要忘记第一部分：创建数据库连接package com.mySqlsource;import java.sql.Connection;public class Database {private String dbUrl = "jdbc:mysql://localhost:3306/bookdb";private String dbUser="root";private String dbPwd="123456";public Database () throws Exception{Class.forName("com.mysql.jdbc...

首页 / MYSQL / mysql 通信协议 -- 创建连接

mysql 通信协议 -- 创建连接

内容导读

内容图文

内容总结

内容备注

内容手机端

【mysql 通信协议 -- 创建连接】教程文章相关的互联网学习教程文章

mysql创建定时任务

在mysql中创建 oracle scott 用户的四个表及插入初始化数据【代码】【图】

MYSQL定时创建表分区【代码】

MySql分区后创建索引加速单表查询和连表查询【代码】【图】

mysql中外键的创建与删除【代码】【图】

mysql笔记02 创建高性能的索引

MySQL索引的创建、删除和查看

PHP 创建 MySQL 表【代码】

【mysql创建用户|删除用户|修改用户权限|常用命令】

Python 使用 PyMysql、DBUtils 创建连接池，提升性能【代码】【图】

mysql创建表，表中存在中文时乱码问题【图】

MySQL ODBC创建【图】

Mysql 创建权限较小的用户(只对特定数据库有操作权限)【代码】【图】

查看mysql表结构和表创建语句的方法【代码】

iReport连接Mysql创建图表报表【代码】【图】

MYSQL - 相关标签

通信协议 - 相关标签

MYSQL - 技术教程分类

MYSQL - 最新教程

MYSQL - 最热教程