vuminh224/pr.tp.grpc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

push

Browse Source
This commit is contained in:
Vu Tuan Minh
2025-04-01 16:18:51 +02:00
parent 46dbc9e4ce
commit e9c518ce40
3 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/fr/istic/grpc/echo/EchoClient.java
View File

@@ -2,9 +2,10 @@ package fr.istic.grpc.echo;
import com.google.rpc.context.AttributeContext.*; import com.google.rpc.context.AttributeContext.*;
import fr.istic.grpc.echo.Echo.*; import fr.istic.grpc.echo.Echo.*;
import fr.istic.grpc.echo.EchoServiceGrpc.*;
import io.grpc.*; import io.grpc.*;
public class EchoClient { public class EchoClient {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {

11
src/main/java/fr/istic/grpc/echo/EchoServeur.java
View File

@@ -1,17 +1,14 @@
package fr.istic.grpc.echo; package fr.istic.grpc.echo;
import fr.istic.grpc.echo.Echo.MessageReceive;
import fr.istic.grpc.echo.Echo.MessageSent;
import fr.istic.grpc.todo.*; import fr.istic.grpc.todo.*;
import io.grpc.*; import io.grpc.*;
import io.grpc.stub.StreamObserver;
import java.io.*; import java.io.*;
public class EchoServeur { public class EchoServeur {
public void echo(MessageSent min, StreamObserver<MessageReceive> responseObserver) { public static void main(String[] args) throws IOException, InterruptedException {
MessageReceive reply = MessageReceive.newBuilder().setMessage(min.getMessage().toUpperCase()).build(); Server server = ServerBuilder.forPort(8080).addService(new EchoService()).build().start();
responseObserver.onNext(reply); System.out.println("Serveur started");
responseObserver.onCompleted(); server.awaitTermination();
} }
} }

7
src/main/java/fr/istic/grpc/echo/EchoService.java
View File

@@ -6,5 +6,10 @@ import fr.istic.grpc.echo.EchoServiceGrpc.*;
import io.grpc.stub.*; import io.grpc.stub.*;
public class EchoService extends EchoServiceImplBase { public class EchoService extends EchoServiceImplBase {
public void echo(MessageSent min, StreamObserver<MessageReceive> responseObserver) {
MessageReceive reply = MessageReceive.newBuilder().setMessage(min.getMessage().toUpperCase()).build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
} }
}