Thrift简介与实践

3-11 后端 magicwt 2,176 views

Thrift简介与实践

3-11 2,176 views

Thrift（http://thrift.apache.org/）是一个支持多种语言的远程服务调用框架，最初由Facebook开发，目前由Apache基金会负责维护。

安装

tar -zxvf thrift-0.9.1.tar.gz
cd thrift-0.9.1/
./configure
make
make install

安装成功后，可以使用“thrift”命令。

定义远程服务接口

Thrift提供了接口描述语言，用于定义远程服务接口，例如，“TestService.thrift”中定义了“greet”方法：

namespace java com.magicwt.service
service TestService {
    string greet(1:string name)
}

namespace java com.magicwt.service

service TestService {

string greet(1:string name)

}

使用“thrift”命令根据“TestService.thrift”生成相应的Java代码文件：

thrift -r -gen java TestService.thrift

执行成功后，会在gen-java/com/magicwt/service目录下生成TestService.java。

远程服务调用测试

创建Maven工程，增加对Thrift的依赖：

<dependency>
    <groupId>org.apache.thrift</groupId>
    <artifactId>libthrift</artifactId>
    <version>0.9.1</version>
</dependency>

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

<artifactId>libthrift</artifactId>

</dependency>

导入TestService.java，创建TestServiceImpl类实现TestService中的Iface接口，实现其中的greet方法：

package com.magicwt.service.impl;

import com.magicwt.service.TestService;
import org.apache.thrift.TException;

public class TestServiceImpl implements TestService.Iface {

    @Override
    public String greet(String name) throws TException {
        return "hi, " + name;
    }

}

package com.magicwt.service.impl;

import com.magicwt.service.TestService;

import org.apache.thrift.TException;

public class TestServiceImpl implements TestService.Iface {

@Override

public String greet(String name) throws TException {

return "hi, " + name;

}

创建TestServer和TestClient类分别作为测试服务端和测试客户端。
TestServer：

package com.magicwt;

import com.magicwt.service.TestService;
import com.magicwt.service.impl.TestServiceImpl;
import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.server.TThreadPoolServer.Args;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;

import java.net.InetSocketAddress;

public class TestServer {

    public static void main(String[] array) throws Exception {
        TProcessor processor = new TestService.Processor(new TestServiceImpl());
        TServerTransport transport = new TServerSocket(new InetSocketAddress("127.0.0.1", 9001));
        Args args = new Args(transport);
        args.processor(processor);
        args.protocolFactory(new TBinaryProtocol.Factory());
        TServer server = new TThreadPoolServer(args);
        server.serve();
    }
}

package com.magicwt;

import com.magicwt.service.TestService;

import com.magicwt.service.impl.TestServiceImpl;

import org.apache.thrift.TProcessor;

import org.apache.thrift.protocol.TBinaryProtocol;

import org.apache.thrift.server.TServer;

import org.apache.thrift.server.TThreadPoolServer;

import org.apache.thrift.server.TThreadPoolServer.Args;

import org.apache.thrift.transport.TServerSocket;

import org.apache.thrift.transport.TServerTransport;

import java.net.InetSocketAddress;

public class TestServer {

public static void main(String[] array) throws Exception {

TProcessor processor = new TestService.Processor(new TestServiceImpl());

TServerTransport transport = new TServerSocket(new InetSocketAddress("127.0.0.1", 9001));

Args args = new Args(transport);

args.processor(processor);

args.protocolFactory(new TBinaryProtocol.Factory());

TServer server = new TThreadPoolServer(args);

server.serve();

}

TestClient：

package com.magicwt;

import com.magicwt.service.TestService.Client;
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 TestClient {

    public static void main(String[] args) throws Exception {
        TTransport transport = new TSocket("127.0.0.1", 9001);
        TProtocol protocol = new TBinaryProtocol(transport);
        Client client = new Client(protocol);
        transport.open();
        System.out.println(client.greet("admin"));
        transport.close();
    }
}

package com.magicwt;

import com.magicwt.service.TestService.Client;

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 TestClient {

public static void main(String[] args) throws Exception {

TTransport transport = new TSocket("127.0.0.1", 9001);

TProtocol protocol = new TBinaryProtocol(transport);

Client client = new Client(protocol);

transport.open();

System.out.println(client.greet("admin"));

transport.close();

}

先后启动TestServer和TestClient，TestClient的控制台输出如下：

说明远程服务调用成功。

版权属于: 我爱我家

原文地址: http://magicwt.com/2014/03/11/thrift%e7%ae%80%e4%bb%8b%e4%b8%8e%e5%ae%9e%e8%b7%b5/

转载时必须以链接形式注明原始出处及本声明。