boot整合AgentScope智能体

<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.5.13</version><relativePath/><!-- lookup parent from repository --></parent><groupId>com.testaidemo</groupId><artifactId>testAgentScopeDemo</artifactId><version>0.0.1-SNAPSHOT</version><name>testAgentScopeDemo</name><description>testAgentScopeDemo</description><properties><java.version>17</java.version><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.18.0</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-collections4</artifactId><version>4.5.0</version></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.20.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>2.0.47</version></dependency><dependency><groupId>io.agentscope</groupId><artifactId>agentscope</artifactId><version>1.0.9</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><executions><execution><id>default-compile</id><phase>compile</phase><goals><goal>compile</goal></goals><configuration><annotationProcessorPaths><path><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></path></annotationProcessorPaths></configuration></execution><execution><id>default-testCompile</id><phase>test-compile</phase><goals><goal>testCompile</goal></goals><configuration><annotationProcessorPaths><path><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></path></annotationProcessorPaths></configuration></execution></executions></plugin></plugins></build><repositories><repository><id>spring-milestones</id><name>Spring Milestones</name><url>https://repo.spring.io/milestone</url><releases><enabled>true</enabled></releases><snapshots><enabled>false</enabled></snapshots></repository></repositories></project>server: port:8008spring: application: name: testAgentScopeDemo package com.testaidemo;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication public class TestAgentScopeDemoApplication{public static void main(String[]args){SpringApplication.run(TestAgentScopeDemoApplication.class, args);}}package com.testaidemo.dto;importlombok.Data;@Data public class JudgeResult{private Boolean finished;private String correctAnswer;}/** * 定义模型 */ package com.testaidemo.commont;importio.agentscope.core.formatter.dashscope.DashScopeMultiAgentFormatter;importio.agentscope.core.model.DashScopeChatModel;public class ModelFactory{/** * 单智能体 * @return */ public static DashScopeChatModelcreateQwenModel(){String apiKey=System.getenv("DASHSCOPE_API_KEY");if(apiKey==null||apiKey.isBlank()){throw new IllegalStateException("DASHSCOPE_API_KEY is required");}returnDashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build();}/** * 多智能体 * @return */ public static DashScopeChatModelcreateMultiQwenModel(){String apiKey=System.getenv("DASHSCOPE_API_KEY");if(apiKey==null||apiKey.isBlank()){throw new IllegalStateException("DASHSCOPE_API_KEY is required");}returnDashScopeChatModel.builder().apiKey(apiKey).modelName("qwen3-max").formatter(new DashScopeMultiAgentFormatter()).build();}}package com.testaidemo.commont;importio.agentscope.core.message.ToolResultBlock;importio.agentscope.core.tool.Tool;importio.agentscope.core.tool.ToolEmitter;importio.agentscope.core.tool.ToolParam;/** * 调用工具 */ public class WeatherService{@Tool(description="查看城市天气")public String getWeather(@ToolParam(name="city", description="City name")String city){returncity +" weather: Sunny, 25°C";}@Tool(description="2个数子相加")public int add(@ToolParam(name="a", description="First number")int a, @ToolParam(name="b", description="Second number")int b){returna + b;}@Tool(description="生成数据")public ToolResultBlock generate(@ToolParam(name="count")int count, ToolEmitter emitter){for(int i=0;i<count;i++){emitter.emit(ToolResultBlock.text("Progress "+ i));}returnToolResultBlock.text("Completed");}}package com.testaidemo.controller;importcom.testaidemo.commont.ModelFactory;importcom.testaidemo.commont.WeatherService;importcom.testaidemo.dto.JudgeResult;importio.agentscope.core.ReActAgent;importio.agentscope.core.memory.InMemoryMemory;importio.agentscope.core.message.Msg;importio.agentscope.core.message.MsgRole;importio.agentscope.core.message.TextBlock;importio.agentscope.core.model.DashScopeChatModel;importio.agentscope.core.model.GenerateOptions;importio.agentscope.core.pipeline.MsgHub;importio.agentscope.core.tool.Toolkit;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;importreactor.core.publisher.Flux;importjava.util.List;/** * 测试接口 */ @RestController @RequestMapping("/ai")public class ChatController{/** * http://127.0.0.1:8008/ai/sendReActAgent * 简单单智能体 * @return */ @GetMapping("/sendReActAgent")public StringsendReActAgent(){DashScopeChatModel model=ModelFactory.createQwenModel();ReActAgent agent=ReActAgent.builder().name("Nexus").sysPrompt("You are a helpful enterprise assistant.").model(model).memory(new InMemoryMemory()).build();Msg response=agent.call(Msg.builder().textContent("你好，请介绍一下 AgentScope 是什么").build()).block();if(response!=null){returnresponse.getTextContent();}else{returnnull;}}/** * http://127.0.0.1:8008/ai/sendReActAgentStream * 简单智能体:流输出（有点问题） * @return */ @GetMapping("/sendReActAgentStream")public Flux<String>sendReActAgentStream(String prompt){DashScopeChatModel model=ModelFactory.createQwenModel();GenerateOptions options=GenerateOptions.builder().stream(Boolean.TRUE).build();returnmodel.stream(List.of(Msg.builder().textContent(prompt).build()), List.of(), options).map(chatResponse ->chatResponse.getContent().stream().filter(TextBlock.class::isInstance).map(TextBlock.class::cast).map(TextBlock::getText).reduce("", String::concat)).filter(text ->text!=null&&!text.isBlank());}/** * * http://127.0.0.1:8008/ai/sendMultiReActAgent * 多智能体 */ @GetMapping("/sendMultiReActAgent")public voidsendMultiReActAgent(){DashScopeChatModel model=ModelFactory.createMultiQwenModel();// Topic String topic=""" The two circles are externally tangent and there is no relative sliding. The radius of circle A is1/3 the radius of circle B. Circle A rolls around circle B one trip back to its starting point. How manytimeswill circle A revolveintotal?""";// Create debaters ReActAgent alice=ReActAgent.builder().name("Alice").sysPrompt("You're a debater named Alice. Topic: "+ topic).model(model).memory(new InMemoryMemory()).build();ReActAgent bob=ReActAgent.builder().name("Bob").sysPrompt("You're a debater named Bob. Topic: "+ topic).model(model).memory(new InMemoryMemory()).build();// Create moderator ReActAgent moderator=ReActAgent.builder().name("Moderator").sysPrompt("You're a moderator evaluating a debate on: "+ topic).model(model).memory(new InMemoryMemory()).build();// Run debatefor(int round=1;round<=5;round++){System.out.println("\n=== Round "+ round +" ===\n");try(MsgHub hub=MsgHub.builder().participants(alice, bob, moderator).build()){hub.enter().block();Msg aliceMsg=alice.call(Msg.builder().name("user").role(MsgRole.USER).content(TextBlock.builder().text("Present your argument.").build()).build()).block();System.out.println("Alice: "+ aliceMsg.getTextContent());Msg bobMsg=bob.call(Msg.builder().name("user").role(MsgRole.USER).content(TextBlock.builder().text("Respond to Alice and present your argument.").build()).build()).block();System.out.println("Bob: "+ bobMsg.getTextContent());}// Moderator judgment Msg judgeMsg=moderator.call(Msg.builder().name("user").role(MsgRole.USER).content(TextBlock.builder().text("Evaluate the debate. Is there a correct answer?").build()).build(), JudgeResult.class).block();JudgeResult result=judgeMsg.getStructuredData(JudgeResult.class);if(result.getFinished()){System.out.println("\n=== Debate Concluded ===");System.out.println("Answer: "+ result.getCorrectAnswer());break;}}}/** * http://127.0.0.1:8008/ai/sendReActAgentTool * 测试调用工具 * @return */ @GetMapping("/sendReActAgentTool")public StringsendReActAgentTool(){DashScopeChatModel model=ModelFactory.createQwenModel();Toolkit toolkit=new Toolkit();toolkit.registerTool(new WeatherService());ReActAgent agent=ReActAgent.builder().name("Assistant").model(model).toolkit(toolkit).build();Msg response=agent.call(Msg.builder().textContent("你好，查看一下苏州天气").build()).block();if(response!=null){returnresponse.getTextContent();}else{returnnull;}}}备注： AgentScope-Java版 Github地址：https://github.com/agentscope-ai/agentscope-java 帮助文档：https://java.agentscope.io/en/intro.html