使用Java过程中源码记录

package cicada.authorization.config; /** * Autogenerated by Thrift Compiler (0.9.3) * * 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.3)", date = "2016-09-05") public class UserSessionService { public interface Iface { public CreateSessionRet CreateSession(String userId) throws TException; public GetUserIdRet GetUserId(String sessionId) throws TException; public RemoveSessionStatus RemoveSession(String sessionId) throws TException; } public interface AsyncIface { public void CreateSession(String userId, AsyncMethodCallback resultHandler) throws TException; public void GetUserId(String sessionId, AsyncMethodCallback resultHandler) throws TException; public void RemoveSession(String sessionId, AsyncMethodCallback resultHandler) throws 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 CreateSessionRet CreateSession(String userId) throws TException { send_CreateSession(userId); return recv_CreateSession(); } public void send_CreateSession(String userId) throws TException { CreateSession_args args = new CreateSession_args(); args.setUserId(userId); sendBase("CreateSession", args); } public CreateSessionRet recv_CreateSession() throws TException { CreateSession_result result = new CreateSession_result(); receiveBase(result, "CreateSession"); if (result.isSetSuccess()) { return result.success; } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "CreateSession failed: unknown result"); } public GetUserIdRet GetUserId(String sessionId) throws TException { send_GetUserId(sessionId); return recv_GetUserId(); } public void send_GetUserId(String sessionId) throws TException { GetUserId_args args = new GetUserId_args(); args.setSessionId(sessionId); sendBase("GetUserId", args); } public GetUserIdRet recv_GetUserId() throws TException { GetUserId_result result = new GetUserId_result(); receiveBase(result, "GetUserId"); if (result.isSetSuccess()) { return result.success; } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetUserId failed: unknown result"); } public RemoveSessionStatus RemoveSession(String sessionId) throws TException { send_RemoveSession(sessionId); return recv_RemoveSession(); } public void send_RemoveSession(String sessionId) throws TException { RemoveSession_args args = new RemoveSession_args(); args.setSessionId(sessionId); sendBase("RemoveSession", args); } public RemoveSessionStatus recv_RemoveSession() throws TException { RemoveSession_result result = new RemoveSession_result(); receiveBase(result, "RemoveSession"); if (result.isSetSuccess()) { return result.success; } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "RemoveSession 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 CreateSession(String userId, AsyncMethodCallback resultHandler) throws TException { checkReady(); CreateSession_call method_call = new CreateSession_call(userId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class CreateSession_call extends org.apache.thrift.async.TAsyncMethodCall { private String userId; public CreateSession_call(String userId, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.userId = userId; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("CreateSession", org.apache.thrift.protocol.TMessageType.CALL, 0)); CreateSession_args args = new CreateSession_args(); args.setUserId(userId); args.write(prot); prot.writeMessageEnd(); } public CreateSessionRet getResult() throws TException { if (getState() != 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_CreateSession(); } } public void GetUserId(String sessionId, AsyncMethodCallback resultHandler) throws TException { checkReady(); GetUserId_call method_call = new GetUserId_call(sessionId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call;