我有一个基于 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已连接!”行)。没有错误消息。
奇怪的是，如果我首先运行我的网络应用程序，抛出一个查询，然后启动我的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"); }); }
最佳答案
你的 Controller 的结构有点困惑。以下是一些错误的地方:
加载模块时连接到 Java 服务器，但在路由命中之前不会分配
connect事件处理程序。这意味着您通常会错过连接事件，除非服务器尚未运行。所以，这完全解释了你所观察到的情况。如果启动 Express 服务器时 java 服务器已经启动，您将错过连接事件，因此您永远不会执行get_processed_data()函数中的任何逻辑。每次路由被命中时，您都会安装一个新的连接处理程序，这意味着您将获得分配的多个事件处理程序，尽管由于第一个问题，它们都可能不会被命中。
如果您希望 socket.io 连接持续连接，这将是重写 Controller 的一种方法:
var socket = require('socket.io-client')('http://localhost:8080');
socket.on('connect', function () {
console.log("client connected.");
});
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");
});
var transactionCntr = 0;
module.exports.get_processed_data = function(text, res) {
var timestamp = new Date().getTime();
var transactionId = transactionCntr++;
console.log('sending data to client');
function onResponse(data) {
// for concurrency reasons, make sure this is the right
// response. The server must return the same
// transactionId that it was sent
if (data.transactionId === transactionId) {
console.log('\tserverResponse' event trigged, data:');
res.send(data);
socket.off('serverResponse', onResponse);
}
}
socket.on('serverResponse', onResponse);
// send data and transactionId
socket.emit('myEvent', [timestamp ,text, transactionId], function (data) {
console.log('\tSending query ... waiting for ACK');
console.log(data);
});
}
您当前的结构存在一个问题，因为它似乎无法确定哪个响应与哪个请求对应，并且可能存在并发问题。每次只使用单独的 http 请求会更简单，因为这样响应将与适当的请求唯一配对。
通过您的 socket.io 连接，您可以在请求/响应中使用某种 ID，以便您可以判断哪个响应属于哪个请求。我已经展示了它在 Express 服务器中的工作原理。从 Java 服务器，您必须将 transactionId 回显到 Express 服务器的响应中，以便它可以跟踪哪个响应与哪个请求相关。
正如您的代码一样，如果同时对 '/api/getProcessedData' 路由发出多个请求，则来自不同请求的响应很容易混淆。这是您做事方式的架构问题。
我不是 Java 专家，但在我看来就像这样:
Thread.sleep(60000*3);
将使您的线程休眠 180,000 毫秒(3 分钟)，然后您的代码立即调用 server.stop()。因此，您的 Java 服务器会在 3 分钟后自行关闭。
因此，您只能在启动后的前 3 分钟内连接到 Java 服务器。
这里的逻辑问题是你为什么要停止你的服务器？
关于node.js - 使用带有 Express 和 Nodejs 的 socket.io-client 将查询发送到 java 服务器，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30803640/