app.js 908 B

123456789101112131415161718192021222324252627282930313233
  1. const socketClient = require('./socketClient')
  2. const Koa = require('koa')
  3. const app = new Koa()
  4. var http = require('http');
  5. var server = http.createServer(app.callback());
  6. io = require('socket.io').listen(server);
  7. var protocal = require('./protocal/protocal')
  8. var sendProtocal = require('./protocal/sendProtocal')
  9. var command = require('./protocal/command')
  10. // 为这个socket实例添加一个"data"事件处理函数
  11. socketClient.on('validData', function (data) {
  12. var dataStrs = "";
  13. data.forEach(function (t) {
  14. dataStrs += t.toString(16);
  15. })
  16. // 第二位command位转换成对应协议名
  17. const protocalType = command[data[1]];
  18. const json = protocal[protocalType](data);
  19. console.log(protocalType)
  20. if (protocalType === undefined) {
  21. console.log('Uknown command')
  22. return;
  23. }
  24. io.sockets.emit(protocalType, json);
  25. });
  26. module.exports = server