{"id":23172,"date":"2019-09-24T12:00:38","date_gmt":"2019-09-24T03:00:38","guid":{"rendered":"https:\/\/www.techscore.com\/blog\/?p=23172"},"modified":"2019-09-26T13:09:29","modified_gmt":"2019-09-26T04:09:29","slug":"grpc%e3%81%ae%e3%83%95%e3%83%ad%e3%83%bc%e5%88%b6%e5%be%a1%e3%82%92%e8%a9%a6%e3%81%97%e3%81%a6%e3%81%bf%e3%81%9f","status":"publish","type":"post","link":"https:\/\/www.techscore.com\/blog\/2019\/09\/24\/grpc%e3%81%ae%e3%83%95%e3%83%ad%e3%83%bc%e5%88%b6%e5%be%a1%e3%82%92%e8%a9%a6%e3%81%97%e3%81%a6%e3%81%bf%e3%81%9f\/","title":{"rendered":"gRPC\u306e\u30d5\u30ed\u30fc\u5236\u5fa1\u3092\u8a66\u3057\u3066\u307f\u305f"},"content":{"rendered":"

\u672c\u8a18\u4e8b\u3067\u306fgRPC\u306eServer streaming RPC \u3067\u306e\u30d5\u30ed\u30fc\u5236\u5fa1\u3092\u30b5\u30f3\u30d7\u30eb\u30b3\u30fc\u30c9\u3092\u4ea4\u3048\u306a\u304c\u3089\u89e3\u8aac\u3057\u307e\u3059\u3002<\/p>\n

gRPC\u3068\u306f<\/h1>\n

gRPC\u306fGoogle\u306b\u3088\u3063\u3066\u958b\u767a\u3055\u308c\u305fRPC\u30d7\u30ed\u30c8\u30b3\u30eb\u3067\u3001\u901a\u4fe1\u306bHTTP2\u4e0a\u3067Protocol Buffers\u306b\u3088\u308b\u30b7\u30ea\u30a2\u30e9\u30a4\u30bc\u30fc\u30b7\u30e7\u30f3\u3092\u5229\u7528\u3059\u308b\u3053\u3068\u3067\u3001\u9ad8\u6027\u80fd\uff08\u8efd\u91cf\u3001\u9ad8\u901f\uff09\u306a\u30e1\u30c3\u30bb\u30fc\u30b8\u30f3\u30b0\u3092\u53ef\u80fd\u3068\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n

\u4ee5\u4e0b\u306e\u8868\u3067\u306f\u3001\u73fe\u5728\u4e3b\u6d41\u3067\u3042\u308b3\u3064\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u4ea4\u63db\u4ed5\u69d8\u3092\u6bd4\u8f03\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n\n\n\n\n\n\n\n
\u65b9\u5f0f<\/th>\n\u30b9\u30ad\u30fc\u30de\u8a18\u8ff0\u8a00\u8a9e(IDL)<\/th>\n\u30d7\u30ed\u30c8\u30b3\u30eb<\/th>\n\u30b7\u30ea\u30a2\u30e9\u30a4\u30bc\u30fc\u30b7\u30e7\u30f3<\/th>\n\u7279\u5fb4<\/th>\n<\/tr>\n<\/thead>\n
gRPC<\/td>\nProtocol Buffers<\/td>\nHTTP2<\/td>\nProtocol Buffers<\/td>\n\u30cf\u30a4\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u3067\u30de\u30a4\u30af\u30ed\u30b5\u30fc\u30d3\u30b9\u9593\u901a\u4fe1\u306b\u6700\u9069<\/td>\n<\/tr>\n
REST<\/td>\nOpenAPI(Swagger)<\/td>\nHTTP<\/td>\nJSON<\/td>\n\u30c7\u30d5\u30a1\u30af\u30c8\u30b9\u30bf\u30f3\u30c0\u30fc\u30c9\u3067\u3042\u308bREST\u306e\u5ef6\u9577\u7dda\u4e0a\u306a\u305f\u3081\u4f7f\u3044\u3084\u3059\u3044<\/td>\n<\/tr>\n
GraphQL<\/td>\nGraphQL<\/td>\nHTTP<\/td>\nJSON<\/td>\n\u30d5\u30ed\u30f3\u30c8\u30a8\u30f3\u30c9\u3068\u306e\u76f8\u6027\u304c\u826f\u3044<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

\u203b3\u3064\u306e\u65b9\u5f0f\u3068\u3082\u306b\u3001\u30b7\u30ea\u30a2\u30e9\u30a4\u30bc\u30fc\u30b7\u30e7\u30f3\u306b\u306f\u4ed6\u306e\u4ed5\u69d8\u3092\u9078\u629e\u3059\u308b\u3053\u3068\u3082\u53ef\u80fd\u3067\u3059\u304c\u3001\u4e00\u822c\u7684\u306a\u3082\u306e\u3092\u8a18\u8f09\u3057\u3066\u3044\u307e\u3059<\/p>\n

\u3044\u305a\u308c\u304b\u306e\u65b9\u5f0f\u306b\u7d71\u4e00\u3059\u308b\u3053\u3068\u3082\u3067\u304d\u307e\u3059\u304c\u3001\u5927\u898f\u6a21\u306a\u30b7\u30b9\u30c6\u30e0\u306b\u65bc\u3044\u3066\u306f\u3001\u30de\u30a4\u30af\u30ed\u30b5\u30fc\u30d3\u30b9\u9593\u901a\u4fe1\u306bgRPC\u3001\u30d5\u30ed\u30f3\u30c8\u30a8\u30f3\u30c9\u3068\u306e\u901a\u4fe1\u306bGraphQL\u3001\u5916\u90e8\u516c\u958b\u3059\u308bAPI\u306bOpenAPI\u3068\u3044\u3063\u305f\u3088\u3046\u306b\u3001\u30e6\u30fc\u30b9\u30b1\u30fc\u30b9\u306b\u5fdc\u3058\u3066\u4f7f\u3044\u5206\u3051\u308b\u306e\u3082\u826f\u3044\u3068\u601d\u3044\u307e\u3059\u3002<\/p>\n

gRPC\u3092\u5229\u7528\u3057\u3066\u307f\u305f\u611f\u60f3\u3067\u3059\u304c\u3001\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u3082\u3055\u308b\u3053\u3068\u306a\u304c\u3089\u3001OpenAPI\u3068\u6bd4\u3079\u3066\u4ed5\u69d8\u304c\u5358\u7d14\u306a\u5206\u3001IDL\u3092\u5143\u306b\u751f\u6210\u3055\u308c\u308b\u96db\u5f62\uff08\u30b9\u30bf\u30d6\uff09\u306e\u54c1\u8cea\u304c\u9ad8\u304f\u8907\u6570\u8a00\u8a9e\u3067\u306e\u5229\u7528\u3092\u30b9\u30e0\u30fc\u30ba\u306b\u884c\u3046\u3053\u3068\u304c\u3067\u304d\u305d\u3046\u3060\u3068\u611f\u3058\u307e\u3057\u305f\u3002<\/p>\n

gRPC\u306e\u547c\u3073\u51fa\u3057\u30b9\u30bf\u30a4\u30eb<\/h2>\n

gRPC\u306e\u547c\u3073\u51fa\u3057\u30b9\u30bf\u30a4\u30eb\u306b\u306f\u3001\u5358\u9805RPC\u30683\u3064\uff08\u30b5\u30fc\u30d0\/\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\/\u53cc\u65b9\u5411\uff09\u306e\u30b9\u30c8\u30ea\u30fc\u30df\u30f3\u30b0RPC\u304c\u3042\u308a\u307e\u3059\u3002
\n\u8a73\u3057\u304f\u306fRPC life cycle<\/a>\u3092\u3054\u89a7\u304f\u3060\u3055\u3044\u3002
\n\u672c\u8a18\u4e8b\u3067\u306fServer streaming RPC\u306b\u3064\u3044\u3066\u30d5\u30a9\u30fc\u30ab\u30b9\u3057\u307e\u3059\u3002<\/p>\n

\u30b5\u30fc\u30d0\u30fc\u30b9\u30c8\u30ea\u30fc\u30df\u30f3\u30b0\u3068\u30d5\u30ed\u30fc\u5236\u5fa1<\/h2>\n

gRPC\u306e\u5b9a\u7fa9\u304b\u3089\u751f\u6210\u3055\u308c\u308b\u30b9\u30bf\u30d6\u306f\u3001\u57fa\u672c\u7684\u306b\u30ce\u30f3\u30d6\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0\u306a\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u30b9\u30bf\u30a4\u30eb\u3067\u5229\u7528\u3055\u308c\u308b\u3088\u3046\u306b\u8a2d\u8a08\u3055\u308c\u3066\u3044\u307e\u3059\u3002<\/p>\n

Server streaming RPC\u3067\u30b9\u30c8\u30ea\u30fc\u30e0\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u6d41\u3057\u7d9a\u3051\u305f\u5834\u5408\u3001\u9001\u4fe1\u5074\u304c\u53d7\u4fe1\u5074\u306e\u30b9\u30eb\u30fc\u30d7\u30c3\u30c8\u3092\u8d85\u3048\u3066\u5168\u529b\u3067\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u6d41\u3057\u7d9a\u3051\u308b\u3068\u3001\u901a\u4fe1\u7528\u306e\u30d0\u30c3\u30d5\u30a1\u3092\u5727\u8feb\u3057\u3066\u3044\u304f\u3053\u3068\u306b\u306a\u308a\u307e\u3059\u3002
\n\u3053\u306e\u554f\u984c\u3092\u56de\u907f\u3059\u308b\u305f\u3081\u306b\u3001\u30c7\u30fc\u30bf\u8ee2\u9001\u6642\u306b\u9001\u4fe1\u5074\u304c\u53d7\u4fe1\u5074\u306b\u5408\u308f\u305b\u3066\u8ee2\u9001\u30ec\u30fc\u30c8\u3092\u30b3\u30f3\u30c8\u30ed\u30fc\u30eb\u3059\u308b\u3001\u30d5\u30ed\u30fc\u5236\u5fa1\u3092\u884c\u3046\u5fc5\u8981\u304c\u3042\u308a\u307e\u3059\u3002<\/p>\n

\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0\u30b9\u30bf\u30a4\u30eb\u3067\u3042\u308c\u3070\u30d0\u30c3\u30d5\u30a1\u304c\u6ea2\u308c\u305d\u3046\u306b\u306a\u308b\u3068\u30d6\u30ed\u30c3\u30af\u3057\u3066\u30e1\u30e2\u30ea\u304c\u7a7a\u304f\u307e\u3067\u5f85\u3064\u3001\u3068\u3044\u3046\u5b9f\u88c5\u3092\u3059\u308c\u3070RPC\u306e\u5b9f\u88c5\u8005\u306b\u30d5\u30ed\u30fc\u5236\u5fa1\u3092\u610f\u8b58\u3055\u305b\u306a\u3044\u3088\u3046\u306b\u3067\u304d\u305d\u3046\u3067\u3059\u3002
\n\u3057\u304b\u3057\u3001\uff08\u30b7\u30f3\u30b0\u30eb\u30b9\u30ec\u30c3\u30c9\u306e\uff09\u30ce\u30f3\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0\u30b9\u30bf\u30a4\u30eb\u306e\u5834\u5408\u3001\u30d6\u30ed\u30c3\u30af\uff1d\u5168\u51e6\u7406\u505c\u6b62\u3068\u306a\u308b\u305f\u3081\u305d\u3046\u306f\u3044\u304d\u307e\u305b\u3093\u3002<\/p>\n

gRPC\u3067\u30d5\u30ed\u30fc\u5236\u5fa1\u3092\u884c\u3046\u306b\u306f\u3069\u3046\u3059\u308c\u3070\u3088\u3044\u304b\u8abf\u3079\u3066\u307f\u307e\u3057\u305f\u3002<\/p>\n

\u30b5\u30f3\u30d7\u30eb\u5b9f\u88c5<\/h1>\n

\u30d5\u30ed\u30fc\u5236\u5fa1\u306e\u30b5\u30f3\u30d7\u30eb\u3068\u3057\u3066\u3001gRPC\u3067Linux\u306eyes\u30b3\u30de\u30f3\u30c9\u3063\u307d\u3044\u3082\u306e\u3092\u5b9f\u88c5\u3057\u307e\u3057\u305f\u3002
\n\u5b9f\u88c5\u306bSpringBoot\u3068Kotlin\u3092\u5229\u7528\u3057\u3066\u304a\u308a\u3001\u5168\u30bd\u30fc\u30b9\u306f
GitHub<\/a>\u3067\u516c\u958b\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n

\u7121\u9650\u30eb\u30fc\u30d7\u3067\u5168\u529b\u9001\u4fe1<\/h2>\n

\u624b\u59cb\u3081\u306b\u3001\u53d7\u4fe1\u5074\u3092\u8003\u616e\u305b\u305a\u5168\u529b\u7121\u9650\u30eb\u30fc\u30d7\u3067\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u4fe1\u3057\u7d9a\u3051\u308b yes \u30e1\u30bd\u30c3\u30c9\u3092\u4f5c\u6210\u3057\u307e\u3057\u305f\u3002<\/p>\n

\noverride fun yes(request: Yes.YesRequest, responseObserver: StreamObserver) {\n    val reply = Yes.YesReply.newBuilder().setMessage(request.messageWithDefault).build()\n    while (true) {\n        responseObserver.onNext(reply)\n    }\n}\n<\/pre>\n

\u6848\u306e\u5b9a\u3001\u547c\u3073\u51fa\u3059\u3068\u3059\u3050\u306b\u30d0\u30c3\u30d5\u30a1\uff08Netty\u306eDirectMemory\uff09\u304c\u6ea2\u308c\u307e\u3059\u3002<\/p>\n

Exception in thread \"grpc-default-executor-1\" io.grpc.netty.shaded.io.netty.util.internal.OutOfDirectMemoryError: failed to allocate 16777216 byte(s) of direct memory (used: 1778385175, max: 1791492096)\n        at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.incrementMemoryCounter(PlatformDependent.java:656)\n        at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.allocateDirectNoCleaner(PlatformDependent.java:611)\n        at io.grpc.netty.shaded.io.netty.buffer.PoolArena$DirectArena.allocateDirect(PoolArena.java:768)\n        at io.grpc.netty.shaded.io.netty.buffer.PoolArena$DirectArena.newChunk(PoolArena.java:744)\n        at io.grpc.netty.shaded.io.netty.buffer.PoolArena.allocateNormal(PoolArena.java:245)\n        at io.grpc.netty.shaded.io.netty.buffer.PoolArena.allocate(PoolArena.java:215)\n        at io.grpc.netty.shaded.io.netty.buffer.PoolArena.allocate(PoolArena.java:147)\n        at io.grpc.netty.shaded.io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:327)\n        at io.grpc.netty.shaded.io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187)\n        at io.grpc.netty.shaded.io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:123)\n        at io.grpc.netty.shaded.io.grpc.netty.NettyWritableBufferAllocator.allocate(NettyWritableBufferAllocator.java:51)\n        at io.grpc.internal.MessageFramer.writeKnownLengthUncompressed(MessageFramer.java:226)\n        at io.grpc.internal.MessageFramer.writeUncompressed(MessageFramer.java:167)\n        at io.grpc.internal.MessageFramer.writePayload(MessageFramer.java:140)\n...snip...\n<\/code><\/pre>\n

\u4f59\u8ac7\u3067\u3059\u304c\u3001Java\u3067\u306egRPC\u3067\u3088\u304f\u5229\u7528\u3055\u308c\u308bNetty\u306f\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u51e6\u7406\u306bDirectBuffer\u3092\u4f7f\u3046\u305f\u3081\u3001\u30e1\u30e2\u30ea\u7ba1\u7406\u306f\u30d2\u30fc\u30d7\u4ee5\u5916\u306b\u3082\u30c0\u30a4\u30ec\u30af\u30c8\u30e1\u30e2\u30ea\uff08XX:MaxDirectMemorySize\u306a\u3069\uff09\u3092\u610f\u8b58\u3059\u308b\u5fc5\u8981\u304c\u3042\u308a\u307e\u3059\u3002<\/p>\n

\u30d5\u30ed\u30fc\u5236\u5fa1\u7248<\/h2>\n

gRPC\u306b\u306f\u81ea\u52d5\u30d5\u30ed\u30fc\u5236\u5fa1\u6a5f\u69cb\u304c\u5099\u308f\u3063\u3066\u304a\u308a\u3001\u610f\u8b58\u3057\u305f\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u3059\u308c\u3070\u30d0\u30c3\u30af\u30d7\u30ec\u30c3\u30b7\u30e3\u30fc\u304c\u6a5f\u80fd\u3057\u307e\u3059\u3002
\n\u3053\u306e
issue<\/a>\u306b\u8a18\u8f09\u3055\u308c\u3066\u3044\u305f\u30b5\u30f3\u30d7\u30eb\u30b3\u30fc\u30c9\u901a\u308a\u306b\u5b9f\u88c5\u3057\u305fyesWithFc\u30e1\u30bd\u30c3\u30c9\u304c\u3053\u3061\u3089\u3002<\/p>\n

\noverride fun yesWithFc(request: Yes.YesRequest, responseObserver: StreamObserver) {\n    require(responseObserver is ServerCallStreamObserver) { \"response observer is not ServerCallStreamObserver\" }\n    val reply = Yes.YesReply.newBuilder().setMessage(request.messageWithDefault).build()\n    val drain = {\n        while (responseObserver.isReady()) {\n            responseObserver.onNext(reply)\n        }\n    }\n    responseObserver.setOnReadyHandler(drain)\n    drain()\n}\n<\/pre>\n

\u30d5\u30ed\u30fc\u5236\u5fa1\u306e\u8981\u70b9\u306f\u4ee5\u4e0b\u306b\u306a\u308a\u307e\u3059\u3002<\/p>\n