Socean.Rpc

An efficient rpc framework,stable and efficient,the rps is about 110k on two core i5 notebook computer and it would be higher in 24 core device.

一个高效的rpc框架，框架特点是 稳定和 高效，在双核i5笔记本电脑上,每秒处理请求数（rps）在11w左右,理论上在24核服务器上应该会更高，不过没实际测试过

本框架性能可满足部分unity3d服务器端的需求，双核笔记本上支持10000长连接，且每秒10个请求，在性能好的服务器上，20000长连接且每秒20个请求应该是没问题的

---

server sample :

1.定义实体

public class Book
{
    public string Name { get; set; }
}

定义MessageProcessor

 public class DefaultMessageProcessor : IMessageProcessor
 {

      public ResponseBase Process(string title, byte[] contentBytes)
      {

          if (title == "book/name/change")
          {
              var content = Encoding.UTF8.GetString(contentBytes);

              //here we use newtonsoft.Json serializer 
              //you need add refer "newtonsoft.Json.dll"
              var book = JsonConvert.DeserializeObject<Book>(content);
              book.Name = "new name";

              var responseContent = JsonConvert.SerializeObject(book);
              return new BytesResponse(Encoding.UTF8.GetBytes(responseContent));
          }

          if (title == "empty")
          {
              return new EmptyResponse();
          }

          return new ErrorResponse(ResponseErrorCode.SERVICE_NOT_FOUND);
      }
  }

2.启动服务

var server = new KeepAliveRpcServer();
server.Bind(IPAddress.Any, 11111);
server.AutoReconnect = true;
server.MessageProcessor = new DefaultMessageProcessor();

server.Start();  

---

client sample:

1.定义实体

public class Book
{
    public string Name { get; set; }
}

2.执行调用

public Book ChangeBookName(Book book)
{
    using (var rpcClient = ShortConnectionRpcClientFactory.Create(IPAddress.Parse("127.0.0.1"), 11111))
    {
        var requestContent = JsonConvert.SerializeObject(book);
        var response = rpcClient.Query("book/name/change", Encoding.UTF8.GetBytes(requestContent));
        var content = Encoding.UTF8.GetString(response.ContentBytes);
        return JsonConvert.DeserializeObject<Book>(content);
    }
}

---

其他：

NetworkSettings类可修改连接超时时间等参数

若果要进行性能测试(load test)，最好是在客户端把NetworkSettings.ClientDetectReceiveInterval设置成1，并提升线程优先级至ThreadPriority.Highest

Socean.Rpc.Core未来的变动会比较小，接下来会推出Socean.Rpc.Contract，以支持各种扩展，如MVC中的route等功能