1024programmer Java (Transfer) Using Thrift0.9.1 to implement cross-language calls to Golang, Php, Python, and Java

(Transfer) Using Thrift0.9.1 to implement cross-language calls to Golang, Php, Python, and Java

author: admin Post: November 24, 2023 122read 0Comment

Question introduction: What is Thrift? Where is the official website of Thrift? How to implement cross-language calls between Golang, Java, Python, and PHP through Thrift? 1. What is Thrift Thrift is a scalable cross-language service development software framework. It combines a powerful software stack with a code generation engine to build services. Thrift is fac

Question introduction:
What is Thrift?
Where is the official website of Thrift?
How to implement cross-language calls between Golang, Java, Python, and PHP through Thrift?

1. What is Thrift
Thrift is a scalable cross-language service development software framework. It combines a powerful software stack with a code generation engine to build services.
Thrift was developed by Facebook. It opened source code in April 2007 and entered the Apache incubator in May 2008. Thrift was created to solve the problem of large data transmission and communication between systems in the Facebook system and the need for cross-platform features due to different language environments between systems. Therefore, thrift can support a variety of programming languages, such as: C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, Javascript, Node.js, Smalltalk, and OCaml. (The current version 0.9.1 has started Supports golang language) to communicate between multiple different languages. Thrift can be used as a binary high-performance communication middleware, supporting data (object) serialization and multiple types of RPC services.
Thrift allows you to define data types and service interfaces in a simple definition file. Taking as an input file, the compiler generates code used to easily generate RPC client and server communication for seamless cross-programming languages. In short, developers only need to prepare a thrift script and use the thrift code generator (enter a command like gcc) to generate the required development language code.

Tools similar to Thrift include Avro and protocol buffer, but compared to Thrift, they are not as comprehensive and widely used as Thrift.

1) A glance at the internal framework of thrift
According to the overall framework given in the official documentation, Thrift can be divided into 4 layers from bottom to top:
+——- ————————————+
| Server | — Server process scheduling
| (single-threaded, event-driven etc) |
+—————————— ————-+
| Processor | — RPC interface processing function distribution, the implementation of the IDL defined interface will be hooked into it
| (compiler generated) |
+————————————————+
| Protocol | — Protocol
| (JSON, compact etc) |
+——————— ——————+
| Transport | — Network transmission
| (raw TCP, HTTP etc) |
+- ——————————————+

Thrift actually implements the C/S mode. The interface definition file is used to generate server-side and client-side code (can be in different languages) through a code generation tool, thereby achieving cross-language support for the server and client. Users declare their own services in the Thirft description file. These services will be compiled to generate code files in the corresponding language. Then the user can implement the service (the client calls the service and the server provides the service). Among them, protocol (protocol layer, defines the data transmission format, which can be binary or XML, etc.) and transport (transport layer, defines the data transmission method, which can be TCP/IP transmission, memory sharing or file sharing, etc.) are used as runtime libraries.

TJSONProtocol – JSON format
TSimpleJSONProtocol – Provides a JSON write-only protocol, and the generated files are easy to parse through scripting languages.
TDebugProtocol – Use an easy-to-understand and readable text format for debugging
(b) Supported data transmission methods
TSocket – blocking socker
TFramedTransport – in frame units For transmission, used in non-blocking services.
　　TFileTransport – transfer in the form of files.
TMemoryTransport – uses memory for I/O. The java implementation actually uses a simple ByteArrayOutputStream internally.
TZlibTransport – uses zlib for compression, used in conjunction with other transmission methods. There is currently no java implementation.
　　　（c）Supported service models
　　TSimpleServer – a simple single-threaded service model, commonly used in…/p>

#View the go server and you can see the data interaction

  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
  3. –>from client Call: 1408268739272 php client map[a:idoall b:1]
  4. –>from client Call: 1408268739273 php client map[a:idoall b:2]
  5. –>from client Call: 1408268739274 php client map[a:idoall b:3]
  6. –>from client Call: 1408268739275 php client map[a:idoall b:4]
  7. –>from client Call: 1408268739275 php client map[a:idoall b:5]
  8. Stduent—>id: 1111 name:student-idoall-php sex:false age:2000


4) Interaction between java client implementation and golang server
#Install maven project management tool

  1. root@m1:/home/hadoop/thrift_demo# apt-get install maven


#Copy the Thrift package used by java to thrift_demo

  1. root@m1:/home/hadoop/thrift_demo# cp -r /home/hadoop/thrift-git/tutorial/gen-java .
  2. root@m1:/home/hadoop/thrift_demo# cd gen-java
  3. root@m1:/home/hadoop/thrift_demo/gen-java# mkdir -p src/main/java
  4. root@m1:/home/hadoop/thrift_demo/gen-java# mkdir META-INF
  5. root@m1:/home/hadoop/thrift_demo/gen-java# mkdir lib
  6. root@m1:/home/hadoop/thrift_demo/gen-java# cp -r /home/hadoop/thrift-git/lib/java/build/libthrift-0.9.1.jar ./lib/


#Write java client code

  1. root@m1:/home/hadoop/thrift_demo/gen-java# vi idoall/org/demo/c.java
  2. package idoall.org.demo;
  3. import java.util.HashMap;
  4. import java.util.List;
  5. import java.util.Map;
  6. import org.apache.thrift.TException;
  7. import org.apache.thrift.protocol.TBinaryProtocol;
  8. import org.apache.thrift.protocol.TProtocol;
  9. import org.apache.thrift.transport.TFramedTransport;
  10. import org.apache.thrift.transport.TSocket;
  11. import org.apache.thrift.transport.TTransport;
  12. import org.apache.thrift.transport.TTransportException;
  13. public class c {
  15. public static final String SERVER_IP = “m1”;
  16. public static final int SERVER_PORT = 10086;
  17. public static final int TIMEOUT = 30000;
  18. /**
  19. * @param args
  20. */
  21. public static void main(String[] args) {
  23. long startTime=System.currentTimeMillis(); //Get the start time
  24. TTransport transport = null;
  25. try {
  26. transport = new TFramedTransport(new TSocket(SERVER_IP,
  27. SERVER_PORT, TIMEOUT));
  28. //The protocol must be consistent with the server
  29. TProtocol protocol = new TBinaryProtocol(transport);
  30. idoallThrift.Client client = new idoallThrift.Client(
  31. protocol);
  32. transport.open();
  34. for(int i=1;i<6;i++)
  35. {
  36. Map m = new HashMap();
  37. m.put(“a”, “idoall”);
  38. m.put(“b”, “org”+i);
  40. List result = client.CallBack(System.currentTimeMillis(),”java client”,m);
  41. System.out.println(“JAVAClient Call->” + result);
  42. }
  44. Student s = new Student();
  45. s.sid=1111;
  46. s.sname=”student-idoall-java”;
  47. s.ssex = true;
  48. s.sage = 20000;
  49. client.put(s);
  50. long endTime = System.currentTimeMillis();
  51. System.out.println(“This call took:” + endTime + “-” + startTime + “=” + (endTime – startTime)+”milliseconds”);
  53. } catch (TTransportException e) {
  54. e.printStackTrace();
  55. } catch (TException e) {
  56. e.printStackTrace();
  57. } finally {
  58. if (null != transport) {
  59. transport.close();
  60. }
  61. }
  62. }
  63. }


#Configure the MANIFEST file of the jar package

  1. root@m1:/home/hadoop/thrift_demo/gen-java# vi META-INF/MANIFEST.MF
  2. Manifest-Version: 1.0
  3. Main-Class: idoall.org.demo.c
  4. Class-Path: lib/**.jar


#Make Maven description file pom.xml

  1. root@m1:/home/hadoop/thrift_demo/gen-java# vi pom.xml
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation=”http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd”>
  4. 4.0.0
  5. idoall.org.demo
  6. idoall.org.demo
  7. 0.0.1-SNAPSHOT
  8. jar
  9. idoall.org.demo
  10. http://maven.apache.org
  12. UTF-8
  16. junit
  17. junit
  18. 3.8.1
  19. test
  22. org.apache.thrift
  23. libthrift
  24. 0.9.1
  27. org.slf4j
  28. slf4j-log4j12
  29. 1.5.8
  35. maven-assembly-plugin
  39. idoall.org.demo.c
  43. jar-with-dependencies
  48. org.apache.maven.plugins
  49. maven-compiler-plugin
  51. 1.6
  52. 1.6


#Use the maven tool to package the relevant dependencies into the target directory of the current directory and generate idoall.org.demo-0.0.1-SNAPSHOT-jar-with-dependencies.jar

  1. root@m1:/home/hadoop/thrift_demo/gen-java# mv idoall src/main/java/
  2. root@m1:/home/hadoop/thrift_demo/gen-java# mvn assembly:assembly
  3. #Only part of the prompt information is given below
  4. [INFO] ———————————————– —————————-
  5. [INFO] BUILD SUCCESS
  6. [INFO] ———————————————– —————————-
  7. [INFO] Total time: 7.618s
  8. [INFO] Finished at: Sun Aug 17 09:36:48 CST 2014
  9. [INFO] Final Memory: 12M/29M
  10. [INFO] ———————————————– —————————-


#Run go server

  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086


#Run the packaged java client

  1. root@m1:/home/hadoop/thrift_demo/gen-java# java -jar target/idoall.org.demo-0.0.1-SNAPSHOT-jar-with-dependencies.jar
  2. JAVAClient Call->[key:idoall value:org1]
  3. JAVAClient Call->[key:idoall value:org2]
  4. JAVAClient Call->[key:idoall value:org3]
  5. JAVAClient Call->[key:idoall value:org4]
  6. JAVAClient Call->[key:idoall value:org5]
  7. This call took: 1408268973582-1408268973477=105 milliseconds


#View the go server and you can see the data interaction

  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
  3. –>from client Call: 1408268973547 java client map[a:idoall b:org1]
  4. –>from client Call: 1408268973568 java client map[b:org2 a:idoall]
  5. –>from client Call: 1408268973568 java client map[b:org3 a:idoall]
  6. –>from client Call: 1408268973568 java client map[b:org4 a:idoall]
  7. –>from client Call: 1408268973569 java client map[b:org5 a:idoall]
  8. Student—>id: 1111 name:student-idoall-java sex:true age:20000

thrift_demo.tar.gz (1.18 MB, download times: 1)
/modelVersion>

  • idoall.org.demo
  • idoall.org.demo
  • 0.0.1-SNAPSHOT
  • jar
  • idoall.org.demo
  • http://maven.apache.org
  • UTF-8
  • junit
  • junit
  • 3.8.1
  • test
  • org.apache.thrift
  • libthrift
  • 0.9.1
  • org.slf4j
  • slf4j-log4j12
  • 1.5.8
  • maven-assembly-plugin
  • idoall.org.demo.c
  • jar-with-dependencies
  • org.apache.maven.plugins
  • maven-compiler-plugin
  • 1.6
  • 1.6


  • #Use the maven tool to package the relevant dependencies into the target directory of the current directory and generate idoall.org.demo-0.0.1-SNAPSHOT-jar-with-dependencies.jar

    1. root@m1:/home/hadoop/thrift_demo/gen-java# mv idoall src/main/java/
    2. root@m1:/home/hadoop/thrift_demo/gen-java# mvn assembly:assembly
    3. #Only part of the prompt information is given below
    4. [INFO] ———————————————– —————————-
    5. [INFO] BUILD SUCCESS
    6. [INFO] ———————————————– —————————-
    7. [INFO] Total time: 7.618s
    8. [INFO] Finished at: Sun Aug 17 09:36:48 CST 2014
    9. [INFO] Final Memory: 12M/29M
    10. [INFO] ———————————————– —————————-


    #Run go server

    1. root@m1:/home/hadoop/thrift_demo# go run s.go
    2. thrift server in 0.0.0.0:10086


    #Run the packaged java client

    1. root@m1:/home/hadoop/thrift_demo/gen-java# java -jar target/idoall.org.demo-0.0.1-SNAPSHOT-jar-with-dependencies.jar
    2. JAVAClient Call->[key:idoall value:org1]
    3. JAVAClient Call->[key:idoall value:org2]
    4. JAVAClient Call->[key:idoall value:org3]
    5. JAVAClient Call->[key:idoall value:org4]
    6. JAVAClient Call->[key:idoall value:org5]
    7. This call took: 1408268973582-1408268973477=105 milliseconds


    #View the go server and you can see the data interaction

    1. root@m1:/home/hadoop/thrift_demo# go run s.go
    2. thrift server in 0.0.0.0:10086
    3. –>from client Call: 1408268973547 java client map[a:idoall b:org1]
    4. –>from client Call: 1408268973568 java client map[b:org2 a:idoall]
    5. –>from client Call: 1408268973568 java client map[b:org3 a:idoall]
    6. –>from client Call: 1408268973568 java client map[b:org4 a:idoall]
    7. –>from client Call: 1408268973569 java client map[b:org5 a:idoall]
    8. Student—>id: 1111 name:student-idoall-java sex:true age:20000

    thrift_demo.tar.gz (1.18 MB, download times: 1)

    This article is from the internet and does not represent1024programmerPosition, please indicate the source when reprinting:https://www.1024programmer.com/transfer-using-thrift0-9-1-to-implement-cross-language-calls-to-golang-php-python-and-java-5/
    Reward
    tag:

    author: admin

    Previous article
    Next article

    Related recommendations

    Leave a Reply

    Your email address will not be published. Required fields are marked *

    Contact Us

    Contact us

    181-3619-1160

    Online consultation: QQ交谈

    E-mail: 34331943@QQ.com

    Working hours: Monday to Friday, 9:00-17:30, holidays off

    Follow wechat
    Scan wechat and follow us

    Scan wechat and follow us

    Follow Weibo
    Back to top
    首页
    微信
    电话
    搜索