Quick Start

本案例展示了一个基于 Apache RocketMQ Lite 版本与 AgentScope 集成的演示案例，通过消息中间件实现跨 Agent 的解耦通信与事件驱动交互，支持高并发、低延迟的分布式智能体协作场景。

基本的前期准备工作

1. 部署 Apache RocketMQ

部署 Apache RocketMQ 的 LiteTopic 版本(关于开源版本，预计在2月发布)，或购买支持 LiteTopic 的 RocketMQ 商业版实例，并创建以下资源：

  • 1.1 创建接收响应请求的轻量级Topic：WorkerAgentResponse(agentscope-client用于接收响应结果)
  • 1.2 创建与WorkerAgentResponse 绑定的轻量级消费者ID：CID_HOST_AGENT_LITE(agentscope-client中用于订阅WorkerAgentResponse)
  • 1.3 创建普通Topic：LLM_TOPIC(agentscope-server用于接收请求)
  • 1.4 创建普通消费者CID：LLM_CID(agentscope-server中用于订阅LLM_TOPIC)

2. 获取大模型服务

  1. 进入阿里云百炼平台
  2. 获取对应调用服务的apiKey

运行环境

  • JDK 17 及以上
  • Maven 3.9 及以上

代码打包与示例运行

1. 编译打包

mvn clean package -Dmaven.test.skip=true -Dcheckstyle.skip=true

2. 基本参数介绍

参数名称基本介绍是否必填
rocketMQEndpointrocketmq服务接入点是
rocketMQNamespacerocketmq命名空间否
bizTopic普通Topic是
bizConsumerGroup普通消费者CID是
rocketMQAKrocketmq账号否
rocketMQSKrocketmq密码否
apiKey百炼平台调用apiKey是
workAgentResponseTopicLiteTopic是
workAgentResponseGroupIDLiteConsumer CID是

以下2个Agent进程建议分别在不同的窗口中运行

3.运行agentscope-server

cd agentscope-server/target

java -DrocketMQEndpoint= -DrocketMQNamespace= -DbizTopic=LLM_TOPIC -DbizConsumerGroup=LLM_CID -DrocketMQAK= -DrocketMQSK= -DapiKey= -jar agentscope-server-2.1.1-SNAPSHOT-jar-with-dependencies.jar

4.运行agentscope-client

cd agentscope-client/target 

java -DrocketMQNamespace= -DworkAgentResponseTopic=WorkerAgentResponse -DworkAgentResponseGroupID=CID_HOST_AGENT_LITE -DrocketMQAK= -DrocketMQSK= -jar agentscope-client-2.1.1-SNAPSHOT-jar-with-dependencies.jar

5.开始体验

启动后可在终端与agentscope构建的agent进行会话