let serve = app.listen(3001); const io = socketio(serve); io.on('connection', socket => { socket.on('login', (username) => { console.log(username+'上线了！'); }); } 

<script src="http://47.107.66.252:3001/socket.io/socket.io.js"></script> <script type="text/javascript"> const socket = io.connect('http://47.107.66.252:3001'); </script> 

 let serve = app.listen(3001); const io = socketio(serve); io.on('connection', socket => { const socketId = socket.id; //登录时建立一个username到socketId的映射表 socket.on('login', (username) => { socketHandler.saveUserSocketId(username, socketId) }); socket.on('chat',(data) => { Idtoid.findOne({ username: data.to_user }).then((rs) => { //根据用户名在映射表中找到对应的socketId io.to(rs.socketid).emit('receiveMsg',{ from_user:data.from_user, message:data.message, time:data.time, avater:data.avater, _id:data._id }) }) }) }) 

...mapMutations([ 'update_chatList' ]), updateBySocket() { socket.removeAllListeners(); socket.on('receiveMsg', (data) => { let from_user = data.from_user; //如果当前页面为与from_user的对话框，则交由对话框页面处理 if (this.$route.query.chatwith == from_user) { return; } this.update_chatList(data); }) } 

//发送消息 sendMessage() { if (!this.userInfo._id){ Toast("请先登录！"); return; } if (this.content == '') { return; } this.axios.post('/chat/chatwith', {//向后端传输聊天记录 chatWithId: this.tUserInfo._id, user_id: this.userInfo._id, content: this.content }).then((result) => { //把自己发送的内容更新到dataList中 this.dataList.push({ user_id: {//这个有点乱了，这个是自己的信息 avater: this.userInfo.avater }, chatWith: { _id: this.chatWithId }, addTime: Date.now(), content: this.content }); //更新聊天用户的列表 this.update_chatList({ _id: this.tUserInfo._id,//自己的id from_user: this.chatWith,//与你聊天的用户 message: this.content,//消息内容 time: Date.now(),//时间); me: true,//判别是不是自己发送的 avater:this.tUserInfo.avater }); //要发送给对方的数据 let data = { from_user: this.userInfo.username,//发送方 to_user: this.chatWith,//接收方 message: this.content,//消息内容 time: Date.now(), //时间); avater: this.userInfo.avater, _id: this.userInfo._id }; socket.emit('chat', data); this.content = ''; }) }, updateBySocket() { socket.on('receiveMsg', (data) => { //判断一下是不是当前的对话框 if (data.from_user == this.chatWith) { //把收到的消息保存到聊天记录中 this.dataList.push({ chatWith: { _id: this.userInfo._id }, user_id: {//自己的信息 avater: data.avater }, addTime: data.addTime, content: data.message }); this.update_chatList({ _id: this.tUserInfo._id, from_user: this.chatWith,//与你聊天的用户 message: data.message,//消息内容 time: data.addTime,//时间); me: true,//判别是不是自己当前页面 avater:this.tUserInfo.avater }); } }) } 

[types.UPDATE_CHATLIST](state, data) { let flag = 0;//判断新的聊天是否存在于当前的列表中 state.chatList.forEach((item)=>{ if (item.chatWith.username == data.from_user) { flag = 1; if (!data.me) {//判断当前是否在对话框页面中 item.unread++; state.unread++; } //更新 item.content = data.message; item.addTime = data.time; //按添加时间排序 state.chatList.sort((a, b) => { return new Date(b.addTime) - new Date(a.addTime) }); //跳出循环 return false; } }); //是新的并且不在对话框页面 if (!flag&&!data.me) { //添加到第一条 state.chatList.unshift({ chatWith: { avater: data.avater, username: data.from_user, _id: data._id }, addTime: data.time, content: data.message, unread: 1 }); state.unread++; }else if (!flag&&data.me){//新的并且在对话框页面，不需要增加unread state.chatList.unshift({ chatWith: { avater: data.avater, username: data.from_user, _id: data._id }, addTime: data.time, content: data.message, }); } } 

mounted() { this.$nextTick(() => { this.initImg(); }) } 

beforeRouteEnter(to, from, next) { if (from.path == '/upload' ) { next(vm => { vm._getList = true }) } else { next() } } 

activated() { this.$nextTick(() => { if (this._getList) { this.getPyqLists(); } }) } 

<template> <div> <myheader :title="'发布动态'"> <i class="iconfont icon-fanhui1 left" slot="left" @click="goback"></i> </myheader> <div class="upload"> <div v-if="userInfo._id"> <!--图片上传--> <div class="weui-gallery" id="gallery"> <span class="weui-gallery__img" id="galleryImg"></span> <div class="weui-gallery__opr"> <a href="javascript:" class="weui-gallery__del"> <i class="weui-icon-delete weui-icon_gallery-delete"></i> </a> </div> </div> <div class="weui-cells weui-cells_form"> <div class="weui-cell"> <div class="weui-cell__bd"> <textarea class="weui-textarea" v-model="content" placeholder="你想说啥" rows="3"></textarea> </div> </div> <div class="weui-cell"> <div class="weui-cell__bd"> <div class="weui-uploader"> <div class="weui-uploader__bd"> <ul class="weui-uploader__files" id="uploaderFiles"> <li ref="files" class="weui-uploader__file" v-for="(image,index) in images" :key="index" :style="'backgroundImage:url(' + image +' )'"><span @click="deleteimg(index)" class="x">&times;</span></li> </ul> <div v-show="images.length < maxCount" class="weui-uploader__input-box"> <input @change="change" id="uploaderInput" class="weui-uploader__input " type="file" multiple accept="image/*"> </div> </div> </div> </div> </div> </div> <a class="weui-btn weui-btn_primary btn-put" style="margin: 20px " @click.prevent.once="put">发送</a> </div> <unlogin v-else> </unlogin> </div> </div> </template> 

<ul class="weui-uploader__files" id="uploaderFiles"> <li ref="files" class="weui-uploader__file" v-for="(image,index) in images" :key="index" :style="'backgroundImage:url(' + image +' )'"><span @click="deleteimg(index)" class="x">&times;</span></li> </ul> <div v-show="!this.$refs.files||this.$refs.files.length < maxCount" class="weui-uploader__input-box"> <input @change="change" id="uploaderInput" class="weui-uploader__input" type="file" multiple accept="image/*"> </div> 

data() { return { content: '',//分享动态的文字内容 maxSize: 10240000 / 2,//图片的最大大小 maxCount: 8,//最大数量 filesArr: [],//保存要上传图片的数组 images: []//转成base64后的图片的数组 } } 

deleteimg(index) { this.filesArr.splice(index, 1); this.images.splice(index, 1); } 

change(e) { let files = e.target.files; // 如果没有选中文件，直接返回 if (files.length === 0) { return; } if (this.images.length + files.length > this.maxCount) { Toast('最多只能上传' + this.maxCount + '张图片！'); return; } let reader; let file; let images = this.images; for (let i = 0; i < files.length; i++) { file = files[i]; this.filesArr.push(file); reader = new FileReader(); if (file.size > self.maxSize) { Toast('图片太大，不允许上传！'); continue; } reader.onload = (e) => { let img = new Image(); img.onload = function () { let canvas = document.createElement('canvas'); let ctx = canvas.getContext('2d'); let w = img.width; let h = img.height; // 设置 canvas 的宽度和高度 canvas.width = w; canvas.height = h; ctx.drawImage(img, 0, 0, w, h); let base64 = canvas.toDataURL('image/png'); images.push(base64); }; img.src = e.target.result; }; reader.readAsDataURL(file); } } 

put() { Indicator.open('发布中...'); let self = this; let content = this.content; let param = new FormData(); param.append('content', content); param.append('username', this.userInfo._id); this.filesArr.forEach((file) => { param.append('file2', file); }); self.axios.post('/upload/uploadFile', param, { headers: { "Content-Type": "application/x-www-form-urlencoded" } }).then(function (result) { console.log(result.data); self.$router.push({path: '/home'}); Indicator.close(); Toast(result.data.msg) }) } 

let filePath; let fileName; let Storage = multer.diskStorage({ destination: function (req, file, cb) {//计算图片存放地址 cb(null, './public/img'); }, filename: function (req, file, cb) {//图片文件名 fileName = Date.now() + '_' + parseInt(Math.random() * 1000000) + '.png'; filePath = './public/img/' + fileName; cb(null, fileName) } }); let upload = multer({storage: Storage}).any();//file2表示图片上传文件的key router.post('/uploadFile', function (req, res, next) { upload(req, res, function (err) { let content = req.body.content || ''; let username = req.body.username; let imgs = [];//要保存到数据库的图片地址数组 if (err) { return res.end(err); } if (req.files.length === 0) { new Pyq({ writer: username, content: content }).save().then((result) => { res.json({ result: result, code: '0', msg: '上传成功' }); }) } /*client.delete('public/img/1.png', function (err) { console.log(err) });*/ let i = 0; req.files.forEach((item, index) => { let filePath = `./public/img/${item.filename}`; put(item.filename,filePath,(result)=>{ imgs.push(result.url); i++; if (i === req.files.length) { //forEach循环是同步的，但上传图片是异步的，所以用一个i去标记图片是否全部上传成功 //这时才把数据保存到数据库 new Pyq({ content: content, writer: username, pimg: imgs }).save().then(() => { res.json({ code: '0', msg: '发布成功' }); }) } }) }) }) });