良心分享:基于Java+SpringBoot+Netty+WebSocket+Uniapp轻松搭建在线互动问答程序

简介: 本文将详细介绍如何基于你自己的开源项目搭建一个在线互动问答程序,包括微信小程序和H5网页版。该项目服务端主要使用了Java + Spring Boot + Netty + WebSocket等技术栈,聊天客户端使用的是UniApp来轻松搭建微信小程序和H5网页端。

一步一步教你搭建在线互动问答程序(微信小程序/H5网页)

本文将详细介绍如何基于你自己的开源项目搭建一个在线互动问答程序,包括微信小程序和H5网页版。
该项目服务端主要使用了Java + Spring Boot + Netty + WebSocket等技术栈,聊天客户端使用的是UniApp来轻松搭建微信小程序和H5网页端。

1. 项目准备

在开始之前,请确保已经准备好以下环境和工具:

  • IDE(推荐使用IntelliJ IDEA)
  • HBuilder X
  • 微信小程序开发工具

2. 架构设计

在线互动问答程序的架构设计如下:

  • 服务端使用Java和Spring Boot框架搭建,其中使用Netty框架实现WebSocket服务器。
  • 客户端提供了微信小程序和H5两种平台,可以通过WebSocket与服务端进行通信。

3. 服务端搭建

  • Github完整代码DEMO
https://gitee.com/yeeevip/yeee-chatgpt

https://github.com/yeeevip/yeee-chatgpt

3.1 创建Spring Boot项目

使用IDE创建一个新的Spring Boot项目,并添加相关依赖:

<dependencies>
    ...
    <!-- 该依赖封装了Netty + websocket,并集成到springboot-starter中 -->
    <dependency>
        <groupId>vip.yeee.memo</groupId>
        <artifactId>common-netty-websocket</artifactId>
    </dependency>
    <!-- 引入此依赖为了使用openai的stream模式来快速获取内容 -->
    <dependency>
        <groupId>com.squareup.okhttp3</groupId>
        <artifactId>okhttp-sse</artifactId>
    </dependency>
    <!-- 以下两个依赖为服务鉴权依赖 -->
    <dependency>
        <groupId>vip.yeee.memo</groupId>
        <artifactId>common-app-auth-server</artifactId>
    </dependency>
    <dependency>
        <groupId>vip.yeee.memo</groupId>
        <artifactId>common-app-auth-client</artifactId>
    </dependency>
    ...
</dependencies>

3.2 编写WebSocket端点Endpoint

添加WebSocket的支持后,我们需要编写具体的端点事件方法,如OnOpen、OnMessage等事件,用于实现消息的接收和发送逻辑。

@Component
@ServerEndpoint(path = "/ws/airobot/{chatId}", port = "8802", readerIdleTimeSeconds = "15")
public class ChatAppWebSocket {
   

    @Autowired
    private ApiChatGptBiz apiChatGptBiz;

    // ws打开时触发
    @OnOpen
    public void onOpen(Session session, HttpHeaders headers, @PathParam("chatId") String chatId) {
   
        apiChatGptBiz.handleWsOnOpen(session, headers, chatId);
    }

    // 收到客户端ws消息时触发
    @OnMessage
    public void onMessage(Session session, String msg) {
   
        apiChatGptBiz.handleWsOnMessage(session, msg);
    }

    // 客户端ws连接关闭时触发
    @OnClose
    public void onClose(Session session) throws IOException {
   
        apiChatGptBiz.handleWsOnClose(session);
    }

    // 这里主要处理netty的一些事件,如读超时、写超时,可以方便实现心跳检测
    @OnEvent
    public void onEvent(Session session, Object evt) {
   
        apiChatGptBiz.handleWsOnEvent(session, evt);
    }

}

3.3 集成ChatGPT模型

根据你的ChatGPT模型实现,添加相关代码将模型集成到服务端中。你可以使用开源的ChatGPT模型,或自行训练一个模型。
具体实现将模型集成到服务端的步骤和代码,根据你使用的具体ChatGPT模型会有所不同,请参考相应的文档和示例。
这里主要调用的是openai的api接口,代码如下:

@Component
public class OpenaiApiService {
   

    @Autowired
    private OkHttpClient okHttpClient;
    @Autowired
    private OkHttp3Kit okHttp3Kit;

    // 使用okhttp的sse请求模式来调用会话接口,流式调用的话阻塞影响小性能比较好
    public EventSource chatCompletions(Map<String, String> headers, ChatParams params, EventSourceListener eventSourceListener) {
   
        try {
   
            EventSource.Factory factory = EventSources.createFactory(okHttpClient);
            ObjectMapper mapper = new ObjectMapper();
            String requestBody = mapper.writeValueAsString(params);
            Request request = new Request.Builder()
                    .url(getApiHost() + "/v1/chat/completions")
                    .post(RequestBody.create(MediaType.parse(ContentType.JSON.getValue()), requestBody))
                    .headers(Headers.of(headers))
                    .build();
            return factory.newEventSource(request, eventSourceListener);
        } catch (Exception e) {
   
            throw new BizException("chatCompletions error");
        }
    }
}

3.4 实现业务逻辑

根据你的需求,实现业务逻辑。此处的业务逻辑是处理用户输入的消息,在服务端调用ChatGPT模型生成回复,并将回复发送给客户端。

@Service
public class ChatService {
   

    ...

    public void doWsChat(String msg, String chatId, String uid) {
   
        WsEventSourceListener listener = new WsEventSourceListener(chatId, uid, msg);

        String limitUserKey = StrUtil.isNotBlank(chatRedisRepository.getUserOpenIdCache(uid)) ? chatRedisRepository.getUserOpenIdCache(uid) : uid;

        if (!this.checkLimit(uid, msg, limitUserKey, listener)) {
   
            return;
        }

        ...

        ChatParams params = new ChatParams();
        List<ChatMessage2> messages = ChatLocalRepository.getChatContext(chatId, chatRedisRepository.getPreRecordCount());
        ChatMessage2 chatMessage2 = this.buildUserMessage(msg);
        messages.add(chatMessage2);
        params.setMessages(messages);
        params.setUser(authService.getUserId());
        params.setStream(true);
        listener.setStartTime(new Date());
        EventSource eventSource = openaiApiService.chatCompletions(headers(), params, listener);
        listener.setEventSource(eventSource);
        ChatAppWsContext.setUserRecentESL(chatId, uid, listener);
    }

    ...

}

4. 客户端开发

4.1 使用UniApp微信小程序/H5

    ...
    // 与服务器建立连接
    vm.ws = uni.connectSocket({
   
        url: vm.baseWsAddr + '/ws/airobot/' + vm.chatId,
        header: {
   
            'Utoken': 'Bearer ' + t
        },
        complete: () => {
   
        }
    })
    // 处理服务器返回的消息
    vm.ws.onMessage(function (e) {
   
        ...
    })
    vm.ws.onOpen(function (e) {
   
        console.log('ws open')
        setInterval(function() {
   
            if (vm.ws) {
   
                vm.ws.send({
   
                    data: 'ping'
                })
            }
        }, 5000);
    })
...

4.2 客户端效果预览

  • 微信小程序

    chatgpt_preview.png

  • H5网页版

    chatgpt_preview2.png

5. 总结

本文详细介绍了如何基于Java + Spring Boot + Netty + WebSocket技术栈搭建一个ChatGPT程序,并使用Uniapp开发微信小程序和H5作为客户端。通过完成这个项目,你可以搭建一个功能强大的聊天机器人系统,满足用户的各种需求。希望这篇文章能够帮助你顺利完成ChatGPT程序的搭建与开发!

  • Github完整代码DEMO
https://gitee.com/yeeevip/yeee-chatgpt

https://github.com/yeeevip/yeee-chatgpt
目录
相关文章
|
22天前
|
传感器 安全 算法
消防救援支队消防员单兵装备智能养护舱电机驱动java版程序(二)
本文探讨消防救援中智能养护舱电机驱动的Java程序设计,作为系列文章第二部分。通过自动化和智能化手段,智能养护舱提升了装备维护效率与准确性。文章详细介绍了电机驱动模块的设计与实现,包括硬件选型、PID控制策略、安全保护机制及Java程序架构,确保电机精确控制、稳定性和安全性。未来将优化功能并引入智能算法和物联网技术,进一步提升装备维护智能化水平。
|
22天前
|
IDE Java 开发工具
消防救援支队消防员单兵装备智能养护舱点击驱动java版程序(一)
智能消防作战服架通过电机驱动系统提升消防员作业效率和安全性。本文介绍基于Java的电机驱动程序开发,涵盖硬件准备、软件环境搭建及驱动程序实现。重点包括串口通信配置、电机控制类设计与控制逻辑实现,确保电机高效稳定运行。通过正确配置通信协议和串口参数,并添加异常处理机制,保障系统的安全性和可靠性。
|
3月前
|
SQL 安全 Java
Java 异常处理:筑牢程序稳定性的 “安全网”
本文深入探讨Java异常处理,涵盖异常的基础分类、处理机制及最佳实践。从`Error`与`Exception`的区分,到`try-catch-finally`和`throws`的运用,再到自定义异常的设计,全面解析如何有效管理程序中的异常情况,提升代码的健壮性和可维护性。通过实例代码,帮助开发者掌握异常处理技巧,确保程序稳定运行。
72 2
|
3月前
|
IDE Java 编译器
开发 Java 程序一定要安装 JDK 吗
开发Java程序通常需要安装JDK(Java Development Kit),因为它包含了编译、运行和调试Java程序所需的各种工具和环境。不过,某些集成开发环境(IDE)可能内置了JDK,或可使用在线Java编辑器,无需单独安装。
141 2
|
4月前
|
开发框架 前端开发 网络协议
Spring Boot结合Netty和WebSocket,实现后台向前端实时推送信息
【10月更文挑战第18天】 在现代互联网应用中,实时通信变得越来越重要。WebSocket作为一种在单个TCP连接上进行全双工通信的协议,为客户端和服务器之间的实时数据传输提供了一种高效的解决方案。Netty作为一个高性能、事件驱动的NIO框架,它基于Java NIO实现了异步和事件驱动的网络应用程序。Spring Boot是一个基于Spring框架的微服务开发框架,它提供了许多开箱即用的功能和简化配置的机制。本文将详细介绍如何使用Spring Boot集成Netty和WebSocket,实现后台向前端推送信息的功能。
1055 1
|
4月前
|
Java Maven 数据安全/隐私保护
如何实现Java打包程序的加密代码混淆,避免被反编译?
【10月更文挑战第15天】如何实现Java打包程序的加密代码混淆,避免被反编译?
759 2
|
4月前
|
前端开发 Java C++
RSocket vs WebSocket:Spring Boot 3.3 中的两大实时通信利器
本文介绍了在 Spring Boot 3.3 中使用 RSocket 和 WebSocket 实现实时通信的方法。RSocket 是一种高效的网络通信协议,支持多种通信模式,适用于微服务和流式数据传输。WebSocket 则是一种标准协议,支持全双工通信,适合实时数据更新场景。文章通过一个完整的示例,展示了如何配置项目、实现前后端交互和消息传递,并提供了详细的代码示例。通过这些技术,可以大幅提升系统的响应速度和处理效率。
|
4月前
|
安全 Java Linux
java程序设置开机自启
java程序设置开机自启
217 1
|
4月前
|
运维 Java Linux
【运维基础知识】Linux服务器下手写启停Java程序脚本start.sh stop.sh及详细说明
### 启动Java程序脚本 `start.sh` 此脚本用于启动一个Java程序,设置JVM字符集为GBK,最大堆内存为3000M,并将程序的日志输出到`output.log`文件中,同时在后台运行。 ### 停止Java程序脚本 `stop.sh` 此脚本用于停止指定名称的服务(如`QuoteServer`),通过查找并终止该服务的Java进程,输出操作结果以确认是否成功。
159 1
|
4月前
|
Java Python
如何通过Java程序调用python脚本
如何通过Java程序调用python脚本
62 0