文章目录前言一、确定技术栈二、数据库设计1.引入库2.使用Spring Boot创建后端项目3.实现WebSocket通信3.1创建WebSocket配置类3.2创建ChatWebSocketHandler类3.3前端WebSocket连接与通信总结前言随着人社交产品的不断发展即时通讯聊天这门技术也越来越重要很多人都开启了学习通讯技术本文就介绍了即时通讯的基础内容。一、确定技术栈在开始设计和搭建聊天系统之前需要确定所需技术栈。常用的技术栈包括前端、后端和数据库。例如前端可以选择uni-app后端可以选择java Srping BootWebSocket实时通信非关系型数据库Redis关系数据库可以选择MySql。二、数据库设计1.引入库我们将使用MySQL作为数据库。首先创建以下数据表用户表users: 存储用户信息好友关系表friends: 存储用户之间的好友关系聊天记录表messages: 存储聊天记录CREATETABLEusers(idbigint(20)NOTNULLAUTO_INCREMENT,usernamevarchar(255)NOTNULL,passwordvarchar(255)NOTNULL,nicknamevarchar(255)DEFAULTNULL,avatarvarchar(255)DEFAULTNULL,PRIMARYKEY(id),UNIQUEKEYusername_UNIQUE(username))ENGINEInnoDBDEFAULTCHARSETutf8mb4;CREATETABLEfriends(user_idbigint(20)NOTNULL,friend_idbigint(20)NOTNULL,PRIMARYKEY(user_id,friend_id),FOREIGNKEY(user_id)REFERENCESusers(id),FOREIGNKEY(friend_id)REFERENCESusers(id))ENGINEInnoDBDEFAULTCHARSETutf8mb4;CREATETABLEmessages(idbigint(20)NOTNULLAUTO_INCREMENT,sender_idbigint(20)NOTNULL,receiver_idbigint(20)NOTNULL,contenttextNOTNULL,timestampdatetime(6)NOTNULL,PRIMARYKEY(id),FOREIGNKEY(sender_id)REFERENCESusers(id),FOREIGNKEY(receiver_id)REFERENCESusers(id))ENGINEInnoDBDEFAULTCHARSETutf8mb4;2.使用Spring Boot创建后端项目选择以下依赖Web选择Spring Web模块用于创建RESTful Web服务 MySQLDriver选择MySQL驱动用于连接MySQL数据库 JPA选择Spring --Data JPA模块用于操作数据库WebSocket选择WebSocket模块用于实现实时通信3.实现WebSocket通信3.1创建WebSocket配置类ConfigurationEnableWebSocketpublicclassWebSocketConfigimplementsWebSocketConfigurer{AutowiredprivateChatWebSocketHandlerchatWebSocketHandler;OverridepublicvoidregisterWebSocketHandlers(WebSocketHandlerRegistryregistry){registry.addHandler(chatWebSocketHandler,/chat).setAllowedOrigins(*).withSockJS();}}3.2创建ChatWebSocketHandler类ServicepublicclassChatWebSocketHandlerextendsTextWebSocketHandler{// 用于存储WebSocketSessionprivatefinalMapString,WebSocketSessionsessionsnewConcurrentHashMap();OverrideprotectedvoidhandleTextMessage(WebSocketSessionsession,TextMessagemessage)throwsException{// TODO: 处理客户端发送的消息如解析JSON存储到数据库转发给其他客户端等}OverridepublicvoidafterConnectionEstablished(WebSocketSessionsession)throwsException{// TODO: 用户连接后的操作如将session添加到sessions中}OverridepublicvoidafterConnectionClosed(WebSocketSessionsession,CloseStatusstatus)throwsException{// TODO: 用户断开连接后的操作如将session从sessions中移除}// 其他WebSocket处理方法}3.3前端WebSocket连接与通信在uni-app项目中使用WebSocket与后端进行实时通信。例如// 创建WebSocket连接constsocketnewWebSocket(ws://localhost:8080/chat);// 监听WebSocket连接成功事件socket.addEventListener(open,(event){console.log(WebSocket连接成功);});// 监听WebSocket接收消息事件socket.addEventListener(message,(event){console.log(收到消息: ,event.data);// TODO: 处理收到的消息如显示到聊天界面等});// 发送消息functionsendMessage(content){constmessage{senderId:1,receiverId:2,content:content,timestamp:newDate(),};socket.send(JSON.stringify(message));}总结提示上述提供了一个设计思路过程详细设计还需要考虑掉线多端登录消息同步等问题。基于上面可能出现的一些疑难杂症可以看下开源的一些框架学习如宠友IMhttps://www.chongyou.info/1/product/im.html有5个端客户支撑安卓、苹果APP、小程序、H5、PC端。
