# coding:utf-8
import agentcp
if __name__ == "__main__":
print(f"\n开始:agentcp版本:{agentcp.__version__},{__file__}")
# 以当前文件夹为acp根路径
acp = agentcp.AgentCP(".", seed_password="888777")
# 创建接收者Agent
llrecv = acp.create_aid("aid.pub","name1")
@llrecv.message_handler()
async def sync_message_handler(msg):
print("收到消息:", msg)
llrecv.reply_message(msg, "hello world")
return True
llrecv.online()
# 创建发送者Agent
llsend = acp.create_aid("aid.pub","name2")
@llsend.message_handler()
async def sync_message_handler_test(msg):
llsend.reply_message(msg, "hello world")
return True
llsend.online()
# 控制台交互测试
while True:
user_input = input("请输入内容:")
llsend.quick_send_messsage_content(llrecv.id, user_input, sync_message_handler_test)