Thrift在0.9.1版本之前，一直只提交了對(duì)單一接口服務(wù)的支持，即一個(gè)RPC服務(wù)器（對(duì)應(yīng)一個(gè)端口）支持一個(gè)服務(wù)接口的實(shí)現(xiàn)。
但是很多時(shí)候，我們的服務(wù)不能實(shí)現(xiàn)在一個(gè)接口里，一是接口里的方法越來越多，不好管理和使用；二是根據(jù)職責(zé)的單一要求，不能類型的方法，不能放在同一接口里。
在 Thrift-0.9.1之前，我們要解決上面的問題，一是通過多個(gè)RPC服務(wù)器來實(shí)現(xiàn)，這個(gè)方法必然導(dǎo)致了我們RPC服務(wù)器越來越多，管理上麻煩；二是通過其他的一些途徑，如使用netty作為RPC服務(wù)器等，這個(gè)方法實(shí)現(xiàn)上相對(duì)麻煩一些，需要去了解netty的知識(shí)。
這些方法在這里就不再詳述了。
從Thrift-0.9.1開始，thrift開始提供對(duì)多接口服務(wù)的支持，使得我們開發(fā)多接口RPC服務(wù)相對(duì)簡(jiǎn)單多了。
這里還是給出例子來說明。
首先，我們做了兩個(gè)接口定義文件來定義兩個(gè)接口：
namespace javacom.eli.test.service
struct Topic
{
1: i32 uid,
2: string name,
3: string content
}
service TopicService
{
void store(1: Topic topic),
Topic retrieve(1: i32 uid)
}
namespace javacom.eli.test.service
struct User
{
1: i32 uid,
2: string name,
3: string blurb
}
service UserService
{
void store1(1: User user),
User retrieve1(1: i32 uid)
}
然后使用Thrift-0.9.1.exe生成相應(yīng)的JavaBean及接口：
然后，我們寫兩個(gè)接口的實(shí)現(xiàn)類：
import org.apache.thrift.TException;
import com.eli.test.service.Topic;
import com.eli.test.service.TopicService;
public class TopicImpl implements TopicService.Iface{
public void store(Topic topic)throws TException
{
System.out.println("theinput topic: ");
System.out.println("id:"+topic.getUid());
System.out.println("name:"+topic.getName());
System.out.println("content:"+topic.getContent());
}
public Topic retrieve(int uid)throws TException
{
System.out.println("theinput uid: "+uid);
return newTopic(uid,"test","test");
}
}
import org.apache.thrift.TException;
import com.eli.test.service.User;
import com.eli.test.service.UserService;
public class UserImpl implements UserService.Iface{
public void store1(User user)throws TException
{
System.out.println("theinput user: ");
System.out.println("uid:"+user.getUid());
System.out.println("name:"+user.getName());
System.out.println("blur:"+user.getBlurb());
}
public User retrieve1(int uid)throws TException
{
System.out.println("theinput uid: "+uid);
return newUser(uid,"tom","123");
}
}
上述工作完成以后，就可以寫服務(wù)器代碼了。
服務(wù)器代碼與單一接口的服務(wù)器代碼最大的不同是使用了“TMultiplexedProcessor”類，通過該類，可以注冊(cè)多個(gè)接口的服務(wù)實(shí)現(xiàn)類：
TMultiplexedProcessor processor = new TMultiplexedProcessor();
processor.registerProcessor("TopicService", newTopicService.Processor<TopicService.Iface>(newTopicImpl()));
processor.registerProcessor("UserService", new UserService.Processor<UserService.Iface>(new UserImpl()));
其他代碼就跟以前的服務(wù)器代碼一樣了。
完整的服務(wù)器代碼如下：
TMultiplexedProcessor processor = newTMultiplexedProcessor();
TServerTransport t = new TServerSocket(9090);
TServer server = new TThreadPoolServer(newTThreadPoolServer.Args(t).processor(processor));
processor.registerProcessor("TopicService", newTopicService.Processor<TopicService.Iface>(newTopicImpl()));
processor.registerProcessor("UserService", newUserService.Processor<UserService.Iface>(newUserImpl()));
// TSimpleServer server = new TSimpleServer(new Args(t).processor(processor));
System.out.println("the serveris started and is listening at 9090...");
server.serve();
最后是客戶端代碼了，客戶端代碼的不同之處是引入了“TMultiplexedProtocol”類，它來幫助客戶端區(qū)別調(diào)用哪個(gè)接口：
TMultiplexedProtocol mp1 = new TMultiplexedProtocol(protocol,"TopicService");
TopicService.Clientservice1 = new TopicService.Client(mp1);
完整的客戶端測(cè)試代碼如下：
TSocket transport = new TSocket("localhost",9090);
TBinaryProtocol protocol = new TBinaryProtocol(transport);
TMultiplexedProtocolmp1 = new TMultiplexedProtocol(protocol,"TopicService");
TopicService.Client service1 = newTopicService.Client(mp1);
TMultiplexedProtocolmp2 = new TMultiplexedProtocol(protocol,"UserService");
UserService.Client service2 = newUserService.Client(mp2);
transport.open();
service1.store(new Topic(668,"test topic","just a test!"));
service2.store1(new User(888,"tom","haha"));
System.out.println(service1.retrieve(168));
System.out.println(service2.retrieve1(999));
transport.close();
運(yùn)行服務(wù)器代碼和客戶端代碼，則客戶端會(huì)打印如下結(jié)果：
Topic(uid:168, name:test, content:test)
User(uid:999, name:tom, blurb:123)
服務(wù)器端會(huì)打印如下的信息：
the server is started and is listening at 9090...
the input topic:
id: 668
name: test topic
content: just a test!
the input user:
uid: 888
name: tom
blur: haha
the input uid: 168
the input uid: 999
通過上面的例子，可以看到，Thrift-0.9.1版本很簡(jiǎn)單的解決了多接口服務(wù)的問題，隨便說一下，該版本并沒有解決所有語言的多接口實(shí)現(xiàn)問題，只是解決了Java和其他幾個(gè)語言。請(qǐng)大家在使用的時(shí)候，查清楚您使用的語言是否解決了這個(gè)問題。