前几天偶尔在网上看到thrift的信息,其内容和做用极大的引发了个人兴趣,由于我也是作iOS开发的,经过在网上的查询发现信息虽然不少实用的不多,容易误导他人,通过本身的成功实践,作了笔录,为了方便朋友了解和阅读,就也啰里啰嗦的整理一下繁琐的东西,但愿对个人朋友和他人能有所帮助。php
我是在Mac上经过终端先安装brew,再在终端输入brew命令行来安装thrift的,固然还有其余的方式,你们能够去网上了解一下,而我用brew是对其偏心,是由于brew做为Mac OSX上的软件包管理工具,能在Mac中方便的安装软件或者卸载软件, 只须要一个命令, 而不用麻烦的终端命令,很是方便,另外brew 又叫Homebrew。具体安装步骤很是简单以下:html
1,打开终端,输入ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)"。固然也能够直接复制这个命令行粘贴到终端,按回车键java
2,而后一会会跳出这个语句:Press RETURN to continue or any other key to abort,其意思就是按回车键继续,或者其余键跳出,固然咱们按回车键,而后就开始安装了。node
3,注意,有时候过程可能稍慢,请耐心等候,其以上过程可能须要输入你的本机帐号密码,直接输入而后按回车键便可,python
第一次我还不肯定是否真的安装成功,就有操做一次结果提醒我已经安装过,再次安装会覆盖之前的,因此你们不用担忧再次输入操做,如图:jquery
/usr/local/bin不在PATH中
找到解决方式。其实解决这个问题真的很简单。以下:
sudo vim .bash_profile
添加:
保存,source .bash_profile使配置修改生效。
从新启动终端 再次使用brew 命令就ok了。
使用brew安装软件,经过在终端一行命令便可(brew的命令都是在终端输入的),如:sudo brew install git,就会安装git,咱们也能够sudo brew update更新brew,经常使用命令列示以下:ios
1,sudo brew uninstall wget 卸载软件wgetgit
2, sudo brew search /wge*/ 查询软件wgetgithub
3, sudo brew list 列出已安装的软件apache
4, sudo brew home 用浏览器打开brew的官方网站
5, sudo brew info 显示软件信息
6, sudo brew deps 显示包依赖
好比:输入3,和4
固然经过以上就知道如何安装thrift了,只须要在终端输入brew命令行sudo brew install thrift,过程如图:
注意过程很慢,可从图最下3.9%,最后安装成功可从下图比较:
一直到出现你的本机名的时候才算成功
不过我在安装输入sudo brew install thrift 的时候提示:Running Homebrew as root is extremely dangerous and no longer supported
参考:mac下面经过brew安装东西的时候报Error: Running Homebrew as root is extremely dangerous and no longer supported的解决
其实就是把 sudo 去掉, 直接输入 brew install thrift
安装成功你们就可使用thrift了,若是不了解thrift的朋友能够在网上查查,这里也作一些了解:
thrift最初由Facebook研发,主要用于各个服务之间的RPC通讯,支持跨语言,经常使用的语言ActionScript3,glibc,cocoa(开发ios用的),C++,C#,delphi,erlang,go,haskell,html,java,javame(山寨机开发),jquery,node.js,Ocaml,perl,php,python,ruby,smalltalk,xsd,简单的说,就是可让人快速的写Socket Server(服务器)和Client(客户端)。其实不用thrift开发socket也不难,那么为何要用thrift开发呢?主要有两个缘由,一个是由于thrift自己帮你封装了不少基本的东西,你不须要本身去写socket里面的bind,accept之类的,以及他们的逻辑。能够很快速的开发基于进程的,线程的,SSL的socket。第二个理由是标准化,跨语言和跨平台,windows不算在其中。主要是在各类Posix兼容的操做系统中均可以不须要改造基本直接可用,支持的语言种类也不少,基本你会写的,他都支持。你不会写的,他也支持。相似的项目还有ICE和Avro,可是感受都没有thrift作的易用性好。并且这是facebook开源的诸多项目中,为数很少的能正常编译的软件,
使用thrift须要先定义接口文件,在thrift里简称叫IDL,全称叫Interface Description Language,接口描述语言。接口描述语言里面须要定义接口中所使用的数据类型,方法等等
数据类型包括:
基本类型:
bool: 布尔类型(true或者false)
byte: 有符号8位整型
i16: 有符号16位整型
i32: 有符号32位整型
i64: 有符号64位整型
double: 64位浮点数
string: UTF8编码的字符串
特殊类型:
binary: 未编码的二进制字节流
struct:结构体类型
container:
list:列表,能够理解为数组,其中的元素能够是任意类型的。
exceptions:
用来抛出你本身定义的异常状况
service:
这个是最重要的定义,有些地方说是虚函数,可是理解成你程序中所使用的方法更容易明白一些。他须要你定义返回类型,这有点相似于C或者java的函数定义。但你要明白,这个返回是给socket的。若是你定义错了,将不只仅是你得不到返回值这么简单的事情。而是程序会报错
如今,再按照上面的步骤进行下去,就能够正确安装thrift了.
1,建立一个服务Hello,建立文件Hello.thrift,代码以下:
namespace java service.demo service Hello{ string helloString(1:string para) }
这里定义了一个名为helloString的方法,入参和返回值都是一个string类型的参数.
2,终端进入Hello.thrift所在目录,执行命令:
thrift -r -gen java Hello.thrift
发如今当前目录下多了一个gen-java的目录,里面的有一个Hello.java的文件.这个java文件包含Hello服务的接口定义Hello.Iface,以及服务调用的底层通讯细节,包括客户端的调用逻辑Hello.Client以及服务端的处理逻辑Hello.Processor,
3,建立一个Maven管理的Java项目,pom.xml中添加相关的依赖,并将Hello.java文件复制到项目中:
<dependency> <groupId>org.apache.thrift</groupId> <artifactId>libthrift</artifactId> <version>0.10.0</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.5</version> </dependency>
此处须要注意,若是你的pom.xml中原来就有的话,难么,你须要先新建标签dependencies;
好比个人:
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>thrift_test</groupId> <artifactId>thrift_test</artifactId> <version>1.0-SNAPSHOT</version> <dependencies> <dependency> <groupId>org.apache.thrift</groupId> <artifactId>libthrift</artifactId> <version>0.10.0</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.5</version> </dependency> </dependencies> </project>
注意到了吗,新建了<dependencies>标签;
4,建立HelloServiceImpl实现Hello.Iface接口:
package service.demo; import org.apache.thrift.TException; /** * @author yogo.wang * @date 2017/02/21-下午2:13. */ public class HelloServiceImpl implements Hello.Iface { public String helloString(String para) throws TException { return "result:"+para; } }
5,建立服务端实现代码HelloServiceServer,把HelloServiceImpl做为一个具体的处理器传递给Thrift服务器:
package service.demo; import org.apache.thrift.TProcessor; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.server.TServer; import org.apache.thrift.server.TSimpleServer; import org.apache.thrift.transport.TServerSocket; import org.apache.thrift.transport.TTransportException; /** * @author yogo.wang * @date 2017/02/21-下午2:15. */ public class HelloServiceServer { /** * 启动thrift服务器 * @param args */ public static void main(String[] args) { try { System.out.println("服务端开启...."); TProcessor tprocessor = new Hello.Processor<Hello.Iface>(new HelloServiceImpl()); // 简单的单线程服务模型 TServerSocket serverTransport = new TServerSocket(9898); TServer.Args tArgs = new TServer.Args(serverTransport); tArgs.processor(tprocessor); tArgs.protocolFactory(new TBinaryProtocol.Factory()); TServer server = new TSimpleServer(tArgs); server.serve(); }catch (TTransportException e) { e.printStackTrace(); } } }
6,建立客户端实现代码HelloServiceClient,调用Hello.client访问服务端的逻辑实现:
package service.demo; 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; /** * @author yogo.wang * @date 2017/02/21-下午2:35. */ public class HelloServiceClient { public static void main(String[] args) { System.out.println("客户端启动...."); TTransport transport = null; try { transport = new TSocket("localhost", 9898, 30000); // 协议要和服务端一致 TProtocol protocol = new TBinaryProtocol(transport); Hello.Client client = new Hello.Client(protocol); transport.open(); String result = client.helloString("哈哈"); System.out.println(result); } catch (TTransportException e) { e.printStackTrace(); } catch (TException e) { e.printStackTrace(); } finally { if (null != transport) { transport.close(); } } } }
所有工做完成后,下面来测试一下,先执行服务端main方法,在执行客户端main方法,会在客户端控制台打印出:result:哈哈.
这里注意几点:
(1)先执行服务端的main方法,而后执行客户端的main方法;
(2)当把Hello.java文件放到项目中的时候,个人老是报错,说thrift生成的Hello.java文件 中的override 不能重写,我直接把关键字override注销了;错误消失;
在terminal 中执行 mvn clean; 成功
执行mvn clean install 成功
执行 mvn clean install -Dmaven.test.skip=true 成功;
例子下载地址:thrift 架构的Java的小例子 demo