流式输出能集成支持一下websocket吗，小程序貌似不支持sse #4

soulForLove · 2023-03-05T02:13:21Z

非常感谢

gulihua10010 · 2023-03-05T08:21:05Z

我也正在做小程序，也是用websocket进行传输的，过两天就会把项目上传到github上来，到时候你可以参考下。
其实只需要在 websocket 接收消息的时候，调用流式的方法，然后在回调函数中进行发送接口响应数据就行了，我把关键代码贴上给你参考下吧。
`

/**
 * 收到客户端消息后调用的方法
 *
 * @param message 客户端发送过来的消息
 */
@OnMessage
public void onMessage(String message, Session session)
{
    log.debug("Message received from session {} :{}: ip {}", session.getId(), message, this.ip);
    try
    {
        ConversationRequest req = this.convertParam(message, ConversationRequest.class);
        BizValidation.paramValidate(req.getContent(), "content", "content不能为空!");
        if (!req.getIsDemo())
        {
            BizValidation.paramValidate(req.getAuthValue(), "authValue", "Authorization不能为空!");
        }
        ChatGptService chatGptService = SpringUtil.getBean(ChatGptServiceBean.get(req.getAuthType()));
        Cache<String, String> cache = SpringUtil.getBean("fifuCache");
        ChatGptAskReqBO reqBO = new ChatGptAskReqBO();
        reqBO.setContent(HtmlUtil.cleanHtmlTag(req.getContent()));

        reqBO.setId(req.getId());
        if (CollUtil.isNotEmpty(req.getMessages()))
        {
            List<ChatGptAskReqBO.ChatMessageBO> list = new ArrayList<>();
            for (ConversationRequest.ChatMessage msg : req.getMessages())
            {
                if (StrUtil.isBlank(msg.getContent()))
                {
                    continue;
                }
                ChatGptAskReqBO.ChatMessageBO chat = new ChatGptAskReqBO.ChatMessageBO();
                chat.setRole(msg.getRole());
                chat.setContent(HtmlUtil.cleanHtmlTag(msg.getContent()));
                list.add(chat);
            }
            reqBO.setMessages(list);

        }
        reqBO.setParentId(req.getParentId());
        reqBO.setConversationId(req.getConversationId());
        reqBO.setAuthValue(req.getAuthValue());
        log.debug("onMessageon.receive: {}", reqBO.toString());
        chatGptService.conversation(reqBO, param -> {
            if (!param.getIsSuccess())
            {
                WebsocketUtil.cleanCache(this.ip);

            }
            if (null != param.getContent())
            {
                try
                {
                    log.debug("onMessageon.send: {}", param.toString());

                    session.getBasicRemote().sendText(JSONObject.toJSONString(param));
                }
                catch (IOException e)
                {
                    WebsocketUtil.cleanCache(this.ip);
                    log.error("websocket.onMessage.sendText:", e);
                }
            }
        });
    }
    catch (Exception e)
    {
        log.error("websocket.onMessage:", e);
        try
        {
            ConversationResBO resBO = new ConversationResBO();
            resBO.setContent(e.getMessage());
            resBO.setIsDone(false);
            resBO.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
            session.getBasicRemote().sendText(JSONObject.toJSONString(resBO));
            sendDone();
        }
        catch (IOException ex)
        {
            log.error("websocket.onMessage.sendText:", e);
        }
    }

}`

soulForLove · 2023-03-05T13:21:35Z

非常感谢，期待！

who120309 · 2023-03-10T05:02:50Z

我也正在做小程序，也是用websocket进行传输的，过两天就会把项目上传到github上来，到时候你可以参考下。其实只需要在 websocket 接收消息的时候，调用流式的方法，然后在回调函数中进行发送接口响应数据就行了，我把关键代码贴上给你参考下吧。 `

/**
 * 收到客户端消息后调用的方法
 *
 * @param message 客户端发送过来的消息
 */
@OnMessage
public void onMessage(String message, Session session)
{
    log.debug("Message received from session {} :{}: ip {}", session.getId(), message, this.ip);
    try
    {
        ConversationRequest req = this.convertParam(message, ConversationRequest.class);
        BizValidation.paramValidate(req.getContent(), "content", "content不能为空!");
        if (!req.getIsDemo())
        {
            BizValidation.paramValidate(req.getAuthValue(), "authValue", "Authorization不能为空!");
        }
        ChatGptService chatGptService = SpringUtil.getBean(ChatGptServiceBean.get(req.getAuthType()));
        Cache<String, String> cache = SpringUtil.getBean("fifuCache");
        ChatGptAskReqBO reqBO = new ChatGptAskReqBO();
        reqBO.setContent(HtmlUtil.cleanHtmlTag(req.getContent()));

        reqBO.setId(req.getId());
        if (CollUtil.isNotEmpty(req.getMessages()))
        {
            List<ChatGptAskReqBO.ChatMessageBO> list = new ArrayList<>();
            for (ConversationRequest.ChatMessage msg : req.getMessages())
            {
                if (StrUtil.isBlank(msg.getContent()))
                {
                    continue;
                }
                ChatGptAskReqBO.ChatMessageBO chat = new ChatGptAskReqBO.ChatMessageBO();
                chat.setRole(msg.getRole());
                chat.setContent(HtmlUtil.cleanHtmlTag(msg.getContent()));
                list.add(chat);
            }
            reqBO.setMessages(list);

        }
        reqBO.setParentId(req.getParentId());
        reqBO.setConversationId(req.getConversationId());
        reqBO.setAuthValue(req.getAuthValue());
        log.debug("onMessageon.receive: {}", reqBO.toString());
        chatGptService.conversation(reqBO, param -> {
            if (!param.getIsSuccess())
            {
                WebsocketUtil.cleanCache(this.ip);

            }
            if (null != param.getContent())
            {
                try
                {
                    log.debug("onMessageon.send: {}", param.toString());

                    session.getBasicRemote().sendText(JSONObject.toJSONString(param));
                }
                catch (IOException e)
                {
                    WebsocketUtil.cleanCache(this.ip);
                    log.error("websocket.onMessage.sendText:", e);
                }
            }
        });
    }
    catch (Exception e)
    {
        log.error("websocket.onMessage:", e);
        try
        {
            ConversationResBO resBO = new ConversationResBO();
            resBO.setContent(e.getMessage());
            resBO.setIsDone(false);
            resBO.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
            session.getBasicRemote().sendText(JSONObject.toJSONString(resBO));
            sendDone();
        }
        catch (IOException ex)
        {
            log.error("websocket.onMessage.sendText:", e);
        }
    }

}`

大佬，小程序出了吗

gulihua10010 · 2023-03-10T12:13:29Z

还没，token 登录方式的端点被封禁了，我正在尝试其他方式

gulihua10010 · 2023-03-17T11:28:17Z

我也正在做小程序，也是用websocket进行传输的，过两天就会把项目上传到github上来，到时候你可以参考下。其实只需要在 websocket 接收消息的时候，调用流式的方法，然后在回调函数中进行发送接口响应数据就行了，我把关键代码贴上给你参考下吧。 `

/**
 * 收到客户端消息后调用的方法
 *
 * @param message 客户端发送过来的消息
 */
@OnMessage
public void onMessage(String message, Session session)
{
    log.debug("Message received from session {} :{}: ip {}", session.getId(), message, this.ip);
    try
    {
        ConversationRequest req = this.convertParam(message, ConversationRequest.class);
        BizValidation.paramValidate(req.getContent(), "content", "content不能为空!");
        if (!req.getIsDemo())
        {
            BizValidation.paramValidate(req.getAuthValue(), "authValue", "Authorization不能为空!");
        }
        ChatGptService chatGptService = SpringUtil.getBean(ChatGptServiceBean.get(req.getAuthType()));
        Cache<String, String> cache = SpringUtil.getBean("fifuCache");
        ChatGptAskReqBO reqBO = new ChatGptAskReqBO();
        reqBO.setContent(HtmlUtil.cleanHtmlTag(req.getContent()));

        reqBO.setId(req.getId());
        if (CollUtil.isNotEmpty(req.getMessages()))
        {
            List<ChatGptAskReqBO.ChatMessageBO> list = new ArrayList<>();
            for (ConversationRequest.ChatMessage msg : req.getMessages())
            {
                if (StrUtil.isBlank(msg.getContent()))
                {
                    continue;
                }
                ChatGptAskReqBO.ChatMessageBO chat = new ChatGptAskReqBO.ChatMessageBO();
                chat.setRole(msg.getRole());
                chat.setContent(HtmlUtil.cleanHtmlTag(msg.getContent()));
                list.add(chat);
            }
            reqBO.setMessages(list);

        }
        reqBO.setParentId(req.getParentId());
        reqBO.setConversationId(req.getConversationId());
        reqBO.setAuthValue(req.getAuthValue());
        log.debug("onMessageon.receive: {}", reqBO.toString());
        chatGptService.conversation(reqBO, param -> {
            if (!param.getIsSuccess())
            {
                WebsocketUtil.cleanCache(this.ip);

            }
            if (null != param.getContent())
            {
                try
                {
                    log.debug("onMessageon.send: {}", param.toString());

                    session.getBasicRemote().sendText(JSONObject.toJSONString(param));
                }
                catch (IOException e)
                {
                    WebsocketUtil.cleanCache(this.ip);
                    log.error("websocket.onMessage.sendText:", e);
                }
            }
        });
    }
    catch (Exception e)
    {
        log.error("websocket.onMessage:", e);
        try
        {
            ConversationResBO resBO = new ConversationResBO();
            resBO.setContent(e.getMessage());
            resBO.setIsDone(false);
            resBO.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
            session.getBasicRemote().sendText(JSONObject.toJSONString(resBO));
            sendDone();
        }
        catch (IOException ex)
        {
            log.error("websocket.onMessage.sendText:", e);
        }
    }

}`

大佬，小程序出了吗

gulihua10010 · 2023-03-17T11:32:48Z

我也正在做小程序，也是用websocket进行传输的，过两天就会把项目上传到github上来，到时候你可以参考下。其实只需要在 websocket 接收消息的时候，调用流式的方法，然后在回调函数中进行发送接口响应数据就行了，我把关键代码贴上给你参考下吧。 `

/**
 * 收到客户端消息后调用的方法
 *
 * @param message 客户端发送过来的消息
 */
@OnMessage
public void onMessage(String message, Session session)
{
    log.debug("Message received from session {} :{}: ip {}", session.getId(), message, this.ip);
    try
    {
        ConversationRequest req = this.convertParam(message, ConversationRequest.class);
        BizValidation.paramValidate(req.getContent(), "content", "content不能为空!");
        if (!req.getIsDemo())
        {
            BizValidation.paramValidate(req.getAuthValue(), "authValue", "Authorization不能为空!");
        }
        ChatGptService chatGptService = SpringUtil.getBean(ChatGptServiceBean.get(req.getAuthType()));
        Cache<String, String> cache = SpringUtil.getBean("fifuCache");
        ChatGptAskReqBO reqBO = new ChatGptAskReqBO();
        reqBO.setContent(HtmlUtil.cleanHtmlTag(req.getContent()));

        reqBO.setId(req.getId());
        if (CollUtil.isNotEmpty(req.getMessages()))
        {
            List<ChatGptAskReqBO.ChatMessageBO> list = new ArrayList<>();
            for (ConversationRequest.ChatMessage msg : req.getMessages())
            {
                if (StrUtil.isBlank(msg.getContent()))
                {
                    continue;
                }
                ChatGptAskReqBO.ChatMessageBO chat = new ChatGptAskReqBO.ChatMessageBO();
                chat.setRole(msg.getRole());
                chat.setContent(HtmlUtil.cleanHtmlTag(msg.getContent()));
                list.add(chat);
            }
            reqBO.setMessages(list);

        }
        reqBO.setParentId(req.getParentId());
        reqBO.setConversationId(req.getConversationId());
        reqBO.setAuthValue(req.getAuthValue());
        log.debug("onMessageon.receive: {}", reqBO.toString());
        chatGptService.conversation(reqBO, param -> {
            if (!param.getIsSuccess())
            {
                WebsocketUtil.cleanCache(this.ip);

            }
            if (null != param.getContent())
            {
                try
                {
                    log.debug("onMessageon.send: {}", param.toString());

                    session.getBasicRemote().sendText(JSONObject.toJSONString(param));
                }
                catch (IOException e)
                {
                    WebsocketUtil.cleanCache(this.ip);
                    log.error("websocket.onMessage.sendText:", e);
                }
            }
        });
    }
    catch (Exception e)
    {
        log.error("websocket.onMessage:", e);
        try
        {
            ConversationResBO resBO = new ConversationResBO();
            resBO.setContent(e.getMessage());
            resBO.setIsDone(false);
            resBO.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
            session.getBasicRemote().sendText(JSONObject.toJSONString(resBO));
            sendDone();
        }
        catch (IOException ex)
        {
            log.error("websocket.onMessage.sendText:", e);
        }
    }

}`

大佬，小程序出了吗

小程序和服务器端程序已经上传到 github，如果对你有帮助的话，您可以参考下：

基于uni-app构建的微信小程序:https://github.com/gulihua10010/wxmini-chatgpt
微信小程序服务端API程序:https://github.com/gulihua10010/chatGptApi

gulihua10010 closed this as completed Mar 17, 2023

gulihua10010 reopened this Mar 17, 2023

gulihua10010 closed this as completed Apr 12, 2023

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

流式输出能集成支持一下websocket吗，小程序貌似不支持sse #4

流式输出能集成支持一下websocket吗，小程序貌似不支持sse #4

soulForLove commented Mar 5, 2023

gulihua10010 commented Mar 5, 2023

soulForLove commented Mar 5, 2023

who120309 commented Mar 10, 2023

gulihua10010 commented Mar 10, 2023

gulihua10010 commented Mar 17, 2023

gulihua10010 commented Mar 17, 2023

流式输出能集成支持一下websocket吗，小程序貌似不支持sse #4

流式输出能集成支持一下websocket吗，小程序貌似不支持sse #4

Comments

soulForLove commented Mar 5, 2023

gulihua10010 commented Mar 5, 2023

soulForLove commented Mar 5, 2023

who120309 commented Mar 10, 2023

gulihua10010 commented Mar 10, 2023

gulihua10010 commented Mar 17, 2023

gulihua10010 commented Mar 17, 2023