binance.com+Websocket

[PROforum]

Здравствуйте. Прочитав статью Асинхронный Websocket для вас и ваших близких пытаюсь подключится к сайту binance.com, но никак не получается . Библиотеку websocket-sharp.dll закинул,директивы добавил,
Поставил расширение Simple WebSocket Client в нем делаю запрос wss://stream.binance.com/stream?streams=!miniTicker@arr@3000ms/[email protected]10/[email protected]10 ответы приходят, но вот как прикрутить к код не знаю. Подскажите где в коде поправить чтоб запросы отправлялись и получались.
зы В коде я не очень.
зыы Навсякий случай добавил шаблон

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.IO;
using System.Text.RegularExpressions;
using ZennoLab.CommandCenter;
using ZennoLab.InterfacesLibrary;
using ZennoLab.InterfacesLibrary.ProjectModel;
using ZennoLab.InterfacesLibrary.ProjectModel.Collections;
using ZennoLab.InterfacesLibrary.ProjectModel.Enums;
using ZennoLab.Macros;
using Global.ZennoExtensions;
using ZennoLab.Emulation;
using WebSocketSharp;
using WebSocketSharp.Server;
using WebSocketSharp.Net;
using System.Threading.Tasks;


namespace ZennoLab.OwnCode
{

        public class CommonCode
    {       
        
        public static void Wss(IZennoPosterProjectModel project) //определяем метод Wss
        {           
Random rnd = new Random(); //инициализация Random
 string data = project.Variables["wss_data"].Value; //загружаем тело запроса из переменной
//подключаем прокси, если необходимо
//string ip = project.Variables["proxy_ip"].Value;
//string login = project.Variables["proxy_login"].Value;
//string pass = project.Variables["proxy_pass"].Value;

      using (var ws = new WebSocket("wss://stream.binance.com/stream?streams=!miniTicker@arr@3000ms/[email protected]/[email protected]")) //определяем ссылку запроса
{   
//ws.SetProxy (ip, login, pass); //устанавливаем прокси, если необходимо
//ws.SetCookie (new Cookie("__cfduid", project.Variables["cookies_value"].Value)); //устанавливаем куки, если необходимо
ws.Origin = "https://binance.com";

ws.OnMessage += (sender, e) => //объявляем, что будем получать сообщение
project.SendInfoToLog(e.Data); //пишем инфу в лог для наглядности
ws.Connect(); //подключаемся по wss
   ws.Send (data); //отправляем тело запроса
System.Threading.Thread.Sleep(1000); //небольшая пауза
    ws.Send ("wss://stream.binance.com/stream?streams=!miniTicker@arr@3000ms/[email protected]/[email protected]"); //отправляем тело второго запроса

int q = 0;

          while (Convert.ToBoolean(project.Variables["wss_lock"].Value)) //пока переменная = true, цикл будет выполняться
    {         
        Thread.Sleep(rnd.Next(4000, 4300));
        q = q + rnd.Next(4, 40);
        ws.Send ("wss://stream.binance.com/stream?streams=!miniTicker@arr@3000ms/[email protected]/[email protected]"); //отправляем тело запроса
            };
    }
        }
        
        public static async Task WssAsync(IZennoPosterProjectModel project) //определяем асинхронный метод       
        {           
           await Task.Run(() => Wss(project)); //запуск метода Wss             
}
    
        /// <summary>
        /// Lock this object to mark part of code for single thread execution
        /// </summary>
        public static object SyncObject = new object();
        
        // Insert your code here

}
}

 

[myndeswx]

Mybe you have figured it out? )

 

[Андрейка2020]

ТС, разобрался ли в вопросе?