base_agent.cpython-310.pyc•9.45 kB
o
�$�g;7 � @ sr d Z ddlZddlZddlZddlmZmZmZmZm Z m
Z
ddl Z ddl m
Z
ejejdd� G dd� d�ZdS ) u
基础智能体类
� N)�Dict�Any�Callable� Coroutine�Optional�List)�
MCPMessagez4%(asctime)s - %(name)s - %(levelname)s - %(message)s)�level�formatc @ s\ e Zd ZdZdedededefdd�Zdedeeee f fd d
�Z
d d � Z d
d� Z dededefdd�Z
defdd�Zdd� Zdd� Zdedeee f fdd�Zded eeee f gef fd d �Zdeee f fd d �Zdeee f fd!d"�Zdeee f fd#d$�Zdeee f fd%d&�Zdefd'd(�Zd)d*� Zdee fd+d,�Z dede fd-d.�Z d/S )0� BaseAgentu 基础智能体类�agent_id�
agent_type�host�portc C sL || _ || _|| _|| _t�d|� ��| _i | _i | _d | _ d| _
i | _ d S )NzAgent:F) r r
r r �logging� getLogger�logger� connections�message_handlers�server�
is_running�agent_addresses)�selfr r
r r � r �5D:\DeepSeek\MCPAgent\mcpTest\src\agents\base_agent.py�__init__ s
zBaseAgent.__init__�returnc C sv || j v r
|| j | d�S || jv r| j| S ddd�ddd�ddd�ddd�d�}||v r9|| | j|< || S d S )
u 获取智能体的地址信息)r �
connection� localhostiJ )r r iK iL iM )�brain�eye�ear�mouthN)r r )r r Zdefault_addressesr r r �get_agent_address s
�zBaseAgent.get_agent_addressc � sv �d| _ t�| j| j| j�I dH | _| j�d| j � d| j� d| j� �� | �
d| j � | �
d| j � | �
d| j
� dS ) u 启动智能体服务器TN�Agent z started on �:�text�command�status)r �
websockets�serve�_handle_connectionr r r r �infor �register_handler�_handle_text_message�_handle_command_message�_handle_status_message�r r r r �start7 s � �$zBaseAgent.startc � sB �| j r| j �� | j �� I dH d| _| j�d| j� d�� dS )u 停止智能体服务器NFr$ z stopped)r �close� wait_closedr r r, r r1 r r r �stopD s �
zBaseAgent.stopc � s �d}d}t |�D ]�}zJd|� d|� �}tj|ddd�I dH }|| j|< | j�d |� d
|� �� d | j|d d
| jid�d�} |�t �
| ��I dH t � | �
||�� W dS ty� }
z(| j�d|d � d|� d|� d|
� �� ||d k rt �|�I dH W Y d}
~
q d}
~
ww dS )u 连接到其他智能体� � zws://r% � �
)Z
ping_intervalZ ping_timeoutNzConnected to agent z at r( � connectedr
�r( �details�� message_type� sender_id� receiver_id�contentTzAttempt � �/z failed to connect to agent �: F)�ranger) �connectr r r, r r
�send�json�dumps�asyncio� create_task�_receive_messages� Exception�error�sleep) r r r r Z max_retriesZ retry_delayZattempt�urir �
status_msg�er r r �connect_to_agentL s> � �
��� ( ��zBaseAgent.connect_to_agentc
� s� � z|� � I dH }| �|�I dH W nY tjjyG | j�d|� d�� || jv r/| j|= | �|| j | j
�I dH rD| j�d|� �� Y dS t yl } z| j� d|� d|� �� t
�d�I dH W Y d}~nd}~ww q) u! 接收来自特定连接的消息TNzConnection to agent z closedzReconnected to agent z Error receiving messages from rD rB )�recv�_process_messager) �
exceptions�ConnectionClosedr r, r rS r r rM rN rJ rO )r r r �messagerR r r r rL t s$ �
���zBaseAgent._receive_messagesc
� st �zo|� � I dH }t�|�}|�d�dkr^|�di ��d�dkr^|�d�}|| j|< | j�d|� d�� d| j|d d
| jid �d �}|� t�
|��I dH |� � I dH }| � |�I dH qN| j� d|� �� |�
� I dH W dS tjjy� t| j�� �D ]\}}||kr�| j|= | j�d|� d�� Y dS q�Y dS ty� } z| j�d| � �� W Y d} ~ dS d} ~ ww )u 处理新的WebSocket连接Nr> r( rA r: r? r$ z
connected�acceptedr
r; r= Tz%Received invalid connection message: �
disconnectedzError handling connection: )rT rH �loads�getr r r, r r
rG rI rU �warningr3 r) rV rW �list�itemsrM rN )
r � websocket�pathrX �datar? �responser �connrR r r r r+ � sF �
$
��� ��� ��z BaseAgent._handle_connectionc
� s� �z0t |t�r
t�|�}n|}|�d�}|| jv r&| j| |�I dH W dS | j�d|� �� W dS tyM } z| j� d|� �� W Y d}~dS d}~ww )u 处理接收到的消息r> Nz No handler for message type: zError processing message: )
�
isinstance�strrH r[ r\ r r r] rM rN )r � message_datarb r> rR r r r rU � s �
��zBaseAgent._process_messager@ rX c
� s� �z�| � |�}|s| j�d|� �� W dS t|t�r |�� }n t|t�r;d|vr-| j|d< d|vr5||d< t� |�}n|}|| j
v rrz| j
| � |�I dH W W dS t yq } z| j�d|� d|� �� W Y d}~W dS d}~ww d |v r�d
|v r�| j�
d |� d |d � d
|d
� d�� | �||d |d
�I dH r�| �||�I dH W S | j�d|� �� W dS | j�d|� d�� W dS t y� } z| j�d|� �� W Y d}~dS d}~ww )u 发送消息到指定智能体u 未找到智能体: Fr? r@ NTzError sending message to rD r r u 尝试连接到智能体 z (r% �)u 无法连接到智能体 zNo connection to agent z and no address informationu 发送消息失败: )r# r rN re r Zto_json�dictr rH rI r rG rM r, rS � send_messager] )r r@ rX �receiverrg rR r r r rj � sJ �
��( ��zBaseAgent.send_messager> �handlerc C s || j |< | j�d|� �� dS )u 注册消息处理器z%Registered handler for message type: N)r r r, )r r> rl r r r r- � s
zBaseAgent.register_handlerc � s. �| j �d|d � d|d �dd�� �� dS )u! 处理文本消息的默认方法zReceived text message from r? rD rA r& � N)r r, r\ )r rX r r r r. � s �,z BaseAgent._handle_text_messagec � s2 �|d � dd�}| j�d|d � d|� �� dS )u! 处理命令消息的默认方法rA r' rm zReceived command from r? rD N)r\ r r, )r rX r' r r r r/ � s � z!BaseAgent._handle_command_messagec � s� �|d � dd�}| j�d|d � d|� �� |dkr4| j�d|d � d |d � d
i �� d �� �� dS |d krE| j�d
|d � �� dS |dkrd|d | jv rV| j|d = | j�d|d � d�� dS dS )u! 处理状态消息的默认方法rA r( rm z Received status update from r? rD r: r$ z connected with type: r< r
rY zConnection accepted by � disconnectedrZ N)r\ r r, r )r rX r( r r r r0 s � � �z BaseAgent._handle_status_messagec � s6 �g }| j D ]}| �||�I dH }|�||f� q|S )u' 广播消息到所有连接的智能体N)r rj �append)r rX �resultsr �resultr r r �broadcast_message s �
zBaseAgent.broadcast_messagec
� s� �|| j v rVz0d| j|dddid�d�}| �||�I dH | j | �� I dH | j |= | j�d|� �� W d S tyU } z| j�d
|� d |� �� W Y d}~d S d}~ww d S )
u! 断开与指定智能体的连接r( rn �reasonZclient_disconnectr; r= NzDisconnected from agent Tz Error disconnecting from agent rD F)r r rj r3 r r, rM rN )r r rQ rR r r r �disconnect_from_agent s, �
��� ��z BaseAgent.disconnect_from_agentc � s@ �t | j�� �}g }|D ]}| �|�I dH }|�||f� q |S )u! 断开与所有智能体的连接N)r^ r �keysrt ro )r Z agent_idsrp r rq r r r �disconnect_all5 s �zBaseAgent.disconnect_allc C s t | j�� �S )u) 获取所有已连接的智能体ID列表)r^ r ru r1 r r r �get_connected_agents> s z BaseAgent.get_connected_agentsc C s
|| j v S )u* 检查是否与指定智能体保持连接)r )r r r r r �is_connected_toB s
zBaseAgent.is_connected_toN) �__name__�
__module__� __qualname__�__doc__rf �intr r r r r# r2 r5 rS rL r+ rU rj r r r- r. r/ r0 rr rt rv r rw �boolrx r r r r r s(
(+$0 r )r| rJ rH r �typingr r r r r r r) �src.utils.mcp_protocolr � basicConfig�INFOr r r r r �<module> s �