Todo List: Socket.io多人协同处理待办事项 – 第七章(第二节)

Javanx

发布于 2019-09-04 12:58:38

5740

发布于 2019-09-04 12:58:38

文章被收录于专栏：web秀web秀

前言

Todo List项目已经接近尾声，很多地方都没有细致的讲解，基本都是以简洁为主，快速的完成一个简单的demo。希望能给小伙伴们带来一些帮助。

代码请戳：Todo List GitHub代码库

Client端

npm install vue-socket.io --save

main.js添加下列代码

import VueSocketIO from 'vue-socket.io'
Vue.use(new VueSocketIO({
  debug: true,
  // 服务器端地址
  connection: 'http://localhost:3000'
}))

components/list.vue

created() {
  // 接收服务端的信息
  this.sockets.subscribe('update-task-callback', (data) => {
    console.log('update-task-callback', data)
    this.$store.commit(types.M_GET_TASK_GROUP, data)
  })
}
...
methods: {
  endDrag () {
    this.drag = false
    // 之前直接调用接口
    // this.$store.dispatch(types.A_CREATED_TASK, {
    //   group_id: this.current,
    //   item: this.currentTask
    // })
    // 现在用socket 更新
    this.$socket.emit('update-task', {
      group_id: this.current,
      item: this.currentTask
    })
    this.current = ''
  }
}

Server端

npm install --save socket.io

/server/app.js

var app = express()
var http = require('http').Server(app);
var io = require('socket.io')(http);

io.on('connection',function(socket) {
  // 接收数据
  socket.on('update-task', function (params) {
    console.log(params)               
    let title = params.item.title;
    let description = params.item.description;
    let enclosure = params.item.imgs;
    let level = params.item.level;
    let group_id  = params.group_id;
    let date = moment().format('YYYY-MM-DD HH:mm:ss');
    let id = params.item.id;
    let csql = params.item.id ? eval('`'+sql.UPDATE_TASK_LIST+'`') : eval('`'+sql.CREATED_TASK_LIST+'`');
    console.log('[SQL:]', csql);
    query(csql, (err, result, fields) => {
      if (err) {
        console.log('[UPDATE_TASK_LIST ERROR]:', err.message)
      }
      query(sql.SELECT_TASK_GROUP, (err, result, fields) => {
        if (err) {
          console.log('[SELECT_TASK_GROUP ERROR]:', err.message)
        }
        // 向所有用户发送数据
        io.emit('update-task-callback', result);
      })
    })
  });
});
...
http.listen(3000, () => {
  console.log('Server running at 3000 port')
})

解析： 1、socket.io监听update-task接收拖动的任务，并把最新要归纳的分组id带回。 2、更新数据 3、更新后查询任务列表，向所有用户广播io.emit() 4、客户端监听update-task-callback消息，得到最新的任务列表数据，并重新渲染页面。