Tatala RPC中间件 项目简介
这个项目最早(2008年)是用于一个网络游戏的Cache Server,以及一个电子商务的Web Session服务。后来不断增加新的功能,除了Java还支持C#,到现在已经可以用它来开发网络游戏的服务器。等过些日子我还会开源网络游戏的服务器源码。 关于性能,当时后台相应请求的效率是每秒10W次,现在我在自己的笔记本上测,只有一个客户端与服务器都在一个物理机上(CPU: i7-3610QM; RAM: 8G; OS: Win7-64),每秒相应12000个请求。 tatala-client-csharp已经上传,同样在笔记本上测试,一个c#客户端一个Java服务端都在一台机器上,每秒响应22000个请求。c#客户端除了性能测试的例子还有一个演示Server推送的聊天室例子。Tatala最大的特点是简单,性能是第二考虑能够满足大部分应用就行。因为性能可以通过增加机器得到提升,而代码简单意味着雇更少的人更快的开发。老板省钱,程序员轻松才是最重要的。 下面是简单介绍。 概述 Tatala是一个简单易用的RPC中间件,并且跨语言跨平台。它将调用方法转变成字节数组(包括被调用类名,目标方法名,参数序列和返回值),在socket基础上实现客户端和服务器之间的互相通信。 目前,Tatala支持Java的客户端与服务器端,和C#的客户端。 特性 * 简单易用可以快速开发和建立网络组件* 跨语言跨平台* 高性能和分布式* 传输协议为短小精悍的二进制* 支持socket长连接* 客户端与服务器端多线程处理* 支持异步请求* 对于大数据支持压缩传输* 支持服务器端主动推送消息* 客户端程序可以捕获服务端抛出的异常,使客户端支持事务回滚* 支持Google Protocol Buffers作为对象序列化进行网络传输* 支持在服务端注册多个filter,在调用业务代码之前预处理传入的数据,注入业务逻辑,如权限检查等* 能够用于跨语言的远程方法调用RPC,高性能的缓存服务器,分布式的消息服务,多人在线游戏服务器,等等快速开始 下载tatala.jar 包含在你项目的classpath中。简单编程是Tatala第一考虑因素,所以用它建立RPC的方式,让开发者感觉就像调用本地普通方法一样简单。不用考虑网络,线程这些东西。现在举一个例子,假如我们有个服务器端的服务ExampleManager接口 和 ExampleManagerImpl实现类。ExampleManager.javapublic interface ExampleManager{
public String sayHello(int Id, String name);
}ExampleManagerImpl.javapublic class ExampleManagerImpl implements ExampleManager{
public String sayHello(int Id, String name) {
return "["+Id+"]"+"Hello "+name+" !";
}
}我们还需要在服务端建立一个socket服务类来部署我们的业务逻辑,在这个例子中socket服务监听端口是10001。 ExampleServer.javapublic class ExampleServer {
public static void main(String args[]) {
int listenPort = 10001;
int poolSize = 10;
AioSocketServer server = new AioSocketServer(listenPort, poolSize);
erver.start();
}
}然后客户端的代码类似这样:EasyClient.javapublic class EasyClient {
private static TransferObjectFactory transferObjectFactory;
private static ExampleManager manager;
public static void main(String[] args) {
transferObjectFactory = new TransferObjectFactory("127.0.0.1", 10001, 5000);
transferObjectFactory.setImplClass("ExampleManagerImpl");
manager = (ExampleManager)ClientProxyFactory.create(ExampleManager.class, transferObjectFactory);
String result = manager.sayHello(18, "JimT");
System.out.println("result: "+result);
}
}创建一个TransferObjectFactory对象,设置server端的IP地址,端口号和超时时间。设置被调用的实现类的类名,建立proxy,调用方法。当然我们需要把接口类(ExampleManager.class) 加入到客户端的classpath里。这就是建立一个Tatala RPC的所有代码,不需要任何配置文件,是不是很简单?更多例子请看教程。 Tatala-中文教程 传输协议 在客户端把调用的方法信息设置到transfer object里, Tatala把transfer object转换成字节数组并且发送给服务器。在服务器端把接收到的字节数组再还原成包含调用信息的transfer object。包括被调用类名,目标方法名,参数信息和返回类型等。Tatala 执行器获得调用信息执行目标方法。 支持类型 Tatala支持的参数和返回类型: bool,byte,short,chat,int,long,float,double,Date,String, byte[],int[],long[],float[],double[],String[],Serializable,Protobuf, WrapperClass 其它描述 需要JDK1.7,因为使用了Java AIO。 第三方类库包括Protobuf,Log4j。 License Apache License Version 2.0
public String sayHello(int Id, String name);
}ExampleManagerImpl.javapublic class ExampleManagerImpl implements ExampleManager{
public String sayHello(int Id, String name) {
return "["+Id+"]"+"Hello "+name+" !";
}
}我们还需要在服务端建立一个socket服务类来部署我们的业务逻辑,在这个例子中socket服务监听端口是10001。 ExampleServer.javapublic class ExampleServer {
public static void main(String args[]) {
int listenPort = 10001;
int poolSize = 10;
AioSocketServer server = new AioSocketServer(listenPort, poolSize);
erver.start();
}
}然后客户端的代码类似这样:EasyClient.javapublic class EasyClient {
private static TransferObjectFactory transferObjectFactory;
private static ExampleManager manager;
public static void main(String[] args) {
transferObjectFactory = new TransferObjectFactory("127.0.0.1", 10001, 5000);
transferObjectFactory.setImplClass("ExampleManagerImpl");
manager = (ExampleManager)ClientProxyFactory.create(ExampleManager.class, transferObjectFactory);
String result = manager.sayHello(18, "JimT");
System.out.println("result: "+result);
}
}创建一个TransferObjectFactory对象,设置server端的IP地址,端口号和超时时间。设置被调用的实现类的类名,建立proxy,调用方法。当然我们需要把接口类(ExampleManager.class) 加入到客户端的classpath里。这就是建立一个Tatala RPC的所有代码,不需要任何配置文件,是不是很简单?更多例子请看教程。 Tatala-中文教程 传输协议 在客户端把调用的方法信息设置到transfer object里, Tatala把transfer object转换成字节数组并且发送给服务器。在服务器端把接收到的字节数组再还原成包含调用信息的transfer object。包括被调用类名,目标方法名,参数信息和返回类型等。Tatala 执行器获得调用信息执行目标方法。 支持类型 Tatala支持的参数和返回类型: bool,byte,short,chat,int,long,float,double,Date,String, byte[],int[],long[],float[],double[],String[],Serializable,Protobuf, WrapperClass 其它描述 需要JDK1.7,因为使用了Java AIO。 第三方类库包括Protobuf,Log4j。 License Apache License Version 2.0