Skip to content

R
react-springbot-sse-chat
Commit 0b8c916f by CodeSeek
Options

Initial commit

parents
Showing with 1241 additions and 0 deletions
README.md 0 → 100644
# react-springbot-sse-dify-chat
react-frontend @ 92f1c3af
Subproject commit 92f1c3af5cf190078c4abf697ccdcab7db0cb874
sse-demo/.gitattributes 0 → 100644
/gradlew text eol=lf
*.bat text eol=crlf
*.jar binary
sse-demo/.gitignore 0 → 100644
HELP.md
.gradle
build/
!gradle/wrapper/gradle-wrapper.jar
!**/src/main/**/build/
!**/src/test/**/build/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
bin/
!**/src/main/**/bin/
!**/src/test/**/bin/
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
out/
!**/src/main/**/out/
!**/src/test/**/out/
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
### VS Code ###
.vscode/
sse-demo/build.gradle 0 → 100644
plugins {
id 'java'
id 'org.springframework.boot' version '3.4.9'
id 'io.spring.dependency-management' version '1.1.7'
}
group = 'cn.com.grandage'
version = '0.0.1-SNAPSHOT'
description = 'sse-demo'
java {
toolchain {
languageVersion = JavaLanguageVersion.of(17)
}
}
repositories {
mavenCentral()
}
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-webflux'
implementation 'org.springframework.boot:spring-boot-starter-web'
implementation 'com.fasterxml.jackson.core:jackson-databind'
implementation 'com.fasterxml.jackson.core:jackson-core'
implementation 'com.fasterxml.jackson.core:jackson-annotations'
testImplementation 'org.springframework.boot:spring-boot-starter-test'
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
}
tasks.named('test') {
useJUnitPlatform()
}
\ No newline at end of file
sse-demo/gradle.properties 0 → 100644
org.gradle.jvmargs=-Xmx1024m -XX:+HeapDumpOnOutOfMemoryError -Dfile.encoding=UTF-8
# org.gradle.java.home=D:/Program Files/Java/jdk-17
\ No newline at end of file
sse-demo/gradle/wrapper/gradle-wrapper.properties 0 → 100644
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-8.14.2-bin.zip
networkTimeout=20000
validateDistributionUrl=true
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
sse-demo/gradlew 0 → 100644
#!/bin/sh
#
# Copyright © 2015-2021 the original authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# SPDX-License-Identifier: Apache-2.0
#
##############################################################################
#
# Gradle start up script for POSIX generated by Gradle.
#
# Important for running:
#
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
# noncompliant, but you have some other compliant shell such as ksh or
# bash, then to run this script, type that shell name before the whole
# command line, like:
#
# ksh Gradle
#
# Busybox and similar reduced shells will NOT work, because this script
# requires all of these POSIX shell features:
# * functions;
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
# «${var#prefix}», «${var%suffix}», and «$( cmd )»;
# * compound commands having a testable exit status, especially «case»;
# * various built-in commands including «command», «set», and «ulimit».
#
# Important for patching:
#
# (2) This script targets any POSIX shell, so it avoids extensions provided
# by Bash, Ksh, etc; in particular arrays are avoided.
#
# The "traditional" practice of packing multiple parameters into a
# space-separated string is a well documented source of bugs and security
# problems, so this is (mostly) avoided, by progressively accumulating
# options in "$@", and eventually passing that to Java.
#
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
# see the in-line comments for details.
#
# There are tweaks for specific operating systems such as AIX, CygWin,
# Darwin, MinGW, and NonStop.
#
# (3) This script is generated from the Groovy template
# https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
# within the Gradle project.
#
# You can find Gradle at https://github.com/gradle/gradle/.
#
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
app_path=$0
# Need this for daisy-chained symlinks.
while
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
[ -h "$app_path" ]
do
ls=$( ls -ld "$app_path" )
link=${ls#*' -> '}
case $link in #(
/*) app_path=$link ;; #(
*) app_path=$APP_HOME$link ;;
esac
done
# This is normally unused
# shellcheck disable=SC2034
APP_BASE_NAME=${0##*/}
# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s\n' "$PWD" ) || exit
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD=maximum
warn () {
echo "$*"
} >&2
die () {
echo
echo "$*"
echo
exit 1
} >&2
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "$( uname )" in #(
CYGWIN* ) cygwin=true ;; #(
Darwin* ) darwin=true ;; #(
MSYS* | MINGW* ) msys=true ;; #(
NONSTOP* ) nonstop=true ;;
esac
CLASSPATH="\\\"\\\""
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD=$JAVA_HOME/jre/sh/java
else
JAVACMD=$JAVA_HOME/bin/java
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD=java
if ! command -v java >/dev/null 2>&1
then
die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
fi
# Increase the maximum file descriptors if we can.
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
case $MAX_FD in #(
max*)
# In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
# shellcheck disable=SC2039,SC3045
MAX_FD=$( ulimit -H -n ) ||
warn "Could not query maximum file descriptor limit"
esac
case $MAX_FD in #(
'' | soft) :;; #(
*)
# In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
# shellcheck disable=SC2039,SC3045
ulimit -n "$MAX_FD" ||
warn "Could not set maximum file descriptor limit to $MAX_FD"
esac
fi
# Collect all arguments for the java command, stacking in reverse order:
# * args from the command line
# * the main class name
# * -classpath
# * -D...appname settings
# * --module-path (only if needed)
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
# For Cygwin or MSYS, switch paths to Windows format before running java
if "$cygwin" || "$msys" ; then
APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
JAVACMD=$( cygpath --unix "$JAVACMD" )
# Now convert the arguments - kludge to limit ourselves to /bin/sh
for arg do
if
case $arg in #(
-*) false ;; # don't mess with options #(
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
[ -e "$t" ] ;; #(
*) false ;;
esac
then
arg=$( cygpath --path --ignore --mixed "$arg" )
fi
# Roll the args list around exactly as many times as the number of
# args, so each arg winds up back in the position where it started, but
# possibly modified.
#
# NB: a `for` loop captures its iteration list before it begins, so
# changing the positional parameters here affects neither the number of
# iterations, nor the values presented in `arg`.
shift # remove old arg
set -- "$@" "$arg" # push replacement arg
done
fi
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
# Collect all arguments for the java command:
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
# and any embedded shellness will be escaped.
# * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
# treated as '${Hostname}' itself on the command line.
set -- \
"-Dorg.gradle.appname=$APP_BASE_NAME" \
-classpath "$CLASSPATH" \
-jar "$APP_HOME/gradle/wrapper/gradle-wrapper.jar" \
"$@"
# Stop when "xargs" is not available.
if ! command -v xargs >/dev/null 2>&1
then
die "xargs is not available"
fi
# Use "xargs" to parse quoted args.
#
# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
#
# In Bash we could simply go:
#
# readarray ARGS < <( xargs -n1 <<<"$var" ) &&
# set -- "${ARGS[@]}" "$@"
#
# but POSIX shell has neither arrays nor command substitution, so instead we
# post-process each arg (as a line of input to sed) to backslash-escape any
# character that might be a shell metacharacter, then use eval to reverse
# that process (while maintaining the separation between arguments), and wrap
# the whole thing up as a single "set" statement.
#
# This will of course break if any of these variables contains a newline or
# an unmatched quote.
#
eval "set -- $(
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
xargs -n1 |
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
tr '\n' ' '
)" '"$@"'
exec "$JAVACMD" "$@"
sse-demo/gradlew.bat 0 → 100644
@rem
@rem Copyright 2015 the original author or authors.
@rem
@rem Licensed under the Apache License, Version 2.0 (the "License");
@rem you may not use this file except in compliance with the License.
@rem You may obtain a copy of the License at
@rem
@rem https://www.apache.org/licenses/LICENSE-2.0
@rem
@rem Unless required by applicable law or agreed to in writing, software
@rem distributed under the License is distributed on an "AS IS" BASIS,
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@rem See the License for the specific language governing permissions and
@rem limitations under the License.
@rem
@rem SPDX-License-Identifier: Apache-2.0
@rem
@if "%DEBUG%"=="" @echo off
@rem ##########################################################################
@rem
@rem Gradle startup script for Windows
@rem
@rem ##########################################################################
@rem Set local scope for the variables with windows NT shell
if "%OS%"=="Windows_NT" setlocal
set DIRNAME=%~dp0
if "%DIRNAME%"=="" set DIRNAME=.
@rem This is normally unused
set APP_BASE_NAME=%~n0
set APP_HOME=%DIRNAME%
@rem Resolve any "." and ".." in APP_HOME to make it shorter.
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
@rem Find java.exe
if defined JAVA_HOME goto findJavaFromJavaHome
set JAVA_EXE=java.exe
%JAVA_EXE% -version >NUL 2>&1
if %ERRORLEVEL% equ 0 goto execute
echo. 1>&2
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
echo. 1>&2
echo Please set the JAVA_HOME variable in your environment to match the 1>&2
echo location of your Java installation. 1>&2
goto fail
:findJavaFromJavaHome
set JAVA_HOME=%JAVA_HOME:"=%
set JAVA_EXE=%JAVA_HOME%/bin/java.exe
if exist "%JAVA_EXE%" goto execute
echo. 1>&2
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
echo. 1>&2
echo Please set the JAVA_HOME variable in your environment to match the 1>&2
echo location of your Java installation. 1>&2
goto fail
:execute
@rem Setup the command line
set CLASSPATH=
@rem Execute Gradle
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" -jar "%APP_HOME%\gradle\wrapper\gradle-wrapper.jar" %*
:end
@rem End local scope for the variables with windows NT shell
if %ERRORLEVEL% equ 0 goto mainEnd
:fail
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
rem the _cmd.exe /c_ return code!
set EXIT_CODE=%ERRORLEVEL%
if %EXIT_CODE% equ 0 set EXIT_CODE=1
if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
exit /b %EXIT_CODE%
:mainEnd
if "%OS%"=="Windows_NT" endlocal
:omega
sse-demo/settings.gradle 0 → 100644
rootProject.name = 'sse-demo'
sse-demo/src/main/java/cn/com/grandage/ssedemo/SseDemoApplication.java 0 → 100644
package cn.com.grandage.ssedemo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SseDemoApplication {
public static void main(String[] args) {
SpringApplication.run(SseDemoApplication.class, args);
}
}
sse-demo/src/main/java/cn/com/grandage/ssedemo/config/CorsConfig.java 0 → 100644
package cn.com.grandage.ssedemo.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import org.springframework.web.filter.CorsFilter;
@Configuration
public class CorsConfig {
@Bean
public CorsFilter corsFilter() {
CorsConfiguration config = new CorsConfiguration();
config.setAllowCredentials(true);
config.addAllowedOriginPattern("*");
config.addAllowedHeader("*");
config.addAllowedMethod("*");
UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
source.registerCorsConfiguration("/**", config);
return new CorsFilter(source);
}
}
sse-demo/src/main/java/cn/com/grandage/ssedemo/config/EncodingConfig.java 0 → 100644
package cn.com.grandage.ssedemo.config;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import java.nio.charset.StandardCharsets;
import java.util.List;
@Configuration
public class EncodingConfig implements WebMvcConfigurer {
@Override
public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
// 配置字符串转换器
StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(StandardCharsets.UTF_8);
converters.add(stringConverter);
// 配置JSON转换器
MappingJackson2HttpMessageConverter jsonConverter = new MappingJackson2HttpMessageConverter();
jsonConverter.setDefaultCharset(StandardCharsets.UTF_8);
converters.add(jsonConverter);
}
}
sse-demo/src/main/java/cn/com/grandage/ssedemo/controller/DifyController.java 0 → 100644
package cn.com.grandage.ssedemo.controller;
import cn.com.grandage.ssedemo.dto.DifyRequest;
import cn.com.grandage.ssedemo.service.DifyService;
import jakarta.annotation.Resource;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import java.time.Duration;
import java.util.UUID;
@RestController
@RequestMapping("/api/dify")
@CrossOrigin(origins = "*")
public class DifyController {
@Resource
private DifyService difyService;
/**
* 纯文本流式输出接口
*/
@PostMapping(value = "/chat/stream",
produces = MediaType.TEXT_PLAIN_VALUE + ";charset=UTF-8",
consumes = MediaType.APPLICATION_JSON_VALUE + ";charset=UTF-8")
public Flux<String> streamChat(@RequestBody ChatRequest chatRequest) {
System.out.println("接收到请求: " + chatRequest.getMessage());
DifyRequest difyRequest = buildDifyRequest(chatRequest);
System.out.println("构建的Dify请求: " + difyRequest);
return difyService.streamChatContent(difyRequest)
.doOnNext(content -> System.out.println("发送内容: " + content))
.delayElements(Duration.ofMillis(20)); // 减少延迟以提高响应速度
}
/**
* 健康检查接口
*/
@GetMapping("/health")
public String health() {
return "服务正常运行中...";
}
/**
* 构建Dify请求对象
*/
private DifyRequest buildDifyRequest(ChatRequest chatRequest) {
DifyRequest difyRequest = new DifyRequest();
difyRequest.setQuery(chatRequest.getMessage());
difyRequest.setUser(chatRequest.getUser() != null ?
chatRequest.getUser() : "user-" + UUID.randomUUID());
difyRequest.setConversationId(chatRequest.getConversationId());
difyRequest.setResponseMode("streaming"); // 确保使用流式模式
return difyRequest;
}
// 内部请求类
public static class ChatRequest {
private String message;
private String user;
private String conversationId;
// 无参构造函数
public ChatRequest() {
}
// Getters and Setters
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getConversationId() {
return conversationId;
}
public void setConversationId(String conversationId) {
this.conversationId = conversationId;
}
@Override
public String toString() {
return "ChatRequest{" +
"message='" + message + '\'' +
", user='" + user + '\'' +
", conversationId='" + conversationId + '\'' +
'}';
}
}
}
\ No newline at end of file
sse-demo/src/main/java/cn/com/grandage/ssedemo/dto/DifyRequest.java 0 → 100644
package cn.com.grandage.ssedemo.dto;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Map;
public class DifyRequest {
private String query;
private Map<String, Object> inputs = Map.of();
@JsonProperty("response_mode")
private String responseMode = "streaming"; // 默认流式模式
private String user;
@JsonProperty("conversation_id")
private String conversationId = ""; // 默认空字符串
private Object files;
@JsonProperty("auto_generate_name")
private Boolean autoGenerateName = true; // 默认自动生成名称
@JsonProperty("workflow_id")
private String workflowId;
@JsonProperty("trace_id")
private String traceId;
// 构造函数
public DifyRequest() {
}
public DifyRequest(String query, String user) {
this.query = query;
this.user = user;
}
// Getters and Setters
public String getQuery() {
return query;
}
public void setQuery(String query) {
this.query = query;
}
public Map<String, Object> getInputs() {
return inputs;
}
public void setInputs(Map<String, Object> inputs) {
this.inputs = inputs;
}
public String getResponseMode() {
return responseMode;
}
public void setResponseMode(String responseMode) {
this.responseMode = responseMode;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getConversationId() {
return conversationId;
}
public void setConversationId(String conversationId) {
this.conversationId = conversationId;
}
public Object getFiles() {
return files;
}
public void setFiles(Object files) {
this.files = files;
}
public Boolean getAutoGenerateName() {
return autoGenerateName;
}
public void setAutoGenerateName(Boolean autoGenerateName) {
this.autoGenerateName = autoGenerateName;
}
public String getWorkflowId() {
return workflowId;
}
public void setWorkflowId(String workflowId) {
this.workflowId = workflowId;
}
public String getTraceId() {
return traceId;
}
public void setTraceId(String traceId) {
this.traceId = traceId;
}
@Override
public String toString() {
return "DifyRequest{" +
"query='" + query + '\'' +
", inputs=" + inputs +
", responseMode='" + responseMode + '\'' +
", user='" + user + '\'' +
", conversationId='" + conversationId + '\'' +
", files=" + files +
", autoGenerateName=" + autoGenerateName +
", workflowId='" + workflowId + '\'' +
", traceId='" + traceId + '\'' +
'}';
}
}
\ No newline at end of file
sse-demo/src/main/java/cn/com/grandage/ssedemo/dto/DifyResponse.java 0 → 100644
package cn.com.grandage.ssedemo.dto;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Map;
import java.util.List;
@JsonIgnoreProperties(ignoreUnknown = true)
public class DifyResponse {
private String event;
@JsonProperty("task_id")
private String taskId;
private String id;
private String answer;
@JsonProperty("message_id")
private String messageId;
@JsonProperty("conversation_id")
private String conversationId;
@JsonProperty("from_variable_selector")
private List<Object> fromVariableSelector;
private String mode;
private Map<String, Object> metadata;
private Object usage;
private List<Object> retrieverResources;
@JsonProperty("created_at")
private Long createdAt;
// 文件相关字段
private String type;
private String belongsTo;
private String url;
// TTS相关字段
private String audio;
// Workflow相关字段
@JsonProperty("workflow_run_id")
private String workflowRunId;
private Object data;
private String status;
private String code;
private String message;
private Integer errorCode;
@JsonProperty("finished_at")
private Long finishedAt;
// Getters and Setters
public String getEvent() {
return event;
}
public void setEvent(String event) {
this.event = event;
}
public String getTaskId() {
return taskId;
}
public void setTaskId(String taskId) {
this.taskId = taskId;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getAnswer() {
return answer;
}
public void setAnswer(String answer) {
this.answer = answer;
}
public String getMessageId() {
return messageId;
}
public void setMessageId(String messageId) {
this.messageId = messageId;
}
public String getConversationId() {
return conversationId;
}
public void setConversationId(String conversationId) {
this.conversationId = conversationId;
}
public String getMode() {
return mode;
}
public void setMode(String mode) {
this.mode = mode;
}
public Map<String, Object> getMetadata() {
return metadata;
}
public void setMetadata(Map<String, Object> metadata) {
this.metadata = metadata;
}
public Object getUsage() {
return usage;
}
public void setUsage(Object usage) {
this.usage = usage;
}
public List<Object> getRetrieverResources() {
return retrieverResources;
}
public void setRetrieverResources(List<Object> retrieverResources) {
this.retrieverResources = retrieverResources;
}
public Long getCreatedAt() {
return createdAt;
}
public void setCreatedAt(Long createdAt) {
this.createdAt = createdAt;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public String getBelongsTo() {
return belongsTo;
}
public void setBelongsTo(String belongsTo) {
this.belongsTo = belongsTo;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public String getAudio() {
return audio;
}
public void setAudio(String audio) {
this.audio = audio;
}
public String getWorkflowRunId() {
return workflowRunId;
}
public void setWorkflowRunId(String workflowRunId) {
this.workflowRunId = workflowRunId;
}
public Object getData() {
return data;
}
public void setData(Object data) {
this.data = data;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public Integer getErrorCode() {
return errorCode;
}
public void setErrorCode(Integer errorCode) {
this.errorCode = errorCode;
}
public Long getFinishedAt() {
return finishedAt;
}
public void setFinishedAt(Long finishedAt) {
this.finishedAt = finishedAt;
}
}
\ No newline at end of file
sse-demo/src/main/java/cn/com/grandage/ssedemo/service/DifyService.java 0 → 100644
package cn.com.grandage.ssedemo.service;
import cn.com.grandage.ssedemo.dto.DifyRequest;
import cn.com.grandage.ssedemo.dto.DifyResponse;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Flux;
import java.util.Objects;
@Service
public class DifyService {
private WebClient webClient;
private final ObjectMapper objectMapper;
@Value("${dify.api.url}")
private String DIFY_API_URL;
@Value("${dify.api.key}")
private String API_KEY;
public DifyService() {
this.objectMapper = new ObjectMapper();
}
/**
* 初始化WebClient
*/
private void initWebClient() {
if (this.webClient == null) {
this.webClient = WebClient.builder()
.baseUrl(DIFY_API_URL)
.defaultHeader(HttpHeaders.AUTHORIZATION, "Bearer " + API_KEY)
.defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.defaultHeader("User-Agent", "DifySSEClient/1.0")
.build();
}
}
/**
* 调用Dify流式API并返回消息内容流
*/
public Flux<DifyStreamData> streamChat(DifyRequest request) {
// 初始化WebClient
initWebClient();
return webClient.post()
.uri("")
.bodyValue(request)
.retrieve()
.bodyToFlux(String.class)
.doOnNext(line -> System.out.println("原始响应行: " + line))
.filter(line -> line != null && !line.trim().isEmpty())
.mapNotNull(this::parseStreamData)
.filter(Objects::nonNull)
.doOnNext(data -> System.out.println("解析后数据: Event=" + data.getEvent() + ", Content=" + data.getContent()));
}
/**
* 仅返回消息内容的流
*/
public Flux<String> streamChatContent(DifyRequest request) {
return streamChat(request)
.doOnNext(data -> System.out.println("过滤前数据: Event=" + data.getEvent() + ", Content=" + data.getContent()))
.filter(data -> "message".equals(data.getEvent()) || "message_end".equals(data.getEvent()))
.filter(data -> data.getContent() != null || "message_end".equals(data.getEvent()))
.map(data -> {
if ("message_end".equals(data.getEvent())) {
return "[DONE]"; // 结束标记
}
return data.getContent();
})
.filter(content -> content != null && !content.isEmpty())
.doOnNext(content -> System.out.println("最终发送内容: " + content));
}
private DifyStreamData parseStreamData(String jsonData) {
try {
System.out.println("尝试解析JSON: " + jsonData);
DifyResponse response = objectMapper.readValue(jsonData, DifyResponse.class);
DifyStreamData streamData = new DifyStreamData();
streamData.setEvent(response.getEvent());
streamData.setTaskId(response.getTaskId());
streamData.setMessageId(response.getMessageId());
streamData.setConversationId(response.getConversationId());
streamData.setCreatedAt(response.getCreatedAt());
// 根据不同事件类型处理
switch (response.getEvent()) {
case "message":
streamData.setContent(response.getAnswer() != null ? response.getAnswer() : "");
System.out.println("Message事件内容: " + response.getAnswer());
break;
case "message_end":
streamData.setMetadata(response.getMetadata());
streamData.setUsage(response.getUsage());
System.out.println("Message结束事件");
break;
case "error":
streamData.setErrorStatus(response.getStatus());
streamData.setErrorCode(response.getCode());
streamData.setErrorMessage(response.getMessage());
System.out.println("错误事件: " + response.getMessage());
break;
default:
// 其他事件类型也保存原始数据
System.out.println("其他事件: " + response.getEvent());
break;
}
return streamData;
} catch (Exception e) {
System.err.println("解析JSON数据时出错: " + jsonData + ", 错误: " + e.getMessage());
e.printStackTrace();
return null;
}
}
/**
* 内部数据传输类
*/
public static class DifyStreamData {
private String event;
private String taskId;
private String messageId;
private String conversationId;
private String content;
private Long createdAt;
private Object metadata;
private Object usage;
private String errorStatus;
private String errorCode;
private String errorMessage;
// Getters and Setters
public String getEvent() {
return event;
}
public void setEvent(String event) {
this.event = event;
}
public String getTaskId() {
return taskId;
}
public void setTaskId(String taskId) {
this.taskId = taskId;
}
public String getMessageId() {
return messageId;
}
public void setMessageId(String messageId) {
this.messageId = messageId;
}
public String getConversationId() {
return conversationId;
}
public void setConversationId(String conversationId) {
this.conversationId = conversationId;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public Long getCreatedAt() {
return createdAt;
}
public void setCreatedAt(Long createdAt) {
this.createdAt = createdAt;
}
public Object getMetadata() {
return metadata;
}
public void setMetadata(Object metadata) {
this.metadata = metadata;
}
public Object getUsage() {
return usage;
}
public void setUsage(Object usage) {
this.usage = usage;
}
public String getErrorStatus() {
return errorStatus;
}
public void setErrorStatus(String errorStatus) {
this.errorStatus = errorStatus;
}
public String getErrorCode() {
return errorCode;
}
public void setErrorCode(String errorCode) {
this.errorCode = errorCode;
}
public String getErrorMessage() {
return errorMessage;
}
public void setErrorMessage(String errorMessage) {
this.errorMessage = errorMessage;
}
@Override
public String toString() {
return "DifyStreamData{" +
"event='" + event + '\'' +
", content='" + content + '\'' +
'}';
}
}
}
\ No newline at end of file
sse-demo/src/main/resources/application.yml 0 → 100644
server:
port: 8080
servlet:
encoding:
charset: UTF-8
enabled: true
force: true
spring:
application:
name: dify-sse-demo
web:
resources:
static-locations: classpath:/static/
logging:
level:
cn.com.grandage.ssedemo: DEBUG
reactor.netty: DEBUG
org.springframework.web: DEBUG
dify:
api:
url: http://192.168.141.145/v1/chat-messages
key: app-yIyPvikvguW4Dc33rarl8ZqW
\ No newline at end of file
sse-demo/src/test/java/cn/com/grandage/ssedemo/SseDemoApplicationTests.java 0 → 100644
package cn.com.grandage.ssedemo;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class SseDemoApplicationTests {
@Test
void contextLoads() {
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment