hhh

app/io/controller/chat.js

@@ -0,0 +1,21 @@
+'use strict';
+
+const Controller = require('egg').Controller;
+
+class ChatController extends Controller {
+  async index() {
+    this.ctx.socket.emit('res', 'test');
+  }
+  async message() { // 方法通过 客户端 this.emit（'message',{}）//触发
+    this.ctx.socket.emit('message', 'test');
+    const params = this.ctx.args[0];
+    // this.ctx.service.message.sendPeerMessage(params);
+    console.log(2, params);
+  }
+
+
+  async online() { // modelMessage.sendOfflineMessage(socket, data.userId);
+  }
+}
+
+module.exports = ChatController;

app/router.js

@@ -7,6 +7,8 @@ module.exports = app => {
   const { router, controller, io } = app;
   router.get('/', controller.home.index);
 
-  // socket.io
-  io.of('/').route('server', io.controller.default.server);
+  io.of('/').route('chat', io.controller.chat.index);
+  io.of('/').route('message', io.controller.chat.message);
+  io.of('/').route('user', io.controller.chat.online);
+
 };

config/config.default.js

@@ -37,7 +37,7 @@ module.exports = appInfo => {
         connectionMiddleware: [],
         packetMiddleware: [],
       },
-      '/example': {
+      '/news': {
         connectionMiddleware: [],
         packetMiddleware: [],
       },