NetCore版RPC框架NewLife.ApiServer

/// <summary>自定义控制器。包含多个服务</summary>
class MyController
{
    /// <summary>添加，标准业务服务，走Json序列化</summary>
    /// <param name="x"></param>
    /// <param name="y"></param>
    /// <returns></returns>
    public Int32 Add(Int32 x, Int32 y) => x + y;

    /// <summary>RC4加解密，高速业务服务，二进制收发不经序列化</summary>
    /// <param name="pk"></param>
    /// <returns></returns>
    public Packet RC4(Packet pk)
    {
        var data = pk.ToArray();
        var pass = "NewLife".GetBytes();

        return data.RC4(pass);
    }
}

/// <summary>用户控制器。会话获取，请求过滤</summary>
[Api("User")]
class UserController : IApi, IActionFilter
{
    /// <summary>会话。同一Tcp/Udp会话多次请求共用，执行服务方法前赋值</summary>
    public IApiSession Session { get; set; }

    [Api(nameof(FindByID))]
    public User FindByID(Int32 uid, Boolean deleted)
    {
        // Session 用法同Web
        var times = Session["Times"].ToInt();
        times++;
        Session["Times"] = times;

        // 故意制造异常
        if (times >= 2)
        {
            // 取得当前上下文
            var ctx = ControllerContext.Current;

            throw new ApiException(507, "[{0}]调用次数过多！Times={1}".F(ctx.ActionName, times));
        }

        var user = new User
        {
            ID = uid,
            Name = Rand.NextString(8),
            Enable = deleted,
            CreateTime = DateTime.Now,
        };

        return user;
    }

    /// <summary>本控制器执行前</summary>
    /// <param name="filterContext"></param>
    public void OnActionExecuting(ControllerContext filterContext)
    {
        // 请求参数
        var ps = filterContext.Parameters;

        // 服务参数
        var cs = filterContext.ActionParameters;

        foreach (var item in ps)
        {
            if (cs != null && !cs.ContainsKey(item.Key))
                XTrace.WriteLine("服务[{0}]未能找到匹配参数 {1}={2}", filterContext.ActionName, item.Key, item.Value);
        }
    }

    /// <summary>本控制器执行后，包括异常发生</summary>
    /// <param name="filterContext"></param>
    public void OnActionExecuted(ControllerContext filterContext)
    {
        var ex = filterContext.Exception;
        if (ex != null && !filterContext.ExceptionHandled)
        {
            XTrace.WriteLine("控制器拦截到异常：{0}", ex.Message);
        }
    }
}

static void TestServer()
{
    // 实例化RPC服务端，指定端口，同时在Tcp/Udp/IPv4/IPv6上监听
    var svr = new ApiServer(1234);
    // 注册服务控制器
    svr.Register<MyController>();
    svr.Register<UserController>();

    // 指定编码器
    svr.Encoder = new JsonEncoder();
    svr.EncoderLog = XTrace.Log;

    // 打开原始数据日志
    var ns = svr.Server as NetServer;
    ns.Log = XTrace.Log;
    ns.LogSend = true;
    ns.LogReceive = true;

    svr.Log = XTrace.Log;
    svr.Start();

    _server = svr;

    // 定时显示性能数据
    _timer = new TimerX(ShowStat, ns, 100, 1000);
}

/// <summary>自定义业务客户端</summary>
class MyClient : ApiClient
{
    public MyClient(String uri) : base(uri) { }

    /// <summary>添加，标准业务服务，走Json序列化</summary>
    /// <param name="x"></param>
    /// <param name="y"></param>
    /// <returns></returns>
    public async Task<Int32> AddAsync(Int32 x, Int32 y)
    {
        return await InvokeAsync<Int32>("My/Add", new { x, y });
    }

    /// <summary>RC4加解密，高速业务服务，二进制收发不经序列化</summary>
    /// <param name="pk"></param>
    /// <returns></returns>
    public async Task<Packet> RC4Async(Packet pk)
    {
        return await InvokeAsync<Packet>("My/RC4", pk);
    }

    public async Task<User> FindUserAsync(Int32 uid, Boolean enable)
    {
        return await InvokeAsync<User>("User/FindByID", new { uid, enable });
    }
}

static async void TestClient()
{
    var client = new MyClient("tcp://127.0.0.1:1234");

    // 指定编码器
    client.Encoder = new JsonEncoder();
    client.EncoderLog = XTrace.Log;

    // 打开原始数据日志
    var ns = client.Client;
    ns.Log = XTrace.Log;
    ns.LogSend = true;
    ns.LogReceive = true;

    client.Log = XTrace.Log;
    client.Open();

    // 定时显示性能数据
    _timer = new TimerX(ShowStat, ns, 100, 1000);

    // 标准服务，Json
    var n = await client.AddAsync(1245, 3456);
    XTrace.WriteLine("Add: {0}", n);

    // 高速服务，二进制
    var buf = "Hello".GetBytes();
    var pk = await client.RC4Async(buf);
    XTrace.WriteLine("RC4: {0}", pk.ToHex());

    // 返回对象
    var user = await client.FindUserAsync(123, true);
    XTrace.WriteLine("FindUser: ID={0} Name={1} Enable={2} CreateTime={3}", user.ID, user.Name, user.Enable, user.CreateTime);

    // 拦截异常
    try
    {
        user = await client.FindUserAsync(123, true);
    }
    catch (ApiException ex)
    {
        XTrace.WriteLine("FindUser出错，错误码={0}，内容={1}", ex.Code, ex.Message);
    }
}