文档章节

Thrift的java和php数据交互

penngo
 penngo
发布于 2015/08/07 17:39
字数 1614
阅读 4806
收藏 12

Thrift是一个软件框架(远程过程调用框架),用来进行可扩展且跨语言的服务的开发,封装了数据传输格式(二进制、json)和网络通信的服务框架,提供多语言(C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml)的网络服务器端和客户端程序组件

适用于搭建大型数据交换及存储的通用工具,对于大型系统中的内部数据传输相对于JSON和xml无论在性能、传输大小上有明显的优势。

本文以注册服务接口和登录服务器接口为教程,

Thrift开发的几个概念:

Server 服务模型

Handler 数据处理接口

Processor 数据处理对象

Protocol 数据传输协议

Transport 数据传输方式


(1)支持的传输格式

TBinaryProtocol – 二进制格式.

TCompactProtocol – 压缩格式

TJSONProtocol – JSON格式

TSimpleJSONProtocol –提供JSON只写协议, 生成的文件很容易通过脚本语言解析。

TDebugProtocol – 使用易懂的可读的文本格式,以便于debug

 

(2) 支持的通信方式(数据传输方式)(Transport)

TFileTransport:文件(日志)传输类,允许client将文件传给server,允许server将收到的数据写到文件中。

THttpTransport:采用Http传输协议进行数据传输

TSocket:采用TCP Socket进行数据传输

TZlibTransport:压缩后对数据进行传输,或者将收到的数据解压

 

下面几个类主要是对上面几个类地装饰(采用了装饰模式),以提高传输效率。

TBufferedTransport:对某个Transport对象操作的数据进行buffer,即从buffer中读取数据进行传输,或者将数据直接写入buffer

TFramedTransport:以frame为单位进行传输,非阻塞式服务中使用。同TBufferedTransport类似,也会对相关数据进行buffer,同时,它支持定长数据发送和接收。

TMemoryBuffer:从一个缓冲区中读写数据


(3)支持的服务模型

TSimpleServer – 简单的单线程服务模型,常用于测试

TThreadedServer - 多线程服务模型,使用阻塞式IO,每个请求创建一个线程。

TThreadPoolServer – 线程池服务模型,使用标准的阻塞式IO,预先创建一组线程处理请求。

TNonblockingServer – 多线程服务模型,使用非阻塞式IO(需使用TFramedTransport数据传输方式)

 

处理大量更新的话,主要是在TThreadedServer和TNonblockingServer中进行选择。TNonblockingServer能够使用少量线程处理大量并发连接,但是延迟较高;TThreadedServer的延迟较低。实际中,TThreadedServer的吞吐量可能会比TNonblockingServer高,但是TThreadedServer的CPU占用要比TNonblockingServer高很多。


服务端编写的一般步骤:

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的方法

上边概述内容参考自:http://elf8848.iteye.com/blog/1960131

下面开始正式代码教程

服务描述文件test.thrift,定义了login服务和register

/**
 * The first thing to know about are types. The available types in Thrift are:
 *
 *  bool        Boolean, one byte
 *  byte        Signed byte
 *  i16         Signed 16-bit integer
 *  i32         Signed 32-bit integer
 *  i64         Signed 64-bit integer
 *  double      64-bit floating point value
 *  string      String
 *  binary      Blob (byte array)
 *  map<t1,t2>  Map from one type to another
 *  list<t1>    Ordered list of one type
 *  set<t1>     Set of unique elements of one type
 *
 * Did you also notice that Thrift supports C style comments?
 */
namespace java com.penngo
namespace php com.penngo
struct User {
	1: i64 id,
	2: string name,
	3: string password
}

service LoginService{
    User login(1:string name, 2:string psw);
} 

service RegisterService{
    User createUser(1:string name, 2:string psw);
}

使用thrift生成对应平台语言代码

thrift -gen java test.thrift

thrift -gen php test.thrift

如果php需要生成服务器端,需求改为thrift -gen php:server test.thrift

java

实现LoginServiceImpl.java登录接口业务

import org.apache.thrift.TException;
public class LoginServiceImpl implements LoginService.Iface{
	public LoginServiceImpl(){
	}
	public User login(String name, String psw) throws TException{
		User user = null;
		if(name.equals("penngo") && psw.equals("123")){
			user = new User();
			user.setId(1);
			user.setName("penngo");
		}
		return user;
	}
}

实现RegisterServiceImpl.java注册接口业务

import org.apache.thrift.TException;
public class RegisterServiceImpl implements RegisterService.Iface{
	public RegisterServiceImpl(){
	}
	public User createUser(String name, String psw) throws TException{
		User user = new User();
		user.setId(2);
		user.setName(name);
		user.setPassword(psw);
		return user;
	}
}

服务器端java代码

package com.penngo.main;

import org.apache.thrift.TMultiplexedProcessor;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TTransportException;
import com.penngo.LoginService;
import com.penngo.LoginServiceImpl;
import com.penngo.RegisterService;
import com.penngo.RegisterServiceImpl;

public class Server {
	private void start() {
		try {
			TServerSocket serverTransport = new TServerSocket(7911);
			// 用户登录
			LoginService.Processor loginProcessor = new LoginService.Processor(
					new LoginServiceImpl());
			// 用户注册
			RegisterService.Processor registerProcessor = new RegisterService.Processor(
					new RegisterServiceImpl());
			// Factory protFactory = new TBinaryProtocol.Factory(true, true);
			// TServer server = new TThreadPoolServer(new
			// TThreadPoolServer.Args(serverTransport)
			// .processor(loginProcessor));
			TMultiplexedProcessor processor = new TMultiplexedProcessor();
			processor.registerProcessor("LoginService", loginProcessor);
			processor.registerProcessor("RegisterService", registerProcessor);
			TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(
					serverTransport).processor(processor));
			System.out.println("Starting server on port 7911 ...");
			server.serve();
		} catch (TTransportException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void main(String args[]) {
		Server srv = new Server();
		srv.start();
	}
}

客户端java

package com.penngo.main;

import org.apache.thrift.*;
import org.apache.thrift.protocol.*;
import org.apache.thrift.transport.*;
import com.penngo.LoginService;
import com.penngo.RegisterService;
import com.penngo.User;

public class Client {
	public static void main(String[] args) {
		try {
			TTransport transport = new TSocket("localhost", 7911);
			TProtocol protocol = new TBinaryProtocol(transport);
			TMultiplexedProtocol mp1 = new TMultiplexedProtocol(protocol,
					"LoginService");
			// TProtocol protocol = new TBinaryProtocol(transport);
			// LoginService.Client client = new LoginService.Client(protocol);
			LoginService.Client loginClient = new LoginService.Client(mp1);
			TMultiplexedProtocol mp2 = new TMultiplexedProtocol(protocol,
					"RegisterService");
			RegisterService.Client registerClient = new RegisterService.Client(
					mp2);
			transport.open();

			User user = loginClient.login("penngo", "123");
			if (user != null) {
				System.out.println("登录成功:" + user.getId() + " "
						+ user.getName());
			} else {
				System.out.println("登录失败");
			}
			User user2 = registerClient.createUser("test", "123");
			if (user2 != null) {
				System.out.println("创建用户成功:" + user2.getId() + " "
						+ user2.getName());
			} else {
				System.out.println("创建用户失败");
			}
			transport.close();
		} catch (TException x) {
			x.printStackTrace();
		}
	}
}

客户端php

<?php
namespace com\penngo;

require_once __DIR__.'/../../lib/Thrift/ClassLoader/ThriftClassLoader.php';
//echo __DIR__.'/../../lib/Thrift/ClassLoader/ThriftClassLoader.php';
use Thrift\ClassLoader\ThriftClassLoader;

$GEN_DIR = realpath(dirname(__FILE__)).'/../../gen-php';

$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', __DIR__ . '/../../lib');
//$loader->registerDefinition('shared', $GEN_DIR);
$loader->registerDefinition('com', $GEN_DIR);
$loader->register();

if (php_sapi_name() == 'cli') {
    ini_set("display_errors", "stderr");
}

use Thrift\Protocol\TBinaryProtocol;
use Thrift\Protocol\TMultiplexedProtocol;
use Thrift\Transport\TSocket;
use Thrift\Transport\THttpClient;
use Thrift\Transport\TBufferedTransport;
use Thrift\Exception\TException;
use com\penngo\RegisterServiceClient;
use com\penngo\LoginServiceClient;

try {
    if (array_search('--http', $argv)) {
        //$socket = new THttpClient('localhost', 8080, '/php/PhpServer.php');
    } else {
        $socket = new TSocket('localhost', 7911);
    }
    $transport = new TBufferedTransport($socket, 1024, 1024);
    $protocol = new TBinaryProtocol($transport);
    $loginProtocol = new TMultiplexedProtocol($protocol, "LoginService");
    $registerProtocol = new TMultiplexedProtocol($protocol, "RegisterService");
    $loginClient = new LoginServiceClient($loginProtocol);
    $registerClient = new RegisterServiceClient($registerProtocol);
    $transport->open();
    $user = $loginClient->login('penngo', '123');
    print "user===={$user->id} {$user->name} \n";
    
    $user = $registerClient->createUser('test', '123456');
    print "user===={$user->id} {$user->name} \n";
    $transport->close();
} catch (TException $tx) {
    print 'TException: '.$tx->getMessage()."\n";
    print 'TException: '.$tx->getTraceAsString()."\n";
}

?>


© 著作权归作者所有

penngo

penngo

粉丝 80
博文 110
码字总数 64730
作品 2
广州
高级程序员
私信 提问
加载中

评论(4)

erpadmin
erpadmin

引用来自“dev_admin”的评论

你在哪里搞成功了,正式运营了没?

引用来自“penngo”的评论

已经上线运营了。
求详细的东西,运营的多成功呀??是不是很赚钱,可以看看么?
penngo
penngo

引用来自“dev_admin”的评论

你在哪里搞成功了,正式运营了没?
已经上线运营了。
erpadmin
erpadmin
你在哪里搞成功了,正式运营了没?
erpadmin
erpadmin
还没有搞的很懂,想和你讨论一下
thrift php服务器端开发

在前文(Thrift的java和php数据交互http://my.oschina.net/penngo/blog/489311)中只介绍了java作服务器端,但是“php是最好的语言”,自然少了php开发的thrift服务器端。 使用的业务例子,还是...

penngo
2015/08/25
0
12
Apache Thrift介绍

Thrift是为了解决facebook系统中各系统之间大数据量的传输通讯以及系统之间语言环境不同需要跨平台这一特性而创造的。所以thrift可以支持多种程序语言,例如: C++, C#, Cocoa, Erlang, Haske...

吕坤
2013/02/19
0
0
Thrift 学习笔记1——Ubuntu环境下Thrift的安装、编译以及测试

1、Thrift 概念 Thrift是一个软件框架,用来进行可扩展且跨语言的服务的开发。它结合了功能强大的软件堆栈和代码生成引擎,以构建在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell,...

天外飞鱼
2013/06/08
0
0
Protobuf Thrift数据描述语言调研

编者注 由于json是字符进行传送,尤其是传送float参数,会直接导致数据传输量暴增。则需要使用二进制化的跨语言传输方法。编者找到Google Protocol Buffers,Apache Thrift,Apache avro。 ...

抢小孩糖吃
2018/01/20
0
0
spring与thrift集成

spring与thrift集成,可以使服务调用和发布更方便。 本文代码是在上篇基础上改进,部分代码介绍请参考上一篇Thrift的java和php数据交互(http://my.oschina.net/penngo/blog/489311) 服务器...

penngo
2015/08/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

REST接口

文章来源 https://zhuanlan.zhihu.com/p/28674721?group_id=886181549958119424 http://www.ruanyifeng.com/blog/2014/05/restful_api.html REST 对请求的约定 REST 用来规范应用如何在 HTTP......

Airship
昨天
1
0
Spring Cloud Config 统一配置中心

Spring Cloud Config 统一配置中心 一、统一配置中心 统一管理配置 通常,我们会使用配置文件来管理应用的配置。如一个 Spring Boot 的应用,可以将配置信息放在 application.yml 文件中,如...

非摩尔根
昨天
1
0
android ------ AAPT2 error: check logs for details解决方法

AAPT 是全称是 Android Asset Packaging Tool,它是构建 App,甚至是构建 Android 系统都必不可少的一个工具。它的作用是将所有资源文件压缩打包到Android APK 当中。我们在 Android SDK 目录...

切切歆语
昨天
2
0
今天的学习

今天学到了<select></select>标签: <label for="unittype">Select unit type: </label><select id="unittype" name="unittype" autofocus > <option value="1"> Miner </option> ......

墨冥
昨天
2
0
程序员随想-关于分享

最早的时候,文字是贵族这些上层人士才会学习的,底层人士没有资格和渠道去学习,同样用文字、图像等其他载体承载的知识大部分也只有贵族阶层才能享受的。后来有了造纸术、印刷术,成本降低,...

Lubby
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部