【发布时间】：2015-06-12 12:54:32
【问题描述】：
我有一个基于 Express 构建的网络应用程序。 nodejs 后端使用 java 服务器来执行一些繁重的操作。 Express 和 java 服务器之间的对话是使用 socketio 完成的。 nodejs 服务器是客户端，使用 socket.io-client 向 java 服务器发送查询。 javaserver 基于 netty-socketio。
这是我在我的 nodejs 应用程序中所做的：
var io = require('socket.io-client')
var socket = io.connect('http://localhost:8080');
socket.on('connect', function () {
console.log('0 Connected!');
socket.emit('myEvent', ['0' ,'here is the query'], function (data) {
console.log('\tSending query ... waiting for ACK0');
console.log(data);
});
socket.on('serverResponse', function (data) {
console.log('\tserverResponse event triggered, data:');
console.log(data);
});
});
在我的网络应用程序之外调用此脚本时，一切都像魅力一样工作，但是当我从 express 调用此代码时，我的客户端无法连接（我没有到达“0 已连接！”行）。没有错误消息。
奇怪的是，如果我首先运行我的 web 应用程序，抛出一个查询，然后启动我的 java 服务器，客户端连接到 java 服务器并且一切正常（仅针对该查询）。关于如何解决这个问题的任何线索？
编辑 1
这是我想要实现的架构：
client javascript backend java server
via browser <---> node/Express/socketio-client <---> netty-socketio
@client's machine | @my server | @my server (the same)
| |
myDNS:80 localhost:8080
Java 服务器上的精度更高。这是后遗症：
public class App {
public static void main(String[] args) throws InterruptedException, UnsupportedEncodingException {
Configuration config = new Configuration();
config.setHostname("localhost");
config.setPort(8080);
final SocketIOServer server = new SocketIOServer(config);
server.addEventListener("myEvent", String[].class, new DataListener<String[]>() {
@Override
public void onData(final SocketIOClient client, String[] data, final AckRequest ackRequest) {
//Id of the client
String id = data[0];
//Acknowledge the request:
ackRequest.sendAckData("ACK_"+id);
//doing some calculations ...
// ... ... ...
// ... ... ...
client.sendEvent("serverResponse", new VoidAckCallback(){
@Override
protected void onSuccess() {}
}, "I am the answer from the server");
}
});
server.start();
System.out.println("[JAVA SERVER INFO] Java server started.");
Thread.sleep(60000*3);//Integer.MAX_VALUE);
server.stop();
System.out.println("[JAVA SERVER INFO] Java server stopped.");
}
}
我的 web 应用 nodejs 后端和我的 java 服务器在同一台机器上运行，与 socket.io 的通信是通过 localhost:8080 完成的。再一次，奇怪的是客户端的脚本在 express 框架之外使用时正在工作，这让我认为这可能是 socket.io-client 和 Express 之间的兼容性问题。
编辑 2
我修改了我的 socket.io-client 代码以更详细地了解正在发生的事情，我补充说：
socket.on('connect_error', function(err){
console.log(err);
});
socket.on('connect_timeout', function(){
console.log("connect_timeout");
});
socket.on('reconnect_attempt', function(){
console.log("reconnect_attempt");
});
当我在 Java 服务器关闭的情况下运行客户端时，我收到一个“connect_error”事件。当 java 服务器打开时，我根本没有收到任何消息。似乎连接既没有失败也没有成功，什么都没有发生......关于如何更好地调试的任何想法？
编辑 3
这是我用来处理来自浏览器的请求的代码：
-
index.js：
var express = require('express'); var router = express.Router(); var controller = require('../controllers/myController.js'); /* GET home page. */ router.get('/', function(req, res, next) { res.render('index', { title: 'Express' }); }); module.exports = router; router.post('/api/getProcessedData', function(req, res, next){ var text = req.body.text; controller.get_processed_data(text, res); }); -
myController.js：
var socket = require('socket.io-client')('http://localhost:8080'); module.exports.get_processed_data = function(text, res) { var timestamp = new Date().getTime(); console.log('starting client'); socket.on('connect', function () { console.log("client connected."); socket.emit('myEvent', [timestamp ,text], function (data) { console.log('\tSending query ... waiting for ACK'); console.log(data); }); socket.on('serverResponse', function (data) { console.log('\tserverResponse' event trigged, data:'); res.send(data); }); }); socket.on('connect_error', function(err){ console.log(err); }); socket.on('connect_timeout', function(){ console.log("connect_timeout"); }); socket.on('reconnect_attempt', function(){ console.log("reconnect_attempt"); }); socket.on('reconnecting', function(){ console.log("reconnecting"); }); }
【问题讨论】：
-
您的网络应用在哪个端口上运行？ Java 服务器在哪个端口上侦听 socket.io 连接？
-
我在最初的帖子中添加了一些信息，希望对您有所帮助。如果您需要更多详细信息，请不要犹豫。