Socket.io Java客戶端從服務器獲得400

我有一個node.js服務器部署在OpenShift雲，我使用socket.io實現實時聊天應用程序。在我的開發機器上它工作正常，但是當我將它部署到OpenShift時，它將向Socket.io Java Client返回400響應代碼。Socket.io Java客戶端從服務器獲得400

請看看它是服務器端的代碼

const 
    http = require('http'), fs = require('fs'), path = require('path'), 
    contentTypes = require('./utils/content-types'), 
    sysInfo = require('./utils/sys-info'), env = process.env, 
    credential = require('./credentials.js'), 
    ChatEvent = require('./chat.js'); 

// Import all dependencies 
var express = require('express'); 
var app = express(); 
var server = require('http').Server(app); 
var socketio = require('socket.io'); 
var io = socketio(server); 

app.use(function(req, res, next) { 
res.header("Access-Control-Allow-Origin", "*"); 
res.header("Access-Control-Allow-Headers", 
     "Origin, X-Requested-With, Content-Type, Accept"); 
    next(); 
}); 


var connectedClients = {}; 

io.set("transports", ['xhr-polling', 'polling', 'websocket']); 

io.sockets.on('connection', function(client) { 
var address = client.request.connection.remoteAddress; 
console.log('Client connected from: [%s] ', address); 
console.log(client); 
var clientId = null; 

client.on('message', function(data) { 
    console.log("Message received: %s", data); 
    client.write("From Server: " + data); 
}); 

client.on('error', function(err) { 
    console.log(err); 
}); 


client.on('echo', function(data) { 
    client.write(data); 
}); 

client.on('disconnect', function() { 
    if (clientId) 
     delete connectedClients[clientId]; 
    console.log('Client Disconnected: [%s]', address); 
}); 

}); 

app.all('*', function(req, res, next) { 
var url = req.url; 
if (url == '/') { 
    url += 'index.html'; 
} 

if (url == '/health') { 
    res.writeHead(HttpStatus.OK); 
    res.end(); 
} else if (url.indexOf('/info/') == 0) { 
    res.setHeader('Content-Type', 'application/json'); 
    res.setHeader('Cache-Control', 'no-cache, no-store'); 
    res.end(JSON.stringify(sysInfo[url.slice(6)]())); 
} else { 
    fs.readFile('./static' + url, function(err, data) { 
     if (err) { 
      res.writeHead(HttpStatus.NOT_FOUND); 
      res.end(); 
     } else { 
      var ext = path.extname(url).slice(1); 
      // res.setHeader('Content-Type', contentTypes[ext]); 
      if (ext === 'html') { 
       res.setHeader('Cache-Control', 'no-cache, no-store'); 
      } 
      res.end(data); 
     } 
    }); 
    } 
}); 

// --------------------- Start Server------------------------ // 

server.listen(env.NODE_PORT || 3000, env.NODE_IP || 'localhost', function()   { 
var host = server.address().address 
var port = server.address().port 
console.log("Chat App listening at http://%s:%s", host, port) 
});

下面是使用https://github.com/socketio/socket.io-client-java

public class SMRChatClient { 

public static void main(String[] args) 
     throws UnknownHostException, IOException, ClassNotFoundException, URISyntaxException { 

    final Socket socket = IO.socket("http://myapp-url.rhcloud.com:8000"); 
    socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      JSONObject object = new JSONObject(); 
      try { 
       object.put("sessionToken", "1d0bbced4d560af3ae22bc4513bfa400"); 
       socket.emit("echo", object.toString()); 

      } catch (JSONException e) { 
       e.printStackTrace(); 
      } 
     } 

    }).on(Socket.EVENT_MESSAGE, new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      System.out.println("Message Received: "); 
      for (int i = 0; i < args.length; i++) { 
       System.out.println(args[i]); 
      } 
     } 

    }).on(Socket.EVENT_DISCONNECT, new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      System.out.println("Client disconnected"); 
     } 

    }).on(Socket.EVENT_CONNECT_ERROR, new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      Exception e = (Exception) args[0]; 
      e.printStackTrace(); 
     } 

    }).on(Socket.EVENT_ERROR, new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      Exception e = (Exception) args[0]; 
      e.printStackTrace(); 
     } 

    }).on(Socket.EVENT_RECONNECT, new Emitter.Listener() { 

     @Override 
     public void call(Object... args) { 
      System.out.println("Reconnecting: "); 
      for (int i = 0; i < args.length; i++) { 
       System.out.println(args[i]); 
      } 
     } 

    }); 
    socket.connect(); 
}

}

的響應是EVENT_ERROR，e.printStackTrace後控制檯我的客戶端代碼（）是：

io.socket.engineio.client.EngineIOException: xhr poll error 
at io.socket.engineio.client.Transport.onError(Transport.java:64) 
at io.socket.engineio.client.transports.PollingXHR.access$100(PollingXHR.java:18) 
at io.socket.engineio.client.transports.PollingXHR$6$1.run(PollingXHR.java:126) 
at io.socket.thread.EventThread$2.run(EventThread.java:75) 
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 
at java.lang.Thread.run(Unknown Source) 
Caused by: java.io.IOException: 400 
at io.socket.engineio.client.transports.PollingXHR$Request$1.run(PollingXHR.java:218) 
... 1 more

連接被建立，但它打破了，雖然我登錄到控制檯，這裏的客戶端套接字;服務器

Socket { 
nsp: 
Namespace { 
    name: '/', 
    server: 
    Server { 
     nsps: [Object], 
    _path: '/socket.io', 
    _serveClient: true, 
    _adapter: [Function: Adapter], 
    _origins: '*:*', 
    sockets: [Circular], 
    eio: [Object], 
    httpServer: [Object], 
    engine: [Object] }, 
sockets: { '/#TiwzTKVNEVtlBVdkAAAC': [Circular] }, 
connected: { '/#TiwzTKVNEVtlBVdkAAAC': [Circular] }, 
fns: [], 
ids: 0, 
adapter: 
    Adapter { 
    nsp: [Circular], 
    rooms: [Object], 
    sids: [Object], 
    encoder: Encoder {} }, 
_events: { connection: [Function] }, 
_eventsCount: 1 }, 
    server: 
    Server { 
nsps: { '/': [Object] }, 
_path: '/socket.io', 
_serveClient: true, 
_adapter: [Function: Adapter], 
_origins: '*:*', 
sockets: 
    Namespace { 
    name: '/', 
    server: [Circular], 
    sockets: [Object], 
    connected: [Object], 
    fns: [], 
    ids: 0, 
    adapter: [Object], 
    _events: [Object], 
    _eventsCount: 1 }, 
eio: 
    Server { 
    clients: [Object], 
    clientsCount: 1, 
    pingTimeout: 60000, 
    pingInterval: 25000, 
    upgradeTimeout: 10000, 
    maxHttpBufferSize: 100000000, 
    transports: [Object], 
    allowUpgrades: true, 
    allowRequest: [Function: bound ], 
    cookie: 'io', 
    cookiePath: false, 
    perMessageDeflate: [Object], 
    httpCompression: [Object], 
    ws: [Object], 
    _events: [Object], 
    _eventsCount: 1 }, 
httpServer: 
    Server { 
    domain: null, 
    _events: [Object], 
    _eventsCount: 5, 
    _maxListeners: undefined, 
    _connections: 0, 
    _handle: [Object], 
    _usingSlaves: false, 
    _slaves: [], 
    _unref: false, 
    allowHalfOpen: true, 
    pauseOnConnect: false, 
    httpAllowHalfOpen: false, 
    timeout: 120000, 
    _pendingResponseData: 0, 
    _connectionKey: '4:127.3.143.1:8080' }, 
engine: 
    Server { 
    clients: [Object], 
    clientsCount: 1, 
    pingTimeout: 60000, 
    pingInterval: 25000, 
    upgradeTimeout: 10000, 
    maxHttpBufferSize: 100000000, 
    transports: [Object], 
    allowUpgrades: true, 
    allowRequest: [Function: bound ], 
    cookie: 'io', 
    cookiePath: false, 
    perMessageDeflate: [Object], 
    httpCompression: [Object], 
    ws: [Object], 
    _events: [Object], 
    _eventsCount: 1 } }, 
adapter: 
    Adapter { 
    nsp: 
     Namespace { 
     name: '/', 
    server: [Object], 
    sockets: [Object], 
    connected: [Object], 
    fns: [], 
    ids: 0, 
    adapter: [Circular], 
    _events: [Object], 
    _eventsCount: 1 }, 
rooms: { '/#TiwzTKVNEVtlBVdkAAAC': [Object] }, 
sids: { '/#TiwzTKVNEVtlBVdkAAAC': [Object] }, 
encoder: Encoder {} }, 
    id: '/#TiwzTKVNEVtlBVdkAAAC', 
    client: 
    Client { 
    server: 
    Server { 
    nsps: [Object], 
    _path: '/socket.io', 
    _serveClient: true, 
    _adapter: [Function: Adapter], 
    _origins: '*:*', 
    sockets: [Object], 
    eio: [Object], 
    httpServer: [Object], 
    engine: [Object] }, 
conn: 
    Socket { 
    id: 'TiwzTKVNEVtlBVdkAAAC', 
    server: [Object], 
    upgrading: false, 
    upgraded: false, 
    readyState: 'open', 
    writeBuffer: [Object], 
    packetsFn: [Object], 
    sentCallbackFn: [], 
    cleanupFn: [Object], 
    request: [Object], 
    remoteAddress: '127.3.143.1', 
    checkIntervalTimer: null, 
    upgradeTimeoutTimer: null, 
    pingTimeoutTimer: [Object], 
    transport: [Object], 
    _events: [Object], 
    _eventsCount: 3 }, 
encoder: Encoder {}, 
decoder: Decoder { reconstructor: null, _callbacks: [Object] }, 
id: 'TiwzTKVNEVtlBVdkAAAC', 
request: 
    IncomingMessage { 
    _readableState: [Object], 
    readable: true, 
    domain: null, 
    _events: {}, 
    _eventsCount: 0, 
    _maxListeners: undefined, 
    socket: [Object], 
    connection: [Object], 
    httpVersionMajor: 1, 
    httpVersionMinor: 1, 
    httpVersion: '1.1', 
    complete: true, 
    headers: [Object], 
    rawHeaders: [Object], 
    trailers: {}, 
    rawTrailers: [], 
    upgrade: false, 
    url: '/socket.io/?EIO=3&transport=polling', 
    method: 'GET', 
    statusCode: null, 
    statusMessage: null, 
    client: [Object], 
    _consuming: false, 
    _dumped: true, 
    _query: [Object], 
    res: [Object], 
    cleanup: [Function: cleanup] }, 
onclose: [Function: bound ], 
ondata: [Function: bound ], 
onerror: [Function: bound ], 
ondecoded: [Function: bound ], 
sockets: { '/#TiwzTKVNEVtlBVdkAAAC': [Circular] }, 
nsps: { '/': [Circular] }, 
connectBuffer: [] }, 
    conn: 
    Socket { 
id: 'TiwzTKVNEVtlBVdkAAAC', 
server: 
    Server { 
    clients: [Object], 
    clientsCount: 1, 
    pingTimeout: 60000, 
    pingInterval: 25000, 
    upgradeTimeout: 10000, 
    maxHttpBufferSize: 100000000, 
    transports: [Object], 
    allowUpgrades: true, 
    allowRequest: [Function: bound ], 
    cookie: 'io', 
    cookiePath: false, 
    perMessageDeflate: [Object], 
    httpCompression: [Object], 
    ws: [Object], 
    _events: [Object], 
    _eventsCount: 1 }, 
upgrading: false, 
upgraded: false, 
readyState: 'open', 
writeBuffer: [ [Object] ], 
packetsFn: [ undefined ], 
sentCallbackFn: [], 
cleanupFn: [ [Function], [Function] ], 
request: 
    IncomingMessage { 
    _readableState: [Object], 
    readable: true, 
    domain: null, 
    _events: {}, 
    _eventsCount: 0, 
    _maxListeners: undefined, 
    socket: [Object], 
    connection: [Object], 
    httpVersionMajor: 1, 
    httpVersionMinor: 1, 
    httpVersion: '1.1', 
    complete: true, 
    headers: [Object], 
    rawHeaders: [Object], 
    trailers: {}, 
    rawTrailers: [], 
    upgrade: false, 
    url: '/socket.io/?EIO=3&transport=polling', 
    method: 'GET', 
    statusCode: null, 
    statusMessage: null, 
    client: [Object], 
    _consuming: false, 
    _dumped: true, 
    _query: [Object], 
    res: [Object], 
    cleanup: [Function: cleanup] }, 
remoteAddress: '127.3.143.1', 
checkIntervalTimer: null, 
upgradeTimeoutTimer: null, 
pingTimeoutTimer: 
    Timeout { 
    _called: false, 
    _idleTimeout: 85000, 
    _idlePrev: [Object], 
    _idleNext: [Object], 
    _idleStart: 1634714, 
    _onTimeout: [Function], 
    _repeat: null }, 
transport: 
    XHR { 
    readyState: 'open', 
    discarded: false, 
    closeTimeout: 30000, 
    maxHttpBufferSize: 100000000, 
    httpCompression: [Object], 
    supportsBinary: true, 
    _events: [Object], 
    _eventsCount: 5, 
    sid: 'TiwzTKVNEVtlBVdkAAAC', 
    req: null, 
    res: null, 
    writable: false }, 
_events: 
    { close: [Object], 
    data: [Function: bound ], 
    error: [Function: bound ] }, 
_eventsCount: 3 }, 
    rooms: {}, 
    acks: {}, 
    connected: true, 
disconnected: false, 
handshake: 
    { headers: 
    { 'user-agent': 'Java/1.8.0_51', 
    host: 'myapp-url.rhcloud.com:8000', 
    accept: 'text/html, image/gif, image/jpeg, *; q=.2, */*; q=.2', 
    'x-forwarded-for': '117.203.6.68', 
    'x-client-ip': '117.203.6.68', 
    'x-forwarded-proto': 'http', 
    'x-forwarded-host': 'myapp-url.rhcloud.com', 
    'x-forwarded-port': '8000', 
    connection: 'close' }, 
time: 'Sun May 29 2016 10:01:22 GMT-0400 (EDT)', 
address: '127.3.143.1', 
xdomain: false, 
secure: false, 
issued: 1464530482029, 
url: '/socket.io/?EIO=3&transport=polling', 
query: { EIO: '3', transport: 'polling' } } }

任何幫助S的輸出，將不勝感激！

來源

2016-05-29 Gaurav Agarwal

確定服務器在端口8000上運行？ – robertklep

不，實際上，OpenShift建議使用8000作爲網絡套接字，儘管openshift在8080上運行應用程序，但端口80和8000被轉發到8080. –

這就是這個，有趣的:-)但我不是這個問題。 – robertklep

這裏的問題是，OpenShift的啓動腳本已開始4名工人線程我的應用程序，這是導致無效的會話ID的問題，這似乎是在node.js的集羣問題

來源

2016-05-29 16:43:51

Socket.io Java客戶端從服務器獲得400

回答

相關問題