0

让我澄清一下，这有点复杂。我正在实现一个表单来在数据库中插入数据。

我在同一个客户端有两个 websockets 连接，连接在同一个 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]);   
    }
4

2 回答 2

4

我想知道为什么你需要 2 个连接。打开一个连接并将有效负载作为 JSON 发送。

例如

var ws = new WebSocket("ws://localhost:1336");
ws.send(JSON.stringify({ command: "checkname", params: "xxxx"; });
ws.send(JSON.stringify({ command: "submit", params: { ... });

在服务器端，您只需要解析有效负载并确定执行哪个命令。

于 2013-08-12T09:39:33.240 回答
2

我只是想知道为什么你需要 websocket。您似乎需要验证用户在应用程序中的存在。如果用户不存在，那么您需要在数据库中插入，否则会抛出错误。

您可以通过 jquery post 和 jquery 表单验证 http://api.jquery.com/jQuery.post/

于 2013-08-05T09:25:33.683 回答