分布式服务架构学习（九）：实现自己的序列化工具引擎（八）-序列化Thrift实现

小咪咪 2022-05-17 07:05 134阅读 0赞

与protobuf类似，适用Thrift之前，需要编写以.thrift结尾的IDL文件，再适用Thrift提供的编译器生成对应的代码。对java而言，所生成的java bean都集成了类org.apache.thrift.TBase。

代码如下：

package ares.remoting.framework.serialization.serializer.impl;
    
    import ares.remoting.framework.serialization.serializer.ISerializer;
    import org.apache.thrift.TBase;
    import org.apache.thrift.TDeserializer;
    import org.apache.thrift.TException;
    import org.apache.thrift.TSerializer;
    import org.apache.thrift.protocol.TBinaryProtocol;
    
    /**
     * @author fuss created on 18/7/23.
     * @version $Id$
     */
    public class ThriftSerializer implements ISerializer {
    
    
        public <T> byte[] serialize(T obj) {
            try {
                TSerializer serializer = new TSerializer(new TBinaryProtocol.Factory());
                return serializer.serialize((TBase) obj);
            } catch (TException e) {
                throw new RuntimeException(e);
            }
        }
    
    
        public <T> T deserialize(byte[] data, Class<T> clazz) {
            try {
                TBase o = (TBase) clazz.newInstance();
                TDeserializer tDeserializer = new TDeserializer();
                tDeserializer.deserialize(o, data);
                return (T) o;
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
    
        }
    
    
    }

maven依赖配置，代码如下：

<dependency>
                <groupId>org.apache.thrift</groupId>
                <artifactId>libfb303</artifactId>
                <version>0.9.3</version>
            </dependency>
            <dependency>
                <groupId>org.apache.thrift</groupId>
                <artifactId>libthrift</artifactId>
                <version>0.9.3</version>
            </dependency>