手机版
你好,游客 登录 注册
背景:
阅读新闻

Thrift使用实例

[日期:2014-07-17] 来源:Linux社区  作者:Spring_java_gg [字体: ]

首先下载thrift.exe,和相应lib包,注意版本号一定要一致,否则编译会不识别出现错误。

可能会出现org.slf4j这个错误,那么你要把slf4j-api.jar下载下来引入到你的工程中

namespace Java com.nerd.thrift.service
/**
 *
 */
service sayThriftService{
void say();
}

通过在命令行中转到 thrift-1.8.0.exe -gen java  sayThriftService

在磁盘文件夹中(com.nerd.thrift.service)可发现这个脚本相应的java代码

如下:

public class sayThriftService {

  /**
  *
  */
  public interface Iface {

    public void say() throws org.apache.thrift.TException;

  }

  public interface AsyncIface {

    public void say(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.say_call> resultHandler) throws org.apache.thrift.TException;

  }

  public static class Client extends org.apache.thrift.TServiceClient implements Iface {
    public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
      public Factory() {}
      public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
        return new Client(prot);
      }
      public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
        return new Client(iprot, oprot);
      }
    }
    ...................省略(具体看自己的生成代码)

--------------------------------------分割线 --------------------------------------

Golang通过Thrift框架完美实现跨语言调用 http://www.linuxidc.com/Linux/2013-09/90748.htm

Hadoop的Thrift server配置 http://www.linuxidc.com/Linux/2013-09/90641.htm

利用ruby通过Thrift接口批量插入HBase http://www.linuxidc.com/Linux/2013-04/82880.htm

在Linux(CentOS)上安装Thrift+Scribe http://www.linuxidc.com/Linux/2012-12/76340.htm

使用Java快速入门Thrift http://www.linuxidc.com/Linux/2012-07/64933.htm

--------------------------------------分割线 --------------------------------------

先写一个Server类:

package com.nerd.clq;

import org.apache.thrift.TException;
import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
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 com.nerd.clq.thrift.sayThriftService;
import com.nerd.clq.thrift.sayThriftService.Iface;

public class Server implements sayThriftService.Iface{
 private static TServer server;
 @Override
 public void say() throws TException {
  System.out.println(System.currentTimeMillis());
 }
 
 public static void main(String[] args) throws TException {
  Server server1 = new Server();
  TServerSocket serverTransport = new TServerSocket(8080);
                TProtocolFactory proFactory = new TBinaryProtocol.Factory();
                sayThriftService.Processor<Iface> processor = new sayThriftService.Processor<Iface>(server1);
                Args arg = new Args(serverTransport) {
  }.protocolFactory(proFactory).processor(processor);
  server = new TThreadPoolServer(arg);
  //启动服务(先启动这个类,然后启动client类)
  server.serve();
 }
}

client客户端类

package com.nerd.clq;


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 com.nerd.clq.thrift.sayThriftService;


public class Client {
 public static void main(String[] args) throws TException {
    TTransport transport = new TSocket("localhost", 8080);
    TProtocol protocol = new TBinaryProtocol(transport);
    sayThriftService.Client client = new sayThriftService.Client(protocol);
    transport.open();
    client.say();
    transport.close();
 }
 
}

 服务器编写的一般步骤:
1. 创建Handler
2. 基于Handler创建Processor
3. 创建Transport
4. 创建Protocol方式
5. 基于Processor, Transport和Protocol创建Server
6. 运行Server

客户端编写的一般步骤:
1. 创建Transport
2. 创建Protocol方式
3. 基于Transport和Protocol创建Client
4. 运行Client的方法

创建Transport的时候,一般都需要创建相应的Socket。

本文永久更新链接地址http://www.linuxidc.com/Linux/2014-07/104313.htm

linux
相关资讯       Thrift  Thrift使用  Thrift实例 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款