MetaGPT 核心模块时序图集

sequenceDiagram
    participant Env as Environment
    participant Role as Role
    participant Memory as Memory
    participant LLM as LLM Provider
    participant Action as Action
Env->>Role: run()
Role->>Role: _observe()
Role->>Role: msg_buffer.pop_all()
Role->>Role: 过滤感兴趣消息
Role->>Memory: add_batch(news)

alt 有新消息
    Role->>Role: _think()
    alt 单一动作
        Role->>Role: _set_state(0)
    else 多动作-按顺序
        Role->>Role: _set_state(state+1)
    else 多动作-LLM选择
        Role->>LLM: aask(state_prompt)
        LLM-->>Role: next_state
        Role->>Role: _set_state(next_state)
    end
    
    Role->>Role: _act()
    Role->>Action: run(history)
    Action->>LLM: aask(prompt)
    LLM-->>Action: response
    Action-->>Role: AIMessage
    Role->>Memory: add(message)
    Role->>Env: publish_message(response)
else 无新消息
    Role-->>Env: None (idle)
end</pre>
</details>

sequenceDiagram
    participant Action as Action
    participant Node as ActionNode
    participant LLM as LLM Provider
    participant Parser as OutputParser
    participant Model as PydanticModel
Action->>Node: fill(req, llm, schema, mode)
Node->>Node: set_llm(llm)
Node->>Node: set_context(req)

alt schema == "raw"
    Node->>LLM: aask(raw_prompt)
    LLM-->>Node: content
    Node->>Node: self.content = content
else 结构化输出
    Node->>Node: compile(context, schema, mode)
    Node->>Node: compile_instruction()
    Node->>Node: compile_example()
    Node->>Node: get_mapping(mode)
    
    Node->>Node: _aask_v1(prompt, class_name, mapping)
    Node->>LLM: aask(prompt)
    LLM-->>Node: raw_content
    
    alt schema == "json"
        Node->>Parser: llm_output_postprocess(content, schema)
    else schema == "markdown"
        Node->>Parser: parse_data_with_mapping(content, mapping)
    end
    
    Parser-->>Node: parsed_data
    Node->>Model: create_model_class(class_name, mapping)
    Model-->>Node: output_class
    Node->>Node: output_class(**parsed_data)
    Node->>Node: self.instruct_content = instance
end

Node-->>Action: self</pre>
</details>

sequenceDiagram
    participant Role1 as 发送角色
    participant Env as Environment
    participant Role2 as 接收角色1
    participant Role3 as 接收角色2
    participant History as History
Role1->>Env: publish_message(message)
Env->>Env: 检查 message.send_to

loop 遍历所有角色
    Env->>Env: is_send_to(message, role.addresses)
    alt 地址匹配
        Env->>Role2: put_message(message)
        Role2->>Role2: msg_buffer.push(message)
    else 地址不匹配
        Env->>Role3: (跳过)
    end
end

Env->>History: add(message)
Env-->>Role1: True (发送成功)

Note over Env: 如果没有找到接收者，记录警告日志</pre>
</details>