Golang、Php、Python、Java基于Thrift0.9.1实现跨语言调用

root@m1:/home/hadoop/thrift_demo/gen-java# vi idoall/org/demo/c.java

packageidoall.org.demo;

importjava.util.HashMap;

importjava.util.List;

importjava.util.Map;

importorg.apache.thrift.TException;

importorg.apache.thrift.protocol.TBinaryProtocol;

importorg.apache.thrift.protocol.TProtocol;

importorg.apache.thrift.transport.TFramedTransport;

importorg.apache.thrift.transport.TSocket;

importorg.apache.thrift.transport.TTransport;

importorg.apache.thrift.transport.TTransportException;

publicclassc {

    publicstaticfinalString SERVER_IP = "m1";

    publicstaticfinalintSERVER_PORT = 10086;

    publicstaticfinalintTIMEOUT = 30000;

    /**

     * @param args

     */

    publicstaticvoidmain(String[] args) {

        longstartTime=System.currentTimeMillis();   //获取开始时间

        TTransport transport = null;

        try{

            transport = newTFramedTransport(newTSocket(SERVER_IP,

                    SERVER_PORT, TIMEOUT));

            // 协议要和服务端一致

            TProtocol protocol = newTBinaryProtocol(transport);

            idoallThrift.Client client = newidoallThrift.Client(

                    protocol);

            transport.open();

            for(inti=1;i<6;i++)

            {

                Map m = newHashMap();

                m.put("a", "idoall");

                m.put("b", "org"+i);

                List result = client.CallBack(System.currentTimeMillis(),"java client",m);

                System.out.println("JAVAClient Call->"+ result);

            }

            Student s = newStudent();

            s.sid=1111;

            s.sname="student-idoall-java";

            s.ssex = true;

            s.sage = 20000;

            client.put(s);

            longendTime = System.currentTimeMillis();

            System.out.println("本次调用用时:"+ endTime + "-"+ startTime + "="+ (endTime - startTime)+"毫秒");

        } catch(TTransportException e) {

            e.printStackTrace();

        } catch(TException e) {

            e.printStackTrace();

        } finally{

            if(null!= transport) {

                transport.close();

            }

        }

    }

}