15815213711
2024-08-26 67b8b6731811983447e053d4396b3708c14dfe3c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
'use strict';
 
const IoServer = require('socket.io');
const IoClient = require('socket.io-client');
const Koa = require('koa');
const EESocketServer = Symbol('Ee#SocketServer');
const EEIpcServer = Symbol('Ee#IpcServer');
const EEHttpServer = Symbol('Ee#HttpServer');
 
const EeSocket = {
 
  /**
   * 提供基础库 - 避免用户重复安装
   */
  Koa,
  IoServer,
  IoClient,
 
  /**
   * 启动所有服务
   */ 
  startAll(app) {
    this._createSocketServer(app);
    this._createHttpServer(app);
    this._createIpcServer(app);
  },
 
  /**
   * 创建SocketServer
   */ 
  _createSocketServer(app) {
    const SocketServer = require('./socketServer');
    this[EESocketServer] = new SocketServer(app);
 
    return this[EESocketServer];
  },
 
  /**
   * 获取 Socket Server
   */
  getSocketServer() {
    return this[EESocketServer] || null;
  },  
 
  /**
   * 创建 Http Server
   */ 
  _createHttpServer(app) {
    const HttpServer = require('./httpServer');
    this[EEHttpServer] = new HttpServer(app);
 
    return this[EEHttpServer];
  },
 
  /**
   * 获取 Http Server
   */
  getHttpServer() {
    return this[EEHttpServer] || null;
  }, 
 
  /**
   * 创建 IPC Server
   */ 
  _createIpcServer(app) {
    const IpcServer = require('./ipcServer');
    this[EEIpcServer] = new IpcServer(app);
 
    return this[EEIpcServer];
  },
 
  /**
   * 获取 IPC Server
   */
  getIpcServer() {
    return this[EEIpcServer] || null;
  },   
 
}
 
 
module.exports = EeSocket;