<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <groupId>ThriftTest</groupId>    <artifactId>ThriftTest</artifactId>    <version>0.0.1-SNAPSHOT</version>    <packaging>jar</packaging>    <name>ThriftTest</name>    <url>http://maven.apache.org</url>    <properties>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>    </properties>    <dependencies>        <dependency>            <groupId>junit</groupId>            <artifactId>junit</artifactId>            <version>3.8.1</version>            <scope>test</scope>        </dependency>        <dependency>            <groupId>org.apache.thrift</groupId>            <artifactId>libthrift</artifactId>            <version>0.8.0</version>        </dependency>        <dependency>            <groupId>org.slf4j</groupId>            <artifactId>slf4j-log4j12</artifactId>            <version>1.5.8</version>        </dependency>    </dependencies></project>

package ThriftTest.ThriftTest;/** * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING *  @generated */import org.apache.thrift.scheme.IScheme;import org.apache.thrift.scheme.SchemeFactory;import org.apache.thrift.scheme.StandardScheme;import org.apache.thrift.scheme.TupleScheme;import org.apache.thrift.protocol.TTupleProtocol;import org.apache.thrift.protocol.TProtocolException;import org.apache.thrift.EncodingUtils;import org.apache.thrift.TException;import org.apache.thrift.async.AsyncMethodCallback;import org.apache.thrift.server.AbstractNonblockingServer.*;import java.util.List;import java.util.ArrayList;import java.util.Map;import java.util.HashMap;import java.util.EnumMap;import java.util.Set;import java.util.HashSet;import java.util.EnumSet;import java.util.Collections;import java.util.BitSet;import java.nio.ByteBuffer;import java.util.Arrays;import javax.annotation.Generated;import org.slf4j.Logger;import org.slf4j.LoggerFactory;@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-2-1")public class HelloWorldService {  public interface Iface {    public String sayHello(String username) throws org.apache.thrift.TException;  }  public interface AsyncIface {    public void sayHello(String username, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;  }  public static class Client extends org.apache.thrift.TServiceClient implements Iface {    public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {      public Factory() {}      public Client getClient(org.apache.thrift.protocol.TProtocol prot) {        return new Client(prot);      }      public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {        return new Client(iprot, oprot);      }    }    public Client(org.apache.thrift.protocol.TProtocol prot)    {      super(prot, prot);    }    public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {      super(iprot, oprot);    }    public String sayHello(String username) throws org.apache.thrift.TException    {      send_sayHello(username);      return recv_sayHello();    }    public void send_sayHello(String username) throws org.apache.thrift.TException    {      sayHello_args args = new sayHello_args();      args.setUsername(username);      sendBase("sayHello", args);    }    public String recv_sayHello() throws org.apache.thrift.TException    {      sayHello_result result = new sayHello_result();      receiveBase(result, "sayHello");      if (result.isSetSuccess()) {        return result.success;      }      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "sayHello failed: unknown result");    }  }  public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {    public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {      private org.apache.thrift.async.TAsyncClientManager clientManager;      private org.apache.thrift.protocol.TProtocolFactory protocolFactory;      public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {        this.clientManager = clientManager;        this.protocolFactory = protocolFactory;      }      public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {        return new AsyncClient(protocolFactory, clientManager, transport);      }    }    public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {      super(protocolFactory, clientManager, transport);    }    public void sayHello(String username, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {      checkReady();      sayHello_call method_call = new sayHello_call(username, resultHandler, this, ___protocolFactory, ___transport);      this.___currentMethod = method_call;      ___manager.call(method_call);    }    public static class sayHello_call extends org.apache.thrift.async.TAsyncMethodCall {      private String username;      public sayHello_call(String username, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {        super(client, protocolFactory, transport, resultHandler, false);        this.username = username;      }      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sayHello", org.apache.thrift.protocol.TMessageType.CALL, 0));        sayHello_args args = new sayHello_args();        args.setUsername(username);        args.write(prot);        prot.writeMessageEnd();      }      public String getResult() throws org.apache.thrift.TException {        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {          throw new IllegalStateException("Method call not finished!");        }        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);        return (new Client(prot)).recv_sayHello();      }    }  }  public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {    private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());    public Processor(I iface) {      super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));    }    protected Processor(I iface, Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {      super(iface, getProcessMap(processMap));    }    private static <I extends Iface> Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> getProcessMap(Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {      processMap.put("sayHello", new sayHello());      return processMap;    }    public static class sayHello<I extends Iface> extends org.apache.thrift.ProcessFunction<I, sayHello_args> {      public sayHello() {        super("sayHello");      }      public sayHello_args getEmptyArgsInstance() {        return new sayHello_args();      }      protected boolean isOneway() {        return false;      }      public sayHello_result getResult(I iface, sayHello_args args) throws org.apache.thrift.TException {        sayHello_result result = new sayHello_result();        result.success = iface.sayHello(args.username);        return result;      }    }  }//  public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> {//    private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName());//    public AsyncProcessor(I iface) {//      super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>()));//    }////    protected AsyncProcessor(I iface, Map<String,  org.apache.thrift.AsyncProcessFunction<I, ? extends  org.apache.thrift.TBase, ?>> processMap) {//      super(iface, getProcessMap(processMap));//    }////    private static <I extends AsyncIface> Map<String,  org.apache.thrift.AsyncProcessFunction<I, ? extends  org.apache.thrift.TBase,?>> getProcessMap(Map<String,  org.apache.thrift.AsyncProcessFunction<I, ? extends  org.apache.thrift.TBase, ?>> processMap) {//      processMap.put("sayHello", new sayHello());//      return processMap;//    }////    public static class sayHello<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, sayHello_args, String> {//      public sayHello() {//        super("sayHello");//      }////      public sayHello_args getEmptyArgsInstance() {//        return new sayHello_args();//      }////      public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {//        final org.apache.thrift.AsyncProcessFunction fcall = this;//        return new AsyncMethodCallback<String>() {//          public void onComplete(String o) {//            sayHello_result result = new sayHello_result();//            result.success = o;//            try {//              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);//              return;//            } catch (Exception e) {//              LOGGER.error("Exception writing to internal frame buffer", e);//            }//            fb.close();//          }//          public void one rror(Exception e) {//            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;//            org.apache.thrift.TBase msg;//            sayHello_result result = new sayHello_result();//            {//              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;//              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());//            }//            try {//              fcall.sendResponse(fb,msg,msgType,seqid);//              return;//            } catch (Exception ex) {//              LOGGER.error("Exception writing to internal frame buffer", ex);//            }//            fb.close();//          }//        };//      }////      protected boolean isOneway() {//        return false;//      }////      public void start(I iface, sayHello_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {//        iface.sayHello(args.username,resultHandler);//      }//    }////  }  public static class sayHello_args implements org.apache.thrift.TBase<sayHello_args, sayHello_args._Fields>, java.io.Serializable, Cloneable, Comparable<sayHello_args>   {    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("sayHello_args");    private static final org.apache.thrift.protocol.TField USERNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("username", org.apache.thrift.protocol.TType.STRING, (short)1);    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();    static {      schemes.put(StandardScheme.class, new sayHello_argsStandardSchemeFactory());      schemes.put(TupleScheme.class, new sayHello_argsTupleSchemeFactory());    }    public String username; // required    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */    public enum _Fields implements org.apache.thrift.TFieldIdEnum {      USERNAME((short)1, "username");      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();      static {        for (_Fields field : EnumSet.allOf(_Fields.class)) {          byName.put(field.getFieldName(), field);        }      }      /**       * Find the _Fields constant that matches fieldId, or null if its not found.       */      public static _Fields findByThriftId(int fieldId) {        switch(fieldId) {          case 1: // USERNAME            return USERNAME;          default:            return null;        }      }      /**       * Find the _Fields constant that matches fieldId, throwing an exception       * if it is not found.       */      public static _Fields findByThriftIdOrThrow(int fieldId) {        _Fields fields = findByThriftId(fieldId);        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn‘t exist!");        return fields;      }      /**       * Find the _Fields constant that matches name, or null if its not found.       */      public static _Fields findByName(String name) {        return byName.get(name);      }      private final short _thriftId;      private final String _fieldName;      _Fields(short thriftId, String fieldName) {        _thriftId = thriftId;        _fieldName = fieldName;      }      public short getThriftFieldId() {        return _thriftId;      }      public String getFieldName() {        return _fieldName;      }    }    // isset id assignments    public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;    static {      Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);      tmpMap.put(_Fields.USERNAME, new org.apache.thrift.meta_data.FieldMetaData("username", org.apache.thrift.TFieldRequirementType.DEFAULT,          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));      metaDataMap = Collections.unmodifiableMap(tmpMap);      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(sayHello_args.class, metaDataMap);    }    public sayHello_args() {    }    public sayHello_args(      String username)    {      this();      this.username = username;    }    /**     * Performs a deep copy on <i>other</i>.     */    public sayHello_args(sayHello_args other) {      if (other.isSetUsername()) {        this.username = other.username;      }    }    public sayHello_args deepCopy() {      return new sayHello_args(this);    }    public void clear() {      this.username = null;    }    public String getUsername() {      return this.username;    }    public sayHello_args setUsername(String username) {      this.username = username;      return this;    }    public void unsetUsername() {      this.username = null;    }    /** Returns true if field username is set (has been assigned a value) and false otherwise */    public boolean isSetUsername() {      return this.username != null;    }    public void setUsernameIsSet(boolean value) {      if (!value) {        this.username = null;      }    }    public void setFieldValue(_Fields field, Object value) {      switch (field) {      case USERNAME:        if (value =http://www.mamicode.com/= null) {          unsetUsername();        } else {          setUsername((String)value);        }        break;      }    }    public Object getFieldValue(_Fields field) {      switch (field) {      case USERNAME:        return getUsername();      }      throw new IllegalStateException();    }    /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */    public boolean isSet(_Fields field) {      if (field == null) {        throw new IllegalArgumentException();      }      switch (field) {      case USERNAME:        return isSetUsername();      }      throw new IllegalStateException();    }    @Override    public boolean equals(Object that) {      if (that == null)        return false;      if (that instanceof sayHello_args)        return this.equals((sayHello_args)that);      return false;    }    public boolean equals(sayHello_args that) {      if (that == null)        return false;      boolean this_present_username = true && this.isSetUsername();      boolean that_present_username = true && that.isSetUsername();      if (this_present_username || that_present_username) {        if (!(this_present_username && that_present_username))          return false;        if (!this.username.equals(that.username))          return false;      }      return true;    }    @Override    public int hashCode() {      List<Object> list = new ArrayList<Object>();      boolean present_username = true && (isSetUsername());      list.add(present_username);      if (present_username)        list.add(username);      return list.hashCode();    }    public int compareTo(sayHello_args other) {      if (!getClass().equals(other.getClass())) {        return getClass().getName().compareTo(other.getClass().getName());      }      int lastComparison = 0;      lastComparison = Boolean.valueOf(isSetUsername()).compareTo(other.isSetUsername());      if (lastComparison != 0) {        return lastComparison;      }      if (isSetUsername()) {        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.username, other.username);        if (lastComparison != 0) {          return lastComparison;        }      }      return 0;    }    public _Fields fieldForId(int fieldId) {      return _Fields.findByThriftId(fieldId);    }    public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);    }    public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);    }    @Override    public String toString() {      StringBuilder sb = new StringBuilder("sayHello_args(");      boolean first = true;      sb.append("username:");      if (this.username == null) {        sb.append("null");      } else {        sb.append(this.username);      }      first = false;      sb.append(")");      return sb.toString();    }    public void validate() throws org.apache.thrift.TException {      // check for required fields      // check for sub-struct validity    }    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {      try {        write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));      } catch (org.apache.thrift.TException te) {        throw new java.io.IOException(te);      }    }    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {      try {        read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));      } catch (org.apache.thrift.TException te) {        throw new java.io.IOException(te);      }    }    private static class sayHello_argsStandardSchemeFactory implements SchemeFactory {      public sayHello_argsStandardScheme getScheme() {        return new sayHello_argsStandardScheme();      }    }    private static class sayHello_argsStandardScheme extends StandardScheme<sayHello_args> {      public void read(org.apache.thrift.protocol.TProtocol iprot, sayHello_args struct) throws org.apache.thrift.TException {        org.apache.thrift.protocol.TField schemeField;        iprot.readStructBegin();        while (true)        {          schemeField = iprot.readFieldBegin();          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {            break;          }          switch (schemeField.id) {            case 1: // USERNAME              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {                struct.username = iprot.readString();                struct.setUsernameIsSet(true);              } else {                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);              }              break;            default:              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);          }          iprot.readFieldEnd();        }        iprot.readStructEnd();        // check for required fields of primitive type, which can‘t be checked in the validate method        struct.validate();      }      public void write(org.apache.thrift.protocol.TProtocol oprot, sayHello_args struct) throws org.apache.thrift.TException {        struct.validate();        oprot.writeStructBegin(STRUCT_DESC);        if (struct.username != null) {          oprot.writeFieldBegin(USERNAME_FIELD_DESC);          oprot.writeString(struct.username);          oprot.writeFieldEnd();        }        oprot.writeFieldStop();        oprot.writeStructEnd();      }    }    private static class sayHello_argsTupleSchemeFactory implements SchemeFactory {      public sayHello_argsTupleScheme getScheme() {        return new sayHello_argsTupleScheme();      }    }    private static class sayHello_argsTupleScheme extends TupleScheme<sayHello_args> {      public void write(org.apache.thrift.protocol.TProtocol prot, sayHello_args struct) throws org.apache.thrift.TException {        TTupleProtocol oprot = (TTupleProtocol) prot;        BitSet optionals = new BitSet();        if (struct.isSetUsername()) {          optionals.set(0);        }        oprot.writeBitSet(optionals, 1);        if (struct.isSetUsername()) {          oprot.writeString(struct.username);        }      }      public void read(org.apache.thrift.protocol.TProtocol prot, sayHello_args struct) throws org.apache.thrift.TException {        TTupleProtocol iprot = (TTupleProtocol) prot;        BitSet incoming = iprot.readBitSet(1);        if (incoming.get(0)) {          struct.username = iprot.readString();          struct.setUsernameIsSet(true);        }      }    }  }  public static class sayHello_result implements org.apache.thrift.TBase<sayHello_result, sayHello_result._Fields>, java.io.Serializable, Cloneable, Comparable<sayHello_result>   {    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("sayHello_result");    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0);    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();    static {      schemes.put(StandardScheme.class, new sayHello_resultStandardSchemeFactory());      schemes.put(TupleScheme.class, new sayHello_resultTupleSchemeFactory());    }    public String success; // required    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */    public enum _Fields implements org.apache.thrift.TFieldIdEnum {      SUCCESS((short)0, "success");      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();      static {        for (_Fields field : EnumSet.allOf(_Fields.class)) {          byName.put(field.getFieldName(), field);        }      }      /**       * Find the _Fields constant that matches fieldId, or null if its not found.       */      public static _Fields findByThriftId(int fieldId) {        switch(fieldId) {          case 0: // SUCCESS            return SUCCESS;          default:            return null;        }      }      /**       * Find the _Fields constant that matches fieldId, throwing an exception       * if it is not found.       */      public static _Fields findByThriftIdOrThrow(int fieldId) {        _Fields fields = findByThriftId(fieldId);        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn‘t exist!");        return fields;      }      /**       * Find the _Fields constant that matches name, or null if its not found.       */      public static _Fields findByName(String name) {        return byName.get(name);      }      private final short _thriftId;      private final String _fieldName;      _Fields(short thriftId, String fieldName) {        _thriftId = thriftId;        _fieldName = fieldName;      }      public short getThriftFieldId() {        return _thriftId;      }      public String getFieldName() {        return _fieldName;      }    }    // isset id assignments    public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;    static {      Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);      tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));      metaDataMap = Collections.unmodifiableMap(tmpMap);      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(sayHello_result.class, metaDataMap);    }    public sayHello_result() {    }    public sayHello_result(      String success)    {      this();      this.success = success;    }    /**     * Performs a deep copy on <i>other</i>.     */    public sayHello_result(sayHello_result other) {      if (other.isSetSuccess()) {        this.success = other.success;      }    }    public sayHello_result deepCopy() {      return new sayHello_result(this);    }    public void clear() {      this.success = null;    }    public String getSuccess() {      return this.success;    }    public sayHello_result setSuccess(String success) {      this.success = success;      return this;    }    public void unsetSuccess() {      this.success = null;    }    /** Returns true if field success is set (has been assigned a value) and false otherwise */    public boolean isSetSuccess() {      return this.success != null;    }    public void setSuccessIsSet(boolean value) {      if (!value) {        this.success = null;      }    }    public void setFieldValue(_Fields field, Object value) {      switch (field) {      case SUCCESS:        if (value =http://www.mamicode.com/= null) {          unsetSuccess();        } else {          setSuccess((String)value);        }        break;      }    }    public Object getFieldValue(_Fields field) {      switch (field) {      case SUCCESS:        return getSuccess();      }      throw new IllegalStateException();    }    /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */    public boolean isSet(_Fields field) {      if (field == null) {        throw new IllegalArgumentException();      }      switch (field) {      case SUCCESS:        return isSetSuccess();      }      throw new IllegalStateException();    }    @Override    public boolean equals(Object that) {      if (that == null)        return false;      if (that instanceof sayHello_result)        return this.equals((sayHello_result)that);      return false;    }    public boolean equals(sayHello_result that) {      if (that == null)        return false;      boolean this_present_success = true && this.isSetSuccess();      boolean that_present_success = true && that.isSetSuccess();      if (this_present_success || that_present_success) {        if (!(this_present_success && that_present_success))          return false;        if (!this.success.equals(that.success))          return false;      }      return true;    }    @Override    public int hashCode() {      List<Object> list = new ArrayList<Object>();      boolean present_success = true && (isSetSuccess());      list.add(present_success);      if (present_success)        list.add(success);      return list.hashCode();    }    public int compareTo(sayHello_result other) {      if (!getClass().equals(other.getClass())) {        return getClass().getName().compareTo(other.getClass().getName());      }      int lastComparison = 0;      lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());      if (lastComparison != 0) {        return lastComparison;      }      if (isSetSuccess()) {        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success);        if (lastComparison != 0) {          return lastComparison;        }      }      return 0;    }    public _Fields fieldForId(int fieldId) {      return _Fields.findByThriftId(fieldId);    }    public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);    }    public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);      }    @Override    public String toString() {      StringBuilder sb = new StringBuilder("sayHello_result(");      boolean first = true;      sb.append("success:");      if (this.success == null) {        sb.append("null");      } else {        sb.append(this.success);      }      first = false;      sb.append(")");      return sb.toString();    }    public void validate() throws org.apache.thrift.TException {      // check for required fields      // check for sub-struct validity    }    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {      try {        write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));      } catch (org.apache.thrift.TException te) {        throw new java.io.IOException(te);      }    }    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {      try {        read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));      } catch (org.apache.thrift.TException te) {        throw new java.io.IOException(te);      }    }    private static class sayHello_resultStandardSchemeFactory implements SchemeFactory {      public sayHello_resultStandardScheme getScheme() {        return new sayHello_resultStandardScheme();      }    }    private static class sayHello_resultStandardScheme extends StandardScheme<sayHello_result> {      public void read(org.apache.thrift.protocol.TProtocol iprot, sayHello_result struct) throws org.apache.thrift.TException {        org.apache.thrift.protocol.TField schemeField;        iprot.readStructBegin();        while (true)        {          schemeField = iprot.readFieldBegin();          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {            break;          }          switch (schemeField.id) {            case 0: // SUCCESS              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {                struct.success = iprot.readString();                struct.setSuccessIsSet(true);              } else {                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);              }              break;            default:              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);          }          iprot.readFieldEnd();        }        iprot.readStructEnd();        // check for required fields of primitive type, which can‘t be checked in the validate method        struct.validate();      }      public void write(org.apache.thrift.protocol.TProtocol oprot, sayHello_result struct) throws org.apache.thrift.TException {        struct.validate();        oprot.writeStructBegin(STRUCT_DESC);        if (struct.success != null) {          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);          oprot.writeString(struct.success);          oprot.writeFieldEnd();        }        oprot.writeFieldStop();        oprot.writeStructEnd();      }    }    private static class sayHello_resultTupleSchemeFactory implements SchemeFactory {      public sayHello_resultTupleScheme getScheme() {        return new sayHello_resultTupleScheme();      }    }    private static class sayHello_resultTupleScheme extends TupleScheme<sayHello_result> {      public void write(org.apache.thrift.protocol.TProtocol prot, sayHello_result struct) throws org.apache.thrift.TException {        TTupleProtocol oprot = (TTupleProtocol) prot;        BitSet optionals = new BitSet();        if (struct.isSetSuccess()) {          optionals.set(0);        }        oprot.writeBitSet(optionals, 1);        if (struct.isSetSuccess()) {          oprot.writeString(struct.success);        }      }      public void read(org.apache.thrift.protocol.TProtocol prot, sayHello_result struct) throws org.apache.thrift.TException {        TTupleProtocol iprot = (TTupleProtocol) prot;        BitSet incoming = iprot.readBitSet(1);        if (incoming.get(0)) {          struct.success = iprot.readString();          struct.setSuccessIsSet(true);        }      }    }  }}

package ThriftTest.ThriftTest;import org.apache.thrift.TProcessor;import org.apache.thrift.protocol.TBinaryProtocol;import org.apache.thrift.protocol.TCompactProtocol;import org.apache.thrift.protocol.TJSONProtocol;import org.apache.thrift.protocol.TSimpleJSONProtocol;import org.apache.thrift.server.TServer;import org.apache.thrift.server.TSimpleServer;import org.apache.thrift.transport.TServerSocket;/** * blog http://www.micmiu.com * * @author Michael * */public class HelloServerDemo {    public static final int SERVER_PORT = 8090;    public void startServer() {        try {            System.out.println("HelloWorld TSimpleServer start ....");            TProcessor tprocessor = new HelloWorldService.Processor<HelloWorldService.Iface>(                    new HelloWorldImpl());            // HelloWorldService.Processor<HelloWorldService.Iface> tprocessor =            // new HelloWorldService.Processor<HelloWorldService.Iface>(            // new HelloWorldImpl());            // 简单的单线程服务模型，一般用于测试            TServerSocket serverTransport = new TServerSocket(SERVER_PORT);            TServer.Args tArgs = new TServer.Args(serverTransport);            tArgs.processor(tprocessor);            tArgs.protocolFactory(new TBinaryProtocol.Factory());            // tArgs.protocolFactory(new TCompactProtocol.Factory());            // tArgs.protocolFactory(new TJSONProtocol.Factory());            TServer server = new TSimpleServer(tArgs);            server.serve();        } catch (Exception e) {            System.out.println("Server start error!!!");            e.printStackTrace();        }    }    /**     * @param args     */    public static void main(String[] args) {        HelloServerDemo server = new HelloServerDemo();        server.startServer();    }}

package ThriftTest.ThriftTest;import org.apache.thrift.TException;import org.apache.thrift.protocol.TBinaryProtocol;import org.apache.thrift.protocol.TCompactProtocol;import org.apache.thrift.protocol.TJSONProtocol;import org.apache.thrift.protocol.TProtocol;import org.apache.thrift.transport.TSocket;import org.apache.thrift.transport.TTransport;import org.apache.thrift.transport.TTransportException;/** * blog http://www.micmiu.com * * @author Michael * */public class HelloClientDemo {    public static final String SERVER_IP = "localhost";    public static final int SERVER_PORT = 8090;    public static final int TIMEOUT = 30000;    /**     *     * @param userName     */    public void startClient(String userName) {        TTransport transport = null;        try {            transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT);            // 协议要和服务端一致            TProtocol protocol = new TBinaryProtocol(transport);            // TProtocol protocol = new TCompactProtocol(transport);            // TProtocol protocol = new TJSONProtocol(transport);            HelloWorldService.Client client = new HelloWorldService.Client(                    protocol);            transport.open();            String result = client.sayHello(userName);            System.out.println("Thrify client result =: " + result);        } catch (TTransportException e) {            e.printStackTrace();        } catch (TException e) {            e.printStackTrace();        } finally {            if (null != transport) {                transport.close();            }        }    }    /**     * @param args     */    public static void main(String[] args) {        HelloClientDemo client = new HelloClientDemo();        client.startClient("Michael");    }}

package ThriftTest.ThriftTest;import org.apache.thrift.TProcessor;import org.apache.thrift.protocol.TBinaryProtocol;import org.apache.thrift.server.TServer;import org.apache.thrift.server.TThreadPoolServer;import org.apache.thrift.transport.TServerSocket;/** * blog http://www.micmiu.com * * @author Michael * */public class HelloServerDemo2 {    public static final int SERVER_PORT = 8090;    public void startServer() {        try {            System.out.println("HelloWorld TThreadPoolServer start ....");            TProcessor tprocessor = new HelloWorldService.Processor<HelloWorldService.Iface>(                    new HelloWorldImpl());             TServerSocket serverTransport = new TServerSocket(SERVER_PORT);             TThreadPoolServer.Args ttpsArgs = new TThreadPoolServer.Args(             serverTransport);             ttpsArgs.processor(tprocessor);             ttpsArgs.protocolFactory(new TBinaryProtocol.Factory());            // 线程池服务模型，使用标准的阻塞式IO，预先创建一组线程处理请求。             TServer server = new TThreadPoolServer(ttpsArgs);             server.serve();        } catch (Exception e) {            System.out.println("Server start error!!!");            e.printStackTrace();        }    }    /**     * @param args     */    public static void main(String[] args) {        HelloServerDemo server = new HelloServerDemo();        server.startServer();    }}

package ThriftTest.ThriftTest;import org.apache.thrift.TProcessor;import org.apache.thrift.protocol.TCompactProtocol;import org.apache.thrift.server.TNonblockingServer;import org.apache.thrift.server.TServer;import org.apache.thrift.transport.TFramedTransport;import org.apache.thrift.transport.TNonblockingServerSocket;/** * blog http://www.micmiu.com * * @author Michael * */public class HelloServerDemo3 {    public static final int SERVER_PORT = 8090;    public void startServer() {        try {            System.out.println("HelloWorld TNonblockingServer start ....");            TProcessor tprocessor = new HelloWorldService.Processor<HelloWorldService.Iface>(                    new HelloWorldImpl());            TNonblockingServerSocket tnbSocketTransport = new TNonblockingServerSocket(                    SERVER_PORT);            TNonblockingServer.Args tnbArgs = new TNonblockingServer.Args(                    tnbSocketTransport);            tnbArgs.processor(tprocessor);            tnbArgs.transportFactory(new TFramedTransport.Factory());            tnbArgs.protocolFactory(new TCompactProtocol.Factory());            // 使用非阻塞式IO，服务端和客户端需要指定TFramedTransport数据传输的方式            TServer server = new TNonblockingServer(tnbArgs);            server.serve();        } catch (Exception e) {            System.out.println("Server start error!!!");            e.printStackTrace();        }    }    /**     * @param args     */    public static void main(String[] args) {        HelloServerDemo server = new HelloServerDemo();        server.startServer();    }}

package ThriftTest.ThriftTest;import org.apache.thrift.TException;import org.apache.thrift.protocol.TCompactProtocol;import org.apache.thrift.protocol.TProtocol;import org.apache.thrift.transport.TFramedTransport;import org.apache.thrift.transport.TSocket;import org.apache.thrift.transport.TTransport;import org.apache.thrift.transport.TTransportException;/** * blog http://www.micmiu.com * * @author Michael * */public class HelloClientDemo3 {    public static final String SERVER_IP = "localhost";    public static final int SERVER_PORT = 8090;    public static final int TIMEOUT = 30000;    /**     *     * @param userName     */    public void startClient(String userName) {        TTransport transport = null;        try {            transport = new TFramedTransport(new TSocket(SERVER_IP,                    SERVER_PORT, TIMEOUT));            // 协议要和服务端一致            TProtocol protocol = new TCompactProtocol(transport);            HelloWorldService.Client client = new HelloWorldService.Client(                    protocol);            transport.open();            String result = client.sayHello(userName);            System.out.println("Thrify client result =: " + result);        } catch (TTransportException e) {            e.printStackTrace();        } catch (TException e) {            e.printStackTrace();        } finally {            if (null != transport) {                transport.close();            }        }    }    /**     * @param args     */    public static void main(String[] args) {        HelloClientDemo client = new HelloClientDemo();        client.startClient("Michael");    }}