让我澄清一下，这有点复杂。我正在实现一个表单以在数据库中插入数据。
我在同一客户端有两个websocket连接，连接在同一个nodejs服务器上。
用户在表单的"名称"文本字段中插入名称后，将触发一个连接。将数据发送到服务器，服务器检查数据库名称是否已存在，并回复"这已存在。梅德，你正在插入已经存在的东西"。
如果表单的所有字段都不为空，则会触发另一个连接，并将数据发送到服务器以将其插入数据库。
我认为在服务器端区分使用数组的不同连接是个好主意。如果数组的第一个元素是"name"，则调用checkName函数，或者如果它是"insert"，则调用insertInDB函数。
我创建了两个小的测试文件。它们不起作用。连接是开放的，客户端发送数据。我在服务器和客户端都没有收到任何错误。但服务器从不响应。我没有得到预期的数字，回到客户端。无论如何，我认为这不是正确的。这是完整的，我希望代码对您有所帮助。
有可能吗，我想做什么？任何提示或替代方案？
谢谢
代码....服务器端
function WebSocketTest1(){
var a=1;
var b=2;
var c = [a,b];
var so = new WebSocket("ws://localhost:1337");
so.onerror=function (evt)
{message.textContent = evt;}
so.onopen = function(){
message.textContent = "opened";
so.send(c);
message.textContent = "sended";
}
so.onmessage = function (evt) {
var received_msg = evt.data;
document.getElementById("message").innerHTML=received_msg;
}
}
function WebSocketTest2(){
var d=3;
var e=4;
var f = [d,e];
var sa = new WebSocket("ws://localhost:1337");
sa.onerror=function (evt)
{message2.textContent = evt;}
sa.onopen = function(){
message2.textContent = "opened";
sa.send(f);
message2.textContent = "sended";
}
sa.onmessage = function (evt) {
var received_msg = evt.data;
document.getElementById("message2").innerHTML=received_msg;
}
}
</script>
</head>
<input type="button" value="one" onClick="WebSocketTest1()"><br/>
<input type="button" value="two" onClick="WebSocketTest2()"><br/>
<body>
<div id="message"></div>
mesage2</br>
<div id="message2"></div>
</body>
</html>
在服务器端，我列出了会话，仅与特定会话通信，代码在此处找到和服务器端(代码段(
var connections = {};
var connectionIDCounter = 0;
var connection = request.accept(null, request.origin);
// Store a reference to the connection using an incrementing ID
connection.id = connectionIDCounter ++;
connections[connection.id] = connection;
console.log((new Date()) + ' Connection accepted.');
connection.on('message', function(message) {
var ja=message;
if(ja[0]==1)
{ja[1]=7;}
else if(ja[0]==3)
{ja[1]=8;}
});
connection.on('close', function(reasonCode, description) {
console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
delete connections[connection.id];
});
});
// Send a message to a connection by its connectionID
function sendToConnectionId(connectionID, data) {
var connection = connections[connectionID];
if (connection && connection.connected) {
connection.send(ja[1]);
}
我想知道为什么你需要 2 个连接。打开一个连接并将有效负载作为 JSON 发送。
例如
var ws = new WebSocket("ws://localhost:1336");
ws.send(JSON.stringify({ command: "checkname", params: "xxxx"; });
ws.send(JSON.stringify({ command: "submit", params: { ... });
在服务器端，您只需解析有效负载并确定执行哪个命令。
我只是想知道为什么你需要websocket。您似乎需要验证应用程序中的用户状态。如果用户不存在，则需要在数据库中插入否则抛出错误。
你可以通过jQuery帖子和jQuery表单验证http://api.jquery.com/jQuery.post/