vue+socket.io+express+mongodb 實現(xiàn)簡易多房間在線群聊示例

mongod

cd server
node index.js

cd client
cnpm install
npm run dev

|--chat-vue-node
 |--client // 前端客戶端：基于 vue-cli 搭建的所有聊天頁面
 |--server // 后臺服務(wù)端
 |--api.js // express 通過 mongoose 操作 mongodb 數(shù)據(jù)庫的所有接口
 |--db.js // 數(shù)據(jù)庫初始化、Schema數(shù)據(jù)模型
 |--index.js // 后臺服務(wù)啟動入口
 |--package.json
 .gitignore
 README.md

// 客戶端連接
var socket = io.connect('http://localhost:8081')
// 服務(wù)端監(jiān)聽到連接
io.on('connection', function(socket){
 // ......
}

// 客戶端發(fā)送進入房間請求
socket.emit('joinToRoom', data)
// 服務(wù)端監(jiān)聽
socket.on('joinToRoom', function (data) {
 // ......
 // 服務(wù)端處理進入房間、離開房間
 socket.join(roomGroupId)
 // 有人進入房間，向該群其它的成員發(fā)送更新在線成員
 io.sockets.in(roomGroupId).emit('joinToRoom', chat)
 io.sockets.in(roomGroupId).emit('updateGroupNumber', roomNum[roomGroupId])
}

// 客戶端發(fā)送聊天消息
socket.emit('emitChat', chat)
// 服務(wù)端監(jiān)聽并向群內(nèi)其它人群發(fā)該消息
socket.on('emitChat', function (data) {
 let roomGroupId = chat.chatToGroup
 // 向特定的群成員轉(zhuǎn)發(fā)消息
 socket.in(roomGroupId).emit('broadChat', chat)
})

// 用戶信息的數(shù)據(jù)結(jié)構(gòu)模型
const accountSchema = new Schema({
 account: {type: Number}, // 用戶賬號
 nickName: {type: String}, // 用戶昵稱
 pass: {type: Number}, // 密碼
 regTime: {type: Number} // 注冊時間
})
// 聊天群的數(shù)據(jù)結(jié)構(gòu)模型：聊天群包含的成員
const relationSchema = new Schema({
 groupAccount: Number, // 群賬號
 groupNickName: String, // 群昵稱
 groupNumber: [] // 群成員
})
// 單個聊天群的聊天消息記錄
const groupSchema = new Schema({
 account: Number, // 聊天者的賬號
 nickName: String, // 聊天者的昵稱
 chatTime: Number, // 發(fā)消息的時間戳
 chatMes: String, // 聊天的消息內(nèi)容
 chatToGroup: Number, // 聊天的所在群賬號
 chatType: String // 消息類型：進入群、離開群、發(fā)消息
})

routes: [
 // {path: '/', name: 'Hello', component: Hello},
 {path: '/', redirect: '/login', name: 'Hello', component: Hello},
 {path: '/login', name: 'Login', component: Login},
 {path: '/center', name: 'Center', component: Center},
 {path: '/chatGroup', name: 'ChatGroup', component: ChatGroup}
]
// 未登錄時，通過編程式跳去登錄頁：
router.push({ path: 'login' })

export default new Vuex.Store({
 state: {
 chatState: {
 account: null,
 nickName: null
 },
 groupState: null // 點擊進群的時候更新
 },
 mutations: {
 updateChatState (state, obj) {
 state.chatState = obj
 },
 updateGroupState (state, obj) {
 state.groupState = obj
 }
 },
 actions: {
 updateChatState ({commit}, obj) {
 commit('updateChatState', obj)
 },
 updateGroupState ({commit}, obj) {
 commit('updateGroupState', obj)
 }
 },
 getters: {
 getChatState (state) {
 return state.chatState
 },
 getGroupState (state) {
 return state.groupState
 }
 }
})

// 更新
this.$store.dispatch('updateChatState', {account: null, nickName: null})
// 獲取
this.$store.getters.getChatState

module.exports = function (app) {
 app.all("*", function(req, res, next) {
 next()
 })
 // api login 登錄
 app.get('/api/user/login', function (req, res) { // ... })
 // api register 注冊
 app.get('/api/user/register', function (req, res) { // ... })
 // getAccountGroup 獲取可進入的房間
 app.get('/api/user/getAccountGroup', function (req, res) { // ... })
 // getGroupNumber 獲取當(dāng)前房間的群成員
 app.get('/api/user/getGroupNumber', function (req, res) { // ... })
 // api getChatLog 獲取當(dāng)前房間的聊天記錄
 app.get('/api/getChatLog', function (req, res) { // ... })
 app.get('*', function(req, res){
 res.end('404')
 })
}