Groups | Search | Server Info | Keyboard shortcuts | Login | Register [http] [https] [nntp] [nntps]

Groups > comp.lang.java.programmer > #27621

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

Show all headers | View raw

On Saturday, November 17, 2012 8:34:30 PM UTC+1, ankit patel wrote:
> Please help me i want to change my java api transport protocol from binary to json.
> 
> so that it can be tested by cUrl.

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

Back to comp.lang.java.programmer | Previous | Next | Find similar | Unroll thread

Thread

Re: How to change protocol to TJSONProtocol. in apache thrift java mrantonindanek@gmail.com - 2014-02-28 14:31 -0800

csiph-web