最近很火的MCP是什么？

#连接SQLite数据库仅需定义查询函数+启动HTTP服务import sqlite3import sqlite3import jsonfrom http.server import BaseHTTPRequestHandler, HTTPServerfrom urllib.parse import urlparse, parse_qsclass SecureMCPService(BaseHTTPRequestHandler):    """增强版MCP协议服务端，支持参数化查询和错误处理"""    def _set_headers(self, status_code=200):        """设置HTTP响应头"""        self.send_response(status_code)        self.send_header('Content-type', 'application/json')        self.end_headers()    def _parse_request(self):        """解析请求参数"""        content_length = int(self.headers['Content-Length'])        raw_data = self.rfile.read(content_length).decode()        try:            return json.loads(raw_data)        except json.JSONDecodeError:            return None    def _execute_safe_query(self, query, params=None):        """安全执行数据库查询"""        try:            with sqlite3.connect('example.db') as conn:                cursor = conn.cursor()                cursor.execute(query, params or ())                if query.strip().upper().startswith('SELECT'):                    columns = [col[0] for col in cursor.description]                    return [dict(zip(columns, row)) for row in cursor.fetchall()]                else:                    conn.commit()                    return {"affected_rows": cursor.rowcount}        except sqlite3.Error as e:            return {"error": f"Database error: {str(e)}"}    def do_POST(self):        """处理POST请求"""        parsed_path = urlparse(self.path)        # 路由处理        if parsed_path.path == '/api/query':            request_data = self._parse_request()            if not request_data or 'statement' not in request_data:                self._set_headers(400)                self.wfile.write(json.dumps({"error": "Invalid request"}).encode())                return            # 执行安全查询            result = self._execute_safe_query(                request_data['statement'],                 request_data.get('parameters')            )            self._set_headers()            self.wfile.write(json.dumps(result).encode())        else:            self._set_headers(404)            self.wfile.write(json.dumps({"error": "Endpoint not found"}).encode())def start_server(port=8080):    """启动安全HTTP服务器"""    server_address = ('', port)    httpd = HTTPServer(server_address, SecureMCPService)    print(f'MCP服务运行中，监听端口：{port}')    try:        httpd.serve_forever()    except KeyboardInterrupt:        httpd.server_close()        print('n服务已停止')if __name__ == '__main__':    # 初始化示例数据库    with sqlite3.connect('example.db') as conn:        conn.execute('''CREATE TABLE IF NOT EXISTS users                         (id INTEGER PRIMARY KEY, name TEXT, email TEXT)''')        conn.commit()    start_server()