1. ওভারভিউ
gRPC হল একটি ভাষা-নিরপেক্ষ, প্ল্যাটফর্ম-নিরপেক্ষ রিমোট প্রসিডিওর কল (RPC) ফ্রেমওয়ার্ক এবং Google-এ তৈরি টুলসেট। এটি আপনাকে প্রোটোকল বাফার ব্যবহার করে একটি পরিষেবা সংজ্ঞায়িত করতে দেয়, একটি বিশেষভাবে শক্তিশালী বাইনারি সিরিয়ালাইজেশন টুলসেট এবং ভাষা। তারপরে এটি আপনাকে বিভিন্ন ভাষায় আপনার পরিষেবা সংজ্ঞা থেকে ইডিওম্যাটিক ক্লায়েন্ট এবং সার্ভার স্টাব তৈরি করতে দেয়।
এই কোডল্যাবে, আপনি শিখবেন কীভাবে একটি জাভা-ভিত্তিক পরিষেবা তৈরি করতে হয় যা জিআরপিসি ফ্রেমওয়ার্ক ব্যবহার করে একটি API প্রকাশ করে এবং তারপর জেনারেট করা জিআরপিসি ক্লায়েন্ট-সাইড স্টাব ব্যবহার করার জন্য একটি ক্লায়েন্ট লিখতে হয়।
আপনি কি শিখবেন
- প্রোটোকল বাফার ভাষা
- কিভাবে জাভা ব্যবহার করে একটি gRPC পরিষেবা বাস্তবায়ন করবেন
- কিভাবে জাভা ব্যবহার করে একটি gRPC ক্লায়েন্ট বাস্তবায়ন করতে হয়
কিভাবে আপনি এই টিউটোরিয়াল ব্যবহার ব্যবহার করবেন?
আপনি Node.js অ্যাপ তৈরি করার অভিজ্ঞতাকে কীভাবে মূল্যায়ন করবেন?
Go অ্যাপ তৈরি করার বিষয়ে আপনার অভিজ্ঞতাকে আপনি কীভাবে মূল্যায়ন করবেন?
2. সেটআপ এবং প্রয়োজনীয়তা
স্ব-গতিসম্পন্ন পরিবেশ সেটআপ
- ক্লাউড কনসোলে সাইন ইন করুন এবং একটি নতুন প্রকল্প তৈরি করুন বা বিদ্যমান একটি পুনরায় ব্যবহার করুন৷ আপনার যদি ইতিমধ্যেই একটি Gmail বা Google Workspace অ্যাকাউন্ট না থাকে, তাহলে আপনাকে অবশ্যই একটি তৈরি করতে হবে।
প্রজেক্ট আইডিটি মনে রাখবেন, সমস্ত Google ক্লাউড প্রকল্প জুড়ে একটি অনন্য নাম (উপরের নামটি ইতিমধ্যে নেওয়া হয়েছে এবং আপনার জন্য কাজ করবে না, দুঃখিত!)। এটি পরে এই কোডল্যাবে PROJECT_ID হিসাবে উল্লেখ করা হবে।
- এর পরে, Google ক্লাউড সংস্থানগুলি ব্যবহার করার জন্য আপনাকে ক্লাউড কনসোলে বিলিং সক্ষম করতে হবে৷
এই কোডল্যাবের মাধ্যমে চালানোর জন্য খুব বেশি খরচ করা উচিত নয়, যদি কিছু থাকে। "ক্লিনিং আপ" বিভাগে যে কোনও নির্দেশাবলী অনুসরণ করতে ভুলবেন না যা আপনাকে কীভাবে সংস্থানগুলি বন্ধ করতে হবে তা পরামর্শ দেয় যাতে আপনি এই টিউটোরিয়ালের বাইরে বিলিং করতে না পারেন৷ Google ক্লাউডের নতুন ব্যবহারকারীরা $300 USD বিনামূল্যের ট্রায়াল প্রোগ্রামের জন্য যোগ্য৷
গুগল ক্লাউড শেল
যদিও এই কোডল্যাবটি আপনার কম্পিউটার থেকে পরিচালনা করা যেতে পারে, এই কোডল্যাবে আমরা Google ক্লাউড শেল ব্যবহার করব, ক্লাউডে চলমান একটি কমান্ড লাইন পরিবেশ।
এই ডেবিয়ান-ভিত্তিক ভার্চুয়াল মেশিনটি আপনার প্রয়োজনীয় সমস্ত বিকাশের সরঞ্জামগুলির সাথে লোড করা হয়েছে। এটি একটি ক্রমাগত 5GB হোম ডিরেক্টরি অফার করে এবং Google ক্লাউডে চলে, যা নেটওয়ার্ক কর্মক্ষমতা এবং প্রমাণীকরণকে ব্যাপকভাবে উন্নত করে। এর মানে হল যে এই কোডল্যাবের জন্য আপনার যা দরকার তা হল একটি ব্রাউজার (হ্যাঁ, এটি একটি Chromebook এ কাজ করে)।
- ক্লাউড কনসোল থেকে ক্লাউড শেল সক্রিয় করতে, কেবল ক্লাউড শেল সক্রিয় করুন ক্লিক করুন
(পরিবেশের সাথে সংযোগ স্থাপন এবং সংযোগের জন্য এটি শুধুমাত্র কয়েক মুহূর্ত নিতে হবে)।
একবার ক্লাউড শেলের সাথে সংযুক্ত হয়ে গেলে, আপনি দেখতে পাবেন যে আপনি ইতিমধ্যেই প্রমাণীকৃত এবং প্রকল্পটি ইতিমধ্যেই আপনার PROJECT_ID তে সেট করা আছে।
gcloud auth list
কমান্ড আউটপুট
Credentialed accounts: - <myaccount>@<mydomain>.com (active)
gcloud config list project
কমান্ড আউটপুট
[core] project = <PROJECT_ID>
যদি, কোন কারণে, প্রকল্পটি সেট করা না হয়, কেবল নিম্নলিখিত কমান্ডটি জারি করুন:
gcloud config set project <PROJECT_ID>
আপনার PROJECT_ID খুঁজছেন? সেটআপ ধাপে আপনি কোন আইডি ব্যবহার করেছেন তা দেখুন বা ক্লাউড কনসোল ড্যাশবোর্ডে দেখুন:
ক্লাউড শেল ডিফল্টরূপে কিছু এনভায়রনমেন্ট ভেরিয়েবলও সেট করে, যা আপনার ভবিষ্যত কমান্ড চালানোর সময় কার্যকর হতে পারে।
echo $GOOGLE_CLOUD_PROJECT
কমান্ড আউটপুট
<PROJECT_ID>
- অবশেষে, ডিফল্ট জোন এবং প্রকল্প কনফিগারেশন সেট করুন।
gcloud config set compute/zone us-central1-f
আপনি বিভিন্ন জোন বিভিন্ন চয়ন করতে পারেন. আরও তথ্যের জন্য, অঞ্চল এবং অঞ্চল দেখুন।
3. একটি gRPC পরিষেবা তৈরি করুন
Maven এর সাথে একটি নতুন জাভা প্রকল্প তৈরি করুন:
$ mvn archetype:generate -DgroupId=com.example.grpc \ -DartifactId=grpc-hello-server \ -DarchetypeArtifactId=maven-archetype-quickstart \ -DinteractiveMode=false $ cd grpc-hello-server
একটি gRPC সংজ্ঞা ফাইল যোগ করুন
জিআরপিসি-তে, পরিষেবা পেলোড (অনুরোধ এবং প্রতিক্রিয়া) এবং পরিষেবা ক্রিয়াকলাপগুলি একটি IDL (ইন্টারফেস সংজ্ঞা ভাষা) তে ক্যাপচার করা দরকার। জিআরপিসি বার্তা পেলোড এবং ক্রিয়াকলাপ সংজ্ঞায়িত করতে প্রোটোবাফার 3 সিনট্যাক্স ব্যবহার করে। হ্যালো রিকোয়েস্ট এবং হ্যালো রেসপন্স সহ একটি সাধারণ গ্রিটিং সার্ভিসের জন্য একটি প্রোটো ফাইল তৈরি করা যাক।
প্রথমে, নতুন প্রোটো ফাইলটি ধরে রাখতে একটি নতুন প্রোটো ডিরেক্টরি তৈরি করুন:
$ mkdir -p src/main/proto
তারপর, একটি নতুন প্রোটো ফাইল তৈরি করুন src/main/proto/GreetingService.proto ।
আপনি ফাইল সম্পাদনা করতে vim,nano, বা emacs ব্যবহার করতে পারেন:
src/main/proto/GreetingService.proto
syntax = "proto3";
package com.example.grpc;
// Request payload
message HelloRequest {
// Each message attribute is strongly typed.
// You also must assign a "tag" number.
// Each tag number is unique within the message.
string name = 1;
// This defines a strongly typed list of String
repeated string hobbies = 2;
// There are many more basics types, like Enum, Map
// See https://developers.google.com/protocol-buffers/docs/proto3
// for more information.
}
message HelloResponse {
string greeting = 1;
}
// Defining a Service, a Service can have multiple RPC operations
service GreetingService {
// Define a RPC operation
rpc greeting(HelloRequest) returns (HelloResponse);
}
gRPC নির্ভরতা এবং প্লাগইন যোগ করুন
আপনার সংজ্ঞা পাওয়া গেলে, আমরা এই ফাইল থেকে সার্ভার-সাইড স্টাব এবং ক্লায়েন্ট-সাইড স্টাব উভয়ই তৈরি করতে পারি। আপনাকে gRPC নির্ভরতা এবং প্লাগইন যোগ করতে হবে।
প্রথমে, pom.xml এ gRPC নির্ভরতা যোগ করুন:
pom.xml
<project>
...
<dependencies>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-netty-shaded</artifactId>
<version>1.24.0</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-protobuf</artifactId>
<version>1.24.0</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-stub</artifactId>
<version>1.24.0</version>
</dependency>
<dependency>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>
<version>1.3.2</version>
</dependency>
...
</dependencies>
...
</project>
তারপর প্লাগইন যোগ করুন:
pom.xml
<project>
...
<dependencies>
...
</dependencies>
<build>
<extensions>
<extension>
<groupId>kr.motd.maven</groupId>
<artifactId>os-maven-plugin</artifactId>
<version>1.6.2</version>
</extension>
</extensions>
<plugins>
<plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
<configuration>
<protocArtifact>com.google.protobuf:protoc:3.9.0:exe:${os.detected.classifier}</protocArtifact>
<pluginId>grpc-java</pluginId>
<pluginArtifact>io.grpc:protoc-gen-grpc-java:1.24.0:exe:${os.detected.classifier}</pluginArtifact>
</configuration>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>compile-custom</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
স্টাব তৈরি করুন
আপনি যখন অ্যাপ্লিকেশনটি তৈরি করবেন, প্লাগইনটি প্রোটো সংজ্ঞাগুলিকে জাভা কোডে রূপান্তর করবে।
$ mvn -DskipTests package
উত্পন্ন ফাইল দেখতে:
$ find target/generated-sources
পরিষেবাটি বাস্তবায়ন করুন
প্রথমে, একটি নতুন GreetingServiceImpl ক্লাস তৈরি করুন যা greeting অপারেশন বাস্তবায়ন করবে:
src/main/java/com/example/grpc/GreetingServiceImpl.java
package com.example.grpc;
import io.grpc.stub.StreamObserver;
public class GreetingServiceImpl extends GreetingServiceGrpc.GreetingServiceImplBase {
@Override
public void greeting(GreetingServiceOuterClass.HelloRequest request,
StreamObserver<GreetingServiceOuterClass.HelloResponse> responseObserver) {
// HelloRequest has toString auto-generated.
System.out.println(request);
// You must use a builder to construct a new Protobuffer object
GreetingServiceOuterClass.HelloResponse response = GreetingServiceOuterClass.HelloResponse.newBuilder()
.setGreeting("Hello there, " + request.getName())
.build();
// Use responseObserver to send a single response back
responseObserver.onNext(response);
// When you are done, you must call onCompleted.
responseObserver.onCompleted();
}
}
সার্ভার বাস্তবায়ন
অবশেষে, আপনাকে একটি পোর্ট শুনতে এবং এই পরিষেবা বাস্তবায়ন নিবন্ধন করার জন্য একটি সার্ভার শুরু করতে হবে। App ক্লাস সম্পাদনা করুন এবং এটির প্রধান পদ্ধতি:
src/main/java/com/example/grpc/App.java
package com.example.grpc;
import io.grpc.*;
public class App
{
public static void main( String[] args ) throws Exception
{
// Create a new server to listen on port 8080
Server server = ServerBuilder.forPort(8080)
.addService(new GreetingServiceImpl())
.build();
// Start the server
server.start();
// Server threads are running in the background.
System.out.println("Server started");
// Don't exit the main thread. Wait until server is terminated.
server.awaitTermination();
}
}
অবশেষে, সার্ভার চালান:
$ mvn -DskipTests package exec:java -Dexec.mainClass=com.example.grpc.App ... Server Started
4. সেবা গ্রহণ
জেনারেটর ইতিমধ্যেই সমস্ত ক্লায়েন্ট-সাইড স্টাব তৈরি করেছে৷ ল্যাবের সরলতার জন্য, আমরা একই মাভেন প্রকল্প ব্যবহার করব, তবে কেবল একটি নতুন প্রধান পদ্ধতির সাথে একটি নতুন Client ক্লাস যুক্ত করব।
প্রথমে, একটি নতুন ক্লাউড শেল সেশন খুলতে + এ ক্লিক করুন যাতে আপনাকে সার্ভারটি বন্ধ করতে হবে না:
নতুন সেশনে, grpc-hello-server ডিরেক্টরিতে স্যুইচ করুন:
$ cd grpc-hello-server
তারপর, নতুন Client ক্লাস যোগ করুন:
src/main/java/com/example/grpc/Client.java
package com.example.grpc;
import io.grpc.*;
public class Client
{
public static void main( String[] args ) throws Exception
{
// Channel is the abstraction to connect to a service endpoint
// Let's use plaintext communication because we don't have certs
final ManagedChannel channel = ManagedChannelBuilder.forTarget("localhost:8080")
.usePlaintext(true)
.build();
// It is up to the client to determine whether to block the call
// Here we create a blocking stub, but an async stub,
// or an async stub with Future are always possible.
GreetingServiceGrpc.GreetingServiceBlockingStub stub = GreetingServiceGrpc.newBlockingStub(channel);
GreetingServiceOuterClass.HelloRequest request =
GreetingServiceOuterClass.HelloRequest.newBuilder()
.setName("Ray")
.build();
// Finally, make the call using the stub
GreetingServiceOuterClass.HelloResponse response =
stub.greeting(request);
System.out.println(response);
// A Channel should be shutdown before stopping the process.
channel.shutdownNow();
}
}
অবশেষে, ক্লায়েন্ট চালান:
$ mvn -DskipTests package exec:java -Dexec.mainClass=com.example.grpc.Client ... greeting: "Hello there, Ray"
তাই তো! বেশ সহজ ডান?
5. স্ট্রিমিং পরিষেবা
আপনি চেষ্টা করতে পারেন আরো অনেক কিছু আছে. উদাহরণস্বরূপ, আপনি অনুরোধ বা প্রতিক্রিয়া প্যারামিটারে প্রোটো ফাইলে stream কীওয়ার্ড যোগ করে সহজেই একটি স্ট্রিমিং পরিষেবা তৈরি করতে পারেন, যেমন
src/main/proto/GreetingService.proto
syntax = "proto3";
package com.example.grpc;
...
// Defining a Service, a Service can have multiple RPC operations
service GreetingService {
// MODIFY HERE: Update the return to streaming return.
rpc greeting(HelloRequest) returns (stream HelloResponse);
}
শুধুমাত্র একটির পরিবর্তে একাধিক প্রতিক্রিয়া পাঠাতে আপনার সার্ভার আপডেট করুন। আপনি একাধিক responseObserver.onNext(...) কল করে এটি করতে পারেন:
src/main/java/com/example/grpc/GreetingServiceImpl.java
package com.example.grpc;
import io.grpc.stub.StreamObserver;
public class GreetingServiceImpl extends GreetingServiceGrpc.GreetingServiceImplBase {
@Override
public void greeting(GreetingServiceOuterClass.HelloRequest request,
StreamObserver<GreetingServiceOuterClass.HelloResponse> responseObserver) {
...
// Feel free to construct different responses if you'd like.
responseObserver.onNext(response);
responseObserver.onNext(response);
responseObserver.onNext(response);
// When you are done, you must call onCompleted.
responseObserver.onCompleted();
}
}
ক্লায়েন্টকে অবশ্যই ব্লকিং স্টাবের পরিবর্তে একটি অ্যাসিঙ্ক্রোনাস স্টাব ব্যবহার করতে হবে। stub প্রকারটি GreetingServiceStub এ আপডেট করা নিশ্চিত করে ক্লায়েন্ট কোড আপডেট করুন:
src/main/java/com/example/grpc/Client.java
package com.example.grpc;
import io.grpc.*;
// New import
import io.grpc.stub.*;
public class Client
{
public static void main( String[] args ) throws Exception
{
final ManagedChannel channel = ManagedChannelBuilder.forTarget("localhost:8080")
.usePlaintext(true)
.build();
// Replace the previous synchronous code with asynchronous code.
// This time use an async stub:
GreetingServiceGrpc.GreetingServiceStub stub = GreetingServiceGrpc.newStub(channel);
// Construct a request
GreetingServiceOuterClass.HelloRequest request =
GreetingServiceOuterClass.HelloRequest.newBuilder()
.setName("Ray")
.build();
// Make an Asynchronous call. Listen to responses w/ StreamObserver
stub.greeting(request, new StreamObserver<GreetingServiceOuterClass.HelloResponse>() {
public void onNext(GreetingServiceOuterClass.HelloResponse response) {
System.out.println(response);
}
public void onError(Throwable t) {
}
public void onCompleted() {
// Typically you'll shutdown the channel somewhere else.
// But for the purpose of the lab, we are only making a single
// request. We'll shutdown as soon as this request is done.
channel.shutdownNow();
}
});
}
}
অ্যাপ্লিকেশন পুনর্নির্মাণ:
$ mvn -DskipTests package
সার্ভার এবং ক্লায়েন্ট উভয়ই তার নিজস্ব ক্লাউড শেল সেশনে পুনরায় চালু করুন।
সার্ভার শুরু করতে:
$ mvn exec:java -Dexec.mainClass=com.example.grpc.App ... Server Started
ক্লায়েন্ট শুরু করতে:
$ mvn exec:java -Dexec.mainClass=com.example.grpc.Client ... greeting: "Hello there, Ray" greeting: "Hello there, Ray" greeting: "Hello there, Ray"
6. অভিনন্দন!
আমরা যা কভার করেছি:
- প্রোটোকল বাফার ভাষা
- কিভাবে জাভা ব্যবহার করে একটি gRPC সার্ভার বাস্তবায়ন করতে হয়
- কিভাবে জাভা ব্যবহার করে একটি gRPC ক্লায়েন্ট বাস্তবায়ন করতে হয়
পরবর্তী পদক্ষেপ:
- gRPC জাভা সম্পর্কে আরও জানুন
- GitHub-এ আরও জিআরপিসি জাভা উদাহরণ দেখুন
- জিআরপিসি-তে স্ট্রিমিং সম্পর্কে জানুন
- GRPC থেকে REST ট্রান্সকোডিং সম্পর্কে আরও জানুন
আমাদের আপনার মতামত দিন
- আমাদের খুব সংক্ষিপ্ত সমীক্ষা সম্পূর্ণ করার জন্য একটু সময় নিন