[ADD] gRPC

Author: heowc

README.md

@@ -5,4 +5,5 @@
 # Version
 
 * java 1.8
+* kotlin 1.3.31
 * spring boot 2.1.3.RELEASE

SpringBootGRpc/build.gradle

@@ -0,0 +1,63 @@
+buildscript {
+	ext {
+		springBootVersion = '2.1.3.RELEASE'
+		gRpcVersion = '0.8.8'
+	}
+	repositories {
+		mavenCentral()
+	}
+	dependencies {
+		classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
+		classpath("com.google.protobuf:protobuf-gradle-plugin:${gRpcVersion}")
+	}
+}
+
+
+plugins {
+	id "com.google.protobuf" version "0.8.8"
+	id "java"
+}
+
+apply plugin: 'java'
+apply plugin: 'eclipse'
+apply plugin: 'org.springframework.boot'
+apply plugin: 'io.spring.dependency-management'
+
+group = 'com.example'
+version = '0.0.1-SNAPSHOT'
+sourceCompatibility = 1.8
+
+repositories {
+	mavenCentral()
+}
+
+dependencies {
+	compile('org.springframework.boot:spring-boot-starter-web')
+	compile('io.github.lognet:grpc-spring-boot-starter:3.3.0')
+	compile('com.google.protobuf:protobuf-java-util:3.8.0')
+	testCompile('org.springframework.boot:spring-boot-starter-test')
+}
+
+sourceSets {
+	main {
+		java {
+			srcDirs 'build/generated/source/proto/main/java'
+			srcDirs 'build/generated/source/proto/main/grpc'
+		}
+	}
+}
+protobuf {
+	protoc {
+		path = protocPath
+	}
+	plugins {
+		grpc {
+			artifact = 'io.grpc:protoc-gen-grpc-java:1.21.0'
+		}
+	}
+	generateProtoTasks {
+		all()*.plugins {
+			grpc {}
+		}
+	}
+}

SpringBootGRpc/src/main/java/com/example/SpringBootGRpcApplication.java

@@ -0,0 +1,47 @@
+package com.example;
+
+import io.grpc.stub.StreamObserver;
+import org.lognet.springboot.grpc.GRpcService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.util.StringUtils;
+
+@SpringBootApplication
+public class SpringBootGRpcApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(SpringBootGRpcApplication.class, args);
+	}
+}
+
+@GRpcService
+class MessageSenderImpl extends MessageSenderGrpc.MessageSenderImplBase {
+
+	private static final Logger logger = LoggerFactory.getLogger(MessageSenderImpl.class);
+
+	@Override
+	public void send(MessageSenderProto.MessageRequest request, StreamObserver<MessageSenderProto.MessageResponse> responseObserver) {
+
+		logger.info("send >> request={}", request);
+
+		try {
+			if (StringUtils.isEmpty(request.getContents())) {
+				throw new IllegalArgumentException("content is empty");
+			}
+
+			MessageSenderProto.MessageResponse response = MessageSenderProto.MessageResponse.newBuilder()
+					.setStatus("success")
+					.setReason("ok")
+					.build();
+
+			responseObserver.onNext(response);
+		} catch (Exception ex) {
+			responseObserver.onError(ex);
+		} finally {
+			responseObserver.onCompleted();
+		}
+
+	}
+}

SpringBootGRpc/src/main/proto/message_sender.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+
+option java_package = "com.example";
+option java_outer_classname = "MessageSenderProto";
+
+service MessageSender {
+
+    rpc send (MessageRequest) returns (MessageResponse) {}
+}
+
+message MessageRequest {
+    string from = 2;
+    string to = 3;
+    string contents = 4;
+}
+
+message MessageResponse {
+    string status = 1;
+    string reason = 2;
+}

SpringBootGRpc/src/main/resources/application.properties

@@ -0,0 +1 @@
+grpc.port=6565

SpringBootGRpc/src/test/java/com/example/SpringBootGRpcApplicationTests.java

@@ -0,0 +1,47 @@
+package com.example;
+
+import io.grpc.ManagedChannel;
+import io.grpc.ManagedChannelBuilder;
+import io.grpc.StatusRuntimeException;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class SpringBootGRpcApplicationTests {
+
+    private static final Logger logger = LoggerFactory.getLogger(SpringBootGRpcApplicationTests.class);
+
+    private ManagedChannel channel;
+
+    @Before
+    public void init() {
+        channel = ManagedChannelBuilder.forAddress("localhost", 6565)
+                .usePlaintext()
+                .build();
+    }
+
+    @Test
+    public void test() {
+        MessageSenderGrpc.MessageSenderBlockingStub messageSenderBlockingStub = MessageSenderGrpc.newBlockingStub(channel);
+
+        MessageSenderProto.MessageRequest messageRequest = MessageSenderProto.MessageRequest.newBuilder()
+                .setFrom("wonchul")
+                .setTo("naeun")
+                .setContents("hello!")
+                .build();
+
+        try {
+            MessageSenderProto.MessageResponse messageResponse = messageSenderBlockingStub.send(messageRequest);
+            logger.info("test >> response={}", messageResponse);
+        } catch (StatusRuntimeException sr) {
+            logger.error("status={}", sr.getStatus()); // Status{code=UNKNOWN, description=null, cause=null}
+            logger.error("metadata={}", sr.getTrailers()); // Metadata(content-type=application/grpc)
+        }
+    }
+}

settings.gradle

@@ -39,6 +39,9 @@ findProject(':SpringBootException')?.name = 'spring-boot-exception'
 include 'SpringBootGracefulShutdown'
 findProject(':SpringBootGracefulShutdown')?.name = 'spring-boot-graceful-shutdown'
 
+include 'SpringBootGRpc'
+findProject(':SpringBootGRpc')?.name = 'spring-boot-grpc'
+
 include 'SpringBootHateoas'
 findProject(':SpringBootHateoas')?.name = 'spring-boot-hateoas'