node.js 개발 (3-2)

var server = net.createServer()
server.on('connection', function (socket) {
  console.log('connection')
})
server.on('error', function (err) {
  console.log('error')
})
server.on('close', function () {
  console.log('close')
})
server.listen(4001)

var server = net.createServer()
server.on('connection', function (socket) {
  console.log('connection')
  var conn = new Connection(socket)

  conn.on('packet', function (header, data) {
    console.log('packet receive')
  })
  conn.on('packet_error', function (err) {
    console.log('packet receive')
  })
  conn.on('error', function (err) {
    console.log('socket error')
  })
  conn.on('close', function () {
    console.log('socket close')
  })
})
server.on('error', function (err) {
  console.log('error')
})
server.on('close', function () {
  console.log('close')
})
server.listen(4001)

var User = function (conn) {
  this.conn = conn

  this.name = ''
  this.id = ''
}

User.prototype = {
  send: function (header, data) {
    this.conn.send(header, data)
  },

  // connection
  onPacket: function (header, data) {
    console.log('User:parsePacket', data)
  },
  onPacketError: function (err) {
    console.log('packet_error:', err)
    this.conn.close(proto.PK_CRITICALERROR)
    this.conn.pause()
  },
  onError: function (err) {
    console.log('socket error:', err)
    if (err.code != 'ECONNRESET') {
      this.conn.close(proto.PK_CRITICALERROR)
    }
    this.conn.pause()
  },
  onClose: function () {
    console.log('socket closed')
    this.conn = null
  },
}

server.on('connection', function (socket) {
  console.log('connection')
  var conn = new Connection(socket)

  var user = new User(conn)
  user.name = 'anonymous'

  conn.on('packet', function (header, data) {
    user.onPacket(header, data)
  })
  conn.on('packet_error', function (err) {
    user.onPacketError(err)
  })
  conn.on('error', function (err) {
    user.onError(err)
  })
  conn.on('close', function () {
    user.onClose()
  })
})

/**
 * world.js
 * 서버
 *
 * @require net
 */

// module
var net = require('net')
var util = require('util')

// include
var Connection = require('../common/connection')
var User = require('./user')

var World = function () {
  // 기본옵션
  this.option = {
    port: 8080,
    maxConnection: 10000,
    maxUser: 10000,
  }

  // 소켓서버
  this.server = net.createServer()

  // 유저목록
  this.users = []

  // server-event
  var self = this
  this.server.on('connection', function (socket) {
    self.onConnection(socket)
  })
  this.server.on('error', function (err) {
    console.log('err:', err.message)
    self.onError(err)
  })
  this.server.on('close', function () {
    self.onClose()
  })
}

util.inherits(World, require('events').EventEmitter)

util._extend(World.prototype, {
  config: function (option) {
    if (option) {
      util._extend(this.option, option)
    }
    console.log('## Setting ################################')
    console.log(this.option)
  },
  start: function () {
    console.log('## Start #################################')
    console.log('Welcome to the world~')

    this.server.listen(this.option.port)
    console.log('Listen:', this.option.port)
  },
  enter: function (user) {
    this.users.push(user)
    console.log('current user:' + this.users.length)
  },
  leave: function (user) {
    var index = this.users.indexOf(user)
    this.users.splice(index, 1)
    console.log('current user:' + this.users.length)
  },

  onConnection: function (socket) {
    var conn = new Connection(socket)
    if (this.option.maxConnection <= this.users.length) {
      conn.close(proto.PK_CRITICALERROR, 'max connection error')
      return
    }

    var user = new User(this, conn)
    this.enter(user)

    // socket-event
    var self = this
    conn.on('packet', function (header, data) {
      user.onPacket(header, data)
    })
    conn.on('packet_error', function (err) {
      user.onPacketError(err)
    })
    conn.on('error', function (err) {
      user.onError(err)
    })
    conn.on('close', function () {
      user.onClose()
    })
  },
  onError: function (err) {
    console.log('server error:', err.message)
  },
  onClose: function (close) {
    console.log('server close')
  },
})

module.exports = new World()

require('./world').start()