<PackageReference Include="DotNetCoreRpc.Client" Version="1.0.2" />

class Program
{
    static void Main(string[] args)
    {
        IServiceCollection services = new ServiceCollection();
        //*注册DotNetCoreRpcClient核心服务
        services.AddDotNetCoreRpcClient()
        //*通信是基于HTTP的,内部使用的HttpClientFactory,自行注册即可
        .AddHttpClient("WebDemo", client => { client.BaseAddress = new Uri("http://localhost:13285/"); });
        IServiceProvider serviceProvider = services.BuildServiceProvider();
        //*获取RpcClient使用这个类创建具体服务代理对象
        RpcClient rpcClient = serviceProvider.GetRequiredService<RpcClient>();
        //IPersonService是我引入的服务包interface，需要提供ServiceName,即AddHttpClient的名称
        IPersonService personService = rpcClient.CreateClient<IPersonService>("WebDemo");
        PersonDto personDto = new PersonDto
        {
            Id = 1,
            Name = "yi念之间",
            Address = "中国",
            BirthDay = new DateTime(2000,12,12),
            IsMarried = true,
            Tel = 88888888888
        };
        bool addFlag = personService.Add(personDto);
        Console.WriteLine($"添加结果=[{addFlag}]");
        var person = personService.Get(personDto.Id);
        Console.WriteLine($"获取person结果=[{person.ToJson()}]");
        var persons = personService.GetAll();
        Console.WriteLine($"获取persons结果=[{persons.ToList().ToJson()}]");
        personService.Delete(person.Id);
        Console.WriteLine($"删除完成");
        Console.ReadLine();
    }
}

<PackageReference Include="DotNetCoreRpc.Server" Version="1.0.2" />

//实现契约接口IPersonService
public class PersonService:IPersonService
{
    private readonly ConcurrentDictionary<int, PersonDto> persons = new ConcurrentDictionary<int, PersonDto>();
    public bool Add(PersonDto person)
    {
        return persons.TryAdd(person.Id, person);
    }

    public void Delete(int id)
    {
        persons.Remove(id,out PersonDto person);
    }

    //自定义Filter
    [CacheFilter(CacheTime = 500)]
    public PersonDto Get(int id)
    {
        return persons.GetValueOrDefault(id);
    }

    //自定义Filter
    [CacheFilter(CacheTime = 300)]
    public IEnumerable<PersonDto> GetAll()
    {
        foreach (var item in persons)
        {
            yield return item.Value;
        }
    }
}

//*要继承自抽象类RpcFilterAttribute
public class CacheFilterAttribute: RpcFilterAttribute
{
    public int CacheTime { get; set; }

    //*支持属性注入,可以是public或者private
    //*这里的FromServices并非Asp.Net Core命名空间下的,而是来自DotNetCoreRpc.Core命名空间
    [FromServices]
    private RedisConfigOptions RedisConfig { get; set; }

    [FromServices]
    public ILogger<CacheFilterAttribute> Logger { get; set; }

    public override async Task InvokeAsync(RpcContext context, RpcRequestDelegate next)
    {
        Logger.LogInformation($"CacheFilterAttribute Begin,CacheTime=[{CacheTime}],Class=[{context.TargetType.FullName}],Method=[{context.Method.Name}],Params=[{JsonConvert.SerializeObject(context.Parameters)}]");
        await next(context);
        Logger.LogInformation($"CacheFilterAttribute End,ReturnValue=[{JsonConvert.SerializeObject(context.ReturnValue)}]");
    }
}

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddSingleton<IPersonService, PersonService>()
        .AddSingleton(new RedisConfigOptions { Address = "127.0.0.1:6379", Db = 10 })
        //*注册DotNetCoreRpcServer
        .AddDotNetCoreRpcServer(options => {
            //*确保添加的契约服务接口事先已经被注册到DI容器中

            //添加契约接口
            //options.AddService<IPersonService>();

            //或添加契约接口名称以xxx为结尾的
            //options.AddService("*Service");

            //或添加具体名称为xxx的契约接口
            //options.AddService("IPersonService");

            //或扫描具体命名空间下的契约接口
            options.AddNameSpace("IRpcService");

            //可以添加全局过滤器,实现方式和CacheFilterAttribute一致
            options.AddFilter<LoggerFilterAttribute>();
        });
    }

    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        //这一堆可以不要+1
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }

        //添加DotNetCoreRpc中间件既可
        app.UseDotNetCoreRpc();

        //这一堆可以不要+2
        app.UseRouting();

        //这一堆可以不要+3
        app.UseEndpoints(endpoints =>
        {
            endpoints.MapGet("/", async context =>
            {
                await context.Response.WriteAsync("Server Start!");
            });
        });
    }
}