-
Notifications
You must be signed in to change notification settings - Fork 331
Open
Description
对接dify智能体不能正常接收dify服务端的流信息,日志如下:
09-17 15:36:32.381 [OkHttp http://120.92.xx.xx/...] INFO c.x.d.service.AudioService:177 - 向设备发送音频消息(sendAudioMessage) - SessionId: a96d4eef-5deb-cb23-148e-efb864257270, 文本: , 音频路径: null
09-17 15:36:32.381 [OkHttp http://120.92.xx.xx/...] WARN c.x.d.service.DialogueService:804 - 对话 1758094588836 没有可用的音频路径
09-17 15:36:32.381 [ForkJoinPool.commonPool-worker-3] INFO c.x.d.service.MessageService:38 - sendTtsMessage发送消息 - SessionId: a96d4eef-5deb-cb23-148e-efb864257270, Message: {"type":"tts","state":"stop"}
09-17 15:36:32.381 [OkHttp http://120.92.xx.xx/...] DEBUG c.x.dialogue.llm.ChatService:336 - 总共处理了 0 个句子
原因是智能体的消息流需要实现onAgentMessage
回调函数,复用onMessage(MessageEvent event)
回调函数的实现逻辑即可。如下:
@Override public void onAgentMessage(AgentMessageEvent event) { sink.next(ChatResponse.builder().generations( List.of(new Generation(new AssistantMessage(event.getAnswer(), Map.of("messageId", event.getMessageId(), "conversationId", event.getConversationId()))))) .build()); System.out.println("Agent消息: " + event); }
Metadata
Metadata
Assignees
Labels
No labels