Клиент JSONRpc через веб-сокет C#

Question

Мне нужен клиент JSON-Rpc для связи через сервер через веб-сокет. В частности, мне нужно создать интерфейс и использовать методы для отправки запросов JSON на сервер.

Кто-нибудь знает, как это сделать?

Я нашел StreamJsonRpc библиотека, но она работает через поток, а не через websocket.

Могу ли я получить поток от подключения через веб-сокет и передать его в StreamJsonRpc?
У вас есть другие идеи?

Answer 1

Вам нужны только Json.net и WebSocket4Net.

Вы можете увидеть там.

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Security.Authentication;
using WebSocket4Net;

namespace LightStreamSample
{
    class WebSocket4NetSample
    {
        static void Main(string[] args)
        {
            var channelName = "[your websocket server channel name]";
            // note: reconnection handling needed.
            var websocket = new WebSocket("wss://[your web socket server websocket url]", sslProtocols: SslProtocols.Tls12);
            websocket.Opened += (sender, e) =>
            {
                websocket.Send(
                    JsonConvert.SerializeObject(
                        new
                        {
                            method = "subscribe",
                            @params = new { channel = channelName },
                            id = 123,
                        }
                    )
                );
            };
            websocket.MessageReceived += (sender, e) =>
            {
                dynamic data = JObject.Parse(e.Message);
                if (data.id == 123)
                {
                    Console.WriteLine("subscribed!");
                }
                if (data.@params != null)
                {
                    Console.WriteLine([e-mail] + " " + [e-mail]);
                }
            };

            websocket.Open();

            Console.ReadKey();
        }
    }
}

Answer 2

Чтобы обновить этот пост, теперь можно передавать поток из веб-сокета с помощью StreamJsonRpc.

Пример веб-сокета Github для .NetCore

       using (var jsonRpc = new JsonRpc(new WebSocketMessageHandler(socket)))
            {
                try
                {
                    jsonRpc.AddLocalRpcMethod("Tick", new Action<int>(tick => Console.WriteLine($"Tick {tick}!")));
                    jsonRpc.StartListening();
                    Console.WriteLine("JSON-RPC protocol over web socket established.");
                    int result = await jsonRpc.InvokeWithCancellationAsync<int>("Add", new object[] { 1, 2 }, cancellationToken);
                    Console.WriteLine($"JSON-RPC server says 1 + 2 = {result}");

                    // Request notifications from the server.
                    await jsonRpc.NotifyAsync("SendTicksAsync");

                    await jsonRpc.Completion.WithCancellation(cancellationToken);
                }
                catch (OperationCanceledException)
                {
                    // Closing is initiated by Ctrl+C on the client.
                    // Close the web socket gracefully -- before JsonRpc is disposed to avoid the socket going into an aborted state.
                    await socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Client closing", CancellationToken.None);
                    throw;
                }
            }

Реализация .Net Framework похожа, но немного отличается