python实现CONNECT, CONNACK 和 DISCONNECT 报文，Server 和 Client 之间能够建立、确认和断开 Session。

下面是一个简单的 Python 实现，它可以实现建立、确认和断开 Session，实现 CONNECT、CONNACK 和 DISCONNECT 报文的发送和响应。

import socket

# 定义常量
CONNECT = b'\x10\x0c\x00\x04MQTT\x04\x02\x00\x0a\x00\x16'
CONNACK = b'\x20\x02\x00\x00'
DISCONNECT = b'\xe0\x00'
BUFFER_SIZE = 1024

# 创建 socket 对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 连接服务器
server_address = ('localhost', 8888)
client_socket.connect(server_address)

# 发送 CONNECT 报文
client_socket.send(CONNECT)

# 等待 CONNACK 报文
data = client_socket.recv(BUFFER_SIZE)

# 检查是否收到 CONNACK 报文
if data == CONNACK:
    print('Received CONNACK')
else:
    print('Unexpected response')

# 发送 DISCONNECT 报文
client_socket.send(DISCONNECT)

# 关闭连接
client_socket.close()

服务器端代码：

import socket

# 定义常量
CONNECT = b'\x10\x0c\x00\x04MQTT\x04\x02\x00\x0a\x00\x16'
CONNACK = b'\x20\x02\x00\x00'
DISCONNECT = b'\xe0\x00'
BUFFER_SIZE = 1024

# 创建 socket 对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 绑定地址和端口
server_address = ('localhost', 8888)
server_socket.bind(server_address)

# 监听连接
server_socket.listen(1)

while True:
    # 等待连接
    client_socket, client_address = server_socket.accept()
    
    # 接收 CONNECT 报文
    data = client_socket.recv(BUFFER_SIZE)
    
    # 发送 CONNACK 报文
    client_socket.send(CONNACK)
    
    # 等待 DISCONNECT 报文
    data = client_socket.recv(BUFFER_SIZE)
    
    # 发送 DISCONNECT 报文
    client_socket.send(DISCONNECT)
    
    # 关闭连接
    client_socket.close()

这里同样使用了 Python 内置的 socket 库来实现。客户端和服务器端都使用了同样的常量 CONNECT、CONNACK 和 DISCONNECT，它们分别代表了 CONNECT、CONNACK 和 DISCONNECT 报文。客户端连接服务器后，发送 CONNECT 报文，服务器在收到 CONNECT 报文后，立即发送 CONNACK 报文，确认建立 Session。客户端收到 CONNACK 报文后，输出 "Received CONNACK"。接着，客户端发送 DISCONNECT 报文，服务器收到后立即发送 DISCONNECT 报文，断开 Session。