企业邮箱注册账号,搜索引擎seo如何优化,建设外贸网站公司,济南富腾网站建设通过websocket实现简单的聊天室功能
需求分析如图#xff1a; 搭建的项目结构如图#xff1a; 前端步骤#xff1a;
vue create socket_demo (创建项目)views下面建立Home , Login组件路由里面配置路径Home组件内部开启websocket连接
前端相关组件代码#xff1a; Login…通过websocket实现简单的聊天室功能
需求分析如图 搭建的项目结构如图 前端步骤
vue create socket_demo (创建项目)views下面建立Home , Login组件路由里面配置路径Home组件内部开启websocket连接
前端相关组件代码 Login组件
!-- Login.vue --
templatedivinput typetext placeholder请输入用户名 v-modelusernamenbsp;nbsp;button clickenterRoom进入聊天室/button/div
/templatescript
export default {name: login,data() {return {username: ,}},methods: {enterRoom() {let username this.username.trim()if (username.length 6) {alert(用户名小于6位请重新输入)return}// 保存用户名localStorage.setItem(username, username)// 进入首页this.$router.push(/)},}
}
/scriptstyle/styleHome组件
!-- Home.vue --
templatedivulli v-foritem in msgList :keyitem.idpspan{{item.user}}/spanspan{{new Date(item.dateTime)}}/span/pp消息{{item.msg}}/p/li/ulinput typetext placeholder请输入消息 v-modelmsgnbsp;nbsp;button clicksendMsg发送/button/div
/templatescript
let ws new WebSocket(ws://localhost:8000)
export default {name: home,data() {return {msg: ,username: ,msgList: []}},mounted() {this.username localStorage.getItem(username)if (!this.username) {this.$router.push(/login)return}ws.onopen (e) {console.log(WebSocket opne , e);}ws.onclose (e) {console.log(WebSocket onclose , e);}ws.onerror (e) {console.log(WebSocket onerror , e);}// 接收服务端发送过来的消息ws.onmessage (e) {// console.log(WebSocket onmessage , e);flet msg JSON.parse(e.data)// console.log(msg, msg);this.msgList.push(msg)}},methods: {// 发送消息sendMsg() {if (!this.msg) {return}let obj {id: Math.floor(Math.random() * 100),user: this.username,dateTime: new Date().getTime(),msg: this.msg}ws.send(JSON.stringify(obj))this.msg },}}
/scriptstyle/stylerouter/index.js
import Vue from vue
import VueRouter from vue-router
import Login from ../views/Login.vueVue.use(VueRouter)const routes [{path: /login,name: login,component: Login},{path: /,name: home,component: () import(../views/Home.vue)}
]const router new VueRouter({routes,mode: history
})export default router
后端步骤
在项目外层创建server文件夹src目录同级npm init -y创建安装包npm i ws (安装websocket的插件ws)index.js 文件内部开启服务初始化相关事件
后端服务的启动server下面建立index.js文件package.json里面配置命令npm run dev启动
index.js文件
const Ws require(ws);((Ws) {// 开启服务const server new Ws.Server({host: localhost,port: 8000})const init () {bindEvent()}// 初始化相关事件function bindEvent() {server.on(open, handleOpen)server.on(close, handleClose)server.on(error, handleError)server.on(connection, handleConnection)}function handleOpen() {console.log(websocket open);}function handleClose() {console.log(websocket Close);}function handleError() {console.log(websocket Error);}function handleConnection(ws) {console.log(websocket Connection);ws.on(message, handleMessage)}function handleMessage(msg) {// console.log(msg, msg.toString());let message msg.toString()// 获取所有和服务端连接的客户端并向它们推送消息server.clients.forEach(c {c.send(message)})}init()
})(Ws);效果图
