文章目录
- 前言
- 一、确定技术栈
- 二、数据库设计:
- 1.引入库
- 2.使用Spring Boot创建后端项目
- 3.实现WebSocket通信:
- 3.1创建WebSocket配置类:
- 3.2创建ChatWebSocketHandler类:
- 3.3前端WebSocket连接与通信:
- 总结
前言
随着人社交产品的不断发展,即时通讯聊天这门技术也越来越重要,很多人都开启了学习通讯技术,本文就介绍了即时通讯的基础内容。
一、确定技术栈
在开始设计和搭建聊天系统之前,需要确定所需技术栈。常用的技术栈包括前端、后端和数据库。例如,前端可以选择uni-app,后端可以选择java Srping Boot,WebSocket实时通信,非关系型数据库Redis,关系数据库可以选择MySql。
二、数据库设计:
1.引入库
我们将使用MySQL作为数据库。首先,创建以下数据表:
用户表(users): 存储用户信息
好友关系表(friends): 存储用户之间的好友关系
聊天记录表(messages): 存储聊天记录
CREATETABLE`users`(`id`bigint(20)NOTNULLAUTO_INCREMENT,`username`varchar(255)NOTNULL,`password`varchar(255)NOTNULL,`nickname`varchar(255)DEFAULTNULL,`avatar`varchar(255)DEFAULTNULL,PRIMARYKEY(`id`),UNIQUEKEY`username_UNIQUE`(`username`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4;CREATETABLE`friends`(`user_id`bigint(20)NOTNULL,`friend_id`bigint(20)NOTNULL,PRIMARYKEY(`user_id`,`friend_id`),FOREIGNKEY(`user_id`)REFERENCES`users`(`id`),FOREIGNKEY(`friend_id`)REFERENCES`users`(`id`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4;CREATETABLE`messages`(`id`bigint(20)NOTNULLAUTO_INCREMENT,`sender_id`bigint(20)NOTNULL,`receiver_id`bigint(20)NOTNULL,`content`textNOTNULL,`timestamp`datetime(6)NOTNULL,PRIMARYKEY(`id`),FOREIGNKEY(`sender_id`)REFERENCES`users`(`id`),FOREIGNKEY(`receiver_id`)REFERENCES`users`(`id`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4;2.使用Spring Boot创建后端项目
选择以下依赖:
- Web:选择Spring Web模块,用于创建RESTful Web服务 MySQL
- Driver:选择MySQL驱动,用于连接MySQL数据库 JPA:选择Spring --Data JPA模块,用于操作数据库
- WebSocket:选择WebSocket模块,用于实现实时通信
3.实现WebSocket通信:
3.1创建WebSocket配置类:
@Configuration@EnableWebSocketpublicclassWebSocketConfigimplementsWebSocketConfigurer{@AutowiredprivateChatWebSocketHandlerchatWebSocketHandler;@OverridepublicvoidregisterWebSocketHandlers(WebSocketHandlerRegistryregistry){registry.addHandler(chatWebSocketHandler,"/chat").setAllowedOrigins("*").withSockJS();}}3.2创建ChatWebSocketHandler类:
@ServicepublicclassChatWebSocketHandlerextendsTextWebSocketHandler{// 用于存储WebSocketSessionprivatefinalMap<String,WebSocketSession>sessions=newConcurrentHashMap<>();@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连接constsocket=newWebSocket("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));}总结
提示:上述提供了一个设计思路过程详细设计还需要考虑掉线多端登录,消息同步等问题。
基于上面可能出现的一些疑难杂症可以看下开源的一些框架学习,如:宠友IM(https://www.chongyou.info/1/product/im.html)有5个端客户支撑:安卓、苹果APP、小程序、H5、PC端。