c# restsharp官网_hbase shell put

大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

using System;
using System.Net.Http;
using System.Threading.Tasks;
using System.Collections.Generic;
using Newtonsoft.Json;
using System.Net;
using System.IO;
using System.Text;
using RestSharp;

namespace HttpClientQuery
{

class PageInfo
{

public int start { get; set; } //得是public类型

public string table { get; set; }

}

class FilterData
{

public string name { get; set; }

public string value { get; set; }

}

class DocQueryParam
{

public string id { get; set; }

public List<FilterData> filterData { get; set; }

public List<PageInfo> paginationInfo { get; set; }

public int searchType { get; set; }

public string tablename { get; set; }

}

class FileInfo
{

public string fileId { get; set; }
public string name { get; set; }
public int fileSize { get; set; }
public string fileType { get; set; }
public int level { get; set; }
public DateTime recordTime { get; set; }

}

class DocQueryResult
{

public Boolean result { get; set; }
public string errMessage { get; set; }
public string queryId { get; set; }
public List<FileInfo> queryFileList { get; set; }
public List<PageInfo> paginationHistoryInfo { get; set; }
public string IsEnd { get; set; }

}

class DocQuery
{

public DocQuery()
{

}
/// <summary>
/// 使用get方法异步请求
/// </summary>
/// <param name=”url”>目标链接</param>
/// <returns>返回的字符串</returns>
public static async Task<string> postAsync(string url, String jsonStr)
{

HttpClient client = new HttpClient(new HttpClientHandler() { UseCookies = false });

HttpContent content = new StringContent(jsonStr);
content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue(“application/json”);

HttpResponseMessage response = await client.PostAsync(url, content);
response.EnsureSuccessStatusCode();//用来抛异常的
string responseBody = await response.Content.ReadAsStringAsync();

Console.WriteLine(responseBody);

return responseBody;

}

public static string post(string url, string postdata)
{

HttpWebResponse hw;
string result = string.Empty;
HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
req.Method = “POST”;
req.ContentType = “application/json”;
#region 添加Post 参数
byte[] data = Encoding.UTF8.GetBytes(postdata);
req.ContentLength = data.Length;
using (Stream reqStream = req.GetRequestStream())
{

reqStream.Write(data, 0, data.Length);//将post对象放入请求流中
reqStream.Close();
}
#endregion
try
{

HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
Stream stream = resp.GetResponseStream();
//获取响应内容
using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
{

result = reader.ReadToEnd();
}
}
catch (WebException w)
{

hw = (HttpWebResponse)w.Response;
StreamReader sr = new StreamReader(hw.GetResponseStream(), Encoding.UTF8, false);
result = sr.ReadToEnd();
}
return result;
}

public static DocQueryResult restPost(string postdata, string url, string query)
{

RestSharp.RestClient client = new RestSharp.RestClient(url);
RestRequest req = new RestRequest(query, Method.POST);
req.RequestFormat = RestSharp.DataFormat.Json;
//req.AddHeader(“cache-control”, “no-cache”);

req.AddJsonBody(postdata);
//IRestResponse rsp = client.Execute(req);
//return rsp.Content;
IRestResponse<DocQueryResult> rsp = client.Execute<DocQueryResult>(req);
DocQueryResult result = rsp.Data;
return result;
}

public void test()
{

DocQueryParam docQueryParam = new DocQueryParam();
docQueryParam.id = “2311”;
docQueryParam.searchType = 2;
docQueryParam.tablename = “c_data”;

List<FilterData> filterDataList = new List<FilterData>();

FilterData filterData = new FilterData();
filterData.name = “model”;
filterData.value = “L”;
filterDataList.Add(filterData);

filterData = new FilterData();
filterData.name = “batch”;
filterData.value = “02”;
filterDataList.Add(filterData);

docQueryParam.filterData = filterDataList;

List<PageInfo> pageInfoList = new List<PageInfo>();

PageInfo pageInfo = new PageInfo();
pageInfo.start = 20;
pageInfo.table = “c_data”;
pageInfoList.Add(pageInfo);

docQueryParam.paginationInfo = pageInfoList;

//序列化
//var jsonStr = JsonConvert.SerializeObject(docQueryParam);
//Console.WriteLine(“docQuery json str: ” + jsonStr);

string url = “http://192.168.1.100:8080/archive/archiveQuery”;

var ret = DocQuery.postAsync(url, jsonStr); //给调用该方法的方法加上async
//DocQueryResult docQueryResult = JsonConvert.DeserializeObject<DocQueryResult>(ret);
//var docQueryResult = JsonConvert.DeserializeObject<DocQueryResult>(ret.Result);
//string isend = docQueryResult.getIsEnd();

Console.ReadKey();

}

}
}