Как отправить двоичные данные с помощью socket.io?

Question

, поэтому у меня возникли проблемы с отправкой двоичных данных с помощью socket.io в node.js (клиент Js и клиент Android).

Существует не так много информации ни в:

http://socket.io/blog/introducing-socket-io-1-0/

http://socket.io/get-started/chat/

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

единственный код, они дают следующее:

var socket = new WebSocket('ws://localhost'); 
socket.binaryType = 'arraybuffer'; 
socket.send(new ArrayBuffer); 

Мой ответ ниже.

Answer 1

Наконец-то у меня есть работа с JS и Android (Java), поэтому я решил поделиться им с вами, ребята.

Давайте начнем с кода сервера: (Node JS)

var http = require('http'); 

var app = http.createServer(function ejecute(request, response){}); 
var io = require('socket.io').listen(app); 


io.on('connection', function(socket) { 
     socket.on('message', function(data){ 
      console.log("recieved data:"); 
      console.log(data); 

      var bufArr = new ArrayBuffer(4); 
      var bufView = new Uint8Array(bufArr); 
      bufView[0]=6; 
      bufView[1]=7; 
      bufView[2]=8; 
      bufView[3]=9; 
      socket.emit('message',bufArr); 
     }); 
    }); 
app.listen(3000); 

Позволяет прыгать на клиенте Javascript

var socket = io("http://localhost:3000"); 
    socket.emit('message', 'hola from js client'); 

    socket.on('message', function(msg){ 
    var bufView = new Uint8Array(msg); 
    console.log(msg) 
    }); 

И, наконец, давайте покажем клиент для Android (Java):

final Socket socket = IO.socket("http://localhost:3000",opts); 

    socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() { 
     @Override 
     public void call(Object... args) { 
      socket.emit("message","hello from java"); 
     } 
    }); 


    socket.on("message", new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      byte[] bytearray = (byte[])args[0]; //received bytes 

      for (byte b : bytearray) { 
       System.out.println("byte"+b); 
      } 
     } 

    }); 

    socket.on(Socket.EVENT_DISCONNECT, new Emitter.Listener() { 
    @Override 
    public void call(Object... args) {} 
}); 

Надеюсь, это полезно всем вам. Приветствия!