Пример кода для клиента JSON-RPC в C #

Мне нужен простой клиент JSON-RPC 1.0 в C #, предпочтительно с использованием .NET 2.0 или более поздней версии. Я проверил JRock 0.9 У них есть несколько примеров, включая Yahoo Reader, но демонстрационные примеры JSON, а не JSON-RPC. Я понимаю, что мог бы реализовать часть RPC, используя любой из доступных анализаторов JSON, например, JRock или два от Microsoft. Я бы предпочел готовый образец.

Ответы на вопрос(3)

http://jsonrpc2.codeplex.com/SourceControl/changeset/view/13061#63133

Вот почти идентичный клиент wp7, который также доступен через Rx.http://jsonrpc2.codeplex.com/SourceControl/changeset/view/13061#282775

Оба этих примера выполняют свою работу асинхронно, поэтому они могут быть более сложными, чем вы ищете, если, конечно, вы не хотели, чтобы примеры были асинхронными. :)

Удачи!

 Rishi02 окт. 2014 г., 21:16
Привет, Остин, не столько как универсальные методы, сколько тот факт, что метод называется Invoke, когда он является ключевым словом. Я думаю, это называется шаблон прокси? Я пытаюсь понять необходимость в этом и как вызов метода "Invoke" прекрасно подходит компилятору. Спасибо!
 Rishi30 сент. 2014 г., 23:44
У меня возникают проблемы, когда я оборачиваюсь вокруг методов с именем «Invoke <T>». Я уверен, что чего-то здесь не хватает, не могли бы вы указать мне дополнительную информацию о том, почему законно называть метод в качестве ключевого слова? Спасибо!
 Austin Harris01 окт. 2014 г., 17:34
Вы имеете в виду использование универсальных методов?msdn.microsoft.com/en-us/library/twcad0zb.aspx
 Austin Harris03 окт. 2014 г., 03:25
Это не ключевое словоmsdn.microsoft.com/en-us/library/x53a06bb.aspx :)
 Rishi06 окт. 2014 г., 20:33
Хех. Я знал это :)
Решение Вопроса

2 образца здесь

Есть две разные реализации. Прочитать всю ветку + проверить вложения

который работает с TCP (класс Nil - это просто пустой класс, используемый для запросов без возвращаемого значения):

using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using Newtonsoft.Json.Linq;
using AustinHarris.JsonRpc;
using System.Linq;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Reactive.Concurrency;
using System.Net.Sockets;
using System.Text;

namespace JsonRpc
{
    public class JsonRpcClient
    {
        private static object idLock = new object();
        private static int id = 0;
        public Encoding encoding { get; set; }

        public JsonRpcClient(IPEndPoint serviceEndpoint, Encoding encoding)
        {
            this.serviceEndPoint = serviceEndpoint;
            this.encoding = encoding;
        }

        private static Stream CopyAndClose(Stream inputStream)
        {
            const int readSize = 256;
            byte[] buffer = new byte[readSize];
            MemoryStream ms = new MemoryStream();

            int count = inputStream.Read(buffer, 0, readSize);
            while (count > 0)
            {
                ms.Write(buffer, 0, count);
                count = inputStream.Read(buffer, 0, readSize);
            }
            ms.Position = 0;
            inputStream.Close();
            return ms;
        }

        public IObservable<JsonResponse<T>> InvokeWithScheduler<T>(string method, object arg, IScheduler scheduler)
        {
            var req = new AustinHarris.JsonRpc.JsonRequest()
            {
                Method = method,
                Params = new object[] { arg }
            };
            return InvokeRequestWithScheduler<T>(req, scheduler);
        }

        public IObservable<JsonResponse<T>> InvokeSingleArgument<T>(string method, object arg)
        {
            var req = new AustinHarris.JsonRpc.JsonRequest()
            {
                Method = method,
                Params = new object[] { arg }
            };
            return InvokeRequest<T>(req);
        }

        public IObservable<JsonResponse<T>> InvokeWithScheduler<T>(string method, object[] args, IScheduler scheduler)
        {
            var req = new AustinHarris.JsonRpc.JsonRequest()
            {
                Method = method,
                Params = args
            };
            return InvokeRequestWithScheduler<T>(req, scheduler);
        }

        public IObservable<JsonResponse<T>> Invoke<T>(string method, object[] args)
        {
            var req = new AustinHarris.JsonRpc.JsonRequest()
            {
                Method = method,
                Params = args
            };
            return InvokeRequest<T>(req);
        }

        public IObservable<JsonResponse<T>> InvokeRequestWithScheduler<T>(JsonRequest jsonRpc, IScheduler scheduler)
        {
            var res = Observable.Create<JsonResponse<T>>((obs) => 
                scheduler.Schedule(()=>{

                    makeRequest<T>(jsonRpc, obs);
                }));

            return res;
        }

        public IObservable<JsonResponse<T>> InvokeRequest<T>(JsonRequest jsonRpc)
        {
            return InvokeRequestWithScheduler<T>(jsonRpc, ImmediateScheduler.Instance);
        }

        private string sendAndReceive(string messageToSend) {
            string res = null;

        // Data buffer for incoming data.
        byte[] bytes = new byte[1024];

        // Connect to a remote device.
        try {
            // Create a TCP/IP  socket.
            Socket socket = new Socket(AddressFamily.InterNetwork, 
                SocketType.Stream, ProtocolType.Tcp );

            // Connect the socket to the remote endpoint. Catch any errors.
            try {
                socket.Connect(this.serviceEndPoint);

                Console.Write("Socket connected to "+socket.RemoteEndPoint.ToString());

                // Encode the data string into a byte array.
                byte[] msg = encoding.GetBytes(messageToSend);

                // Send the data through the socket.
                int bytesSent = socket.Send(msg);

                // Receive the response from the remote device.
                int bytesRec = socket.Receive(bytes);
                res = encoding.GetString(bytes,0,bytesRec);
                Console.Write("Server response = "+res);

                // Release the socket.
                socket.Shutdown(SocketShutdown.Both);
                socket.Close();

            } catch (ArgumentNullException ane) {
                Console.Write("ArgumentNullException : "+ane.ToString());
            } catch (SocketException se) {
                Console.Write("SocketException : " + se.ToString());
            } catch (Exception e) {
                Console.Write("Unexpected exception : " + e.ToString());
            }

        } catch (Exception e) {
            Console.Write(e.ToString());
        }
        return res;
    }

        private void makeRequest<T>(JsonRequest jsonRpc, IObserver<JsonResponse<T>> obs)
        {
            JsonResponse<T> rjson = null;
            string sstream = "";
            try
            {
                int myId;
                lock (idLock)
                {
                    myId = ++id;
                }
                jsonRpc.Id = myId.ToString();
            }
            catch (Exception ex)
            {
                obs.OnError(ex);
            }
            try
            {
                var json = Newtonsoft.Json.JsonConvert.SerializeObject(jsonRpc)+"\r\n";
                if (typeof(T).Equals(typeof(Nil)))
                {
                    sendAndReceive(json);
                    rjson = new JsonResponse<T>();
                }
                else
                {
                    sstream = sendAndReceive(json);
                    rjson = Newtonsoft.Json.JsonConvert.DeserializeObject<JsonResponse<T>>(sstream);
                }
            }
            catch (Exception ex)
            {
                obs.OnError(ex);
            }
            if (rjson == null)
            {
                string exceptionMessage = "";
                try
                {
                    JObject jo = Newtonsoft.Json.JsonConvert.DeserializeObject(sstream) as JObject;
                    exceptionMessage = jo["Error"].ToString();
                }
                catch(Exception ex){
                    exceptionMessage = sstream+"\r\n"+ex.Message;
                }
                obs.OnError(new Exception(exceptionMessage));
            }
            else
            {
                obs.OnNext(rjson);
            }
            obs.OnCompleted();
        }

        public IPEndPoint serviceEndPoint { get; set; }
    }
}
 bshea10 мар. 2018 г., 19:24
^ Или кто-нибудь? :-)
 bshea09 мар. 2018 г., 21:51
Не могли бы вы привести краткий пример (ы) о том, как правильно назвать это?

Ваш ответ на вопрос