Tatala 中文教程
概述
Tatala是一个简单易用的RPC中间件,并且跨语言跨平台。它将调用方法转变成字节数组(包括被调用类名,目标方法名,参数序列和返回值),在socket基础上实现客户端和服务器之间的互相通信。
目前,Tatala支持Java的客户端与服务器端,和C#的客户端。
特性
- 简单易用可以快速开发和建立网络组件
- 跨语言跨平台
- 高性能和分布式
- 传输协议为短小精悍的二进制
- 支持socket长连接
- 客户端与服务器端多线程处理
- 支持异步请求
- 对于大数据支持压缩传输
- 支持服务器端主动推送消息
- 客户端程序可以捕获服务端抛出的异常,使客户端支持事务回滚
- 支持Google Protocol Buffers作为对象序列化进行网络传输
- 支持在服务端注册多个filter,在调用业务代码之前预处理传入的数据,注入业务逻辑,如权限检查等
- 能够用于跨语言的远程方法调用RPC,高性能的缓存服务器,分布式的消息服务,多人在线游戏服务器,等等
快速开始
下载tatala.jar 包含在你项目的classpath中。
简单编程是Tatala第一考虑因素,所以用它建立RPC的方式,让开发者感觉就像调用本地普通方法一样简单。不用考虑网络,线程这些东西。
现在举一个例子,假如我们有个服务器端的服务ExampleManager接口 和 ExampleManagerImpl实现类。
ExampleManager.java
public interface ExampleManager{
public String sayHello(int Id, String name);
}
ExampleManagerImpl.java
public class ExampleManagerImpl implements ExampleManager{
public String sayHello(int Id, String name) {
return "["+Id+"]"+"Hello "+name+" !";
}
}
我们还需要在服务端建立一个socket服务类来部署我们的业务逻辑,在这个例子中socket服务监听端口是10001。 ExampleServer.java
public class ExampleServer {
public static void main(String args[]) {
int listenPort = 10001;
int poolSize = 10;
AioSocketServer server = new AioSocketServer(listenPort, poolSize);
server.start();
}
}
然后客户端的代码类似这样:
EasyClient.java
public 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 RPC,大致需要三个步骤:
-
建立服务端业务逻辑和socket服务类
-
建立Tatala代理类, 它是介于客户与服务器端之间的中介类。
-
客户端代码
建立服务器端业务逻辑,包括接口(非必须)和实现类。
public interface ExampleManager {
public String sayHello(int Id, String name);
}
public class ExampleManagerImpl implements ExampleManager{
public String sayHello(int Id, String name) {
return "["+Id+"]"+"Hello "+name+" !";
}
}
建立socket 服务类,用于部署业务逻辑。
public class ExampleServer {
public static void main(String args[]) {
int listenPort = 10001;
int poolSize = 10;
AioSocketServer server = new AioSocketServer(listenPort, poolSize);
server.start();
}
}
建立客户端Proxy。
public class ExampleClientProxy {
public String sayHello(int Id, String name) {
TransferObjectFactory transferObjectFactory = new TransferObjectFactory("127.0.0.1", 10001, 5000);
TransferObject to = transferObjectFactory.createTransferObject();
to.setCalleeClass("com.qileyuan.tatala.example.proxy.ExampleServerProxy");
to.setCalleeMethod("sayHello");
to.registerReturnType(TransferObject.DATATYPE_STRING);
to.putInt(Id);
to.putString(name);
Object resultObj = ServerExecutor.execute(to);
String result = (String) resultObj;
return result;
}
}
创建一个TransferObjectFactory对象,设置server端的IP地址,端口号和超时时间。由TransferObjectFactory创建一个transfer object,设置被调用的类名(这里是server proxy),目标方法和返回类型。向transfer object顺序放入参数值。最后调用ServerExecutor。
建立服务器端Proxy。
public class ExampleServerProxy {
private ExampleManager manager = new ExampleManagerImpl();
public String sayHello(TransferObject to) {
int Id = to.getInt();
String name = to.getString();
String result = manager.sayHello(Id, name);
return result;
}
}
在服务器端建立接收类和方法。从transfer object中得到参数值(注意顺序要和客户端放入参数的顺序一致),再调用真正的业务逻辑。
最后建立客户端代码,向Client Proxy发出调用并得到返回结果。
public class ExampleClient {
public static void main(String[] args) throws Exception {
ExampleClientProxy proxy= new ExampleClientProxy();
String result = proxy.sayHello(18, "JimT");
}
}
序列化类型
可以使用序列化的对象作为参数。
to.putSerializable("account", account);
自定义类型参数Wrapper Class
出于性能考虑,可以用wrapper类代替序列化对象。Wrapper类是用户自定义类,手动转化各种属性类型。
AccountWrapper accountWrapper = new AccountWrapper(account);
to.putWrapper("account", accountWrapper);
AccountWrapper 类包含了 Account
public class AccountWrapper implements TransferObjectWrapper {
private Account account;
public AccountWrapper(Account account) {
this.account = account;
}
public int getLength(){
return TransferUtil.getLengthOfInt() +
TransferUtil.getLengthOfString(account.getName()) +
TransferUtil.getLengthOfString(account.getAddress());
}
public void getByteArray(TransferOutputStream touts) {
touts.writeInt(account.getId());
touts.writeString(account.getName());
touts.writeString(account.getAddress());
}
public TestAccountWrapper getObjectWrapper(TransferInputStream tins){
account = new TestAccount();
account.setId(tins.readInt());
account.setName(tins.readString());
account.setAddress(tins.readString());
return this;
}
}
有三个实现方法:
getLength - get customization object byte array length
getByteArray - convert customization object into byte array
getObjectWrapper - convert byte array back to customization object
异步
在客户端Proxy,Tatala支持异步调用。
to.setAsynchronous(true);
Future<AccountWrapper> future = (Future<AccountWrapper>) ServerExecutor.execute(to);
accountWrapper = future.get();
压缩传输
Tatala支持压缩传输数据。不管向服务器传输大数据还是要从服务器得到大数据,都可以在client proxy设置压缩标志。
to.setCompress(true);
非反射调用Default Server Proxy
在服务器端执行被调用类是通过反射来完成的,如果不希望用反射,可以让server Proxy继承DefaultProxy 并且注册到socket server中。而在client Proxy 不需要设置任何被调用类名。
把default proxy注册到socket server中。
DefaultProxy defaultProxy = new ExampleDefaultProxy();
server.registerProxy(defaultProxy);
server.start();
建立自己的Default Proxy ExampleDefaultProxy.java
public class ExampleDefaultProxy extends DefaultProxy{
private ExampleManager manager = new ExampleManagerImpl();
public Object execute(TransferObject to){
String calleeMethod = to.getCalleeMethod();
if(calleeMethod.equals("sayHello")){
int Id = to.getInt();
String name = to.getString();
String result = manager.sayHello(Id, name);
return result;
}
return null;
}
}
无Proxy调用
如果你觉得写Proxy很烦,那你可以试试创建无Proxy的调用方式。这种方式让你不需要编写任何client 和 server proxy代码。因为它是基于Java动态代理技术的,所以性能会有一点点影响,并且不支持wrapper类和C#的版本。
在前面,“快速开始”里第一个例子EasyClient就是无Proxy调用。
服务端推送
对于长连接,有时需要服务端主动推送消息给客户端,例如在聊天室中广播聊天内容给所有用户。只要我们在建立长连接后,保持client session,就可以在业务逻辑中,通过session直接发送消息或方法调用到客户端。有了这个功能可以用Tatala建立简单易用的网络游戏服务器。
详细的例子看聊天室的演示代码。(tatala-java-example里的chatroom)
传输截获与注入Session Filter
Tatala支持在服务器端在调用业务代码之前,截获每次数据传输,预处理传入的二进制字节流或者注入业务逻辑,比如访问权限检查等。
建立session filter
public class MyFilter implements SessionFilter {
public void onClose(ServerSession session) {
//on connection close, do something
}
public boolean onReceive(ServerSession session, byte[] receiveData) {
//after each receive, do something
return true;
}
}
把新建的filter注册到socket server中。
AioSocketServer server = new AioSocketServer(listenPort, poolSize);
MyFilter filter = new MyFilter();
server.registerSessionFilter(filter);
捕获服务端抛出的异常
在某些情况,客户端需要捕获服务端抛出的异常,使得客户端可以事务回滚。 创建ExampleReturnException继承TatalaRollbackException
public class ExampleReturnException extends TatalaRollbackException{
private static final long serialVersionUID = 1L;
public ExampleReturnException() {
super();
}
public ExampleReturnException(String msg) {
super(msg);
}
}
在ExampleManagerImpl中创建一个需要被客户端捕获异常的方法。
public void exceptionCall(int Id) {
if(Id < 0){
throw new ExampleReturnException("Server error: id < 0");
}
}
ExampleServerProxy
public void exceptionCall(TransferObject to) {
int Id = to.getInt();
manager.exceptionCall(Id);
}
Client
public void returnExceptionTest() {
TransferObject to = transferObjectFactory.createTransferObject();
to.setCalleeClass("com.qileyuan.tatala.example.proxy.ExampleServerProxy");
to.setCalleeMethod("exceptionCall");
to.putInt(-1);
to.registerReturnType(TransferObject.DATATYPE_VOID);
ServerExecutor.execute(to);
}
因为TatalaRollbackException继承自RuntimeException,所以在代码中是否需要try-catch是可选项,让代码更简单。
Google Protocol Buffer
既然Tatala支持二进制数组作为参数传输,我们就可用Protobuf作为对象序列化解决方案,代替Serializable和WrapperClass。
Client Proxy
public Account getAccountProto (Account account) throws InvalidProtocolBufferException{
TransferObject to = transferObjectFactory.createTransferObject();
to.setCalleeClass("com.qileyuan.tatala.example.proxy.ExampleServerProxy");
to.setCalleeMethod("getAccountProto");
to.registerReturnType(TransferObject.DATATYPE_BYTEARRAY);
AccountProto.Account.Builder accountProtoBuilder = AccountProto.Account.newBuilder();
accountProtoBuilder.setId(account.getId());
accountProtoBuilder.setName(account.getName());
to.putByteArray(accountProtoBuilder.build().toByteArray());
byte[] returnByteArray = (byte[]) ServerExecutor.execute(to);
AccountProto.Account accountProto = AccountProto.Account.parseFrom(returnByteArray);
if(accountProto != null){
Account returnAccount = new Account();
returnAccount.setId(accountProto.getId());
returnAccount.setName(accountProto.getName());
returnAccount.setAddress(accountProto.getAddress());
return returnAccount;
}else{
return null;
}
}
Server Proxy
public byte[] getAccountProto(TransferObject to) throws InvalidProtocolBufferException {
byte[] byteArray = to.getByteArray();
AccountProto.Account accountProto = AccountProto.Account.parseFrom(byteArray);
Account account = new Account();
account.setId(accountProto.getId());
account.setName(accountProto.getName());
account.setAddress(accountProto.getAddress());
Account returnAccount = manager.getAccount(account);
AccountProto.Account.Builder accountProtoBuilder = AccountProto.Account.newBuilder();
accountProtoBuilder.setId(returnAccount.getId());
accountProtoBuilder.setName(returnAccount.getName());
accountProtoBuilder.setAddress(returnAccount.getAddress());
return accountProtoBuilder.build().toByteArray();
}
传输协议
在客户端把调用的方法信息设置到transfer object里, Tatala把transfer object转换成字节数组并且发送给服务器。在服务器端把接收到的字节数组再还原成包含调用信息的transfer object。包括被调用类名,目标方法名,参数值和返回类型等。Tatala 执行器获得调用信息执行目标方法。
支持类型
Tatala支持的参数和返回类型表格
Type | Java | C# |
bool | Y | Y |
byte | Y | Y |
short | Y | Y |
chat | Y | Y |
int | Y | Y |
long | Y | Y |
float | Y | Y |
double | Y | Y |
Date | Y | Y |
String | Y | Y |
byte[] | Y | Y |
int[] | Y | Y |
long[] | Y | Y |
float[] | Y | Y |
double[] | Y | Y |
String[] | Y | Y |
Serializable | Y | N |
Protobuf | Y | Y |
WrapperClass | Y | Y |
其它描述
需要JDK1.7,因为使用了Java AIO。
第三方类库包括Protobuf,Log4j。
License
Apache License Version 2.0
相关推荐
内容概要:本文探讨了高吞吐量网络链路异常检测中流量采样技术的应用及其效果。面对现代分布式信息系统频繁遭受的网络安全威胁,特别是互联网服务提供商(ISP)面临的威胁,作者提出一种通过减少数据采样频率以降低异常检测计算复杂度的方法。文中介绍了实验环境、系统架构、采用的数据聚合与采样方法以及用于检测异常的人工智能模型(基于自编码器神经网络)。通过对一个真实中型ISP生产环境中实际网络流量数据进行研究,该研究展示了即使在较低采样频率情况下仍能保持较高的异常检测准确性,尤其是针对持续时间较长的DDoS攻击更为显著。此外,论文还验证了所提系统的有效性和应用潜力,为构建高效的网络安全监控机制提供了新思路。 适用人群:对于计算机网络安全、数据分析或机器学习有兴趣的研究人员和从业人员,特别是那些专注于提高异常检测性能和应对高流量数据流的技术人员。 使用场景及目标:适用于希望在不影响业务操作的前提下引入额外层次防护措施的企业级网络管理员;研究者可参考本文中提出的流量预处理方式来探索不同的统计分布和采样间隔设置;企业可以通过部署该类系统快速响应潜在的安全事件并降低成本。
unity ui画线插件
内容概要:本文研究了在基于正交频分多址接入(OFDMA)的中继网络中进行带有比例公平性的下行链路资源分配问题。作者们通过联合优化中继选择、子载波分配和功率分配问题,并采用拉格朗日对偶分解方法求解这一复杂的NP完全问题。实验结果显示所提出的算法相较于启发式算法能显著提高系统吞吐量,并带来更好的用户间公平性。 适合人群:通信工程、无线网络优化、电信行业研发工程师和研究人员。 使用场景及目标:主要应用于提升4G移动通信系统的频谱效率及缓解频率选择衰落的问题,确保多用户之间的传输速率更加公平。同时适用于研究OFDMA技术及其相关领域的学者和技术专家。 其他说明:文中提供了详细的数学模型和模拟结果图表支持理论发现,并讨论了各种假设条件下的性能对比。此外还探讨了连续松弛技巧在解决NP完全问题时的应用价值以及通过调整算法参数来获得近似最优解的方法论意义。
程序系统设计]MATLAB打印纸缺陷检测GUI(不同缺陷类型,GUI界面) [程序系统设计]MATLAB打印纸缺陷检测GUI(不同缺陷类型,GUI界面) [程序系统设计]MATLAB打印纸缺陷检测GUI(不同缺陷类型,GUI界面) [程序系统设计]MATLAB打印纸缺陷检测GUI(不同缺陷类型,GUI界面) [程序系统设计]MATLAB打印纸缺陷检测GUI(不同缺陷类型,GUI界面)
邮件分拣组态王6.55和西门子S7-200plc联机程序2023,带io表,运行效果视频 ,邮件分拣; 组态王6.55; 西门子S7-200plc; 联机程序2023; IO表; 运行效果视频,邮件分拣组态王6.55与S7-200PLC联机程序2023版:带IO表运行效果视频
内容概要:本文提出了一种新的基于跨时间差异(CTD)注意力机制的变化检测方法(称为CTD-Former),用于高效地提取多时相遥感图像中的变化特征。作者重新审视了自注意力机制并深入挖掘多时间相位图像间的关系变化,构建CTD变压器编码器和解码器来增强这些特征。此外,还引入了一致性感知模块(CPB)以保护变化区域的空间结构。实验结果显示,在LEVIR-CD、WHU-CD和CLCD数据集上,该模型相比于当前最优的方法表现出更好的性能。 适合人群:对深度学习、遥感图像处理、尤其是变化检测感兴趣的研究人员和技术专家,特别是熟悉变换器网络架构的从业者。 使用场景及目标:此方法适用于需要从多时相对比遥感影像中识别变化情况的任务,如环境监测、灾害评估、城市规划等领域内的应用开发,能够帮助研究者和决策者更准确地了解地面物体随时间的变化趋势。 其他说明:源代码可在GitHub仓库中获取,这为未来的研究提供了一个重要的参考平台,有助于推动该领域的进一步发展。
该项目是个人实践项目,答辩评审分达到90分,代码都经过调试测试,确保可以运行!,可用于小白学习、进阶。 该资源主要针对计算机、通信、人工智能、自动化等相关专业的学生、老师或从业者下载使用,亦可作为期末课程设计、课程大作业、毕业设计等。 项目整体具有较高的学习借鉴价值!基础能力强的可以在此基础上修改调整,以实现不同的功能。 欢迎下载,欢迎沟通,互相学习,共同进步!提供答疑!
fajslghjlghg
2008-2020年各省每十万人口高等学校平均在校生数数据 1、时间:2008-2020年 2、来源:国家统计j、统计nj 3、指标:行政区划代码、地区名称、年份、每十万人口高等学校平均在校生数 4、范围:31省
毕业设计&课程设计 基于STM32单片机基于RFID的电动车停车管理系统(软件源码+硬件资料+部署教程+功能说明+演示视频),高分项目,开箱即用 用户 分为老师 及 学生 管理员 管理员 登录 用户管理 电动车管理 车卡rfid 电动车进出记录 挂失申请列表 解冻申请列表 补办列表申请 用户(只能管理自己的车) 注册(注册的时候选身份,选择学生或者老师) 登录 个人信息查看 电动车管理 进出校记录 挂失申请 解冻申请 补办申请
内容概要:本文探讨了一种新的基于深度强化学习的方法来解决旅行商问题与无人机组合优化(Traveling Salesman Problem with Drone, TSP-D),针对当前无人机辅助卡车配送中面临的协同调度难题进行了改进。研究者提出一种混合模型(HM),整合了注意力编码器和长短期记忆网络(LSTM)解码器的优势,从而有效地记录了多个车辆的动作序列并实现了协调路径规划。该方法在各种测试用例上展现了卓越性能,并能显著提高大型问题实例的计算效率,同时在实际应用场景如最后一步送货中有潜在的巨大价值。 适合人群:对物流系统优化和无人机应用有兴趣的专业人士,特别是从事最后一公里交付方案设计和技术实施的研究人员及工程师。 使用场景及目标:本研究所提出的深度学习框架主要适用于城市环境中复杂条件下的车辆和无人驾驶飞行系统的共同优化配置,目的是为了找到最优的货物递送方案,在最短的时间内完成所有的客户服务任务并返回起点。 其他说明:实验结果显示该算法在随机位置数据集和现实情况中的优越性超过了现有传统算法,表明它不仅能在简单理想情况下发挥良好效果,同样可以在更为复杂的条件下表现出稳定的性能。
北京中启航向科技发展有限公司开发的城市生活垃圾处理费智慧征管系统,是一个全方位、一体化的解决方案,旨在协助城市管理部门高效、准确地收取生活垃圾处理费。该系统利用先进的人工智能和数据分析技术,实现垃圾分类、计量和收费的智能化管理,提升城市环境卫生质量,同时优化行政资源,提高征收效率。
水测试试纸行业剖析:欧洲是全球最大的市场,占40%的份额.pdf
《电力电子技术(第5版)》王兆安_第2章_电力电子器件
基于STM32的直流电机加减速正反转控制串口输出控制系统(P 1100009-基于STM32的直流电机加减速正反转控制串口输出控制系统(PCB 原理图 报告 源代码 proteus lcd1602) 功能描述:基于STM32平台 1、实现了电机控制正转、反转的功能 2、实现了电机控制加速、减速的功能 3、实现了串口输出控制信息的功能 4、串口可以模拟WIFI 蓝牙 RS232 等带有串口的功能。 资料包含: 1、源代码工程文件 2、仿真工程文件 3、lunwen报告1W字以上 4、原理图工程文件 5、PCB工程文件 ,核心关键词:STM32、直流电机、加减速、正反转控制、串口输出、控制信息、WIFI、蓝牙、RS232、源代码工程文件、仿真工程文件、原理图工程文件、PCB工程文件。,基于STM32的电机串口控制综合系统(含正反转、加减速及多种串口通信功能)
ZYNQ7010采集AD7768
apollo 泊车轨迹优化代码 hybridastar+iaps平滑优化+obca平滑优化 第一个图是matlab绘制 后面的图是程序用sdl库绘制 ,apollo;泊车轨迹优化;hybridastar;iaps平滑优化;obca平滑优化;Matlab绘制;SDL库绘制,基于Apollo的泊车轨迹优化:HybridA*算法+平滑优化技术的实现与展示
乳酸链球菌素检验表格(食品添加剂食用香精质量验收记录表).docx
基于S7-200 PLC和组态王矿井通风控制 ,基于S7-200 PLC; 矿井通风控制; 组态王; 通风系统控制,基于S7-200 PLC与组态王矿井通风控制系统