/
Main.java
63 lines (51 loc) · 2.69 KB
/
Main.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package example.armeria.server.blog.grpc;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.linecorp.armeria.server.Server;
import com.linecorp.armeria.server.docs.DocService;
import com.linecorp.armeria.server.docs.DocServiceFilter;
import com.linecorp.armeria.server.grpc.GrpcService;
import example.armeria.blog.grpc.BlogPost;
import example.armeria.blog.grpc.BlogServiceGrpc;
import io.grpc.reflection.v1alpha.ServerReflectionGrpc;
final class Main {
private static final Logger logger = LoggerFactory.getLogger(Main.class);
public static void main(String[] args) throws Exception {
final Server server = newServer(8080);
server.closeOnJvmShutdown().thenRun(() -> {
logger.info("Server has been stopped.");
});
server.start().join();
logger.info("Server has been started. Serving DocService at http://127.0.0.1:{}/docs",
server.activeLocalPort());
}
private static Server newServer(int port) throws Exception {
final GrpcService grpcService =
GrpcService.builder()
.addService(new BlogService())
.enableUnframedRequests(true)
.exceptionHandler(new GrpcExceptionHandler())
// You can set useBlockingTaskExecutor(true) in order to execute all gRPC methods in
// the blockingTaskExecutor thread pool.
// .useBlockingTaskExecutor(true)
.build();
final BlogPost exampleRequest = BlogPost.newBuilder()
.setTitle("My first blog")
.setContent("Hello Armeria!")
.build();
final DocService docService = DocService.builder()
.exampleRequests(BlogServiceGrpc.SERVICE_NAME,
"CreateBlogPost", exampleRequest)
.exclude(DocServiceFilter.ofServiceName(
ServerReflectionGrpc.SERVICE_NAME))
.build();
return Server.builder()
.http(port)
.service(grpcService)
// You can access the documentation service at http://127.0.0.1:8080/docs.
// See https://armeria.dev/docs/server-docservice for more information.
.serviceUnder("/docs", docService)
.build();
}
private Main() {}
}