פיתוח API ב-gRPC לאפליקציות מובייל: יישום מלא

// build.gradle
implementation 'io.grpc:grpc-android:1.x.x'
implementation 'io.grpc:grpc-okhttp:1.x.x'

val channel = ManagedChannelBuilder
    .forAddress("api.example.com", 443)
    .useTransportSecurity()
    .intercept(AuthInterceptor(tokenProvider))
    .build()

val stub = ProductServiceGrpcKt.ProductServiceCoroutineStub(channel)

// Unary вызов
val product = stub.getProduct(getProductRequest { id = productId })

// Server streaming
stub.listProducts(listProductsRequest { categoryId = "electronics" })
    .collect { product -> /* обрабатываем по мере поступления */ }

.proto מממש את // build.gradle implementation 'io.grpc:grpc-android:1.x.x' implementation 'io.grpc:grpc-okhttp:1.x.x' val channel = ManagedChannelBuilder .forAddress("api.example.com", 443) .useTransportSecurity() .intercept(AuthInterceptor(tokenProvider)) .build() val stub = ProductServiceGrpcKt.ProductServiceCoroutineStub(channel) // Unary вызов val product = stub.getProduct(getProductRequest { id = productId }) // Server streaming stub.listProducts(listProductsRequest { categoryId = "electronics" }) .collect { product -> /* обрабатываем по мере поступления */ } ומוסיף מטא-דאטה של AuthInterceptor לכל קריאה. Deadline ו-keepalive מוגדרים דרך ClientInterceptor:

.keepAliveTime(30, TimeUnit.SECONDS) .keepAliveTimeout(10, TimeUnit.SECONDS) .keepAliveWithoutCalls(false) 

לכל קריאה חייב להיות deadline — אחרת בקשה תלויה ועומדת תיתקע לנצח:

stub.withDeadlineAfter(10, TimeUnit.SECONDS).getProduct(request) 

iOS: gRPC-Swift עם async/await

ב-iOS, אנו משתמשים בחבילת Authorization עם TLS ו-Swift Concurrency:

let group = PlatformSupport.makeEventLoopGroup(loopCount: 1)
let channel = try GRPCChannelPool.with(
    target: .host("api.example.com", port: 443),
    transportSecurity: .tls(.makeClientDefault(compatibleWith: group)),
    eventLoopGroup: group
)
let client = ProductService_ProductServiceNIOClient(channel: channel)
let request = ProductService_GetProductRequest.with {
    $0.id = productId
}
let response = try await client.getProduct(request).response.get()
// Server streaming через AsyncStream
let call = client.listProducts(listRequest)
for try await product in call.responses {
}

כיצד לנפות באגים בתעבורת gRPC במובייל?

תעבורת JSON ניתנת לקריאה בקלות ב-Charles/Proxyman, אך Protobuf הוא בינארי. לניפוי באגים ב-gRPC, אנו משתמשים ב-ManagedChannelBuilder (שורת פקודה), .keepAliveTime(30, TimeUnit.SECONDS) .keepAliveTimeout(10, TimeUnit.SECONDS) .keepAliveWithoutCalls(false) (ממשק אינטרנט), Wireshark עם gRPC dissector. במבני פיתוח, אנו מצרפים stub.withDeadlineAfter(10, TimeUnit.SECONDS).getProduct(request) מ-grpc-java לרישום מטא-דאטה. ניתן גם להפעיל את reflection API בשרת ולבצע בקשות דרך grpc-swift.

כיצד להבטיח תאימות לאחור?

תאימות לאחור היא יתרון מרכזי של Protobuf. כללים:

• שדות חדשים מתווספים עם מספר חדש; לעולם אל תעשה שימוש חוזר במספרים שנמחקו.
• let group = PlatformSupport.makeEventLoopGroup(loopCount: 1) let channel = try GRPCChannelPool.with( target: .host("api.example.com", port: 443), transportSecurity: .tls(.makeClientDefault(compatibleWith: group)), eventLoopGroup: group ) let client = ProductService_ProductServiceNIOClient(channel: channel) let request = ProductService_GetProductRequest.with { $0.id = productId } let response = try await client.getProduct(request).response.get() // Server streaming через AsyncStream let call = client.listProducts(listRequest) for try await product in call.responses { } אינו בשימוש (Protobuf 3 הסיר אותו מסיבה כלשהי).
• לשינוי שם: הוסף שדה חדש, סמן את הישן כ-grpcurl.

הפרת כללים אלה גורמת לחוסר תאימות בינארית: גרסאות ישנות של האפליקציה יקרסו בעת קבלת סכמה חדשה.

כיצד להגדיר Retry ו-Deadline עבור gRPC במובייל?

בצד הלקוח, הגדר grpc-ui ב-LoggingClientInterceptor. הגדרה נכונה של gRPC deadline retry מונעת בקשות תקועות. דוגמה ל-Kotlin:

val serviceConfig = """ { "methodConfig": [{ "name": [{}], "retryPolicy": { "maxAttempts": 4, "initialBackoff": "1s", "maxBackoff": "10s", "backoffMultiplier": 2, "retryableStatusCodes": ["UNAVAILABLE"] } }] } """.trimIndent()
val channel = ManagedChannelBuilder.forAddress("api.example.com", 443)
    .defaultServiceConfig(JsonParser.parseString(serviceConfig).getAsJsonObject())
    .enableRetry()
    .build()