一、Thrift Java服务端和客户端
-
官方网站下载thrift-0.9.1.exe，用于生成代码
-
编写hello.thrift，数据结构描述文件
|
1
2
3
4
5
|
namespace java com.testservice HelloWorldService { string sayHello(1:string username)
} |
-
生成java代码：thrift-0.9.1.exe -r -gen java hello.thrift
-
将当前目录gen-java文件夹下生产代码copy到Eclipse源码目录
-
服务端实现类HelloWorldImpl，服务器启动类HelloWorldServer，客户端类HelloWorldClient
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
package com.abc;
import org.apache.thrift.TException;
public class HelloWorldImpl implements HelloWorldService.Iface {
public HelloWorldImpl() {
}
@Override
public String sayHello(String username) throws TException {
return "hello, " + username;
}
} |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
package com.abc;
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;
public class HelloServer {
public static final int SERVER_PORT = 8090;
public void startServer() {
try {
System.out.println("HelloWorld TSimpleServer start ....");
TProcessor tprocessor = new HelloWorldService.Processor<HelloWorldService.Iface>(new HelloWorldImpl());
TServerSocket serverTransport = new TServerSocket(SERVER_PORT);
TServer.Args tArgs = new TServer.Args(serverTransport);
tArgs.processor(tprocessor);
tArgs.protocolFactory(new TBinaryProtocol.Factory());
TServer server = new TSimpleServer(tArgs);
server.serve();
} catch (Exception e) {
System.out.println("Server start error!!!");
e.printStackTrace();
}
}
public static void main(String[] args) {
HelloServer server = new HelloServer();
server.startServer();
}
} |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
package com.abc;
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 HelloClient {
public static final String SERVER_IP = "localhost";
public static final int SERVER_PORT = 8090;
public static final int TIMEOUT = 30000;
public void startClient(String userName) {
TTransport transport = null;
try {
transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT);
// 协议要和服务端一致
TProtocol protocol = new TBinaryProtocol(transport);
// TProtocol protocol = new TCompactProtocol(transport);
// TProtocol protocol = new TJSONProtocol(transport);
HelloWorldService.Client client = new HelloWorldService.Client(protocol);
transport.open();
String result = client.sayHello(userName);
System.out.println("Thrify client result =: " + result);
} catch (TTransportException e) {
e.printStackTrace();
} catch (TException e) {
e.printStackTrace();
} finally {
if (null != transport) {
transport.close();
}
}
}
public static void main(String[] args) {
HelloClient client = new HelloClient();
client.startClient("Michael");
}
} |
二、python客户端调用刚才创建Java Server示例
-
创建python客户端依赖文件：thrift-0.9.1.exe -r -gen py hello.thrift
-
编写客户端文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
#!/usr/bin/env pythonimport sys
sys.path.append('./gen-py')
from hello import HelloWorldService
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
try:
transport = TSocket.TSocket('localhost', 9090)
transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = HelloWorldService.Client(protocol)
transport.open()
msg = client.sayHello("jack")
print "server reponse: " + msg
except Thrift.TException, ex:
print "%s" % (ex.message)
finally:
transport.close()
|
-
调用：python client.py
-
如果在调用过程出现no module named thrift.thrift错误，需要解压缩thrift源码包，进入lib/python（或lib/py）目录下运行python setup.py install
相关推荐
Thrift通过定义一种中间描述语言（IDL）来允许开发者定义服务接口，然后自动生成对应各种编程语言的客户端和服务端代码，简化了服务之间的通信。 在Thrift 0.9.1这个版本中，可能存在一些编译问题，这可能会影响...
Thrift允许开发者定义服务，然后自动生成相应的代码，使得这些服务可以在多种编程语言之间无缝通信，包括Java、Python、C++、PHP、Ruby、 Erlang、Perl、Haskell、C#、JavaScript、Go、Dart、Rust等。 在本例中，...
然后，通过运行`thrift-0.9.x.exe`，我们可以指定`.thrift`文件和目标语言，如Java、Python、C++等，生成相应的服务端和客户端代码。例如，在命令行中，我们可能会输入： ```bash thrift-0.9.x.exe --gen java my_...
升级版本时，需要确保服务端和客户端使用相同的Thrift版本，以避免可能的兼容性问题。 在实际应用中，Thrift广泛应用于分布式系统，如大数据处理、微服务架构等场景，它的高性能和多语言支持使得跨平台通信变得简单...
3. **示例**：通常，源码包中会包含一些示例代码，这些示例展示了如何使用Thrift来创建服务和客户端，这对于初学者来说是非常有用的资源。 4. **文档**：虽然描述中没有特别提到，但大多数开源项目都会包含一份文档...
使用这个工具，开发者可以编写Thrift IDL文件，然后通过Thrift编译器（通常是`thrift`命令行工具）将这些IDL转换成Java代码，这些代码包括了客户端和服务端的接口和数据结构，使得开发者可以在Java环境中轻松实现...
Thrift的核心理念是通过定义数据结构和服务接口的IDL（Interface Description Language）文件，自动生成不同编程语言的客户端和服务端代码，使得不同语言的应用之间能够高效、便捷地进行通信。 标题中的"thrift.zip...
使用Thrift编译器，你可以为指定的目标语言（如Java、Python、C++等）生成服务端和客户端的代码。这些生成的代码会包含服务接口、服务处理类以及客户端代理类。 3. **服务端实现**： 在服务端，你需要为每个服务...
Thrift 允许开发者通过接口定义语言（IDL）来定义服务，然后自动生成相应的客户端和服务端代码，支持多种编程语言，包括 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, ...
这样，开发者就可以在各自的编程环境中使用这些自动生成的代码来实现服务端和客户端。 4. **网络传输**： - Thrift使用TProtocol进行数据序列化和反序列化，支持多种传输协议，如TCP、HTTP、SSL等，使得跨语言、跨...