Вопрос по javascript, events – Клиент Socket.io: отвечать на все события одним обработчиком?

68

Можно ли сделать так, чтобы клиент socket.io отвечал на все события, не указывая каждое событие отдельно?

Например, что-то вроде этого (что, очевидно, сейчас не работает):

var socket = io.connect("http://myserver");

socket.on("*", function(){
  // listen to any and all events that are emitted from the
  // socket.io back-end server, and handle them here.

  // is this possible? how can i do this?
});

Я хочу, чтобы эта функция обратного вызова вызывалась, когда какие-либо / все события получены клиентским кодом socket.io.

Это возможно? Как?

Я открыл следующий вопрос о пересылке всех типов событий, также я добавил решения, которые нашел:github.com/Automattic/socket.io/issues/1715 Peter Uithoven

Ваш Ответ

12   ответов
22

библиотека socket.io хранит их в словаре. Таким образом, не думайте, что это было бы возможно без изменения источника.

Отисточник:

EventEmitter.prototype.on = function (name, fn) {
    if (!this.$events) {
      this.$events = {};
    }

    if (!this.$events[name]) {
      this.$events[name] = fn;
    } else if (io.util.isArray(this.$events[name])) {
      this.$events[name].push(fn);
    } else {
      this.$events[name] = [this.$events[name], fn];
    }

    return this;
  };
также нашел это:stackoverflow.com/questions/8832414/… Derick Bailey
3

я задам этот вопрос, который не требует взлома кода, а только изменения в том, как вы используете сокет.

Я просто решил, чтобы мое клиентское приложение отправляло точно такое же событие, но с другой полезной нагрузкой.

socket.emit("ev", { "name" : "miscEvent1"} );
socket.emit("ev", { "name" : "miscEvent2"} );

А на сервере что-то вроде ...

socket.on("ev", function(eventPayload) {
   myGenericHandler(eventPayload.name);
});

Я не знаю, может ли постоянное использование одного и того же события вызывать какие-либо проблемы, может быть, коллизии какого-либо масштаба, но это отлично подходит моим целям.

3

долгая дискуссия на эту тему происходит на странице выпуска репозитория Socket.IO. Там размещено множество решений (например, переопределение EventEmitter с EventEmitter2). lmjabreu выпустил еще одно решение пару недель назад: модуль npmsocket.io маска_ввода_источника который исправляет событие подстановки на Socket.IO (работает с текущим Socket.IO, ~ 0.9.14).

Но это только на стороне сервера ... его модуль не может использоваться на стороне клиента (браузер)
5

socket.io-client 1.7.3

По состоянию на май 2017 года ни одно из других решений не могло работать так, как я хотел - сделал перехватчик, используя на Node.js только для целей тестирования:

var socket1 = require('socket.io-client')(socketUrl)
socket1.on('connect', function () {
  console.log('socket1 did connect!')
  var oldOnevent = socket1.onevent
  socket1.onevent = function (packet) {
    if (packet.data) {
      console.log('>>>', {name: packet.data[0], payload: packet.data[1]})
    }
    oldOnevent.apply(socket1, arguments)
  }
})

Рекомендации:

https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Function/apply https://github.com/socketio/socket.io-client/blob/ff4cb3eed04a95c9725b8aaba8b64fa9fa1ca413/lib/socket.js#L257
7

GitHub doc о выставленных событиях упоминаетsocket.on('anything'), Похоже, что «что-нибудь» является заполнителем для пользовательского имени события, а не фактического ключевого слова, которое будет перехватывать любое событие.

Я только начал работать с веб-сокетами и Node.JS, и мне немедленно потребовалось обработать любое событие, а также узнать, какие события были отправлены. Не могу поверить, что эта функция отсутствует в socket.io.

1

которые я нашел (включая socket.io-wildcard и socketio-wildcard), не работали для меня. Очевидно, в socket.io 1.3.5 нет $ emit ...

После прочтения кода socket.io я исправил следующее, которое работало:

var Emitter = require('events').EventEmitter;
var emit = Emitter.prototype.emit;
[...]
var onevent = socket.onevent;
socket.onevent = function (packet) {
    var args = ["*"].concat (packet.data || []);
    onevent.call (this, packet);    // original call
    emit.apply   (this, args);      // additional call to catch-all
};

Это может быть решением и для других. Однако в банкомате я не совсем понимаю, почему, похоже, ни у кого больше нет проблем с существующими «решениями»?!? Есть идеи? Может быть, это моя старая версия узла (0.10.31) ...

Я могу подтвердить, что это работает и, как вы заметили, это единственное, что работает (в смысле: для меня тоже). Большое спасибо!
60

1.3.7

var onevent = socket.onevent;
socket.onevent = function (packet) {
    var args = packet.data || [];
    onevent.call (this, packet);    // original call
    packet.data = ["*"].concat(args);
    onevent.call(this, packet);      // additional call to catch-all
};

Используйте как это:

socket.on("*",function(event,data) {
    console.log(event);
    console.log(data);
});

Ни один из ответов не сработал для меня, хотя один из ответов Матиаса Хопфа и Мароса Пикселя был близок, это моя скорректированная версия.

NOTE: это только ловит пользовательские события, но не подключается / отключается и т. д.

Это сработало отлично - спасибо!
К сожалению, не работает с такими вещами, как «пользователь. *»; Может быть, мне удастся это реализовать.
Спасибо, это помогло мне отладить пропущенные события!
1

Обновленный ответ для v1.3.5. Была ошибка с аргументами, если вы хотите слушать старое событие и* событие вместе.

var Emitter = require('events').EventEmitter;
var emit = Emitter.prototype.emit;
// [...]
var onevent = socket.onevent;
socket.onevent = function (packet) {
    var args = packet.data || [];
    onevent.call (this, packet);    // original call
    emit.apply   (this, ["*"].concat(args));      // additional call to catch-all
};
11

var socket = io.connect();
var globalEvent = "*";
socket.$emit = function (name) {
    if(!this.$events) return false;
    for(var i=0;i<2;++i){
        if(i==0 && name==globalEvent) continue;
        var args = Array.prototype.slice.call(arguments, 1-i);
        var handler = this.$events[i==0?name:globalEvent];
        if(!handler) handler = [];
        if ('function' == typeof handler) handler.apply(this, args);
        else if (io.util.isArray(handler)) {
            var listeners = handler.slice();
            for (var i=0, l=listeners.length; i<l; i++)
                listeners[i].apply(this, args);
        } else return false;
    }
    return true;
};
socket.on(globalEvent,function(event){
    var args = Array.prototype.slice.call(arguments, 1);
    console.log("Global Event = "+event+"; Arguments = "+JSON.stringify(args));
});

Это будет ловить события какconnecting, connect, disconnect, reconnecting тоже, так что будь осторожен.

Socket.IO.js build: 0.9.10, разработка.
Это закончилось в выпуске?
0

Я используюAngular 6 и пакет npm:ngx-socket-io

import { Socket } from "ngx-socket-io";

...

constructor(private socket: Socket) { }

...

После подключения сокета, я использую этот код, это обрабатывает все пользовательские события ...

const onevent = this.socket.ioSocket.onevent;
this.socket.ioSocket.onevent = function (packet: any) {
  const args = packet.data || [];
  onevent.call(this, packet);    // original call
  packet.data = ["*"].concat(args);
  onevent.call(this, packet);      // additional call to catch-all
};
this.socket.on("*", (eventName: string, data: any) => {
  if (typeof data === 'object') {
    console.log(`socket.io event: [${eventName}] -> data: [${JSON.stringify(data)}]`);
  } else {
    console.log(`socket.io event: [${eventName}] -> data: [${data}]`);
  }
});
9

Note: this answer is only valid for socket.io 0.x

Вы можете переопределитьsocket.$emit

С помощью следующего кода у вас есть две новые функции:

Trap all events Trap only events which are not trapped by the old method (it is a default listener)
var original_$emit = socket.$emit;
socket.$emit = function() {
    var args = Array.prototype.slice.call(arguments);
    original_$emit.apply(socket, ['*'].concat(args));
    if(!original_$emit.apply(socket, arguments)) {
        original_$emit.apply(socket, ['default'].concat(args));
    }
}

socket.on('default',function(event, data) {
    console.log('Event not trapped: ' + event + ' - data:' + JSON.stringify(data));
});

socket.on('*',function(event, data) {
    console.log('Event received: ' + event + ' - data:' + JSON.stringify(data));
});
Любые рекомендации по aync операции перед вызовом применяются. setTimeout (function () {original_ $ emit.apply (socket, [& reg; * & reg;]. concat (args)); if (! original_ $ emit.apply (socket, arguments)) {original_ $ emit.apply (socket , ['default' '. concat (args));}}, 2000);
Я использую Socket.IO 1.3.6, и, похоже, нет метода $ emit вsocket больше не
В самом деле. Проверьте ответ @Flion для версий 1.x
17

Finallyесть модуль под названиемsocket.io маска_ввода_источника что позволяет использовать подстановочные знаки на стороне клиента и сервера

var middleware = require('socketio-wildcard')();

io.use(middleware);

io.on('connection', function(socket) {
  socket.on('*', function(){ /* … */ });
});

io.listen(8000);
работает отлично

Похожие вопросы