Spring 7.X (Spring Boot 4.X) gRPC 1.0.0 정식 릴리즈 그리고 gRPC 사용법

<dependencyManagement>
	<dependencies>
		<dependency>
			<groupId>org.springframework.grpc</groupId>
			<artifactId>spring-grpc-dependencies</artifactId>
			<version>0.12.0</version>
			<type>pom</type>
			<scope>import</scope>
		</dependency>
	</dependencies>
</dependencyManagement>
<dependencies>
	<dependency>
		<groupId>org.springframework.grpc</groupId>
		<artifactId>spring-grpc-spring-boot-starter</artifactId>
	</dependency>
...

<dependencyManagement>
	<dependencies>
		<dependency>
			<groupId>org.springframework.grpc</groupId>
			<artifactId>spring-grpc-dependencies</artifactId>
			<version>0.12.0</version>
			<type>pom</type>
			<scope>import</scope>
		</dependency>
	</dependencies>
</dependencyManagement>
<dependencies>
	<dependency>
		<groupId>org.springframework.grpc</groupId>
		<artifactId>spring-grpc-spring-boot-starter</artifactId>
	</dependency>
...

dependencyManagement {
    imports {
        mavenBom 'org.springframework.grpc:spring-grpc-dependencies:0.12.0'
    }
}
dependencies {
    implementation 'org.springframework.grpc:spring-grpc-spring-boot-starter'
...

dependencyManagement {
    imports {
        mavenBom 'org.springframework.grpc:spring-grpc-dependencies:0.12.0'
    }
}
dependencies {
    implementation 'org.springframework.grpc:spring-grpc-spring-boot-starter'
...

pluginManagement {
    repositories {
        gradlePluginPortal()
        mavenCentral()
    }

    // ✨ 여기서 버전을 정의하면, 프로젝트 내 모든 build.gradle에서 버전 생략 가능!
    plugins {
        id 'com.google.protobuf' version '0.9.5'
        id 'io.spring.dependency-management' version '1.1.7'
        id 'org.springframework.boot' version '4.0.0'
        id 'java-library' // 코어 플러그인은 버전 불필요
        id 'java'
    }
}

rootProject.name = 'spring-boot-grpc'

include 'grpc-server'
include 'grpc-client'
include 'grpc-interface'

pluginManagement {
    repositories {
        gradlePluginPortal()
        mavenCentral()
    }

    // ✨ 여기서 버전을 정의하면, 프로젝트 내 모든 build.gradle에서 버전 생략 가능!
    plugins {
        id 'com.google.protobuf' version '0.9.5'
        id 'io.spring.dependency-management' version '1.1.7'
        id 'org.springframework.boot' version '4.0.0'
        id 'java-library' // 코어 플러그인은 버전 불필요
        id 'java'
    }
}

rootProject.name = 'spring-boot-grpc'

include 'grpc-server'
include 'grpc-client'
include 'grpc-interface'

plugins {
    id 'java'
    id 'java-library'
    id 'org.springframework.boot' apply false
    id 'io.spring.dependency-management' apply false
    // Protobuf 컴파일 플러그인
    id 'com.google.protobuf' apply false
}

// 모든 submodule에서 사용하기 위한 설정
subprojects {
    apply plugin: 'java'
    group = 'org.example'
    version = '0.0.1-SNAPSHOT'
    java {
        toolchain {
            languageVersion = JavaLanguageVersion.of(17)
        }
    }

    repositories {
        mavenCentral()
    }
}
description = 'spring-boot-grpc-1.0.0'

// [조건부 적용] grpc-server나 grpc-client 모듈에만 적용 (interface 제외!)
configure(subprojects.findAll { it.name.contains('server') || it.name.contains('client') }) {

    apply plugin: 'org.springframework.boot'
    apply plugin: 'io.spring.dependency-management'

    configurations {
        compileOnly {
            extendsFrom annotationProcessor
        }
    }

    ext {
        set('springGrpcVersion', "1.0.0")
    }

    dependencyManagement {
        imports {
            mavenBom "org.springframework.grpc:spring-grpc-dependencies:${springGrpcVersion}"
            mavenBom "org.springframework.boot:spring-boot-dependencies:4.0.0"
        }
    }

    dependencies {
        // grpc-server와 grpc-client모두 grpc-interface를 공통으로 사용해야 하므로 반드시 포함해야 한다.
        implementation project(':grpc-interface')
        developmentOnly 'org.springframework.boot:spring-boot-devtools'
        compileOnly 'org.projectlombok:lombok'
        annotationProcessor 'org.projectlombok:lombok'
        testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
        annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
        testImplementation 'org.springframework.boot:spring-boot-starter-test'
        implementation 'org.springframework.grpc:spring-grpc-spring-boot-starter'
        testImplementation 'org.springframework.grpc:spring-grpc-test'
    }

    tasks.named('test') {
        useJUnitPlatform()
    }
}

plugins {
    id 'java'
    id 'java-library'
    id 'org.springframework.boot' apply false
    id 'io.spring.dependency-management' apply false
    // Protobuf 컴파일 플러그인
    id 'com.google.protobuf' apply false
}

// 모든 submodule에서 사용하기 위한 설정
subprojects {
    apply plugin: 'java'
    group = 'org.example'
    version = '0.0.1-SNAPSHOT'
    java {
        toolchain {
            languageVersion = JavaLanguageVersion.of(17)
        }
    }

    repositories {
        mavenCentral()
    }
}
description = 'spring-boot-grpc-1.0.0'

// [조건부 적용] grpc-server나 grpc-client 모듈에만 적용 (interface 제외!)
configure(subprojects.findAll { it.name.contains('server') || it.name.contains('client') }) {

    apply plugin: 'org.springframework.boot'
    apply plugin: 'io.spring.dependency-management'

    configurations {
        compileOnly {
            extendsFrom annotationProcessor
        }
    }

    ext {
        set('springGrpcVersion', "1.0.0")
    }

    dependencyManagement {
        imports {
            mavenBom "org.springframework.grpc:spring-grpc-dependencies:${springGrpcVersion}"
            mavenBom "org.springframework.boot:spring-boot-dependencies:4.0.0"
        }
    }

    dependencies {
        // grpc-server와 grpc-client모두 grpc-interface를 공통으로 사용해야 하므로 반드시 포함해야 한다.
        implementation project(':grpc-interface')
        developmentOnly 'org.springframework.boot:spring-boot-devtools'
        compileOnly 'org.projectlombok:lombok'
        annotationProcessor 'org.projectlombok:lombok'
        testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
        annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
        testImplementation 'org.springframework.boot:spring-boot-starter-test'
        implementation 'org.springframework.grpc:spring-grpc-spring-boot-starter'
        testImplementation 'org.springframework.grpc:spring-grpc-test'
    }

    tasks.named('test') {
        useJUnitPlatform()
    }
}

# grpc-server의 build.gradle
description = 'grpc-server'

# grpc-client의 build.gradle
description = 'grpc-client'

# grpc-server의 build.gradle
description = 'grpc-server'

# grpc-client의 build.gradle
description = 'grpc-client'

plugins {
    id 'java-library'
    id 'io.spring.dependency-management'
    // Protobuf 컴파일 플러그인
    id 'com.google.protobuf'
}

description = 'grpc-interface'

// 앞서 언급했듯이 Spring gRPC 0.12.0을 사용하고 있었다면 1.0.0으로 버전만 변경해 주면 된다.
ext {
    set('springGrpcVersion', "1.0.0")
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.grpc:spring-grpc-dependencies:${springGrpcVersion}"
    }
}

dependencies {
    // Protobuf 메시지 (Message) 지원
    // (.proto의 message가 변환된 자바 클래스가 상속받는 기본 클래스들)
    api 'com.google.protobuf:protobuf-java'

    // gRPC 스텁 (Stub) 지원
    // (Service가 변환된 Stub 코드가 의존하는 gRPC 핵심 기능)
    api 'io.grpc:grpc-stub'

    // Protobuf와 gRPC 연결
    // (Protobuf 객체를 gRPC 통신으로 직렬화/역직렬화하는 기능)
    api 'io.grpc:grpc-protobuf'

    // 어노테이션 지원 (@Generated 등 생성된 코드에 붙음)
    implementation 'javax.annotation:javax.annotation-api:1.3.2'
}

// .proto 파일을 자바 코드로 변환해 주기 위한 설정
protobuf {
    // protobuf 컴파일러(protoc) 다운로드
    protoc {
        artifact = "com.google.protobuf:protoc"
    }
    // service/stub 클래스 파일 생성을 위한 플러그인 추가
    plugins {
        grpc {
            artifact = "io.grpc:protoc-gen-grpc-java"
        }
    }
    generateProtoTasks {
        all()*.plugins {
            grpc {
                option '@generated=omit'
            }
        }
    }
}

plugins {
    id 'java-library'
    id 'io.spring.dependency-management'
    // Protobuf 컴파일 플러그인
    id 'com.google.protobuf'
}

description = 'grpc-interface'

// 앞서 언급했듯이 Spring gRPC 0.12.0을 사용하고 있었다면 1.0.0으로 버전만 변경해 주면 된다.
ext {
    set('springGrpcVersion', "1.0.0")
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.grpc:spring-grpc-dependencies:${springGrpcVersion}"
    }
}

dependencies {
    // Protobuf 메시지 (Message) 지원
    // (.proto의 message가 변환된 자바 클래스가 상속받는 기본 클래스들)
    api 'com.google.protobuf:protobuf-java'

    // gRPC 스텁 (Stub) 지원
    // (Service가 변환된 Stub 코드가 의존하는 gRPC 핵심 기능)
    api 'io.grpc:grpc-stub'

    // Protobuf와 gRPC 연결
    // (Protobuf 객체를 gRPC 통신으로 직렬화/역직렬화하는 기능)
    api 'io.grpc:grpc-protobuf'

    // 어노테이션 지원 (@Generated 등 생성된 코드에 붙음)
    implementation 'javax.annotation:javax.annotation-api:1.3.2'
}

// .proto 파일을 자바 코드로 변환해 주기 위한 설정
protobuf {
    // protobuf 컴파일러(protoc) 다운로드
    protoc {
        artifact = "com.google.protobuf:protoc"
    }
    // service/stub 클래스 파일 생성을 위한 플러그인 추가
    plugins {
        grpc {
            artifact = "io.grpc:protoc-gen-grpc-java"
        }
    }
    generateProtoTasks {
        all()*.plugins {
            grpc {
                option '@generated=omit'
            }
        }
    }
}

syntax = "proto3";

// Protobuf 스펙상 패키지 경로
package org.example.grpcinterface;

// [Java 옵션 설정]
// 1. 파일을 각각 분리해서 생성 (필수 권장)
option java_multiple_files = true;
// 2. 생성될 Java 파일의 패키지 경로 (위의 package 정의 보다 이 설정이 우선한다!!)
option java_package = "org.example.grpcinterface";
// 3. (선택) Outer Class 이름 지정 (java_multiple_files=false일 때 주로 씀)
option java_outer_classname = "SimpleProto";

// 서비스 정의 (Interface)
service SimpleService {
  // 요청(HelloRequest)을 받아서 응답(HelloReply)을 반환하는 메소드
  rpc SayHello (HelloRequest) returns (HelloReply);
}

// 요청 메시지 (DTO)
message HelloRequest {
  string name = 1; // 1번 필드
}

// 응답 메시지 (DTO)
message HelloReply {
  string message = 1; // 1번 필드
}

syntax = "proto3";

// Protobuf 스펙상 패키지 경로
package org.example.grpcinterface;

// [Java 옵션 설정]
// 1. 파일을 각각 분리해서 생성 (필수 권장)
option java_multiple_files = true;
// 2. 생성될 Java 파일의 패키지 경로 (위의 package 정의 보다 이 설정이 우선한다!!)
option java_package = "org.example.grpcinterface";
// 3. (선택) Outer Class 이름 지정 (java_multiple_files=false일 때 주로 씀)
option java_outer_classname = "SimpleProto";

// 서비스 정의 (Interface)
service SimpleService {
  // 요청(HelloRequest)을 받아서 응답(HelloReply)을 반환하는 메소드
  rpc SayHello (HelloRequest) returns (HelloReply);
}

// 요청 메시지 (DTO)
message HelloRequest {
  string name = 1; // 1번 필드
}

// 응답 메시지 (DTO)
message HelloReply {
  string message = 1; // 1번 필드
}

syntax = "proto3";

package org.example.grpcinterface;

option java_multiple_files = true;
option java_package = "org.example.grpcinterface";
option java_outer_classname = "FileUploadProto";

service FileUploadService {
  // stream이 Request 쪽에 붙어 있다. (클라이언트가 계속 보낸다는 의미)
  rpc UploadFile( stream FileUploadRequest ) returns ( FileUploadResponse );
}

message FileUploadRequest {
  //oneof: 둘 중 하나만 담아서 보낸다.
  oneof request {
    FileInfo info = 1;          // 첫 번째 메시지 용 (파일 메타 정보)
    bytes chunk_data = 2;       // chunked file data
  }
}

message FileInfo {
  string file_name = 1;
  string file_type = 2;
}

message FileUploadResponse {
  string file_name = 1;
  string status = 2;
  int64 total_size = 3;
}

syntax = "proto3";

package org.example.grpcinterface;

option java_multiple_files = true;
option java_package = "org.example.grpcinterface";
option java_outer_classname = "FileUploadProto";

service FileUploadService {
  // stream이 Request 쪽에 붙어 있다. (클라이언트가 계속 보낸다는 의미)
  rpc UploadFile( stream FileUploadRequest ) returns ( FileUploadResponse );
}

message FileUploadRequest {
  //oneof: 둘 중 하나만 담아서 보낸다.
  oneof request {
    FileInfo info = 1;          // 첫 번째 메시지 용 (파일 메타 정보)
    bytes chunk_data = 2;       // chunked file data
  }
}

message FileInfo {
  string file_name = 1;
  string file_type = 2;
}

message FileUploadResponse {
  string file_name = 1;
  string status = 2;
  int64 total_size = 3;
}

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GrpcClientConfig {
    // 채널(Connection) 빈 생성
    @Bean
    public ManagedChannel simpleChannel() {
        // application.yml의 설정을 가져와서 쓸 수도 있지만,
        // 1.0.0 초기 설정에서는 명시적으로 빌더를 쓰는 것이 확실하다.
        return ManagedChannelBuilder.forAddress("localhost", 9090)
                .usePlaintext() // 개발용: 평문 통신
                .build();
    }

    // Simple 스텁(Stub) 빈 생성
    @Bean
    public SimpleServiceGrpc.SimpleServiceStub simpleStub( ManagedChannel channel) {
        return SimpleServiceGrpc.newStub(channel);
    }
}

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GrpcClientConfig {
    // 채널(Connection) 빈 생성
    @Bean
    public ManagedChannel simpleChannel() {
        // application.yml의 설정을 가져와서 쓸 수도 있지만,
        // 1.0.0 초기 설정에서는 명시적으로 빌더를 쓰는 것이 확실하다.
        return ManagedChannelBuilder.forAddress("localhost", 9090)
                .usePlaintext() // 개발용: 평문 통신
                .build();
    }

    // Simple 스텁(Stub) 빈 생성
    @Bean
    public SimpleServiceGrpc.SimpleServiceStub simpleStub( ManagedChannel channel) {
        return SimpleServiceGrpc.newStub(channel);
    }
}

import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.HelloReply;
import org.example.grpcinterface.HelloRequest;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import java.util.concurrent.CompletableFuture;

@Component
public class SimpleRunner implements CommandLineRunner {
    private final SimpleServiceGrpc.SimpleServiceStub simpleStub;

    public SimpleRunner( SimpleServiceGrpc.SimpleServiceStub simpleStub ) {
        this.simpleStub = simpleStub;
    }

    @Override
    public void run( String... args ) {
        System.out.println( "start simple runner" );
        CompletableFuture<String> future = new CompletableFuture<>();

        // 1. 요청 객체 생성 (Builder 패턴)
        HelloRequest request = HelloRequest.newBuilder()
                .setName("Grpc Developer")
                .build();

        // 2. gRPC 호출 (마치 로컬 메소드 부르듯이!)
        // 여기서 네트워크 통신이 일어난다.
        simpleStub.sayHello( request, new StreamObserver<>() {
            @Override
            public void onNext( HelloReply value ) {
                future.complete( value.getMessage() );
            }

            @Override
            public void onError( Throwable t ) {
                future.completeExceptionally( t );
            }

            @Override
            public void onCompleted() {
            }
        } );

        future.whenComplete( ( resp, err ) -> {
            if ( err != null ) {
                System.out.println("simple service error: " + err.getMessage());
            }
            else {
                System.out.println("simple service response: " + resp);
            }
        });

        future.join();
    }
}

import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.HelloReply;
import org.example.grpcinterface.HelloRequest;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import java.util.concurrent.CompletableFuture;

@Component
public class SimpleRunner implements CommandLineRunner {
    private final SimpleServiceGrpc.SimpleServiceStub simpleStub;

    public SimpleRunner( SimpleServiceGrpc.SimpleServiceStub simpleStub ) {
        this.simpleStub = simpleStub;
    }

    @Override
    public void run( String... args ) {
        System.out.println( "start simple runner" );
        CompletableFuture<String> future = new CompletableFuture<>();

        // 1. 요청 객체 생성 (Builder 패턴)
        HelloRequest request = HelloRequest.newBuilder()
                .setName("Grpc Developer")
                .build();

        // 2. gRPC 호출 (마치 로컬 메소드 부르듯이!)
        // 여기서 네트워크 통신이 일어난다.
        simpleStub.sayHello( request, new StreamObserver<>() {
            @Override
            public void onNext( HelloReply value ) {
                future.complete( value.getMessage() );
            }

            @Override
            public void onError( Throwable t ) {
                future.completeExceptionally( t );
            }

            @Override
            public void onCompleted() {
            }
        } );

        future.whenComplete( ( resp, err ) -> {
            if ( err != null ) {
                System.out.println("simple service error: " + err.getMessage());
            }
            else {
                System.out.println("simple service response: " + resp);
            }
        });

        future.join();
    }
}

import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.HelloReply;
import org.example.grpcinterface.HelloRequest;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.stereotype.Service;

@Service
public class GrpcSimpleService extends SimpleServiceGrpc.SimpleServiceImplBase {
    @Override
    public void sayHello( HelloRequest request, StreamObserver<HelloReply> responseObserver) {
        // 1. 요청 값(request)에서 이름 꺼내기
        String name = request.getName();
        String message = "Hello, " + name + "! Welcome to Spring gRPC 1.0 world.";

        // 2. 응답 객체(Reply) 빌더 패턴으로 생성
        HelloReply reply = HelloReply.newBuilder()
                .setMessage(message)
                .build();

        // 3. 클라이언트에게 응답 보내기
        responseObserver.onNext(reply);

        // 4. 응답 끝났음을 알림 (필수!)
        responseObserver.onCompleted();
    }
}

import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.HelloReply;
import org.example.grpcinterface.HelloRequest;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.stereotype.Service;

@Service
public class GrpcSimpleService extends SimpleServiceGrpc.SimpleServiceImplBase {
    @Override
    public void sayHello( HelloRequest request, StreamObserver<HelloReply> responseObserver) {
        // 1. 요청 값(request)에서 이름 꺼내기
        String name = request.getName();
        String message = "Hello, " + name + "! Welcome to Spring gRPC 1.0 world.";

        // 2. 응답 객체(Reply) 빌더 패턴으로 생성
        HelloReply reply = HelloReply.newBuilder()
                .setMessage(message)
                .build();

        // 3. 클라이언트에게 응답 보내기
        responseObserver.onNext(reply);

        // 4. 응답 끝났음을 알림 (필수!)
        responseObserver.onCompleted();
    }
}

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GrpcClientConfig {
    // 채널(Connection) 빈 생성
    @Bean
    public ManagedChannel simpleChannel() {
        // application.yml의 설정을 가져와서 쓸 수도 있지만,
        // 1.0.0 초기 설정에서는 명시적으로 빌더를 쓰는 것이 확실하다.
        return ManagedChannelBuilder.forAddress("localhost", 9090)
                .usePlaintext() // 개발용: 평문 통신
                .build();
    }

    // FileUpload 스텁(Stub) 빈 생성
    @Bean
    public FileUploadServiceGrpc.FileUploadServiceStub fileUploadStub( ManagedChannel channel) {
        return FileUploadServiceGrpc.newStub(channel);
    }
}

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.example.grpcinterface.SimpleServiceGrpc;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GrpcClientConfig {
    // 채널(Connection) 빈 생성
    @Bean
    public ManagedChannel simpleChannel() {
        // application.yml의 설정을 가져와서 쓸 수도 있지만,
        // 1.0.0 초기 설정에서는 명시적으로 빌더를 쓰는 것이 확실하다.
        return ManagedChannelBuilder.forAddress("localhost", 9090)
                .usePlaintext() // 개발용: 평문 통신
                .build();
    }

    // FileUpload 스텁(Stub) 빈 생성
    @Bean
    public FileUploadServiceGrpc.FileUploadServiceStub fileUploadStub( ManagedChannel channel) {
        return FileUploadServiceGrpc.newStub(channel);
    }
}

import com.google.protobuf.ByteString;
import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.FileInfo;
import org.example.grpcinterface.FileUploadRequest;
import org.example.grpcinterface.FileUploadResponse;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.io.ClassPathResource;
import org.springframework.stereotype.Component;

import java.io.InputStream;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.concurrent.CompletableFuture;

@Component
public class FileUploadRunner implements CommandLineRunner {
    private final FileUploadServiceGrpc.FileUploadServiceStub fileUploadServiceStub;

    public FileUploadRunner( FileUploadServiceGrpc.FileUploadServiceStub fileUploadServiceStub ) {
        this.fileUploadServiceStub = fileUploadServiceStub;
    }

    @Override
    public void run( String... args ) throws Exception {
        System.out.println( "start file upload runner");
        CompletableFuture<String> future = new CompletableFuture<>();

        // 응답을 받을 Observer 정의
        StreamObserver<FileUploadResponse> responseObserver = new StreamObserver<>() {
            // 서버 응답 처리
            @Override
            public void onNext( FileUploadResponse fileUploadResponse ) {
                System.out.println( "---- 서버 응답 시작 ----" );
                System.out.println( "파일명: " + fileUploadResponse.getFileName() );
                System.out.println( "상태: " + fileUploadResponse.getStatus() );
                System.out.println( "파일크기: " + fileUploadResponse.getTotalSize() + " bytes" );
                System.out.println( "---- 서버 응답 끝 ----" );
            }

            //서버에서 에러 발생시 처리
            @Override
            public void onError( Throwable t ) {
                future.completeExceptionally( t );
            }

            //통신 완료 처리
            @Override
            public void onCompleted() {
                future.complete( "파일 업로드 완료!!" );
            }
        };

        // 서버의 리모컨을 전달 받고 서버에게 나의 리모컨을 전달하기
        StreamObserver<FileUploadRequest> requestObserver = fileUploadServiceStub.uploadFile( responseObserver );

        // 업로드 파일에 대한 메타데이터 전송
        ClassPathResource resource = new ClassPathResource( "test-image.jpg" );
        Path path = Paths.get( "src/main/resources/test-image.jpg");
        FileInfo fileInfo = FileInfo.newBuilder()
                .setFileName( resource.getFilePath().getFileName().toString() )
                .setFileType( "image/jpg" )
                .build();

        FileUploadRequest fileUploadRequest = FileUploadRequest.newBuilder()
                .setInfo( fileInfo )
                .build();

        requestObserver.onNext( fileUploadRequest );


        // file chunked data 전송
        try ( InputStream fis = resource.getInputStream() ) {
            //64kb씩 전송
            byte[] buffer = new byte[ 1024 * 64 ];
            int byteRead;
            while ( ( byteRead = fis.read( buffer ) ) != -1 ) {
                // ByteString으로 변환하여 전송
                FileUploadRequest chunkRequest = FileUploadRequest.newBuilder()
                        .setChunkData( ByteString.copyFrom( buffer, 0, byteRead) )
                        .build();

                requestObserver.onNext( chunkRequest );
            }

            //전송 끝 알림
            requestObserver.onCompleted();
        }
        catch (  Exception e ) {
            //예외 발생시 서버로 에러 전달
            requestObserver.onError( e );
            future.completeExceptionally( e );
        }

        future.whenComplete( (result, throwable) -> {
            if ( throwable != null ) {
                System.out.println("에러 발생: " +  throwable.getMessage());
            }
            else {
                System.out.println(result);
            }
        } );

        future.join();
    }
}

import com.google.protobuf.ByteString;
import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.FileInfo;
import org.example.grpcinterface.FileUploadRequest;
import org.example.grpcinterface.FileUploadResponse;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.io.ClassPathResource;
import org.springframework.stereotype.Component;

import java.io.InputStream;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.concurrent.CompletableFuture;

@Component
public class FileUploadRunner implements CommandLineRunner {
    private final FileUploadServiceGrpc.FileUploadServiceStub fileUploadServiceStub;

    public FileUploadRunner( FileUploadServiceGrpc.FileUploadServiceStub fileUploadServiceStub ) {
        this.fileUploadServiceStub = fileUploadServiceStub;
    }

    @Override
    public void run( String... args ) throws Exception {
        System.out.println( "start file upload runner");
        CompletableFuture<String> future = new CompletableFuture<>();

        // 응답을 받을 Observer 정의
        StreamObserver<FileUploadResponse> responseObserver = new StreamObserver<>() {
            // 서버 응답 처리
            @Override
            public void onNext( FileUploadResponse fileUploadResponse ) {
                System.out.println( "---- 서버 응답 시작 ----" );
                System.out.println( "파일명: " + fileUploadResponse.getFileName() );
                System.out.println( "상태: " + fileUploadResponse.getStatus() );
                System.out.println( "파일크기: " + fileUploadResponse.getTotalSize() + " bytes" );
                System.out.println( "---- 서버 응답 끝 ----" );
            }

            //서버에서 에러 발생시 처리
            @Override
            public void onError( Throwable t ) {
                future.completeExceptionally( t );
            }

            //통신 완료 처리
            @Override
            public void onCompleted() {
                future.complete( "파일 업로드 완료!!" );
            }
        };

        // 서버의 리모컨을 전달 받고 서버에게 나의 리모컨을 전달하기
        StreamObserver<FileUploadRequest> requestObserver = fileUploadServiceStub.uploadFile( responseObserver );

        // 업로드 파일에 대한 메타데이터 전송
        ClassPathResource resource = new ClassPathResource( "test-image.jpg" );
        Path path = Paths.get( "src/main/resources/test-image.jpg");
        FileInfo fileInfo = FileInfo.newBuilder()
                .setFileName( resource.getFilePath().getFileName().toString() )
                .setFileType( "image/jpg" )
                .build();

        FileUploadRequest fileUploadRequest = FileUploadRequest.newBuilder()
                .setInfo( fileInfo )
                .build();

        requestObserver.onNext( fileUploadRequest );


        // file chunked data 전송
        try ( InputStream fis = resource.getInputStream() ) {
            //64kb씩 전송
            byte[] buffer = new byte[ 1024 * 64 ];
            int byteRead;
            while ( ( byteRead = fis.read( buffer ) ) != -1 ) {
                // ByteString으로 변환하여 전송
                FileUploadRequest chunkRequest = FileUploadRequest.newBuilder()
                        .setChunkData( ByteString.copyFrom( buffer, 0, byteRead) )
                        .build();

                requestObserver.onNext( chunkRequest );
            }

            //전송 끝 알림
            requestObserver.onCompleted();
        }
        catch (  Exception e ) {
            //예외 발생시 서버로 에러 전달
            requestObserver.onError( e );
            future.completeExceptionally( e );
        }

        future.whenComplete( (result, throwable) -> {
            if ( throwable != null ) {
                System.out.println("에러 발생: " +  throwable.getMessage());
            }
            else {
                System.out.println(result);
            }
        } );

        future.join();
    }
}

import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.FileInfo;
import org.example.grpcinterface.FileUploadRequest;
import org.example.grpcinterface.FileUploadResponse;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.io.OutputStream;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

@Service
public class GrpcFileUploadService extends FileUploadServiceGrpc.FileUploadServiceImplBase {
    private static final String UPLOAD_DIR = "uploads/";

    /**
     * 파일 업로드 처리를 위한 서비스
     *
     * @param responseObserver 서버가 클라이언트에게 응답을 주는 리모컨.
     * @return StreamObserver<FileUploadRequest> 클라이언트가 서버에게 요청을 하는 리모컨.
     */
    @Override
    public StreamObserver<FileUploadRequest> uploadFile( StreamObserver<FileUploadResponse> responseObserver ) {
        // 요청을 처리할 익명 클래스 반환
        return new StreamObserver<FileUploadRequest>() {
            // 상태값 유지 (파일 스트림, 파일명, 수신 파일 사이즈)
            private OutputStream writer;
            private String fileName;
            private long totalSize = 0L;

            @Override
            public void onNext( FileUploadRequest fileUploadRequest ) {
                try {
                    // 처음 업로드 대상 파일 메타 정보 수신
                    if ( fileUploadRequest.hasInfo() ) {
                        FileInfo fileInfo = fileUploadRequest.getInfo();
                        this.fileName = fileInfo.getFileName();

                        //저장 경로 생성
                        Path uploadPath = Paths.get( UPLOAD_DIR );
                        if ( !Files.exists( uploadPath ) ) {
                            Files.createDirectories( uploadPath );
                        }

                        uploadPath = uploadPath.resolve( fileName );
                        this.writer = Files.newOutputStream( uploadPath );
                        System.out.println( "[Server] 파일 생성 시작: " + uploadPath );
                    }
                    //메타 정보 수신 이후 파일 데이터가 전송된다.
                    else if ( fileUploadRequest.hasChunkData() ) {
                        if ( writer == null ) {
                            throw new IOException( "file writer is not created." );
                        }

                        byte[] bytes = fileUploadRequest.getChunkData().toByteArray();
                        writer.write( bytes );
                        writer.flush();
                        totalSize += bytes.length;
                    }
                }
                catch ( IOException e ) {
                    this.onError( e );
                }
            }

            @Override
            public void onError( Throwable throwable ) {
                System.err.println( "에러 발생: " + throwable.getMessage() );
                closeFile();
            }

            @Override
            //클라이언트가 다 보내면 호출됨
            public void onCompleted() {
                closeFile();
                System.out.println( "[Server] 업로드 완료. 파일 크기: " + this.totalSize );

                //응답 보내기
                FileUploadResponse respons = FileUploadResponse.newBuilder()
                        .setFileName( this.fileName )
                        .setTotalSize( this.totalSize )
                        .setStatus( "SUCCESS" )
                        .build();

                responseObserver.onNext( respons );
                responseObserver.onCompleted();
            }

            private void closeFile() {
                try {
                    if ( writer != null ) writer.close();
                }
                catch ( IOException e ) {
                    e.printStackTrace();
                }
            }
        };
    }
}

import io.grpc.stub.StreamObserver;
import org.example.grpcinterface.FileInfo;
import org.example.grpcinterface.FileUploadRequest;
import org.example.grpcinterface.FileUploadResponse;
import org.example.grpcinterface.FileUploadServiceGrpc;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.io.OutputStream;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

@Service
public class GrpcFileUploadService extends FileUploadServiceGrpc.FileUploadServiceImplBase {
    private static final String UPLOAD_DIR = "uploads/";

    /**
     * 파일 업로드 처리를 위한 서비스
     *
     * @param responseObserver 서버가 클라이언트에게 응답을 주는 리모컨.
     * @return StreamObserver<FileUploadRequest> 클라이언트가 서버에게 요청을 하는 리모컨.
     */
    @Override
    public StreamObserver<FileUploadRequest> uploadFile( StreamObserver<FileUploadResponse> responseObserver ) {
        // 요청을 처리할 익명 클래스 반환
        return new StreamObserver<FileUploadRequest>() {
            // 상태값 유지 (파일 스트림, 파일명, 수신 파일 사이즈)
            private OutputStream writer;
            private String fileName;
            private long totalSize = 0L;

            @Override
            public void onNext( FileUploadRequest fileUploadRequest ) {
                try {
                    // 처음 업로드 대상 파일 메타 정보 수신
                    if ( fileUploadRequest.hasInfo() ) {
                        FileInfo fileInfo = fileUploadRequest.getInfo();
                        this.fileName = fileInfo.getFileName();

                        //저장 경로 생성
                        Path uploadPath = Paths.get( UPLOAD_DIR );
                        if ( !Files.exists( uploadPath ) ) {
                            Files.createDirectories( uploadPath );
                        }

                        uploadPath = uploadPath.resolve( fileName );
                        this.writer = Files.newOutputStream( uploadPath );
                        System.out.println( "[Server] 파일 생성 시작: " + uploadPath );
                    }
                    //메타 정보 수신 이후 파일 데이터가 전송된다.
                    else if ( fileUploadRequest.hasChunkData() ) {
                        if ( writer == null ) {
                            throw new IOException( "file writer is not created." );
                        }

                        byte[] bytes = fileUploadRequest.getChunkData().toByteArray();
                        writer.write( bytes );
                        writer.flush();
                        totalSize += bytes.length;
                    }
                }
                catch ( IOException e ) {
                    this.onError( e );
                }
            }

            @Override
            public void onError( Throwable throwable ) {
                System.err.println( "에러 발생: " + throwable.getMessage() );
                closeFile();
            }

            @Override
            //클라이언트가 다 보내면 호출됨
            public void onCompleted() {
                closeFile();
                System.out.println( "[Server] 업로드 완료. 파일 크기: " + this.totalSize );

                //응답 보내기
                FileUploadResponse respons = FileUploadResponse.newBuilder()
                        .setFileName( this.fileName )
                        .setTotalSize( this.totalSize )
                        .setStatus( "SUCCESS" )
                        .build();

                responseObserver.onNext( respons );
                responseObserver.onCompleted();
            }

            private void closeFile() {
                try {
                    if ( writer != null ) writer.close();
                }
                catch ( IOException e ) {
                    e.printStackTrace();
                }
            }
        };
    }
}

클라이언트                    서버
         ------------------>
              connection
         <----------------->
            서로간의 리모컨 교환  //클라이언트는 서버 리모컨으로 서버에게 요청 신호 전달.
                              //서버는 클라이언트 리모컨으로 클라이언트에게 응답 신호 전달
                              //역할을 하기 위해 서로의 리모컨을 교환한다.
         ------------------>
            FileInfo 전송 (서버가 준 리모컨으로 onNext)
         ------------------>
         파일 chunked data 전송 (서버가 준 리모컨으로 onNext) (파일 데이터를 모두 읽을 때까지)
         ------------------>
         파일 전송 끝 이벤트 전송 (서버가 준 리모컨으로 onCompleted)
         <-----------------
             응답 전송 (클라이언트가 준 리모컨으로 onNext)
         <-----------------
             완료 전송 (클라이언트가 준 리모컨으로 onCompleted)
            

클라이언트                    서버
         ------------------>
              connection
         <----------------->
            서로간의 리모컨 교환  //클라이언트는 서버 리모컨으로 서버에게 요청 신호 전달.
                              //서버는 클라이언트 리모컨으로 클라이언트에게 응답 신호 전달
                              //역할을 하기 위해 서로의 리모컨을 교환한다.
         ------------------>
            FileInfo 전송 (서버가 준 리모컨으로 onNext)
         ------------------>
         파일 chunked data 전송 (서버가 준 리모컨으로 onNext) (파일 데이터를 모두 읽을 때까지)
         ------------------>
         파일 전송 끝 이벤트 전송 (서버가 준 리모컨으로 onCompleted)
         <-----------------
             응답 전송 (클라이언트가 준 리모컨으로 onNext)
         <-----------------
             완료 전송 (클라이언트가 준 리모컨으로 onCompleted)