beetlex-io / httpclients

BeetleX http/websocket client support ssl

HttpClients

BeetleX http and websocket clients for .net standard2.0

Install

Install-Package BeetleX.Http.Clients -Version 1.6

            var result = await "https://www.baidu.com/"
                    .FormUrlRequest()
                    .Get();
            Console.WriteLine(result.Body);

            result = await "https://httpbin.org/get"
                     .FormUrlRequest()
                     .Get();
            Console.WriteLine(result.Body);


            result = await "https://httpbin.org/post"
                     .JsonRequest()
                     .SetBody(DateTime.Now)
                     .Post();
            JToken rdata = result.GetResult<JToken>()["data"];

            Console.WriteLine(rdata);


            var buffer = await "https://httpbin.org/image"
                           .BinaryRequest()
                           .Download();

             result = await "http://localhost/Upload"
                           .FormDataRequest()
                           .Upload("g:\\extension_1_4_3_0.rar", "g:\\extension_1_4_3_0_1.rar");

Http Cluster

HttpCluster httpCluster = new HttpCluster();
httpCluster.DefaultNode
.Add("http://192.168.2.25:8080")
.Add("http://192.168.2.26:8080");
var client = httpCluster.JsonRequest("/customers?count=10");
var data = await client.Get();
client = httpCluster.JsonRequest("/orders?size=10");
data = await client.Get();

Http Cluster interface

    public interface INorthWind
    {
        Task<Employee> GetEmployee(int id);
        [Post]
        Task<Employee> Add(Employee emp);
        [Post]
        Task<bool> Login(string name, string value);       
        [Post]
        Task<Employee> Modify([CQuery]int id, Employee body);
    }

HttpCluster httpClusterApi = new HttpClusterApi();
httpCluster.DefaultNode.Add("http://localhost:8080");
northWind = httpCluster.Create<INorthWind>();
var result = await northWind.GetEmployee(1);

Multi server

httpCluster.DefaultNode
    .Add("http://192.168.2.25:8080")
    .Add("http://192.168.2.26:8080");

Server weight

.Add("http://192.168.2.25:8080",10)
.Add("http://192.168.2.26:8080",10);
.Add("http://192.168.2.27:8080",5);

Multi url route

httpClusterApi.GetUrlNode("/order.*")
    .Add("http://192.168.2.25:8080")
    .Add("http://192.168.2.26:8080");
httpClusterApi.GetUrlNode("/employee.*")
    .Add("http://192.168.2.27:8080")
    .Add("http://192.168.2.28:8080");

github auth sample

    [FormUrlFormater]
    [Host("https://github.com")]
    public interface IGithubAuth
    {

        [Get(Route = "login/oauth/access_token")]
        Task<string> GetToken(string client_id, string client_secret, string code);

        [Host("https://api.github.com")]
        [CHeader("User-Agent", "beetlex.io")]
        [Get(Route = "user")]
        Task<string> GetUser(string access_token);
    }
     githubAuth = HttpApiClient.Create<IGithubAuth>();

Websocket

Create wsclient

TextClient client = new TextClient("ws://echo.websocket.org");

send text

 await client.Send("hello");

send and receive

var resutl = await wss.ReceiveFrom("hello henry");

httpclients's Issues

文档提供的示例在nuget新版本（1.2.5.8）下已经无法正常使用了，需要更新下文档

文档提供的示例在nuget新版本（1.2.5.8）下已经无法正常使用了，需要更新下文档

如果远程服务器临时不可用 会无限循环NullReferenceException

按照大佬的BinaryClient例子写了个demo,
发现无限循环NullReferenceException,
大佬是否能同步下新代码呢 方便调试锁定问题上报

Response Set-Cookie 不考虑吗

HttpClients/src/Header.cs

Line 331 in b5c8749

if (line[0] == 'C' && line[5] == 'e' && line[1] == 'o' && line[2] == 'o' && line[3] == 'k' && line[4] == 'i')

关于客户端添加多个服务端的好奇

我看readme 这个组件实现了客户端负载均衡，所以说当某个服务端挂了，它会自己切换服务器吗？

error Unexpected character encountered while parsing value

api端

接口定义

调用的代码

postman

所有的访问都是Get是日志的问题还是本来就有问题

我用的是wiki中的例子，但是在调Add的时候日志是
request http://127.0.0.1:5000/ error [GET /Add 404 Not Found] Response
这里为啥是GET?

public interface INorthWind
{
Task GetEmployee(int id);
[Post]
Task Add(string emp);
[Post]
Task Login(string name, string value);
[Post]
Task Modify([CQuery]int id, string body);
}