项目地址：alpbeta/ai-api-union

需求：实现兼容各大模型厂商api的流式对话和同步对话接口，本项目现兼容智谱、豆包、通义、通义版deepseek

设计

一个ChatController类对外暴露这两个接口，入参都为ChatRequest请求类，属性有会话id，大模型标识符和聊天消息列表，其中消息是一个实体类包含，消息id，关联会话id，发送者角色，消息内容，创建时间。

流式对话返回的是响应式变成中的Flux类型，同步调用返回的是Sring类型。

一个ModelService接口，包含流式调用和同步调用两个方法，入参为String字符串，出参与上述一致。

四个大模型api接口分别实现这个接口创建对应的实现类。

简单工厂模式

创建一个工厂类，基于传入的参数创建对应的大模型接口实现类。

工厂方法模式

创建一个工厂抽象类，继承该接口创建各个大模型工厂类，各个大模型工厂类实现大模型接口实现类。

创建一个获取工厂类，基于传入的参数创建对应的大模型工厂，再创建对应大模型接口实现类

示意图

实施

创建项目

通过 Spring Initializr 网站快速生成一个包含 Spring Boot 依赖的项目骨架，修改对应的partent版本，创建application.yml 激活dev环境，设置profiels.active:dev，创建application-dev.yml，修改端口为8090，server.port:8090(也可以不修改，默认.properties,偏向于yml）

创建测试controller

项目中如果没有controller类，访问8080端口时会报错，找不到路径；

创建一个ChatController类，增加@RestController @RequestMapping("api/chat")注解

创建testChat方法，方法前添加注解 @GetMapping("/testChat"), 入参为空，出参为String，方法内输入return "test chat";

启动项目，访问http:localhost:8090/api/chat/testChat，页面显示上述方法返回的内容 test chat

创建dto包

创建Message实体类，ChatRequest请求类；

ChatRequest请求类，属性有会话id，大模型标识符和聊天消息列表，其中消息是一个实体类包含，消息id，关联会话id，发送者角色，消息内容，创建时间。基于这些内容创建对应的私有属性，数据类型有Integer，String, TimeStamp, List，在类前加@Data注解，需先引入lombok依赖，引入该注解后，可以自动生成样板代码，如getter, setter, toString, equals, 无参构造函数，不需要显示编写这些方法，提高开发效率。

如需生成清晰的API文档，需引入swagger依赖，或knif4j，再补充对应的配置文件，之后在实体类的类名和属性前通过@Schema(description="xx")备注类和属性名对应的含义。之后通过访问http://项目ip:端口号/doc.html，可以访问对应的接口文档，如果接口的入参和出参有用到@Scheme注解的实体类，会显示对应的备注内容。

创建项目实现接口类

在ChatController类增加syncChat和streamChat方法

两个方法前增加PostMapping注解，路径分别是（"/syncChat"）和("/stramChat")。入参增加@RequestBody注解，类型为ChatRequest。 出参分别是String和Flux

增加IModelService接口，包含synChat和stramChat方法，入参都为String，出参与上述保持一致

增加各大模型厂商api实现类

智谱接口实现类 ChatGLMServiceImpl，豆包接口实现类 ArkServiceImpl，通义接口实现类DashScopeServeceImpl，通义-deepseek实现类 DeepSeekServiceImple，都实现IModelService接口

引入各模型依赖，并在application.yml中配置api-key和modelname

分别在各模型接口类中实现同步调用和异步调用方法

实现豆包接口示例

在类前增加@Service注解表示为服务类bean容器，通过@Value注解，从配置文件中获取api-key和modelName的值映射到该类对应属性中。豆包大模型的火山引擎提供的ArkService服务类声明为一个私有属性，后续会使用该服务的方法。

该实现类除接口在的两个方法，还增加了初始化和后处理方法，分别通过@PostConstruct和@PreDestory注解，在接口实现类Bean初始化完成后执行ArkService服务类的实例化，在Bean销毁之前关闭ArkService的所有资源。

syncChat同步方法，使用该模型依赖提供的ChatMeaasge类创建消息列表对象，调用对应的add，role，content，build方法完成消息参数构建，再通过ChatCompletionRequest构建请求参数对象，通过arkService.creatChatCompletion方法输入请求参数，获取模型返回结果

stramChat异步调用方法，消息对象和请求对象构建方式与同步调用方式一致，通过arkService.streamChatCompletion方法获取流式响应结果。返回类型为Flowable，需将其转换成Flux,通过Flux.from(.map(response ->{return response...})).filter(content->!content.isEmpty())获取返回结果

其他大模型实现类通过类似方法进行实现，通义与通义deepseek异步和同步返回的方法不一样,前者通过result.getOutput().getText();获取返回结果，后者方法调用更长一些

创建简单工厂实现类

ModelSimpleFactory，基于传入的参数返回不同的模型接口实现类，实现一个createModelService的方法。实现类用到@value注解从配置文件中获取变量值，不能通过new的方式创建模型类，需通过反射机制，通过上下文的getbean方法创建：applicationContext.getBean。

在ChatController类补充syncChat和streamChat方法逻辑

获取请求对象中的模型标识，消息列表。基于标识创建模型服务对象，将消息传入模型服务返回响应的结果