`
zijan
  • 浏览: 65936 次
  • 性别: Icon_minigender_1
社区版块
存档分类
最新评论

Tatala 中文教程

阅读更多

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

分享到:
评论

相关推荐

    C++类构造与析构机制详解:掌握对象生命周期管理核心技术

    内容概要:本文详细阐述了C++类的构造与析构机制,解释了这两种特殊成员函数的工作原理和应用场景,涵盖构造函数的特点、分类与调用方式、构造函数初始化列表、以及析构函数的作用、调用时机和注意事项。文中还探讨了在C++编程中如何运用这些机制实现高效的资源管理和内存安全,特别是遵循RAII原则、避免常见错误(如资源未释放、重复析构、异常安全问题)、并在多线程环境中合理处理同步操作。 适合人群:具有基础C++编程技能的程序员,尤其是希望深入了解对象生命周期管理和高级资源管理技术的人群。 使用场景及目标:①理解和应用C++类的构造与析构机制来编写高效的代码;②预防和修复由于资源管理不当引发的各种错误和性能问题;③提高对面向对象编程的理解,掌握在多线程环境下的资源管理技巧。 其他说明:通过实际案例深入分析C++中构造函数和析构函数的应用,强调RAII(Resource Acquisition Is Initialization)原则的重要性。同时也提及了未来学习方向如智能指针和移动语义等内容,帮助开发者更好地掌握C++编程技巧。

    2025年汽车租赁业务系统应该具备的功能

    本文为抛砖引玉:简单描述,如需根据自身业务详细设计,请随时联系

    百合检验表格(食品香辛料质量验收记录表)检验表格(食品香辛料质量验收记录表).docx

    百合检验表格(食品香辛料质量验收记录表)检验表格(食品香辛料质量验收记录表).docx

    最新PHP盲盒商城系统源码ThinkPHP框架.zip

    最新PHP盲盒商城系统源码ThinkPHP框架

    奇异值确定K_K值VMD_K._vmd_VMD奇异值_VMDK

    奇异值分解(Singular Value Decomposition,简称SVD)是线性代数中的一种重要矩阵分解方法,广泛应用于数据处理和信号分析。在本场景中,我们关注的是如何利用SVD来确定VMD(Variable Modulation Decomposition,可变调制分解)的K值。VMD是一种信号分解技术,它能够将复杂信号分解为一系列调制频率成分,对于非平稳信号的分析和处理非常有用。 理解SVD的基本概念:任何m×n的实数或复数矩阵A都可以表示为三个矩阵的乘积,即A=UΣV^T,其中U是m×m的正交矩阵,Σ是一个m×n的对角矩阵,其对角线元素是奇异值,V是n×n的正交矩阵。奇异值σ_i按照非降序排列,它们反映了矩阵A的信息量和重要性。 在VMD中,奇异值分解的作用在于识别信号的不同频率成分。当对信号进行VMD时,目标是找到最佳的K值,以使分解后的子带信号尽可能独立且无交叉。K值代表了分解得到的调制模式数量,每个模式对应一个特定的频率范围。 为了确定K值,我们需要分析SVD的结果,即奇异值的分布。奇异值的大小反映了原始信号的结构信息。通常,信号中的主要成分对应较大的奇异值,而噪声或不重要的成分对应较小的奇异值。因此,奇异值的下降趋势可以作为判断信号成分变化的一个指标。 通过绘制奇异值的累积贡献率曲线,我们可以观察到奇异值的显著下降点,这个点通常对应着信号主要成分的结束,后续的奇异值可以视为噪声或次要成分。这个显著下降点即为选择K值的依据。一般来说,选择奇异值曲线出现“转折”或者“平台”的位置作为K值,可以确保主要信号成分被保留,同时尽可能减少噪声的影响。 具体实现步骤如下: 1. 对信号进行SVD,得到奇异值序列。 2. 计算奇异值的累积贡献率,即将奇异值按降序排列后,每个奇异值除以所有奇异值的和,然后累加。 3. 绘制累积贡献率曲线,并寻找曲线的转折点或者平台区。 4. 将转折点对应的奇异值个数作为VMD的K值。 在实际应用中,确定K值还可以结合其他准则,如信息熵、能量集中度等,以确保分解的合理性和稳定性。此外,不同的信号和应用场景可能需要调整K值的选择策略,这需要根据具体问题进行细致的研究和实验验证。 总结来说,利用SVD确定VMD的K值是通过对奇异值分布的分析,找出信号主要成分与噪声之间的界限,从而选择一个合适的分解模式数量。这种方法有助于提取信号的关键特征,提高VMD分解的效率和准确性。。内容来源于网络分享,如有侵权请联系我删除。

    常用护理技术操作规程49项.docx

    常用护理技术操作规程49项.docx

    局部阴影遮挡,灰狼MPPT,灰狼算法 灰狼算法实现部分遮阴的MPPT跟踪,包括光照突变情况,包括灰狼算法程序和matlab simulink模型的搭建,功率,电压,电流波形图和占空比波形图入如下

    局部阴影遮挡,灰狼MPPT,灰狼算法 灰狼算法实现部分遮阴的MPPT跟踪,包括光照突变情况,包括灰狼算法程序和matlab simulink模型的搭建,功率,电压,电流波形图和占空比波形图入如下。 ,局部阴影遮挡; 灰狼MPPT; 灰狼算法; 光照突变; 波形图; 程序搭建; matlab simulink模型,灰狼算法MPPT跟踪,局部遮阴及突变情况研究

    XCP或者CCP标定,A2L标定文件,基于map文件自动更新A2L的地址和结构体变量的地址 源码基于C#需要开发,编译器为VS2022 ,XCP/CCP标定; A2L标定文件; 地图文件自动更新;

    XCP或者CCP标定,A2L标定文件,基于map文件自动更新A2L的地址和结构体变量的地址 源码基于C#需要开发,编译器为VS2022 ,XCP/CCP标定; A2L标定文件; 地图文件自动更新; C#开发; VS2022编译器,基于C#开发的XCP/CCP标定系统,自动更新A2L文件地址与结构体变量

    Win - NEOGEO 颜色转换器-修改kof用

    给那些修改kof的玩家用的工具,简单快捷方便,需要自取

    s10207-024-00818-y.pdf

    s10207-024-00818-y.pdf

    Screenshot_20250314_152955.jpg

    Screenshot_20250314_152955.jpg

    Truvalue V3:环境、社会与治理(ESG)数据分析方法论详解(可复现,有问题请联系博主)

    内容概要:本文档详细介绍了 FactSet 公司推出的 Truvalue V3 平台的内容采集与处理流程及其评分方法。FactSet 利用人工智能技术和语义大数据处理能力收集并解析每日超过4000万份来自20多万信源的全球ESG相关信息。通过对这些非结构化文本数据的深度剖析,Truvalue平台能够识别关键ESG主题并量化情绪倾向度。它不仅提供单篇文章层面的情绪打分(从最消极0到最积极100),而且还综合评估公司长期发展趋势以及短期市场表现。此外,还讨论了动态重要性和重点事件检测等特征,使分析师更容易捕捉到企业活动背后的潜在机会与风险。 适用人群:金融行业从业者如投资顾问、基金经理以及其他关注企业可持续发展和社会责任的专业人士。 使用场景及目标:为投资者提供精准的数据支持以进行资产配置决策;辅助研究员对特定企业或行业的深度调研工作。 其他说明:本方法论特别强调采用SASB标准作为评价基准之一,并解释了几种重要的得分计算公式,如脉搏分数、洞察力分数及时势动量指标等的具体运作机制。同时概述了一些质量控制措施以确保所提供数据的有效性和准确性。

    毕业设计&课程设计 基于STM32单片机的物联网智能家庭安防系统(软件源码+硬件资料+部署教程+设计任务书+演示视频),高分项目,开箱即用

    毕业设计&课程设计 基于STM32单片机的物联网智能家庭安防系统(软件源码+硬件资料+部署教程+设计任务书+演示视频),高分项目,开箱即用 随着公众安全意识的提高,人们对家庭安全防控的需求愈发迫切,如何合理应用控制、通信及监控等自动化技术手段,打造智能化家庭安防系统成为研究重点。因此提出了基于物联网的家庭安防系统,实现监测燃气泄漏并报警、监测火灾烟雾并报警、检测非法入室并报警等功能,极大保障家庭居住场所的安全性。 用STM32单片机开发: 1、监测燃气泄漏(MQ-5)、监测火灾烟雾(DS18B20、MO-7)、检测非法入室(红外对管) 2、液晶显示燃气浓度、烟雾浓度、温度、是否有人闯入、布防状态 3、按键可以设置燃气、烟雾、温度的报警值,大于时候开启蜂鸣器报警以及对应的报警指示灯 4、当系统开启布防,有人闯入,开启蜂鸣器报警以及对应指示灯,撤防时,不检测非法闯入 5、数据通过wIFI上传到手机端 6、当报警时候发送报警短信,短信包含触发报警的情况:如燃气报警发送:gas leakage 温度或者烟雾报警发送:fire smoke alarm 非法入室发送:Illegal Entry

    白胡椒检验表格(食品香辛料质量验收记录表)检验表格(食品香辛料质量验收记录表).docx

    白胡椒检验表格(食品香辛料质量验收记录表)检验表格(食品香辛料质量验收记录表).docx

    信阳市乡镇边界,矢量边界,shp格式

    矢量边界,行政区域边界,精确到乡镇街道,可直接导入arcgis使用

    c++多媒体音视频播放器

    c++多媒体音视频播放器

    Adobe After Effects 插件

    Adobe After Effects 全套插件安装包

    Flac3d函数形式的应力边界施加编程 flac3d应力边界编程处理 本为本人做的简单案例:针对立方体模型,同时考虑重力和一侧应力边界对模型应力分布进行分析 特色:应力函数可以任意改变,调节简单

    Flac3d函数形式的应力边界施加编程 flac3d应力边界编程处理 本为本人做的简单案例:针对立方体模型,同时考虑重力和一侧应力边界对模型应力分布进行分析。 特色:应力函数可以任意改变,调节简单快捷 代码请前咨询了解清楚,不支持 款 针对地应力反演、走滑断层等分析中的应力边界位移边界问题如有需求定制 ,Flac3d;应力边界施加;编程处理;立方体模型;重力影响;应力分布分析;函数形式应力边界;地应力反演;走滑断层;位移边界问题。,Flac3d编程:应力边界施加的简易案例分析

    基于matlab的凝土随机球形骨料球体蒙特卡洛随机分布模型 三种粒径不同的骨料随机分布 模拟混凝土材料的过程,粒径可自行定义,可设置孔隙率 动画显示建模过程 程序已调通,可直接运行 ,基于Ma

    基于matlab的凝土随机球形骨料球体蒙特卡洛随机分布模型 三种粒径不同的骨料随机分布 模拟混凝土材料的过程,粒径可自行定义,可设置孔隙率 动画显示建模过程 程序已调通,可直接运行 ,基于Matlab; 凝土随机球形骨料; 球体蒙特卡洛随机分布模型; 不同粒径骨料随机分布; 模拟混凝土材料; 粒径可定义; 孔隙率可设置; 动画显示建模过程; 程序已调通。,基于Matlab的混凝土骨料随机分布模拟程序

    2008-2020年各省每十万人口高等学校平均在校生数数据

    2008-2020年各省每十万人口高等学校平均在校生数数据 1、时间:2008-2020年 2、来源:国家统计j、统计nj 3、指标:行政区划代码、地区名称、年份、每十万人口高等学校平均在校生数 4、范围:31省

Global site tag (gtag.js) - Google Analytics