[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_11":-5},"routes/user.$name.replies",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":16},"replies",[35],"user",{"_20":21,"_13":14,"_22":23,"_24":14,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34},"loginname","2407724262","page",1,"limit",50,"total","id","41340","avatar_url","https://avatars.githubusercontent.com/u/79882675?v=4","githubUsername","create_at","2021-05-20 00:39:47.134","score",300,"topic_count",3,"reply_count",57,"is_star",false,{"_20":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":34,"_48":34,"_31":49,"_50":51,"_25":52,"_53":54},"45336","author_id","41269","tab","share","content","# 【Pomelo】chat\r\n\r\n[\\[官方\\]Chat源码下载与安装](https://github.com/NetEase/pomelo/wiki/chat%E6%BA%90%E7%A0%81%E4%B8%8B%E8%BD%BD%E4%B8%8E%E5%AE%89%E8%A3%85)\r\n\r\n执行:sh npm-install.sh\r\n\r\n出现下面错误:\r\n\r\n```text\r\nnpm ERR! code 1\r\nnpm ERR! path /data/gocpplua/pomelo/pomelo_prj/chatofpomelo-websocket/game-server/node_modules/heapdump\r\nnpm ERR! command failed\r\nnpm ERR! command sh -c node-gyp rebuild\r\nnpm ERR! make: Entering directory '/data/gocpplua/pomelo/pomelo_prj/chatofpomelo-websocket/game-server/node_modules/heapdump/build'\r\nnpm ERR! CXX(target) Release/obj.target/addon/src/heapdump.o\r\nnpm ERR! addon.target.mk:109: recipe for target 'Release/obj.target/addon/src/heapdump.o' failed\r\nnpm ERR! make: Leaving directory '/data/gocpplua/pomelo/pomelo_prj/chatofpomelo-websocket/game-server/node_modules/heapdump/build'\r\nnpm ERR! gyp info it worked if it ends with ok\r\nnpm ERR! gyp info using node-gyp@7.1.2\r\nnpm ERR! gyp info using node@14.16.1 | linux | x64\r\nnpm ERR! gyp info find Python using Python version 3.5.2 found at \"/usr/bin/python3\"\r\nnpm ERR! gyp info spawn /usr/bin/python3\r\nnpm ERR! gyp info spawn args [\r\nnpm ERR! gyp info spawn args '/home/AA/XX/.nvm/versions/node/v14.16.1/lib/node_modules/npm/node_modules/node-gyp/gyp/gyp_main.py',\r\nnpm ERR! gyp info spawn args 'binding.gyp',\r\nnpm ERR! gyp info spawn args '-f',\r\nnpm ERR! gyp info spawn args 'make',\r\nnpm ERR! gyp info spawn args '-I',\r\nnpm ERR! gyp info spawn args '/data/gocpplua/pomelo/pomelo_prj/chatofpomelo-websocket/game-server/node_modules/heapdump/build/config.gypi',\r\nnpm ERR! gyp info spawn args '-I',\r\nnpm ERR! gyp info spawn args '/home/AA/XX/.nvm/versions/node/v14.16.1/lib/node_modules/npm/node_modules/node-gyp/addon.gypi',\r\nnpm ERR! gyp info spawn args '-I',\r\nnpm ERR! gyp info spawn args '/home/AA/XX/.cache/node-gyp/14.16.1/include/node/common.gypi',\r\nnpm ERR! gyp info spawn args '-Dlibrary=shared_library',\r\nnpm ERR! gyp info spawn args '-Dvisibility=default',\r\nnpm ERR! gyp info spawn args '-Dnode_root_dir=/home/AA/XX/.cache/node-gyp/14.16.1',\r\nnpm ERR! gyp info spawn args '-Dnode_gyp_dir=/home/AA/XX/.nvm/versions/node/v14.16.1/lib/node_modules/npm/node_modules/node-gyp',\r\nnpm ERR! gyp info spawn args '-Dnode_lib_file=/home/AA/XX/.cache/node-gyp/14.16.1/<(target_arch)/node.lib',\r\nnpm ERR! gyp info spawn args '-Dmodule_root_dir=/data/gocpplua/pomelo/pomelo_prj/chatofpomelo-websocket/game-server/node_modules/heapdump',\r\nnpm ERR! gyp info spawn args '-Dnode_engine=v8',\r\nnpm ERR! gyp info spawn args '--depth=.',\r\nnpm ERR! gyp info spawn args '--no-parallel',\r\nnpm ERR! gyp info spawn args '--generator-output',\r\nnpm ERR! gyp info spawn args 'build',\r\nnpm ERR! gyp info spawn args '-Goutput_dir=.'\r\nnpm ERR! gyp info spawn args ]\r\nnpm ERR! gyp info spawn make\r\nnpm ERR! gyp info spawn args [ 'BUILDTYPE=Release', '-C', 'build' ]\r\nnpm ERR! In file included from ../src/heapdump.cc:17:\r\nnpm ERR! ../src/compat-inl.h: In static member function ‘static void compat::CpuProfiler::StartCpuProfiling(v8::Isolate*, v8::Local)’:\r\nnpm ERR! ../src/compat-inl.h:300:19: error: ‘class v8::Isolate’ has no member named ‘GetCpuProfiler’; did you mean ‘GetHeapProfiler’?\r\nnpm ERR! 300 | return isolate->GetCpuProfiler()->StartProfiling(title, record_samples);\r\nnpm ERR! | ^~~~~~~~~~~~~~\r\nnpm ERR! | GetHeapProfiler\r\nnpm ERR! ../src/compat-inl.h:300:73: error: return-statement with a value, in function returning ‘void’ [-fpermissive]\r\nnpm ERR! 300 | return isolate->GetCpuProfiler()->StartProfiling(title, record_samples);\r\nnpm ERR! | ^\r\nnpm ERR! ../src/compat-inl.h: In static member function ‘static const v8::CpuProfile* compat::CpuProfiler::StopCpuProfiling(v8::Isolate*, v8::Local)’:\r\nnpm ERR! ../src/compat-inl.h:310:19: error: ‘class v8::Isolate’ has no member named ‘GetCpuProfiler’; did you mean ‘GetHeapProfiler’?\r\nnpm ERR! 310 | return isolate->GetCpuProfiler()->StopProfiling(title);\r\nnpm ERR! | ^~~~~~~~~~~~~~\r\nnpm ERR! | GetHeapProfiler\r\nnpm ERR! ../src/compat-inl.h: In static member function ‘static v8::Local compat::String::NewFromUtf8(v8::Isolate*, const char*, compat::String::NewStringType, int)’:\r\nnpm ERR! ../src/compat-inl.h:341:46: error: ‘NewStringType’ in ‘class v8::String’ does not name a type\r\nnpm ERR! 341 | isolate, data, static_cast(type), length);\r\nnpm ERR! | ^~~~~~~~~~~~~\r\nnpm ERR! ../src/heapdump.cc: At global scope:\r\nnpm ERR! ../src/heapdump.cc:52:11: error: ‘v8::Handle’ has not been declared\r\nnpm ERR! 52 | using v8::Handle;\r\nnpm ERR! | ^~~~~~\r\nnpm ERR! ../src/heapdump.cc: In function ‘compat::ReturnType {anonymous}::WriteSnapshot(const ArgumentType&)’:\r\nnpm ERR! ../src/heapdump.cc:106:46: error: no matching function for call to ‘v8::String::Utf8Value::Utf8Value(v8::Local)’\r\nnpm ERR! 106 | String::Utf8Value filename_string(args[0]);\r\nnpm ERR! | ^\r\nnpm ERR! In file included from /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:67,\r\nnpm ERR! from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3287:5: note: candidate: ‘v8::String::Utf8Value::Utf8Value(v8::Isolate*, v8::Local)’\r\nnpm ERR! 3287 | Utf8Value(Isolate* isolate, Local obj);\r\nnpm ERR! | ^~~~~~~~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3287:5: note: candidate expects 2 arguments, 1 provided\r\nnpm ERR! ../src/heapdump.cc: In function ‘void {anonymous}::InvokeCallback(const char*)’:\r\nnpm ERR! ../src/heapdump.cc:144:32: warning: ‘v8::Local node::MakeCallback(v8::Isolate*, v8::Local, v8::Local, int, v8::Local*)’ is deprecated: Use MakeCallback(..., async_context) [-Wdeprecated-declarations]\r\nnpm ERR! 144 | argc, argv);\r\nnpm ERR! | ^\r\nnpm ERR! In file included from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:191:50: note: declared here\r\nnpm ERR! 191 | NODE_EXTERN v8::Local MakeCallback(\r\nnpm ERR! | ^~~~~~~~~~~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:108:42: note: in definition of macro ‘NODE_DEPRECATED’\r\nnpm ERR! 108 | __attribute__((deprecated(message))) declarator\r\nnpm ERR! | ^~~~~~~~~~\r\nnpm ERR! ../src/heapdump.cc:144:32: warning: ‘v8::Local node::MakeCallback(v8::Isolate*, v8::Local, v8::Local, int, v8::Local*)’ is deprecated: Use MakeCallback(..., async_context) [-Wdeprecated-declarations]\r\nnpm ERR! 144 | argc, argv);\r\nnpm ERR! | ^\r\nnpm ERR! In file included from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:191:50: note: declared here\r\nnpm ERR! 191 | NODE_EXTERN v8::Local MakeCallback(\r\nnpm ERR! | ^~~~~~~~~~~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:108:42: note: in definition of macro ‘NODE_DEPRECATED’\r\nnpm ERR! 108 | __attribute__((deprecated(message))) declarator\r\nnpm ERR! | ^~~~~~~~~~\r\nnpm ERR! ../src/heapdump.cc: In function ‘compat::ReturnType {anonymous}::Configure(const ArgumentType&)’:\r\nnpm ERR! ../src/heapdump.cc:157:55: error: no matching function for call to ‘v8::Value::Int32Value()’\r\nnpm ERR! 157 | PlatformInit(args.GetIsolate(), args[0]->Int32Value());\r\nnpm ERR! | ^\r\nnpm ERR! In file included from /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:67,\r\nnpm ERR! from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:2869:40: note: candidate: ‘v8::Maybe v8::Value::Int32Value(v8::Local) const’\r\nnpm ERR! 2869 | V8_WARN_UNUSED_RESULT Maybe Int32Value(Local context) const;\r\nnpm ERR! | ^~~~~~~~~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:2869:40: note: candidate expects 1 argument, 0 provided\r\nnpm ERR! ../src/heapdump.cc: In function ‘void {anonymous}::Initialize(v8::Local)’:\r\nnpm ERR! ../src/heapdump.cc:164:51: error: no matching function for call to ‘v8::Object::Set(v8::Local, v8::Local)’\r\nnpm ERR! 164 | C::Integer::New(isolate, kForkFlag));\r\nnpm ERR! | ^\r\nnpm ERR! In file included from /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:67,\r\nnpm ERR! from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3670:37: note: candidate: ‘v8::Maybe v8::Object::Set(v8::Local, v8::Local, v8::Local)’\r\nnpm ERR! 3670 | V8_WARN_UNUSED_RESULT Maybe Set(Local context,\r\nnpm ERR! | ^~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3670:37: note: candidate expects 3 arguments, 2 provided\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3673:37: note: candidate: ‘v8::Maybe v8::Object::Set(v8::Local, uint32_t, v8::Local)’\r\nnpm ERR! 3673 | V8_WARN_UNUSED_RESULT Maybe Set(Local context, uint32_t index,\r\nnpm ERR! | ^~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3673:37: note: candidate expects 3 arguments, 2 provided\r\nnpm ERR! ../src/heapdump.cc:166:53: error: no matching function for call to ‘v8::Object::Set(v8::Local, v8::Local)’\r\nnpm ERR! 166 | C::Integer::New(isolate, kSignalFlag));\r\nnpm ERR! | ^\r\nnpm ERR! In file included from /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:67,\r\nnpm ERR! from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3670:37: note: candidate: ‘v8::Maybe v8::Object::Set(v8::Local, v8::Local, v8::Local)’\r\nnpm ERR! 3670 | V8_WARN_UNUSED_RESULT Maybe Set(Local context,\r\nnpm ERR! | ^~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3670:37: note: candidate expects 3 arguments, 2 provided\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3673:37: note: candidate: ‘v8::Maybe v8::Object::Set(v8::Local, uint32_t, v8::Local)’\r\nnpm ERR! 3673 | V8_WARN_UNUSED_RESULT Maybe Set(Local context, uint32_t index,\r\nnpm ERR! | ^~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:3673:37: note: candidate expects 3 arguments, 2 provided\r\nnpm ERR! ../src/heapdump.cc:168:74: error: no matching function for call to ‘v8::FunctionTemplate::GetFunction()’\r\nnpm ERR! 168 | C::FunctionTemplate::New(isolate, Configure)->GetFunction());\r\nnpm ERR! | ^\r\nnpm ERR! In file included from /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:67,\r\nnpm ERR! from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:6482:46: note: candidate: ‘v8::MaybeLocal v8::FunctionTemplate::GetFunction(v8::Local)’\r\nnpm ERR! 6482 | V8_WARN_UNUSED_RESULT MaybeLocal GetFunction(\r\nnpm ERR! | ^~~~~~~~~~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:6482:46: note: candidate expects 1 argument, 0 provided\r\nnpm ERR! ../src/heapdump.cc:170:78: error: no matching function for call to ‘v8::FunctionTemplate::GetFunction()’\r\nnpm ERR! 170 | C::FunctionTemplate::New(isolate, WriteSnapshot)->GetFunction());\r\nnpm ERR! | ^\r\nnpm ERR! In file included from /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:67,\r\nnpm ERR! from ../src/heapdump.cc:15:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:6482:46: note: candidate: ‘v8::MaybeLocal v8::FunctionTemplate::GetFunction(v8::Local)’\r\nnpm ERR! 6482 | V8_WARN_UNUSED_RESULT MaybeLocal GetFunction(\r\nnpm ERR! | ^~~~~~~~~~~\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/v8.h:6482:46: note: candidate expects 1 argument, 0 provided\r\nnpm ERR! In file included from ../src/heapdump.cc:15:\r\nnpm ERR! ../src/heapdump.cc: At global scope:\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:758:43: warning: cast between incompatible function types from ‘void (*)(v8::Local)’ to ‘node::addon_register_func’ {aka ‘void (*)(v8::Local, v8::Local, void*)’} [-Wcast-function-type]\r\nnpm ERR! 758 | (node::addon_register_func) (regfunc), \\\r\nnpm ERR! | ^\r\nnpm ERR! /home/AA/XX/.cache/node-gyp/14.16.1/include/node/node.h:792:3: note: in expansion of macro ‘NODE_MODULE_X’\r\nnpm ERR! 792 | NODE_MODULE_X(modname, regfunc, NULL, 0) // NOLINT (readability/null_usage)\r\nnpm ERR! | ^~~~~~~~~~~~~\r\nnpm ERR! ../src/heapdump.cc:173:1: note: in expansion of macro ‘NODE_MODULE’\r\nnpm ERR! 173 | NODE_MODULE(addon, Initialize)\r\nnpm ERR! | ^~~~~~~~~~~\r\nnpm ERR! make: *** [Release/obj.target/addon/src/heapdump.o] Error 1\r\nnpm ERR! gyp ERR! build error \r\nnpm ERR! gyp ERR! stack Error: `make` failed with exit code: 2\r\nnpm ERR! gyp ERR! stack at ChildProcess.onExit (/home/AA/XX/.nvm/versions/node/v14.16.1/lib/node_modules/npm/node_modules/node-gyp/lib/build.js:194:23)\r\nnpm ERR! gyp ERR! stack at ChildProcess.emit (events.js:315:20)\r\nnpm ERR! gyp ERR! stack at Process.ChildProcess._handle.onexit (internal/child_process.js:277:12)\r\nnpm ERR! gyp ERR! System Linux 4.15.0-142-generic\r\nnpm ERR! gyp ERR! command \"/home/AA/XX/.nvm/versions/node/v14.16.1/bin/node\" \"/home/AA/XX/.nvm/versions/node/v14.16.1/lib/node_modules/npm/node_modules/node-gyp/bin/node-gyp.js\" \"rebuild\"\r\nnpm ERR! gyp ERR! cwd /data/gocpplua/pomelo/pomelo_prj/chatofpomelo-websocket/game-server/node_modules/heapdump\r\nnpm ERR! gyp ERR! node -v v14.16.1\r\nnpm ERR! gyp ERR! node-gyp -v v7.1.2\r\nnpm ERR! gyp ERR! not ok\r\nnpm timing npm Completed in 5451ms\r\n\r\nnpm ERR! A complete log of this run can be found in:\r\nnpm ERR! /home/AA/XX/.npm/_logs/2021-05-24T12_40_11_114Z-debug.log\r\n============ game-server npm installed ============\r\n\r\n```\r\n\r\n然后网上说执行下面命令即可:\r\n\r\n> npm install --global --production build-tools\r\n\r\n可是我操作以后还是不行。\r\n\r\n由于自己误操作，执行了:\r\n\r\n> polemo start\r\n\r\n既然可以正常运行，于是上面错误我就不管了。\r\n\r\n然后启动 web-server以后，通过浏览器登录两个账号，就可以聊天了。\r\n\r\n> 注意:enter your channel 　需要填写一样。\r\n\r\n通过命令查看pomelo服务:\r\n\r\n```text\r\nXXX\\XXX@cn0314000510l:~$ pomelo list\r\ntry to connect 127.0.0.1:3005\r\n(node:371) Warning: Accessing non-existent property 'padLevels' of module exports inside circular dependency\r\n(Use `node --trace-warnings ...` to show where the warning was created)\r\nserverId serverType pid rss(M) heapTotal(M) heapUsed(M) uptime(m) \r\nchat-server-1 chat 31392 45.67 12.90 11.77 3.50 \r\nconnector-server-1 connector 31391 48.51 15.02 13.55 3.50 \r\ngate-server-1 gate 31393 47.05 14.27 12.92 3.50 \r\nmaster-server-1 master 31380 44.75 12.40 11.20 3.50 \r\n```\r\n\r\n可以看到，除了master 和　connector　服务，还多了chat和gate。\r\n\r\n这些服务都是通过 servers.json 里面进行配置，下面就是servers.json 文件:\r\n\r\n```text\r\n{\r\n \"development\":{\r\n \"connector\":[\r\n {\"id\":\"connector-server-1\", \"host\":\"127.0.0.1\", \"port\":4050, \"clientPort\": 3050, \"frontend\": true}\r\n ],\r\n \"chat\":[\r\n {\"id\":\"chat-server-1\", \"host\":\"127.0.0.1\", \"port\":6050}\r\n ],\r\n \"gate\":[\r\n\t {\"id\": \"gate-server-1\", \"host\": \"127.0.0.1\", \"clientPort\": 3014, \"frontend\": true}\r\n\t ]\r\n },\r\n \"production\":{\r\n \"connector\":[\r\n {\"id\":\"connector-server-1\", \"host\":\"127.0.0.1\", \"port\":4050, \"clientPort\": 3050, \"frontend\": true}\r\n ],\r\n \"chat\":[\r\n {\"id\":\"chat-server-1\", \"host\":\"127.0.0.1\", \"port\":6050}\r\n ],\r\n \"gate\":[\r\n {\"id\": \"gate-server-1\", \"host\": \"127.0.0.1\", \"clientPort\": 3014, \"frontend\": true}\r\n ]\r\n }\r\n}\r\n\r\n```\r\n\r\n\r\n\r\n接着启动web-server，然后打开浏览器，输入`http://127.0.0.1:3001/index.html`, 输入一个用户名和一个房间名，点击　Join按钮。\r\n\r\n首先在下述代码中收到消息:\r\n\r\n```text\r\n// pomelo/lib/connectors/hybrid/switcher.js\r\nsocket.once('data', function(data) {\r\n // FIXME: handle incomplete HTTP method\r\n if(isHttp(data)) {\r\n processHttp(self, self.wsprocessor, socket, data);\r\n } else {\r\n if(!!self.setNoDelay) {\r\n socket.setNoDelay(true);\r\n }\r\n processTcp(self, self.tcpprocessor, socket, data);\r\n }\r\n });\r\n```\r\n\r\n收到'connection'消息，然后到:\r\n\r\n```text\r\n // pomelo/lib/connectors/hybridconnector.js\r\n this.switcher.on('connection', function(socket) {\r\n gensocket(socket);\r\n });\r\n```\r\n\r\n在gensocket中，设置了id,并且发送'connection'事件:\r\n\r\n```text\r\n // pomelo/lib/connectors/hybridconnector.js\r\n var gensocket = function(socket) {\r\n var hybridsocket = new HybridSocket(curId++, socket);\r\n hybridsocket.on('handshake', self.handshake.handle.bind(self.handshake, hybridsocket));\r\n hybridsocket.on('heartbeat', self.heartbeat.handle.bind(self.heartbeat, hybridsocket));\r\n hybridsocket.on('disconnect', self.heartbeat.clear.bind(self.heartbeat, hybridsocket.id));\r\n hybridsocket.on('closing', Kick.handle.bind(null, hybridsocket));\r\n self.emit('connection', hybridsocket);\r\n };\r\n```\r\n\r\n在connector.js中监听了'connection'事件:\r\n\r\n```text\r\npro.afterStart = function(cb) {\r\n this.connector.start(cb);\r\n this.connector.on('connection', hostFilter.bind(this, bindEvents));\r\n};\r\n```\r\n\r\n然后执行bindEvents:\r\n\r\n```text\r\n// /pomelo/lib/components/connector.js\r\nvar bindEvents = function(self, socket) {\r\n var curServer = self.app.getCurServer();\r\n var maxConnections = curServer['max-connections'];\r\n if (self.connection && maxConnections) {\r\n self.connection.increaseConnectionCount();\r\n var statisticInfo = self.connection.getStatisticsInfo();\r\n if (statisticInfo.totalConnCount > maxConnections) {\r\n logger.warn('the server %s has reached the max connections %s', curServer.id, maxConnections);\r\n socket.disconnect();\r\n return;\r\n }\r\n }\r\n```\r\n\r\n在pomelo/lib/common/service/sessionService.js中创建一个session.其中入参sid就是socket id:\r\n\r\n```text\r\n// pomelo/lib/common/service/sessionService.js\r\nSessionService.prototype.create = function(sid, frontendId, socket) {\r\n var session = new Session(sid, frontendId, socket, this);\r\n this.sessions[session.id] = session;\r\n\r\n return session;\r\n};\r\n```\r\n\r\n接着会收到‘meaasge’消息:\r\n\r\n```text\r\n // /pomelo/lib/connectors/hybridsocket.js\r\n socket.on('message', function(msg) {\r\n if(msg) {\r\n msg = Package.decode(msg);\r\n handler(self, msg);\r\n }\r\n });\r\n```\r\n\r\n在上述接口中一次收到TYPE\\_HANDSHAKE、TYPE\\_HANDSHAKE\\_ACK、TYPE\\_HEARTBEAT，最后收到TYPE\\_DATA数据,于是进入回调:\r\n\r\n```text\r\n// pomelo/lib/connectors/common/handler.js\r\nvar handleData = function(socket, pkg) {\r\n if(socket.state !== ST_WORKING) {\r\n return;\r\n }\r\n socket.emit('message', pkg);\r\n};\r\n```\r\n\r\nconnector收到`'message'事件(客户端发送:`'gate.gateHandler.queryEntry'`)，并且处理:`\r\n\r\n```text\r\n// /pomelo/lib/components/connector.js\r\nvar bindEvents = function(self, socket) {\r\n ...\r\n // new message\r\n socket.on('message', function(msg) {\r\n ...\r\n\r\n handleMessage(self, session, dmsg);\r\n }); //on message end\r\n};\r\n```\r\n\r\n然后调用组件server.js的globalHandle接口:\r\n\r\n```text\r\n// pomelo/lib/components/server.js\r\n/**\r\n * Proxy server global handle\r\n */\r\npro.globalHandle = function(msg, session, cb) {\r\n\tthis.server.globalHandle(msg, session, cb);\r\n};\r\n```\r\n\r\n再调用下述接口\$入参msg:{id: 1, type: 0, compressRoute: 0, route: 'gate.gateHandler.queryEntry', body: {…}, …}\$:\r\n\r\n```text\r\n// /pomelo/lib/server/server.js\r\npro.globalHandle = function(msg, session, cb) {\r\n...\r\n var dispatch = function(err, resp, opts) {\r\n if(err) {\r\n handleError(true, self, err, msg, session, resp, opts, function(err, resp, opts) {\r\n response(true, self, err, msg, session, resp, opts, cb);\r\n });\r\n return;\r\n }\r\n\r\n if(self.app.getServerType() !== routeRecord.serverType) {\r\n doForward(self.app, msg, session, routeRecord, function(err, resp, opts) {\r\n response(true, self, err, msg, session, resp, opts, cb);\r\n });\r\n } else {\r\n doHandle(self, msg, session, routeRecord, function(err, resp, opts) {\r\n response(true, self, err, msg, session, resp, opts, cb);\r\n });\r\n }\r\n };\r\n beforeFilter(true, self, msg, session, dispatch);\r\n};\r\n```\r\n\r\n最后会queryEntry，得到对应的connector对应的host和port。\r\n\r\n```text\r\n// app/servers/gate/handler/gateHandler.js\r\nhandler.queryEntry = function(msg, session, next) {\r\n\t...\r\n\t// here we just start `ONE` connector server, so we return the connectors[0] \r\n\tvar res = connectors[0];\r\n\tnext(null, {\r\n\t\tcode: 200,\r\n\t\thost: res.host,\r\n\t\tport: res.clientPort\r\n\t});\r\n};\r\n```\r\n\r\n接着客户端发送进房间消息\$路由:'connector.entryHandler.enter'\$，服务器将用户添加到对应的channel:\r\n\r\n```text\r\n// app/servers/connector/handler/entryHandler.js\r\nhandler.enter = function(msg, session, next) {\r\n\t...\r\n\r\n\t//put user into channel\r\n\tself.app.rpc.chat.chatRemote.add(session, uid, self.app.get('serverId'), rid, true, function(users){\r\n\t\tnext(null, {\r\n\t\t\tusers:users\r\n\t\t});\r\n\t});\r\n};\r\n```\r\n\r\n然后进入ChatRemote.prototype.add:\r\n\r\n```text\r\n// app/servers/chat/remote/chatRemote.js\r\nChatRemote.prototype.add = function(uid, sid, name, flag, cb) {\r\n\tvar channel = this.channelService.getChannel(name, flag);\r\n\tvar username = uid.split('*')[0];\r\n\tvar param = {\r\n\t\troute: 'onAdd',\r\n\t\tuser: username\r\n\t};\r\n\tchannel.pushMessage(param);\r\n\r\n\tif( !! channel) {\r\n\t\tchannel.add(uid, sid);\r\n\t}\r\n\r\n\tcb(this.get(name, flag));\r\n};\r\n\r\n```\r\n\r\n接着进入回调，返回到entryHandler.js的next　回调,\r\n\r\n```text\r\n\t//put user into channel\r\n\tself.app.rpc.chat.chatRemote.add(session, uid, self.app.get('serverId'), rid, true, function(users){\r\n\t\tnext(null, {\r\n\t\t\tusers:users\r\n\t\t});\r\n\t});\r\n```\r\n\r\n最后调用:\r\n\r\n```text\r\n// pomelo/lib/server/server.js\r\n/**\r\n * Send response to client and fire after filter chain if any.\r\n */\r\n\r\nvar response = function(isGlobal, server, err, msg, session, resp, opts, cb) \r\n```","title","【Pomelo】chat","last_reply_at","2021-05-27 02:02:50.158","good","top",5,"visit_count",2783,"2021-05-26 01:12:35.928","author",{"_13":55,"_22":56},"gocpplua","https://avatars.githubusercontent.com/u/46804866?v=4"]