Websockets：从NodeJS websocket服务器到带有WebSocketSharp的C#客户端的多个响应

Question

在 NodeJS 中，我创建了一个小型测试服务器，它在收到消息时发送响应。当我尝试从 C# 客户端发送消息时，没有收到回复。经过研究，我注意到它与可能已关闭的 websocket 连接有关。这就是我想要实现的目标：

1. 我点击一个按钮 (TrySocket) 我向服务器发送一条消息，然后收到答案。
2. 之后，在服务器上对 api 进行轮询操作，大约需要 10 秒。从该 api 接收数据后，我想通过相同的 websocket 连接将其发送给我的客户端。

到目前为止，这是我的 C# 代码。

using System;
using WebSocketSharp;

namespace test_CS
{
    public partial class test : System.Web.UI.Page
    {
        protected async void Page_Load(object sender, EventArgs e)
        {
            
        }

        protected void TrySocket(object sender, EventArgs e)
        {
            var ws = new WebSocket("ws://localhost:8080");
            ws.OnOpen += (senders, d) =>
            {
                Response.Write("CONNECTED<br />");
            };
            ws.OnMessage += (senders, d) =>
            {
                Response.Write(d.Data);
            };
            ws.OnClose += (senders, d) =>
            {
                Response.Write("DISCONNECTED<br />");
            };

            ws.Connect();
            ws.Send("test message 1");
            ws.Close();
        }
    }
}

Answer 1

当然，这是我的 Node 代码。我用setTimeout 模拟了 api 调用 只有函数TrySocket在C#端被调用。

const express = require('express');
const http = require('http');
const WebSocket = require('ws');

const app = express();

const server = http.createServer(app);
const wss = new WebSocket.Server({ server });

wss.on('connection', function connection(ws, req) {
    ws.on('message', function incoming(message) {
        console.log('received: %s', message)
        if (message == 'test message 1') {
            ws.send('this is answer 1<br />');
            //API call simulation with timeout
            setTimeout(() => {
                ws.send('2nd answer<br />');
            }, 3000);
        }
    }) 
})

server.listen(8080, function listening() {
    console.log('Listening on %d', server.address().port)
})

Answer 2

发送“测试消息 1”后，您的连接将关闭。从服务器收到消息后为什么不关闭它。即

protected void TrySocket(object sender, EventArgs e)
{
    var ws = new WebSocket("ws://localhost:8080");
    ws.OnOpen += (senders, d) =>
    {
        Response.Write("CONNECTED<br />");
    };
    ws.OnMessage += (senders, d) =>
    {
        Response.Write(d.Data);
        // if message is close
        //  ws.Close(); close connection
    };
    ws.OnClose += (senders, d) =>
    {
        Response.Write("DISCONNECTED<br />");
    };

    ws.Connect();
    ws.Send("test message 1");
    //ws.Close(); // Remove this.it causes you client to close after sending a message.
   
}

这个客户端没有运行。

using System;    
using System.Net;    
using System.Net.Sockets;
using System.Net.WebSockets;
using System.Text;    
using System.Threading;    


namespace node_pipe
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");
        }
        protected void TrySocket(object sender, EventArgs e){
        var ws = new WebSocket("ws://localhost:8080");
        ws.OnOpen += (senders, d) =>
        {
            Response.Write("CONNECTED<br />");
        };
        ws.OnMessage += (senders, d) =>
        {
            Response.Write(d.Data);
            // if message is close
            //  ws.Close(); close connection
        };
        ws.OnClose += (senders, d) =>
        {
            Response.Write("DISCONNECTED<br />");
        };

        ws.Connect();
        ws.Send("test message 1");
    //ws.Close(); // Remove this.it causes you client to close after sending a message.
   
}
    }
}