0

我正在使用molerrjs 来处理后端的微服务，并使用其中一个前端应用程序来处理通过套接字进行的通信。为此，我正在使用moleculer.io. 我遇到的问题是，即使我将套接字连接到ctx钩子中，当我在控制器函数中onBeforeCall()console.log 时，套接字也不存在。ctx

我的网关看起来像这样（注意套接字被添加到钩子中的ctx对象中：onBeforeCall()

const SocketIOService = require("moleculer-io");

module.exports = {
  name: 'oas',
  mixins: [SocketIOService],

  settings: {
    port: 5000,
    io: {
      namespaces: {
        '/': {
          events: {
            'call': {
              aliases: {
                'auth.register': 'oas.controllers.auth.register'
              },
              whitelist: [
                '**',
              ],
              onBeforeCall: async function(ctx, socket, action, params, callOptions) { // before hook
                console.log('socket: ', socket); // This exists here
                ctx.socket = socket; // Here I attach the socket to the ctx object
              },
              onAfterCall: async function(ctx, socket, res) { // after hook
                // console.log('after hook', res)
                // res: The response data.
              }
            }
          }
        }
      }
    },

    events: {},

    actions: {}
  }
};

我的 auth.service 看起来像这样 - 注意register()尝试访问的函数ctx.socket：

"use strict";

/**
 * @typedef {import('moleculer').Context} Context Moleculer's Context
 */

module.exports = {
    name: "oas.controllers.auth",

    /**
     * Settings
     */
    settings: {

    },

    /**
     * Dependencies
     */
    dependencies: [],

    /**
     * Actions
     */
    actions: {
    async register(ctx) {
      console.log('ctx.socket: ', ctx.socket); // This is undefined

      // Other code...
    },

    /**
     * Events
     */
    events: {

    },

    /**
     * Methods
     */
    methods: {

    },

    /**
     * Service created lifecycle event handler
     */
    created() {

    },

    /**
     * Service started lifecycle event handler
     */
    async started() {

    },

    /**
     * Service stopped lifecycle event handler
     */
    async stopped() {

    }
};

在被调用的register()函数中，ctx.socket是undefined. 我在这里想念什么？我认为它onBeforeCall()旨在用于这种目的，但也许我误解了一些东西。

我应该或可以采用其他方法来确保套接字在被调用函数中可用吗？只是为了澄清一下，套接字在onBeforeCall()钩子中可用。我需要弄清楚如何使它可用。

4

2 回答 2

0

你不能那样做。你不能把任何东西放到ctx. ServiceBroker 将仅序列化和传输ctx.params和ctx.meta属性。但是你不能把socket放进去，因为你喜欢的Socket对象是不可序列化的，所以你不能在远程服务中访问它。它可以在单体项目中工作，而不是在微服务项目中。

于 2021-02-12T14:01:24.097 回答
0

最后我找到了一种方法来做到这一点。ctx正如@Icebob 指出的那样，您不能直接将套接字附加到，而是可以附加它ctx.meta，如下所示：

onBeforeCall: async function(ctx, socket, action, params, callOptions) { // before hook
  ctx.meta.socket = socket;
},

通过这样做，我能够成功访问我register()函数中的套接字。

于 2021-02-12T14:26:12.943 回答