Method run

examples/ahp_agent_monitors_agent.py:215–230

(self)

        return {"jsonrpc": "2.0", "id": req_id, "result": result}

    def run(self):
        log("在 stdin 上监听 JSON-RPC 2.0 消息...")

        for raw_line in sys.stdin:
            line = raw_line.strip()
            if not line:
                continue
            try:
                msg = json.loads(line)
                response = self.dispatch(msg)
                if response is not None:
                    print(json.dumps(response, ensure_ascii=False), flush=True)
            except json.JSONDecodeError as e:
                log(f"JSON 解析错误: {e} | 输入: {line[:60]}")
            except Exception as e:
                log(f"调度错误: {e}")


if __name__ == "__main__":