Re: How to change protocol to TJSONProtocol. in apache thrift java

On Saturday, November 17, 2012 8:34:30 PM UTC+1, ankit patel wrote:


Hi,
you can do it like this:

Server side:

public class JSONThriftServer {

    final static int PORT = 9090;

    public static void startThriftServer(
            ThriftDataBenchmark.Processor<ThriftDataBenchmarkHandler> processor) {
        try {

            TServerTransport serverTransport = new TServerSocket(PORT);

            TServer server = new TSimpleServer(new Args(serverTransport)
                    .processor(processor)
                    .inputProtocolFactory(new TJSONProtocol.Factory())
                    .outputProtocolFactory(new TJSONProtocol.Factory()));

            System.out.println("JSON Thrift server started on port " + PORT
                    + "...");
            server.serve();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        startThriftServer(new ThriftDataBenchmark.Processor<ThriftDataBenchmarkHandler>(
                new ThriftDataBenchmarkHandler()));
    }

}

Client side:

            TTransport transport;

            transport = new TSocket(endPoint, serverPort);
            transport.open();

            TProtocol protocol = new TJSONProtocol(transport);

            ThriftDataBenchmark.Client client = new ThriftDataBenchmark.Client(
                    protocol);

Hope this helps,
Antony