[Support] 我需要在http服务里调用socket服务的api，向某个房间传递信息，但是不知道该怎么实现

[celiu12345]

Describe the problem（描述问题）

import { Config, WSController, OnWSConnection, Inject, OnWSMessage, WSBroadCast, Provide } from "@midwayjs/decorator";
import { Context } from "@midwayjs/socketio";
import { CoolCommException, } from '@cool-midway/core';
import { WSEmit, Scope, ScopeEnum } from '@midwayjs/core';
import * as http from 'http';
import * as jwt from 'jsonwebtoken';
import { DeviceEntity } from '../entity/info';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Repository } from 'typeorm';

/**
 * 设备
 */
@Provide()
@WSController("/device")
export class DeviceController {
  @Inject()
  ctx: Context;

  @Config('module.device.jwt')
  jwtConfig;

  @InjectEntityModel(DeviceEntity)
  deviceEntity: Repository<DeviceEntity>;

  private socketMap;

  constructor() {
    this.socketMap = new Map();
  }

  // 客户端连接
  @OnWSConnection()
  async onConnectionMethod(data) {
    console.log('====websocket Connection=====')
    let query = this.ctx.handshake.query
    let socketId = this.ctx.id
    console.log(socketId)

    const roomId = `device-${query.id}`; // 获取房间ID
    this.ctx.join(roomId); // 加入房间

    if (!this.socketMap[roomId]) {
      this.socketMap.set(roomId, this.ctx)
    }

    console.log("on client connect");
    this.ctx.emit("room", { id: this.ctx.id, room: roomId, data: null, query: this.ctx.handshake.query });
  }


  // 接受消息
  @OnWSMessage('message')
  // @WSBroadCast()
  @WSEmit('myMessageResult')
  async gotMyMessage(room, data) {
    return {'abc': 123}
  }


  @OnWSMessage('event')
  @WSEmit('myEventResult')
  async gotMessage(data) {
    return '1234'
  }

  sendMessageToDevice(room, value) {
    console.log(this.socketMap)
    const client = this.socketMap.get(room);
    if (client) {
      client.emit('data', value);
    } else {
      throw new Error(`No active socket for device with ID ${room}`);
    }
  }

}

这是我的socket代码，我需要在用户通过http提交任务之后，向某个连接socket的设备发送一条开始工作的指令，以下是我在http服务里的代码：

import { Config, Provide, Inject } from '@midwayjs/decorator';
import { BaseService, CoolFileConfig, CoolCommException } from '@cool-midway/core';
import { DeviceController } from '../socket/info';

/**
 * 设备
 */
@Provide()
export class DeviceService extends BaseService {
  

  @Inject()
  deviceController: DeviceController;


  // 测试
  async test(param) {
    this.deviceController.sendMessageToDevice(param.room, 'http链接发送')
  }
}

我可以确定已经通过设备连接并创建了socket房间，但当我在http里调用sendMessageToDevice的时候，控制台打印出的socketMap是{}，请各位大佬帮忙看看，无比感谢

Midway Versions（Midway 版本）

[email protected]

[czy88840616]

1、不要试图在 service 中注入 Controller，层级反转了，你应该单独抽一个消息中转、处理的通用服务
2、应该不需要再创建 map 维持 room 数据，socket.io自己已经做了这个事情，你可以在通用服务中直接用 @app('socket.io') 注入 socket.io 本身，然后通过 api 拿到当前的 room，以及 room 相关的数据

[celiu12345]

我有按照您说的这样尝试过，但是当我调用.to(room),emit()的时候无法给客户端传递信息，但是也不报错。代码如下

// 接受消息
  @OnWSMessage('message')
  @WSEmit('myMessageResult')
  async gotMyMessage(room, data) {
    console.log('-----------message-----------', data)
    // 以下这行代码无任何反应
    this.ctx.to(room).emit('myMessageResult', '111');
  }

就是这段代码，我能100%确定已经创建了socket连接，并且已经加入到了一个叫做device-1的房间，也可以通过this.ctx.rooms打印出来房间，但是当我调用下面的api向客户端发送信息的时候，就没有什么反应，也不报错：

this.ctx.to(room).emit('myMessageResult', '111');

但如果我用我自己维护的socketMap，就可以成功发送给客户端，代码如下：

this.socketMap.get(room).emit('myMessageResult', '111');

其次还有一个地方我不确定，就是这个房间的号是需要我自己设置一个自定义的名字？还是直接用this.ctx.id？目前我使用的是房间号是"device-设备Id"这样的组成房间号，一般会是“device-1”。

[czy88840616]

import { App, Init, Inject, OnWSConnection, OnWSMessage, WSController, sleep } from "@midwayjs/core";
import { Application, Context } from "@midwayjs/socketio";

@WSController('/')
export class WSMessageController {

  @Inject()
  socket: Context;

  @App('socketIO')
  socketApp: Application;

  @Init()
  async init() {
    // 加入一个房间
    this.socket.join('room1');
  }

  @OnWSConnection()
  async onConnection() {
    console.log('socket connected: ' + this.socket.id);
  }

  @OnWSMessage('message')
  onMessage(msg) {
    console.log('got in OnWSMessage: ' + this.socket.id + ':' + msg); // 这里也收不到

    if (msg === 'abc') {
      // 注意，当前的 socket 发送房间消息，不会发送给当前自己的连接
      this.socket.in("room1").emit("hello", `Everybody in room1 from ${this.socket.id}`);
    } else if (msg === 'all') {
      // 注意，使用全局对象发送，这里会发送给所有，包括自己
      this.socketApp.in("room1").emit("hello", `Everybody in room1 from ${this.socket.id}`);
    } else {
      this.socket.emit('hello', `only you from ${this.socket.id}`);
    }
  }
}

[celiu12345]

感谢大佬，按照您说的已经调通了，是我文档没看全，谢谢您