JarCastingJackstaff gRPC framework
Quick Starts / Advance Usage / Smooth and friendly use of gRPC / Origin
Quick Starts:
Step 0: Import grpc-spring-boot-starter in pom.xml. jdk1.8
<!-- https://mvnrepository.com/artifact/org.jackstaff.grpc/grpc-spring-boot-starter -->
<dependency>
<groupId>org.jackstaff.grpc</groupId>
<artifactId>grpc-spring-boot-starter</artifactId>
<version>2.0.13</version>
</dependency>
Step 1: Define protocol interface:
import java.util.function.Consumer;
public interface HelloService {
String sayHello(String greeting); //Unary RPCs
void lotsOfReplies(String greeting, Consumer<String> replies);//Server streaming RPCs
Consumer<String> lotsOfGreetings(List<String> friends); //Client streaming RPCs
Consumer<String> bidiHello(List<String> friends, Consumer<String> replies); //Bidirectional streaming RPCs
}
Step 2: Implements protocol interface(at "server side micro service" project):
import org.jackstaff.grpc.annotation.Server;
@Server(HelloService.class)
public class MyHelloService implements HelloService {
@Override
public String sayHello(String greeting) {
//todo
return "reply " + greeting;
}
@Override
public void lotsOfReplies(String greeting, Consumer<String> replies) {
//todo
replies.accept("hi "+ greeting);
replies.accept(":)");
}
@Override
public Consumer<String> lotsOfGreetings(List<String> friends) {
//todo
return s-> System.out.println(s);
}
@Override
public Consumer<String> bidiHello(List<String> friends, Consumer<String> replies) {
//todo
CompletableFuture.runAsync(()-> friends.forEach(friend->replies.accept("hi "+ friend)));
return s-> System.out.println(s);
}
}
Step 3: Use protocol interface (at "client side micro service" project):
import org.jackstaff.grpc.annotation.Client;
@Service
public class MyClientService {
@Client("my-server")
private HelloService helloService;
public String sayHello(String greeting){
return helloService.sayHello(greeting);
}
}
Step 4: Config "client side " application.yml:
spring:
grpc:
client:
my-server:
host: localhost
port: 9000
Step 5: Config "server side " application.yml:
spring:
grpc:
server:
port: 9000
done.