首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >Websocket4Net发送多条消息

Websocket4Net发送多条消息
EN

Stack Overflow用户
提问于 2015-08-25 16:30:54
回答 2查看 8K关注 0票数 1

我在使用WebSocket4Net库时遇到了问题。

我有事件websocket_opened,当这个事件在打开时引发时,如果我没有发送任何消息,我就有一个异常

System.Exception :您必须在websocket打开后通过websocket发送数据。

在我发送这条消息后,我不能发送任何其他消息。我执行发送命令,但是没有异常,它不工作,如果我检查状态,websocket是打开的

如果我关闭打开事件上的套接字并在closed_event中再次打开它,我就可以发送另一条消息,而不会出现问题。

因此,如果我想发送多条消息,我必须在发送消息后断开连接,然后重新连接以发送下一条消息。

代码语言:javascript
运行
复制
private static void websocket_Opened(object sender, EventArgs e)
{
    websocket.Send(msg);
    websocket.Close();
}

private static void websocket_Closed(object sender, EventArgs e)
{
    websocket.Open();
}

这是正常的吗?你能帮我处理一下这个吗?

EN

回答 2

Stack Overflow用户

发布于 2017-07-11 21:44:13

当我第一次使用WebSocket4Net时,我也有类似的问题。这个库的一个好处是它有一个包含许多github储存库使用实例(试验)。这些测试对我理解它应该如何工作非常有帮助。

更新:,我在下面看到了弗雷德的评论,我认为我真的需要添加一个例子。就是这样,我用了这个api

代码语言:javascript
运行
复制
using SuperSocket.ClientEngine;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using WebSocket4Net;

namespace TestProj
{
  public class WebSocketTest
  {
    static string webSocketUri = "wss://ws.binaryws.com/websockets/v3?app_id=1089";

    static void Main(string[] args)
    {
        var socketManager = new WebSocketManager(webSocketUri);

        socketManager.Send("{\"time\": 1}");
        socketManager.Send("{\"ping\": 1}");
        socketManager.Close();

        Console.WriteLine("Console can be closed...");
        Console.ReadLine();
    }
}
public class WebSocketManager
{
    private AutoResetEvent messageReceiveEvent = new AutoResetEvent(false);
    private string lastMessageReceived;
    private WebSocket webSocket;

    public WebSocketManager(string webSocketUri)
    {
        Console.WriteLine("Initializing websocket. Uri: " + webSocketUri);
        webSocket = new WebSocket(webSocketUri);
        webSocket.Opened += new EventHandler(websocket_Opened);
        webSocket.Closed += new EventHandler(websocket_Closed);
        webSocket.Error += new EventHandler<ErrorEventArgs>(websocket_Error);
        webSocket.MessageReceived += new EventHandler<MessageReceivedEventArgs>(websocket_MessageReceived);

        webSocket.Open();
        while (webSocket.State == WebSocketState.Connecting) { };   // by default webSocket4Net has AutoSendPing=true, 
                                                                    // so we need to wait until connection established
        if (webSocket.State != WebSocketState.Open)
        {
            throw new Exception("Connection is not opened.");
        }
    }

    public string Send(string data)
    {
        Console.WriteLine("Client wants to send data:");
        Console.WriteLine(data);

        webSocket.Send(data);
        if (!messageReceiveEvent.WaitOne(5000))                         // waiting for the response with 5 secs timeout
            Console.WriteLine("Cannot receive the response. Timeout.");

        return lastMessageReceived;
    }

    public void Close()
    {
        Console.WriteLine("Closing websocket...");
        webSocket.Close();
    }

    private void websocket_Opened(object sender, EventArgs e)
    {
        Console.WriteLine("Websocket is opened.");
    }
    private void websocket_Error(object sender, ErrorEventArgs e)
    {
        Console.WriteLine(e.Exception.Message);
    }
    private void websocket_Closed(object sender, EventArgs e)
    {
        Console.WriteLine("Websocket is closed.");
    }

    private void websocket_MessageReceived(object sender, MessageReceivedEventArgs e)
    {
        Console.WriteLine("Message received: " + e.Message);
        lastMessageReceived = e.Message;
        messageReceiveEvent.Set();
    }
  }
}
票数 4
EN

Stack Overflow用户

发布于 2015-09-28 14:25:27

我想这会解决你的问题

代码语言:javascript
运行
复制
websocket.Open();
private static void websocket_Opened(object sender, EventArgs e)
{
    websocket.Send(msg); 
    websocket.Close(); 
}

private static void websocket_Closed(object sender, EventArgs e)
{
    //DO SOMETHINGS
}
票数 -1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/32209337

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档