You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
125 lines
2.8 KiB
125 lines
2.8 KiB
using Forks.JsonRpc.Client;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace ButcherFactory.BO.Utils
|
|
{
|
|
public class ClientRpc
|
|
{
|
|
public ClientRpc(string url)
|
|
{
|
|
mUrl = url;
|
|
}
|
|
|
|
class _Error
|
|
{
|
|
public int? code { get; set; }
|
|
public string message { get; set; }
|
|
}
|
|
class _ErrorResposne
|
|
{
|
|
public _Error error { get; set; }
|
|
}
|
|
|
|
string mUrl;
|
|
|
|
public string Url
|
|
{
|
|
get
|
|
{
|
|
return mUrl;
|
|
}
|
|
}
|
|
|
|
public T Call<T>(string method, params object[] args)
|
|
{
|
|
var resp = DoCall<T>(method, args);
|
|
|
|
if (resp.error != null)
|
|
{
|
|
throw new Exception(string.Format("{0}:{1}", resp.error.code, resp.error.message));
|
|
}
|
|
|
|
return resp.result;
|
|
}
|
|
|
|
LRestClientReponse<T> DoCall<T>(string method, object[] args)
|
|
{
|
|
var request = (HttpWebRequest)WebRequest.Create(mUrl);
|
|
request.Method = "POST";
|
|
request.ContentType = "application/json";
|
|
var dic = new Dictionary<string, object>();
|
|
dic.Add("method", method);
|
|
dic.Add("id", 1);
|
|
dic.Add("params", args);
|
|
|
|
var json = JsonConvert.SerializeObject(dic);
|
|
|
|
var buffer = Encoding.UTF8.GetBytes(json);
|
|
|
|
var requestStream = request.GetRequestStream();
|
|
requestStream.Write(buffer, 0, buffer.Length);
|
|
|
|
var responseJson = GetResponseJSON(request);
|
|
|
|
try
|
|
{
|
|
var result = JsonConvert.DeserializeObject<LRestClientReponse<T>>(responseJson);
|
|
return result;
|
|
}
|
|
catch
|
|
{
|
|
try
|
|
{
|
|
var errorResponse = JsonConvert.DeserializeObject<_ErrorResposne>(responseJson);
|
|
if (errorResponse.error != null)
|
|
{
|
|
throw new JsonRpcException(errorResponse.error.message);
|
|
}
|
|
}
|
|
catch
|
|
{
|
|
throw new Exception("JSON反序列化失败:" + responseJson);
|
|
}
|
|
throw new Exception("JSON反序列化失败:" + responseJson);
|
|
}
|
|
|
|
}
|
|
|
|
public class LRestClientReponseError
|
|
{
|
|
public string code { get; set; }
|
|
public string message { get; set; }
|
|
|
|
public override string ToString()
|
|
{
|
|
return string.Format("{0}:{1}", code, message);
|
|
}
|
|
}
|
|
|
|
public class LRestClientReponse<T>
|
|
{
|
|
public long id { get; set; }
|
|
public LRestClientReponseError error { get; set; }
|
|
public T result { get; set; }
|
|
}
|
|
|
|
private static string GetResponseJSON(HttpWebRequest request)
|
|
{
|
|
var response = request.GetResponse();
|
|
using (var stream = response.GetResponseStream())
|
|
{
|
|
using (var reader = new StreamReader(stream, Encoding.UTF8))
|
|
{
|
|
return reader.ReadToEnd();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|