PythonとC#でWebsocket通信の転送容量をあげたい

Question

C#をサーバ、PythonをクライアントにしてPythonから画像のバイナリ情報をC#に送りました。
ところがC#側での情報取得が遅く、なんとか早くできないかと考えております。

PythonとJSでは速度に問題はなく、1920x1200の画像をブラウザで30FPSで問題なく確認ができました。
PythonとJSの通信での環境は下記のものを使用して実装しました。
Python: WebSocketServer
JS: 普通にJSのWebsocket

C#側とPythonの通信での環境は下記のものを使用して検証しました。
Python: websocket-client
C#: System.net.websocket
ちなみにC#側ではSuperSocketも使用してみましたが、データ容量が一定を越えるとエラーになるため、採用をやめました。

何か良い方法があればお教え頂ければと存じます。

/// <summary>
/// ソケット通信サーバの生成
/// </summary>
static async void CreateSocketServer()
{
  var httpListener = new HttpListener();
  httpListener.Prefixes.Add("http://127.0.0.1:3003/");
  httpListener.Start();

  while (true)
  {
    /// 接続待機
    var listenerContext = await httpListener.GetContextAsync();
    if (listenerContext.Request.IsWebSocketRequest)
    {
      /// httpのハンドシェイクがWebSocketなら接続開始
      ProcessRequest(listenerContext);
    }
    else
    {
      listenerContext.Response.StatusCode = 400;
      listenerContext.Response.Close();
    }
  }
}

/// <summary>
/// ソケット通信サーバの生成
/// </summary>
static async void ProcessRequest(HttpListenerContext listenerContext)
{
  Console.WriteLine("{0}:New Session:{1}", DateTime.Now.ToString(), 
  listenerContext.Request.RemoteEndPoint.Address.ToString());

  /// WebSocketの接続完了を待機してWebSocketオブジェクトを取得する
  var socket = (await listenerContext.AcceptWebSocketAsync(subProtocol: null)).WebSocket;

  /// 新規クライアントを追加
  client.Add(socket);

  /// WebSocketの送受信ループ
  while (socket.State == WebSocketState.Open)
  {
    try
    {
      var buff = new ArraySegment<byte>(new byte[3072000]);
      /// 受信待機
      var ret = await socket.ReceiveAsync(buff, System.Threading.CancellationToken.None);
      /// テキスト
      if (ret.MessageType == WebSocketMessageType.Text)
      {
        Dictionary<string, string> dictionary = new Dictionary<string, string>();
        var data = Encoding.UTF8.GetString(buff.Take(ret.Count).ToArray());
        var json = JsonConvert.SerializeObject(data);
        Console.WriteLine($"{json}");
      }
      /// クローズ
      else if (ret.MessageType == WebSocketMessageType.Close) 
      {
        Console.WriteLine("{0}:Session Close:{1}", DateTime.Now.ToString(), listenerContext.Request.RemoteEndPoint.Address.ToString());
        break;
      }
    }
    catch
    {
      /// クライアントが異常終了した場合
      Console.WriteLine("{0}:Session Abort:{1}", DateTime.Now.ToString(), listenerContext.Request.RemoteEndPoint.Address.ToString());
      break;
    }
  }
  /// クライアントを除外する
  client.Remove(socket);
  socket.Dispose();
}

Answer 1

system.net.socketを使ってみたらいけました。
バッファサイズを指定してもsystem.net.websocketでは何故か処理が遅く、バッファも切れてしまいます。
何故だかはわかりませんが、ローカル環境内の連携ではsocket.ioを使うべきですね。

Answer 2

多くのコネクションを同時に捌く必要がどこまであるのかで判断が必要なのかもしれませんが、非同期処理の場合パフォーマンスが非常に落ちるとの情報があります。
https://stackoverflow.com/questions/9915101/performance-of-receiveasync-vs-beginreceive

一度同期処理にして見て測定して見てはいかがでしょうか？

Comments

[TakakiKuwabara]

同期処理でも変わりませんでした。