（11）学习笔记 ） ASP.NET CORE微服务 Micro-Service ---- Thrift高效通讯 （完结）

namespace csharp RuPeng.ThriftTest1.Contract

service UserService{
   SaveResult Save(1:User user)     
   User Get(1:i32 id)     
   list<User> GetAll()
} 

enum SaveResult {     
  SUCCESS = 0,  
  FAILED = 1,  
}  

struct User {
    1: required i64 Id;
    2: required string Name;
    3: required i32 Age;
    4: optional bool IsVIP;
    5: optional string Remark;
}

cmd -> thrift.exe -gen csharp UserService.thrift

Install-Package apache-thrift-netcore

public class UserServiceImpl : UserService.Iface
{
    public User Get(int id)
    {
        User u = new User();
        u.Id = id;
        u.Name = "用户" + id;
        u.Age = 6; return u;
    }

    public List<User> GetAll()
    {
        List<User> list = new List<User>();
        list.Add(new User { Id = 1, Name = "yzk", Age = 18, Remark = "hello" });
        list.Add(new User { Id = 2, Name = "rupeng", Age = 6 });
        return list;
    }

    public SaveResult Save(User user)
    {
        Console.WriteLine($"保存用户，{user.Id}"); return SaveResult.SUCCESS;
    }
}

TServerTransport transport = new TServerSocket(8800);//监听8800端口
var processor = new RuPeng.ThriftTest1.Contract.UserService.Processor(new UserServiceImpl());//设置实现类
TServer server = new TThreadPoolServer(processor, transport);
server.Serve();

using (TTransport transport = new TSocket("localhost", 8800))
    using (TProtocol protocol = new TBinaryProtocol(transport))
    using (var clientUser = new UserService.Client(protocol))
{
    transport.Open();
    User u = clientUser.Get(1);
    Console.WriteLine($"{u.Id},{u.Name}");
}

service CalcService{ 
     i32 Add(1:i32 i1,2:i32 i2)
}

TServerTransport transport = new TServerSocket(8800);
var processorUserService = new RuPeng.ThriftTest1.Contract.UserService.Processor(new UserServiceImpl())
var processorCalcService = new RuPeng.ThriftTest1.Contract.CalcService.Processor(new CalcServiceImpl());
var processorMulti = new TMultiplexedProcessor();
processorMulti.RegisterProcessor("userService", processorUserService);
processorMulti.RegisterProcessor("calcService", processorCalcService);
TServer server = new TThreadPoolServer(processorMulti, transport);
server.Serve();

using (TTransport transport = new TSocket("localhost", 8800))
    using (TProtocol protocol = new TBinaryProtocol(transport))
    using (var protocolUserService = new TMultiplexedProtocol(protocol, "userService"))
    using (var clientUser = new UserService.Client(protocolUserService))
    using (var protocolCalcService = new TMultiplexedProtocol(protocol,"calcService"))
    using (var clientCalc = new CalcService.Client(protocolCalcService))
{
    transport.Open();
    User u = clientUser.Get(1);
    Console.WriteLine($"{u.Id},{u.Name}");
    Console.WriteLine(clientCalc.Add(1, 2));
}

<dependency>

  <groupId>org.apache.thrift</groupId>

  <artifactId>libthrift</artifactId>

  <version>0.11.0</version>

</dependency>

<dependency>

  <groupId>org.slf4j</groupId>

  <artifactId>slf4j-log4j12</artifactId>

  <version>1.7.5</version>

</dependency>

namespace java com.rupeng.thriftTest1.contract 

thrift.exe -gen java UserService.thrift 

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
public class Main {
  public static void main(String[] args) throws Exception {
      System.out.println("客户端启动....");
      TTransport transport = new TSocket("localhost", 8800, 30000);        
      TProtocol protocol = new TBinaryProtocol(transport);        
      UserService.Client client = new UserService.Client(protocol);        
      transport.open();
      User result = client.Get(1);
      System.out.println(result.getAge()+result.getName()+result.getRemark());
   }
}