Category Archives: Thrift

使用Thrift实现RPC简单示例03

Posted on by — No Comments ↓

接第01部分，本节用来说明Java语言的代码实现。

使用thrift生成java代码之后，会生成两个java文件，无论是Client还是Server都要包含这个文件。

首先是Server端：
1、新建一个java项目，引用libthrift.jar，项目中添加生成的两个java文件。
2、新建一个类MyThriftServer，实现JustATest.Iface接口

package com.neohope.thrift.test;

import org.apache.thrift.TException;

public class MyThriftServer implements JustATest.Iface {
    @Override
    public String SayHelloTo(Person person) throws TException {
        return "Hello "+ person.getName();
    }

    @Override
    public int Add(int a, int b) throws TException {
        return a+b;
    }
}

3、修改TestServer.java

package com.neohope.thrift.test;

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TTransportException;

public class TestServer {
    public static void main(String[] args) {
        try {
            TServerSocket serverTransport = new TServerSocket(1900);
            JustATest.Processor process = new JustATest.Processor(new MyThriftServer());
            TBinaryProtocol.Factory portFactory = new TBinaryProtocol.Factory(true, true);
            TThreadPoolServer.Args thriftArgs = new TThreadPoolServer.Args(serverTransport);
            thriftArgs.processor(process);
            thriftArgs.protocolFactory(portFactory);
            TServer server = new TThreadPoolServer(thriftArgs);
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }
}

4、编译运行

然后是Client端：
1、新建一个java项目，引用libthrift.jar，项目中添加生成的两个java文件。
2、修改TestClient.java

package com.neohope.thrift.test;

import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;

public class TestClient {

    public static void main(String[] args) {
        TTransport transport;
        try {
            transport = new TSocket("localhost", 1900);
            TProtocol protocol = new TBinaryProtocol(transport);
            JustATest.Client client = new JustATest.Client(protocol);
            transport.open();

            Person p = new Person();
            p.setName("neohope");
            System.out.println(client.SayHelloTo(p));
            System.out.println(client.Add(1, 2));
            transport.close();
        } catch (TTransportException e) {
            e.printStackTrace();
        } catch (TException e) {
            e.printStackTrace();
        }
    }
}

3、编译运行

使用Thrift实现RPC简单示例02

Posted on by — No Comments ↓

接第01部分，本节用来说明C#语言的代码实现。

使用thrift生成cs代码之后，会生成两个cs文件，无论是Client还是Server都要包含这个文件。

首先是Server端：
1、新建一个Console项目，引用Thrift程序集中的Thrift.dll，项目中添加生成的两个cs文件。
2、新建一个类MyThriftServer，实现JustATest.Iface接口

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace TestThrift
{
    class MyThriftServer : JustATest.Iface
    {
        public string SayHelloTo(Person person)
        {
            return "Hello " + person.Name;
        }

        public int Add(int a, int b)
        {
            return a + b;
        }
    }
}

3、修改Program.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Thrift.Protocol;
using Thrift.Server;
using Thrift.Transport;

namespace TestThrift
{
    class Program
    {
        static void Main(string[] args)
        {
            TServerSocket serverTransport = new TServerSocket(1900, 0, false);
            JustATest.Processor processor = new JustATest.Processor(new MyThriftServer());
            TServer server = new TSimpleServer(processor, serverTransport);
            server.Serve(); 
        }
    }
}

4、编译运行

然后是Client端：
1、新建一个Console项目，引用Thrift程序集中的Thrift.dll，项目中添加生成的两个cs文件。
2、修改Program.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Thrift.Protocol;
using Thrift.Transport;

namespace TestThriftClient
{
    class Program
    {
        static void Main(string[] args)
        {
            TTransport transport = new TSocket("localhost", 1900); 
            TProtocol protocol = new TBinaryProtocol(transport);
            JustATest.Client client = new JustATest.Client(protocol); 
            transport.Open(); 
 
            Person p = new Person();
            p.Name="neohope";
            Console.WriteLine(client.SayHelloTo(p));
            Console.WriteLine(client.Add(1, 2));
            
            transport.Close();
        }
    }
}

3、编译运行

使用Thrift实现RPC简单示例01

Posted on by — No Comments ↓

看一眼下面的框架，你就会发现，Thrift框架其实与CORBA、ICE很相似。对使用者来说，最大的不同，估计是Thrift用一个可执行文件，生成各种各样的代码咯（别告诉我你信了）。

Thrift Arch

Thrift是典型CS架构，与ICE、CORBA相同，Thrift帮我们处理的底层的网络通信及服务定位，我们只需要告诉Thrift服务在哪里，需要哪个服务，调用参数是什么，然后就坐等处理结果就好咯。

使用Thrift的时候，首先要先下载Thrift的开发包，分两部分。
Thrift
一个是一个EXE文件，适用于从IDL描述文件，生成各类语言代码的。
第二个是源码压缩包，用于编译自己所需语言的支持包。

受用Thrift之前，要先编译需要的语言支持包，我这里用到了C#和Java。
Java包，直接到路径lib/java下，执行ant命令就好了
C#包，直接到路径lib/csharp/src下，用VS编译Thrift.sln就好了

使用Thrift的时候，首先要用IDL语言，定义一个接口描述文件，比如我自己写了一个很简单的接口。
JustATest.thrift

struct Person {
1: string name
2: i32 age
3: string sex
4: string address
}

service JustATest {
  string SayHelloTo(1:Person person);
  i32 Add(1:i32 a,2:i32 b);
}

然后用语言的转化工具，将接口描述文件，转化为对应语言。

#生成java代码，会有两个文件
thrift -gen java JustATest.thrift

#生成C#代码，会有两个文件
thrift -gen csharp JustATest.thrift

在对应的项目中包含这些文件及所需要的库文件（jar、dll），就可以开工了。