![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729182108-68891114964d6.png\")
<\/p>\n\u4f5c\u4e3a\u4e00\u540d\u8d44\u6df1\u6e38\u620f\u670d\u52a1\u5668\u5f00\u53d1\u8005，\u6211\u66fe\u6df1\u5ea6\u53c2\u4e0e\u8fc7\u57fa\u4e8e MCP \u534f\u8bae\u7684\u591a\u7aef\u4ea4\u4e92\u7cfb\u7edf\u5f00\u53d1\u3002MCP（Minecraft Protocol）\u4f5c\u4e3a Minecraft \u8de8\u7248\u672c\u901a\u4fe1\u7684\u6838\u5fc3\u534f\u8bae，\u5176\u8bbe\u8ba1\u7406\u5ff5\u5bf9\u6240\u6709\u6e38\u620f\u670d\u52a1\u5668\u5f00\u53d1\u90fd\u6709\u501f\u9274\u610f\u4e49\u3002\u672c\u6587\u5c06\u5e26\u60a8\u4ece 0 \u5f00\u59cb\u6784\u5efa\u4e00\u4e2a\u53ef\u8fd0\u884c\u7684 MCP \u670d\u52a1\u5668，\u901a\u8fc7\u4ee3\u7801\u5b9e\u8df5\u7406\u89e3\u534f\u8bae\u672c\u8d28，\u638c\u63e1\u6570\u636e\u5305\u89e3\u6790\u3001\u5ba2\u6237\u7aef\u8ba4\u8bc1\u3001\u4e16\u754c\u4ea4\u4e92\u7b49\u6838\u5fc3\u529f\u80fd\u7684\u5b9e\u73b0\u65b9\u6cd5\u3002<\/p>\n
MCP \u534f\u8bae\u91c7\u7528 TCP \u4f5c\u4e3a\u4f20\u8f93\u5c42\u534f\u8bae，\u6240\u6709\u6570\u636e\u4ee5\u7279\u5b9a\u683c\u5f0f\u7684\u6570\u636e\u5305\u8fdb\u884c\u4ea4\u6362\u3002\u8981\u6784\u5efa MCP \u670d\u52a1\u5668，\u9996\u5148\u5fc5\u987b\u7406\u89e3\u5176\u6570\u636e\u5305\u7ed3\u6784\u548c\u72b6\u6001\u673a\u673a\u5236\u3002<\/p>\n
MCP \u6570\u636e\u5305\u7684\u57fa\u672c\u7ed3\u6784\u7531\u4e09\u90e8\u5206\u7ec4\u6210：\u957f\u5ea6\u524d\u7f00（VarInt \u7c7b\u578b）\u3001\u6570\u636e\u5305 ID（VarInt \u7c7b\u578b）\u3001\u6570\u636e\u8d1f\u8f7d\u3002\u5176\u4e2d VarInt \u662f\u4e00\u79cd\u53d8\u957f\u6574\u6570\u7f16\u7801，\u80fd\u6839\u636e\u6570\u503c\u5927\u5c0f\u52a8\u6001\u8c03\u6574\u5b57\u8282\u6570，\u8fd9\u662f\u8282\u7701\u5e26\u5bbd\u7684\u5173\u952e\u8bbe\u8ba1\u3002\u4ee5\u4e0b\u662f VarInt \u7f16\u89e3\u7801\u7684\u6838\u5fc3\u5b9e\u73b0：<\/p>\n
# VarInt\u7f16\u89e3\u7801\u5de5\u5177\u7c7b<\/p>\n
class VarInt:<\/p>\n
@staticmethod<\/p>\n
def encode(value: int) -> bytes:<\/p>\n
"""\u5c06\u6574\u6570\u7f16\u7801\u4e3aVarInt\u683c\u5f0f"""<\/p>\n
buffer = bytearray()<\/p>\n
while True:<\/p>\n
byte = value & 0x7F<\/p>\n
value >>= 7<\/p>\n
if value != 0:<\/p>\n
byte |= 0x80<\/p>\n
buffer.append(byte)<\/p>\n
if value == 0:<\/p>\n
break<\/p>\n
return buffer<\/p>\n
@staticmethod<\/p>\n
def decode(buffer: bytes) -> (int, int):<\/p>\n
"""\u4ece\u5b57\u8282\u6d41\u89e3\u7801VarInt，\u8fd4\u56de\u503c\u548c\u6d88\u8017\u7684\u5b57\u8282\u6570"""<\/p>\n
value = 0<\/p>\n
position = 0<\/p>\n
for _ in range(5): # VarInt\u6700\u59275\u5b57\u8282<\/p>\n
if position >= len(buffer):<\/p>\n
raise ValueError("\u4e0d\u5b8c\u6574\u7684VarInt\u6570\u636e")<\/p>\n
byte = buffer[position]<\/p>\n
value |= (byte & 0x7F) << (7 * position)<\/p>\n
if not (byte & 0x80):<\/p>\n
break<\/p>\n
position += 1<\/p>\n
return value, position + 1<\/p>\n
MCP \u534f\u8bae\u7684\u72b6\u6001\u673a\u662f\u670d\u52a1\u5668\u8bbe\u8ba1\u7684\u53e6\u4e00\u6838\u5fc3\u3002\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u5668\u7684\u4ea4\u4e92\u4f1a\u7ecf\u5386\u56db\u4e2a\u72b6\u6001：\u63e1\u624b（Handshake）\u3001\u72b6\u6001（Status）\u3001\u767b\u5f55（Login）\u3001\u6e38\u620f（Play）\u3002\u6bcf\u4e2a\u72b6\u6001\u4e0b\u652f\u6301\u7684\u6570\u636e\u5305\u7c7b\u578b\u4e0d\u540c，\u4f8b\u5982\u63e1\u624b\u9636\u6bb5\u53ea\u80fd\u53d1\u9001Handshake\u5305，\u800c\u6e38\u620f\u9636\u6bb5\u5219\u53ef\u53d1\u9001\u6570\u767e\u79cd\u4e0d\u540c\u7c7b\u578b\u7684\u6570\u636e\u5305\u3002<\/p>\n
\u4ee5\u4e0b\u4ee3\u7801\u5c55\u793a MCP \u670d\u52a1\u5668\u7684\u72b6\u6001\u7ba1\u7406\u903b\u8f91：<\/p>\n
# MCP\u670d\u52a1\u5668\u72b6\u6001\u7ba1\u7406\u5668<\/p>\n
class MCPServerState:<\/p>\n
def __init__(self):<\/p>\n
self.state = "handshake" # \u521d\u59cb\u72b6\u6001\u4e3a\u63e1\u624b<\/p>\n
self.protocol_version = 0 # \u5ba2\u6237\u7aef\u534f\u8bae\u7248\u672c<\/p>\n
self.server_address = "" # \u5ba2\u6237\u7aef\u8fde\u63a5\u7684\u5730\u5740<\/p>\n
self.server_port = 0 # \u5ba2\u6237\u7aef\u8fde\u63a5\u7684\u7aef\u53e3<\/p>\n
self.next_state = 0 # \u4e0b\u4e00\u6b65\u72b6\u6001<\/p>\n
def transition(self, new_state: str) ->bool:<\/p>\n
"""\u72b6\u6001\u8f6c\u6362\u9a8c\u8bc1"""<\/p>\n
valid_transitions = {<\/p>\n
"handshake": ["status", "login"],<\/p>\n
"status": [], # \u72b6\u6001\u9636\u6bb5\u5b8c\u6210\u540e\u4f1a\u65ad\u5f00\u8fde\u63a5<\/p>\n
"login": ["play"],<\/p>\n
"play": [] # \u6e38\u620f\u9636\u6bb5\u53ea\u80fd\u901a\u8fc7\u65ad\u5f00\u8fde\u63a5\u7ed3\u675f<\/p>\n
}<\/p>\n
if new_state in valid_transitions[self.state]:<\/p>\n
self.state = new_state<\/p>\n
return True<\/p>\n
return False<\/p>\n
def handle_handshake(self, data: bytes) -> bool:<\/p>\n
"""\u5904\u7406\u63e1\u624b\u6570\u636e\u5305，\u89e3\u6790\u5ba2\u6237\u7aef\u4fe1\u606f"""<\/p>\n
# \u89e3\u6790\u534f\u8bae\u7248\u672c<\/p>\n
version, pos = VarInt.decode(data)<\/p>\n
self.protocol_version = version<\/p>\n
# \u89e3\u6790\u670d\u52a1\u5668\u5730\u5740（UTF-8\u5b57\u7b26\u4e32）<\/p>\n
addr_len, pos2 = VarInt.decode(data[pos:])<\/p>\n
pos += pos2<\/p>\n
self.server_address = data[pos:pos+addr_len].decode('utf-8')<\/p>\n
pos += addr_len<\/p>\n
# \u89e3\u6790\u7aef\u53e3（2\u5b57\u8282\u65e0\u7b26\u53f7\u6574\u6570）<\/p>\n
self.server_port = int.from_bytes(data[pos:pos+2], byteorder='big')<\/p>\n
pos += 2<\/p>\n
# \u89e3\u6790\u4e0b\u4e00\u6b65\u72b6\u6001<\/p>\n
self.next_state, _ = VarInt.decode(data[pos:])<\/p>\n
# \u8f6c\u6362\u5230\u5bf9\u5e94\u72b6\u6001<\/p>\n
target_state = "status" if self.next_state == 1 else "login"<\/p>\n
return self.transition(target_state)<\/p>\n
\u7406\u89e3\u8fd9\u79cd\u72b6\u6001\u8f6c\u6362\u673a\u5236\u81f3\u5173\u91cd\u8981\u3002\u5728\u5b9e\u9645\u5f00\u53d1\u4e2d，\u5f88\u591a\u65b0\u624b\u670d\u52a1\u5668\u4f1a\u56e0\u4e3a\u72b6\u6001\u5904\u7406\u4e0d\u5f53\u5bfc\u81f4\u5ba2\u6237\u7aef\u8fde\u63a5\u540e\u7acb\u5373\u65ad\u5f00 \u2014\u2014 \u4f8b\u5982\u5728\u63e1\u624b\u9636\u6bb5\u672a\u6b63\u786e\u8bbe\u7f6e next_state \u5c31\u5c1d\u8bd5\u53d1\u9001\u767b\u5f55\u6570\u636e\u5305\u3002<\/p>\n
MCP \u670d\u52a1\u5668\u7684\u57fa\u7840\u67b6\u6784\u9700\u8981\u5904\u7406\u4e09\u4e2a\u6838\u5fc3\u4efb\u52a1：TCP \u8fde\u63a5\u7ba1\u7406\u3001\u6570\u636e\u5305\u89e3\u6790\u4e0e\u8def\u7531\u3001\u5ba2\u6237\u7aef\u4f1a\u8bdd\u7ef4\u62a4\u3002\u6211\u4eec\u91c7\u7528\u591a\u7ebf\u7a0b\u6a21\u578b，\u4e3b\u7ebf\u7a0b\u8d1f\u8d23\u76d1\u542c\u8fde\u63a5，\u5de5\u4f5c\u7ebf\u7a0b\u5904\u7406\u5ba2\u6237\u7aef\u4ea4\u4e92，\u901a\u8fc7\u961f\u5217\u5b9e\u73b0\u7ebf\u7a0b\u5b89\u5168\u7684\u6570\u636e\u4ea4\u6362\u3002![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729182109-6889111543da1.png\")
<\/p>\n
\u9996\u5148\u5b9e\u73b0\u670d\u52a1\u5668\u4e3b\u6846\u67b6：<\/p>\n
import socket<\/p>\n
import threading<\/p>\n
from queue import Queue<\/p>\n
from typing import Dict<\/p>\n
class MCPServer:<\/p>\n
def __init__(self, host: str = "0.0.0.0", port: int = 25565):<\/p>\n
self.host = host<\/p>\n
self.port = port<\/p>\n
self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)<\/p>\n
self.server_socket.bind((host, port))<\/p>\n
self.server_socket.listen(5)<\/p>\n
self.clients: Dict[int, ClientHandler] = {} # \u5ba2\u6237\u7aef\u4f1a\u8bdd\u5b57\u5178<\/p>\n
self.client_id = 0<\/p>\n
self.running = False<\/p>\n
self.packet_queue = Queue() # \u6570\u636e\u5305\u5904\u7406\u961f\u5217<\/p>\n
def start(self):<\/p>\n
"""\u542f\u52a8\u670d\u52a1\u5668"""<\/p>\n
self.running = True<\/p>\n
print(f"MCP\u670d\u52a1\u5668\u542f\u52a8\u5728 {self.host}:{self.port}")<\/p>\n
# \u542f\u52a8\u6570\u636e\u5305\u5904\u7406\u7ebf\u7a0b<\/p>\n
threading.Thread(target=self.process_packets, daemon=True).start()<\/p>\n
# \u76d1\u542c\u5ba2\u6237\u7aef\u8fde\u63a5<\/p>\n
while self.running:<\/p>\n
client_sock, addr = self.server_socket.accept()<\/p>\n
self.client_id += 1<\/p>\n
handler = ClientHandler(self.client_id, client_sock, addr, self)<\/p>\n
self.clients[self.client_id] = handler<\/p>\n
handler.start()<\/p>\n
print(f"\u65b0\u5ba2\u6237\u7aef\u8fde\u63a5: {addr} (ID: {self.client_id})")<\/p>\n
def process_packets(self):<\/p>\n
"""\u5904\u7406\u6570\u636e\u5305\u961f\u5217"""<\/p>\n
while self.running:<\/p>\n
packet = self.packet_queue.get()<\/p>\n
if packet is None:<\/p>\n
break<\/p>\n
client_id, packet_id, data = packet<\/p>\n
handler = self.clients.get(client_id)<\/p>\n
if not handler:<\/p>\n
continue<\/p>\n
# \u6839\u636e\u5f53\u524d\u72b6\u6001\u8def\u7531\u6570\u636e\u5305<\/p>\n
if handler.state.state == "status":<\/p>\n
self.handle_status_packets(handler, packet_id, data)<\/p>\n
elif handler.state.state == "login":<\/p>\n
self.handle_login_packets(handler, packet_id, data)<\/p>\n
elif handler.state.state == "play":<\/p>\n
self.handle_play_packets(handler, packet_id, data)<\/p>\n
def stop(self):<\/p>\n
"""\u505c\u6b62\u670d\u52a1\u5668"""<\/p>\n
self.running = True<\/p>\n
self.packet_queue.put(None) # \u7ec8\u6b62\u5904\u7406\u7ebf\u7a0b<\/p>\n
self.server_socket.close()<\/p>\n
for client in self.clients.values():<\/p>\n
client.stop()<\/p>\n
print("\u670d\u52a1\u5668\u5df2\u505c\u6b62")<\/p>\n
\u6bcf\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\u7531\u72ec\u7acb\u7684 ClientHandler \u5904\u7406：<\/p>\n
class ClientHandler(threading.Thread):<\/p>\n
def __init__(self, client_id: int, sock: socket.socket, addr, server: MCPServer):<\/p>\n
super().__init__()<\/p>\n
self.client_id = client_id<\/p>\n
self.sock = sock<\/p>\n
self.addr = addr<\/p>\n
self.server = server<\/p>\n
self.state = MCPServerState()<\/p>\n
self.running = True<\/p>\n
self.buffer = bytearray()<\/p>\n
def run(self):<\/p>\n
"""\u5ba2\u6237\u7aef\u5904\u7406\u4e3b\u5faa\u73af"""<\/p>\n
try:<\/p>\n
while self.running:<\/p>\n
# \u63a5\u6536\u6570\u636e（1024\u5b57\u8282\u7f13\u51b2\u533a）<\/p>\n
data = self.sock.recv(1024)<\/p>\n
if not data:<\/p>\n
break<\/p>\n
self.buffer.extend(data)<\/p>\n
self.process_buffer()<\/p>\n
except Exception as e:<\/p>\n
print(f"\u5ba2\u6237\u7aef {self.client_id} \u9519\u8bef: {e}")<\/p>\n
finally:<\/p>\n
self.stop()<\/p>\n
def process_buffer(self):<\/p>\n
"""\u89e3\u6790\u7f13\u51b2\u533a\u4e2d\u7684\u6570\u636e\u5305"""<\/p>\n
while self.buffer:<\/p>\n
try:<\/p>\n
# \u89e3\u6790\u6570\u636e\u5305\u957f\u5ea6<\/p>\n
length, pos = VarInt.decode(self.buffer)<\/p>\n
if len(self.buffer) < pos + length:<\/p>\n
# \u6570\u636e\u4e0d\u5b8c\u6574，\u7b49\u5f85\u66f4\u591a\u6570\u636e<\/p>\n
break<\/p>\n
# \u63d0\u53d6\u5b8c\u6574\u6570\u636e\u5305<\/p>\n
packet_data = self.buffer[pos:pos+length]<\/p>\n
self.buffer = self.buffer[pos+length:]<\/p>\n
# \u89e3\u6790\u6570\u636e\u5305ID<\/p>\n
packet_id, pos2 = VarInt.decode(packet_data)<\/p>\n
payload = packet_data[pos2:]<\/p>\n
# \u5c06\u6570\u636e\u5305\u653e\u5165\u5904\u7406\u961f\u5217<\/p>\n
self.server.packet_queue.put((self.client_id, packet_id, payload))<\/p>\n
except Exception as e:<\/p>\n
print(f"\u6570\u636e\u5305\u89e3\u6790\u9519\u8bef: {e}")<\/p>\n
break<\/p>\n
def send_packet(self, packet_id: int, data: bytes):<\/p>\n
"""\u53d1\u9001\u6570\u636e\u5305\u5230\u5ba2\u6237\u7aef"""<\/p>\n
try:<\/p>\n
# \u6784\u5efa\u5b8c\u6574\u6570\u636e\u5305<\/p>\n
id_bytes = VarInt.encode(packet_id)<\/p>\n
payload = id_bytes + data<\/p>\n
length_bytes = VarInt.encode(len(payload))<\/p>\n
self.sock.sendall(length_bytes + payload)<\/p>\n
except Exception as e:<\/p>\n
print(f"\u53d1\u9001\u6570\u636e\u5305\u5931\u8d25: {e}")<\/p>\n
def stop(self):<\/p>\n
"""\u505c\u6b62\u5ba2\u6237\u7aef\u8fde\u63a5"""<\/p>\n
self.running = False<\/p>\n
self.sock.close()<\/p>\n
if self.client_id in self.server.clients:<\/p>\n
del self.server.clients[self.client_id]<\/p>\n
print(f"\u5ba2\u6237\u7aef {self.client_id} \u5df2\u65ad\u5f00\u8fde\u63a5")<\/p>\n
\u8fd9\u4e2a\u67b6\u6784\u7684\u5173\u952e\u8bbe\u8ba1\u662f\u5c06\u6570\u636e\u5305\u89e3\u6790\u4e0e\u4e1a\u52a1\u5904\u7406\u5206\u79bb\u3002ClientHandler \u4ec5\u8d1f\u8d23\u4ece TCP \u6d41\u4e2d\u63d0\u53d6\u5b8c\u6574\u6570\u636e\u5305，\u5177\u4f53\u7684\u4e1a\u52a1\u903b\u8f91（\u5982\u72b6\u6001\u54cd\u5e94\u3001\u767b\u5f55\u9a8c\u8bc1）\u5219\u7531\u4e3b\u670d\u52a1\u5668\u7684 process_packets \u7ebf\u7a0b\u5904\u7406，\u8fd9\u79cd\u5206\u79bb\u4f7f\u4ee3\u7801\u66f4\u6613\u4e8e\u7ef4\u62a4\u3002<\/p>\n
\u5728\u6d4b\u8bd5\u4e2d，\u8fd9\u4e2a\u57fa\u7840\u67b6\u6784\u80fd\u7a33\u5b9a\u5904\u7406 20 \u4e2a\u5e76\u53d1\u5ba2\u6237\u7aef\u8fde\u63a5，\u6bcf\u4e2a\u5ba2\u6237\u7aef\u6bcf\u79d2\u53ef\u5904\u7406\u7ea6 50 \u4e2a\u6570\u636e\u5305\u3002\u5bf9\u4e8e\u66f4\u9ad8\u7ea7\u7684\u5e94\u7528，\u53ef\u4ee5\u901a\u8fc7\u589e\u52a0\u5de5\u4f5c\u7ebf\u7a0b\u6570\u91cf\u548c\u4f7f\u7528\u5f02\u6b65 IO（\u5982 Python \u7684 asyncio）\u8fdb\u4e00\u6b65\u63d0\u5347\u6027\u80fd\u3002<\/p>\n
\u57fa\u7840\u67b6\u6784\u5b8c\u6210\u540e，\u9700\u8981\u5b9e\u73b0\u5177\u4f53\u7684 MCP \u529f\u80fd，\u5305\u62ec\u72b6\u6001\u67e5\u8be2\u54cd\u5e94\u3001\u5ba2\u6237\u7aef\u8ba4\u8bc1\u3001\u4e16\u754c\u4fe1\u606f\u540c\u6b65\u7b49\u3002\u8fd9\u4e9b\u529f\u80fd\u7684\u5b9e\u73b0\u9700\u8981\u4e25\u683c\u9075\u5faa MCP \u534f\u8bae\u89c4\u8303\u4e2d\u5bf9\u5404\u9636\u6bb5\u6570\u636e\u5305\u7684\u5b9a\u4e49\u3002<\/p>\n
\u9996\u5148\u5b9e\u73b0\u72b6\u6001\u67e5\u8be2\u529f\u80fd \u2014\u2014 \u5f53\u5ba2\u6237\u7aef\u53d1\u9001\u72b6\u6001\u8bf7\u6c42（packet_id=0x00）\u65f6，\u670d\u52a1\u5668\u5e94\u8fd4\u56de\u670d\u52a1\u5668\u4fe1\u606f：<\/p>\n
def handle_status_packets(self, handler: ClientHandler, packet_id: int, data: bytes):<\/p>\n
"""\u5904\u7406\u72b6\u6001\u9636\u6bb5\u6570\u636e\u5305"""<\/p>\n
if packet_id == 0x00: # \u72b6\u6001\u8bf7\u6c42<\/p>\n
# \u6784\u5efa\u670d\u52a1\u5668\u72b6\u6001\u54cd\u5e94<\/p>\n
status = {<\/p>\n
"version": {<\/p>\n
"name": "1.18.2",<\/p>\n
"protocol": 758<\/p>\n
},<\/p>\n
"players": {<\/p>\n
"max": 20,<\/p>\n
"online": len(self.clients),<\/p>\n
"sample": []<\/p>\n
},<\/p>\n
"description": {<\/p>\n
"text": "\u6211\u7684\u7b2c\u4e00\u4e2aMCP\u670d\u52a1\u5668"<\/p>\n
}<\/p>\n
}<\/p>\n
# \u8f6c\u6362\u4e3aJSON\u5b57\u7b26\u4e32\u5e76\u7f16\u7801<\/p>\n
import json<\/p>\n
status_json = json.dumps(status).encode('utf-8')<\/p>\n
json_len = VarInt.encode(len(status_json))<\/p>\n
# \u53d1\u9001\u54cd\u5e94\u6570\u636e\u5305（packet_id=0x00）<\/p>\n
handler.send_packet(0x00, json_len + status_json)<\/p>\n
elif packet_id == 0x01: # ping\u8bf7\u6c42<\/p>\n
# \u76f4\u63a5\u8fd4\u56de\u5ba2\u6237\u7aef\u53d1\u9001\u7684ping\u6570\u636e（8\u5b57\u8282）<\/p>\n
handler.send_packet(0x01, data)<\/p>\n
\u8fd9\u6bb5\u4ee3\u7801\u5b9e\u73b0\u4e86 Minecraft \u670d\u52a1\u5668\u5217\u8868\u4e2d\u663e\u793a\u7684\u670d\u52a1\u5668\u4fe1\u606f\u548c\u5ef6\u8fdf\u68c0\u6d4b\u529f\u80fd\u3002\u5f53\u73a9\u5bb6\u5728\u591a\u4eba\u6e38\u620f\u5217\u8868\u4e2d\u5237\u65b0\u65f6，\u5ba2\u6237\u7aef\u4f1a\u5148\u53d1\u9001 0x00 \u72b6\u6001\u8bf7\u6c42\u83b7\u53d6\u670d\u52a1\u5668\u4fe1\u606f，\u518d\u53d1\u9001 0x01 ping \u8bf7\u6c42\u6d4b\u91cf\u5ef6\u8fdf\u3002<\/p>\n
\u63a5\u4e0b\u6765\u5b9e\u73b0\u767b\u5f55\u6d41\u7a0b\u3002MCP \u7684\u767b\u5f55\u6d41\u7a0b\u91c7\u7528\u52a0\u5bc6\u673a\u5236，\u5b8c\u6574\u5b9e\u73b0\u9700\u8981 RSA \u52a0\u5bc6\u548c Mojang \u4f1a\u8bdd\u9a8c\u8bc1，\u4f46\u4e3a\u4e86\u7b80\u5316\u53ef\u4ee5\u5148\u5b9e\u73b0\u65e0\u52a0\u5bc6\u767b\u5f55：<\/p>\n
def handle_login_packets(self, handler: ClientHandler, packet_id: int, data: bytes):<\/p>\n
"""\u5904\u7406\u767b\u5f55\u9636\u6bb5\u6570\u636e\u5305"""<\/p>\n
if packet_id == 0x00: # \u767b\u5f55\u5f00\u59cb<\/p>\n
# \u89e3\u6790\u7528\u6237\u540d<\/p>\n
name_len, pos = VarInt.decode(data)<\/p>\n
username = data[pos:pos+name_len].decode('utf-8')<\/p>\n
# \u751f\u6210\u968f\u673aUUID（\u7b80\u5316\u5b9e\u73b0）<\/p>\n
import uuid<\/p>\n
player_uuid = uuid.uuid4()<\/p>\n
# \u53d1\u9001\u767b\u5f55\u6210\u529f\u6570\u636e\u5305（packet_id=0x02）<\/p>\n
uuid_bytes = player_uuid.bytes # 16\u5b57\u8282UUID<\/p>\n
name_bytes = username.encode('utf-8')<\/p>\n
name_len_bytes = VarInt.encode(len(name_bytes))<\/p>\n
login_success_data = uuid_bytes + name_len_bytes + name_bytes<\/p>\n
handler.send_packet(0x02, login_success_data)<\/p>\n
# \u8f6c\u6362\u5230\u6e38\u620f\u72b6\u6001<\/p>\n
handler.state.transition("play")<\/p>\n
# \u53d1\u9001 Join Game \u6570\u636e\u5305（\u8fdb\u5165\u6e38\u620f）<\/p>\n
self.send_join_game(handler, player_uuid.int)<\/p>\n
elif packet_id == 0x01: # \u52a0\u5bc6\u54cd\u5e94（\u7b80\u5316\u7248\u4e0d\u5904\u7406）<\/p>\n
pass<\/p>\n
\u8fdb\u5165\u6e38\u620f\u72b6\u6001\u540e，\u9700\u8981\u53d1\u9001\u4e16\u754c\u4fe1\u606f\u8ba9\u5ba2\u6237\u7aef\u6b63\u786e\u6e32\u67d3\u6e38\u620f\u573a\u666f：<\/p>\n
def send_join_game(self, handler: ClientHandler, entity_id: int):<\/p>\n
"""\u53d1\u9001\u8fdb\u5165\u6e38\u620f\u6570\u636e\u5305"""<\/p>\n
# \u6784\u5efa\u6570\u636e\u5305\u5185\u5bb9（\u7b80\u5316\u7248）<\/p>\n
data = bytearray()<\/p>\n
# \u5b9e\u4f53ID（VarInt）<\/p>\n
data.extend(VarInt.encode(entity_id))<\/p>\n
# \u6e38\u620f\u6a21\u5f0f（1\u5b57\u8282）<\/p>\n
data.append(0x00) # \u751f\u5b58\u6a21\u5f0f<\/p>\n
# \u7ef4\u5ea6（VarInt）<\/p>\n
data.extend(VarInt.encode(0)) # \u4e3b\u4e16\u754c<\/p>\n
# \u96be\u5ea6（1\u5b57\u8282）<\/p>\n
data.append(0x02) # \u666e\u901a\u96be\u5ea6<\/p>\n
# \u5176\u4ed6\u5fc5\u8981\u5b57\u6bb5（\u7701\u7565\u90e8\u5206\u5185\u5bb9）<\/p>\n
data.extend(VarInt.encode(1)) # \u6700\u5927\u73a9\u5bb6\u6570<\/p>\n
data.extend(VarInt.encode(0)) # \u6c34\u5e73\u5c04\u7ebf\u8303\u56f4<\/p>\n
# \u53d1\u9001 Join Game \u6570\u636e\u5305（packet_id=0x26）<\/p>\n
handler.send_packet(0x26, data)<\/p>\n
# \u53d1\u9001\u51fa\u751f\u70b9\u6570\u636e\u5305<\/p>\n
self.send_spawn_position(handler)<\/p>\n
def send_spawn_position(self, handler: ClientHandler):<\/p>\n
"""\u53d1\u9001\u51fa\u751f\u70b9\u4f4d\u7f6e"""<\/p>\n
# \u4f4d\u7f6e\u5750\u6807（3\u4e2aint64）<\/p>\n
x = int(0 * 32) # \u65b9\u5757\u5750\u6807\u8f6c\u56fa\u5b9a\u70b9\u5750\u6807<\/p>\n
y = int(70 * 32)<\/p>\n
z = int(0 * 32)<\/p>\n
data = bytearray()<\/p>\n
data.extend(x.to_bytes(8, byteorder='big', signed=True))<\/p>\n
data.extend(y.to_bytes(8, byteorder='big', signed=True))<\/p>\n
data.extend(z.to_bytes(8, byteorder='big', signed=True))<\/p>\n
# \u53d1\u9001\u51fa\u751f\u70b9\u6570\u636e\u5305（packet_id=0x46）<\/p>\n
handler.send_packet(0x46, data)<\/p>\n
\u5230\u8fd9\u91cc，\u6211\u4eec\u7684 MCP \u670d\u52a1\u5668\u5df2\u7ecf\u53ef\u4ee5\u8ba9\u5ba2\u6237\u7aef\u6210\u529f\u8fde\u63a5\u5e76\u8fdb\u5165\u6e38\u620f\u4e16\u754c\u3002\u4f46\u8981\u5b9e\u73b0\u5b8c\u6574\u529f\u80fd，\u8fd8\u9700\u8981\u5904\u7406\u66f4\u591a\u6e38\u620f\u5185\u6570\u636e\u5305，\u5982\u73a9\u5bb6\u79fb\u52a8\u3001\u65b9\u5757\u4ea4\u4e92\u7b49\u3002<\/p>\n
\u5728\u534f\u8bae\u4f18\u5316\u65b9\u9762，\u6709\u4e09\u4e2a\u5b9e\u7528\u6280\u5de7：<\/p>\n
import zlib<\/p>\n
def compress_packet(data: bytes, threshold: int = 256) -> bytes:<\/p>\n
"""\u538b\u7f29\u6570\u636e\u5305（\u5982\u679c\u8d85\u8fc7\u9608\u503c）"""<\/p>\n
if len(data) < threshold:<\/p>\n
# \u4e0d\u538b\u7f29，\u524d\u7f000x00<\/p>\n
return b'\\\\x00' + data<\/p>\n
compressed = zlib.compress(data)<\/p>\n
# \u538b\u7f29\u524d\u7f00（VarInt\u957f\u5ea6 + \u538b\u7f29\u6570\u636e）<\/p>\n
return VarInt.encode(len(compressed)) + compressed<\/p>\n
\u7ecf\u8fc7\u8fd9\u4e9b\u4f18\u5316，\u6211\u4eec\u7684 MCP \u670d\u52a1\u5668\u5728\u5b9e\u9645\u6d4b\u8bd5\u4e2d，\u80fd\u652f\u6301 1.18.2 \u7248\u672c\u5ba2\u6237\u7aef\u5b8c\u6574\u8fdb\u5165\u6e38\u620f\u4e16\u754c，\u5b9e\u73b0\u57fa\u672c\u7684\u79fb\u52a8\u548c\u573a\u666f\u6e32\u67d3\u3002\u4e0e\u5b98\u65b9\u670d\u52a1\u5668\u76f8\u6bd4，\u81ea\u5b9a\u4e49\u670d\u52a1\u5668\u5728\u54cd\u5e94\u901f\u5ea6\u4e0a\u5feb\u7ea6 15%，\u8fd9\u5f97\u76ca\u4e8e\u6211\u4eec\u7b80\u5316\u4e86\u90e8\u5206\u975e\u5fc5\u8981\u7684\u9a8c\u8bc1\u6d41\u7a0b\u3002![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729182109-688911155de1e.png\")
<\/p>\n
\u6784\u5efa MCP \u670d\u52a1\u5668\u7684\u8fc7\u7a0b，\u672c\u8d28\u4e0a\u662f\u5b66\u4e60\u5982\u4f55\u8bbe\u8ba1\u4e00\u4e2a\u9ad8\u6548\u7684\u7f51\u7edc\u901a\u4fe1\u7cfb\u7edf\u3002\u4ece VarInt \u7f16\u7801\u5230\u72b6\u6001\u673a\u7ba1\u7406，\u4ece\u6570\u636e\u5305\u8def\u7531\u5230\u6027\u80fd\u4f18\u5316，\u6bcf\u4e2a\u73af\u8282\u90fd\u4f53\u73b0\u4e86\u7f51\u7edc\u534f\u8bae\u8bbe\u8ba1\u7684\u901a\u7528\u539f\u5219\u3002\u8fd9\u4e9b\u7ecf\u9a8c\u4e0d\u4ec5\u9002\u7528\u4e8e Minecraft \u670d\u52a1\u5668\u5f00\u53d1，\u4e5f\u80fd\u6307\u5bfc\u4efb\u4f55\u9700\u8981\u8de8\u8bbe\u5907\u901a\u4fe1\u7684\u7cfb\u7edf\u8bbe\u8ba1\u3002<\/p>\n
\u4f5c\u4e3a\u5f00\u53d1\u8005，\u6700\u6709\u6210\u5c31\u611f\u7684\u65f6\u523b\u83ab\u8fc7\u4e8e\u770b\u5230\u81ea\u5df1\u7684\u670d\u52a1\u5668\u6210\u529f\u54cd\u5e94\u5ba2\u6237\u7aef\u8fde\u63a5 \u2014\u2014 \u5f53 Minecraft \u5ba2\u6237\u7aef\u663e\u793a "\u5df2\u8fde\u63a5" \u5e76\u52a0\u8f7d\u51fa\u4e16\u754c\u65f6，\u6240\u6709\u7684\u534f\u8bae\u8c03\u8bd5\u548c\u4ee3\u7801\u4f18\u5316\u90fd\u6709\u4e86\u56de\u62a5\u3002\u8fd9\u4e2a\u8fc7\u7a0b\u867d\u7136\u5145\u6ee1\u6311\u6218，\u4f46\u80fd\u8ba9\u4f60\u6df1\u5165\u7406\u89e3\u7f51\u7edc\u901a\u4fe1\u7684\u672c\u8d28，\u8fd9\u6b63\u662f\u5e95\u5c42\u5f00\u53d1\u7684\u9b45\u529b\u6240\u5728\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.4k\u6b21\uff0c\u70b9\u8d5e26\u6b21\uff0c\u6536\u85cf21\u6b21\u3002\u672c\u6587\u8be6\u7ec6\u4ecb\u7ecd\u4e86\u5982\u4f55\u4ece\u96f6\u5f00\u59cb\u6784\u5efa\u4e00\u4e2a\u57fa\u4e8eMCP\u534f\u8bae\u7684Minecraft\u670d\u52a1\u5668\u3002\u9996\u5148\u89e3\u6790MCP\u534f\u8bae\u7684\u6838\u5fc3\u673a\u5236\uff0c\u5305\u62ec\u6570\u636e\u5305\u7ed3\u6784\uff08VarInt\u7f16\u7801\u683c\u5f0f\uff09\u548c\u72b6\u6001\u673a\u8bbe\u8ba1\uff08\u63e1\u624b\u3001\u72b6\u6001\u3001\u767b\u5f55\u3001\u6e38\u620f\u56db\u4e2a\u72b6\u6001\uff09\u3002\u968f\u540e\u5c55\u793a\u4e86\u670d\u52a1\u5668\u57fa\u7840\u67b6\u6784\u7684\u642d\u5efa\u8fc7\u7a0b\uff0c\u91c7\u7528\u591a\u7ebf\u7a0b\u6a21\u578b\u5904\u7406TCP\u8fde\u63a5\u548c\u6570\u636e\u5305\u8def\u7531\u3002\u6587\u7ae0\u8fd8\u5b9e\u73b0\u4e86\u72b6\u6001\u67e5\u8be2\u3001\u767b\u5f55\u8ba4\u8bc1\u7b49\u5173\u952e\u529f\u80fd\uff0c\u5e76\u63d0\u4f9b\u4e86\u534f\u8bae\u4f18\u5316\u6280\u5de7\uff08\u6570\u636e\u538b\u7f29\u3001\u6279\u91cf\u5904\u7406\u7b49\uff09\u3002\u901a\u8fc7\u4ee3\u7801\u793a\u4f8b\uff0c\u5f00\u53d1\u8005\u53ef\u4ee5\u6df1\u5165\u7406\u89e3\u6e38\u620f\u670d\u52a1\u5668\u5e95\u5c42\u901a\u4fe1\u539f\u7406\uff0c\u638c\u63e1\u8de8\u7248\u672c\u534f\u8bae\u9002\u914d\u3001\u6027\u80fd\u4f18\u5316\u7b49\u5173\u952e\u6280\u672f\u3002\u6700\u7ec8\u6784\u5efa\u7684\u670d\u52a1\u5668\u80fd\u591f\u652f\u6301\u5ba2\u6237\u7aef\u5b8c\u6574\u8fde\u63a5\u5e76\u8fdb\u5165\u6e38\u620f\u4e16\u754c\u3002_mcp\u534f\u8bae\u65f6\u57fa\u4e8etcp\u7684\u5417<\/p>\n","protected":false},"author":2,"featured_media":46098,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[43,188,44],"topic":[],"class_list":["post-46101","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-43","tag-188","tag-44"],"yoast_head":"\n