添加基于Thrift的RPC调用方式

Author: zihong

.gitignore

@@ -1,7 +1,9 @@
+HELP.md
 .gradle
-/build/
+build/
 !gradle/wrapper/gradle-wrapper.jar
-/gradle/
+!**/src/main/**
+!**/src/test/**
 
 ### STS ###
 .apt_generated
@@ -17,11 +19,14 @@
 *.iws
 *.iml
 *.ipr
-/out/
+out/
 
 ### NetBeans ###
 /nbproject/private/
 /nbbuild/
 /dist/
 /nbdist/
-/.nb-gradle/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/

README.md

@@ -125,5 +125,21 @@ SpringBoot 使用Nsq消息中间件，此项目为消息消费者例子。
 ### SpringBoot-Nacos-Config
 使用Nacos注册中心实现动态配置
 
+### SpringBoot-SpringSecurity
+SpringBoot 基于Spring-Security实现资源的权限控制  
+[SpringBoot2 集成SpringSecurity对资源访问认证](https://blog.csdn.net/qq_39211866/article/details/90273681)
+
+### SpringBoot-Oauth2
+SpringBoot 基于Oauth2授权协议实现简化、密码、客户端模式.
+
+### SpringBoot-Oauth2-Code
+SpringBoot 基于Oauth2授权协议实现完整的授权码登录流程.
+
+### SpringBoot-Test-Starter
+SpringBoot 自动配置例子，了解SpringBoot的Starter原理。
+
+### SpringBoot-Builder-Docker
+SpringBoot 使用Gradle做依赖管理时，配置打包docker镜像的DEMO   
+
 ### SpringBoot-Utils
 各项目的依赖模块，存放一些工具类

SpringBoot-Thrift-Client/.gitignore

@@ -0,0 +1,32 @@
+HELP.md
+.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**
+!**/src/test/**
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+out/
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/

SpringBoot-Thrift-Client/build.gradle

@@ -0,0 +1,5 @@
+dependencies {
+    compile project(':SpringBoot-Utils')
+    compile 'org.apache.thrift:libthrift:0.12.0'
+    testCompile('org.springframework.boot:spring-boot-starter-test:2.0.4.RELEASE')
+}

SpringBoot-Thrift-Client/src/main/java/com/dashuai/learning/thrift/ThriftClientApplication.java

@@ -0,0 +1,13 @@
+package com.dashuai.learning.thrift;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ThriftClientApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ThriftClientApplication.class, args);
+    }
+
+}

SpringBoot-Thrift-Client/src/main/java/com/dashuai/learning/thrift/api/RPCThriftController.java

@@ -0,0 +1,33 @@
+package com.dashuai.learning.thrift.api;
+
+import com.dashuai.learning.thrift.client.RPCThriftClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+@RestController
+@RequestMapping("/test")
+public class RPCThriftController {
+    private final Logger logger = LoggerFactory.getLogger(RPCThriftController.class);
+    @Autowired
+    RPCThriftClient rpcThriftClient;
+
+    @RequestMapping(value = "/thrift", method = RequestMethod.GET)
+    public String thriftTest(HttpServletRequest request, HttpServletResponse response) {
+        try {
+            rpcThriftClient.open();
+            return rpcThriftClient.getRPCThriftService().getDate("大帥");
+        } catch (Exception e) {
+            logger.error("RPC调用失败", e);
+            return "error";
+        } finally {
+            rpcThriftClient.close();
+        }
+    }
+}

SpringBoot-Thrift-Client/src/main/java/com/dashuai/learning/thrift/client/RPCThriftClient.java

@@ -0,0 +1,45 @@
+package com.dashuai.learning.thrift.client;
+
+import com.dashuai.learning.thrift.service.RPCDateService;
+import org.apache.thrift.protocol.TBinaryProtocol;
+import org.apache.thrift.transport.TSocket;
+import org.apache.thrift.transport.TTransportException;
+
+public class RPCThriftClient {
+    private RPCDateService.Client client;
+    private TBinaryProtocol protocol;
+    private TSocket transport;
+    private String host;
+    private int port;
+
+    public String getHost() {
+        return host;
+    }
+    public void setHost(String host) {
+        this.host = host;
+    }
+    public int getPort() {
+        return port;
+    }
+    public void setPort(int port) {
+        this.port = port;
+    }
+
+    public void init() {
+        transport = new TSocket(host, port);
+        protocol = new TBinaryProtocol(transport);
+        client = new RPCDateService.Client(protocol);
+    }
+
+    public RPCDateService.Client getRPCThriftService() {
+        return client;
+    }
+
+    public void open() throws TTransportException {
+        transport.open();
+    }
+
+    public void close() {
+        transport.close();
+    }
+}

SpringBoot-Thrift-Client/src/main/java/com/dashuai/learning/thrift/config/RPCThriftClientConfig.java

@@ -0,0 +1,23 @@
+package com.dashuai.learning.thrift.config;
+
+import com.dashuai.learning.thrift.client.RPCThriftClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RPCThriftClientConfig {
+    @Value("${thrift.host}")
+    private String host;
+    @Value("${thrift.port}")
+    private int port;
+
+    @Bean(initMethod = "init")
+    public RPCThriftClient rpcThriftClient() {
+        RPCThriftClient rpcThriftClient = new RPCThriftClient();
+        rpcThriftClient.setHost(host);
+        rpcThriftClient.setPort(port);
+        return rpcThriftClient;
+    }
+
+}