写给Java程序员的GRPC入门系列(3)
admin
2024-05-02 17:52:32
0

点击上方GRPC专栏看系列

文章目录

  • Abstract
  • 前置依赖
  • 本文
    • 初始状态
    • 编写自己的Service实现(Server端)
    • 编写客户端
  • 下一步

Abstract

网上有很多GRPC的例子,但是却没有能够写给普通Java开发人员手把手入门少走弯路的教程。
本教程保证按照步骤一步步来你就可以完成GRPC从0到1的构建。
源码地址:grpc-helloworld-for-java

前置依赖

装有maven和JDK。并且保证javac命令可用。

本文

本文是系列的第3篇,将编写自定义的server/service和client调用实现。 代码在分支:step3-client-server。

初始状态

git clone https://github.com/gaoxingliang/grpc-helloworld-for-java.git
--跟着上一篇的branch接着修改
git step2-protobuffer

编写自己的Service实现(Server端)

新建包com.example.cs来放client和server的代码。 当然你也可以把step2生成的代码打包成jar上传maven方便共享。
并且新建类:MyUserServiceImpl.java,这里自定义实现UserService的逻辑,比如这里要求用户名密码相同才认证成功:

package com.example.cs;import com.example.grpc.common.vo.*;
import com.example.grpc.user.*;
import io.grpc.stub.*;public class MyUserServiceImpl extends UserGrpc.UserImplBase {@Overridepublic void login(UserOuterClass.LoginRequest request, StreamObserver responseObserver) {UserOuterClass.APIResponse.Builder resp = UserOuterClass.APIResponse.newBuilder();if (request.getUsername().equals(request.getPassword())) {resp.setResponseCode(0);resp.setResponsemessage("OK");} else {resp.setResponseCode(1);resp.setResponsemessage("FAIL");}responseObserver.onNext(resp.build());responseObserver.onCompleted();}@Overridepublic void logout(Vo.Empty request, StreamObserver responseObserver) {// 没实现。}
}

新建GrpcServer实现:

package com.example.cs;import io.grpc.*;public class GrpcServer {public static void main(String[] args) throws Exception{Server server = ServerBuilder.forPort(7070).addService(new MyUserServiceImpl()).build();server.start();System.out.println("server start at 7070");server.awaitTermination();}
}

并运行,输出:

server start at 7070

编写客户端

GrpcClient.java:

package com.example.cs;import com.example.grpc.user.*;
import io.grpc.*;public class GrpcClient {public static void main(String[] args) throws Exception {ManagedChannel ch = ManagedChannelBuilder.forAddress("localhost", 7070).usePlaintext().build();UserGrpc.UserBlockingStub stub = UserGrpc.newBlockingStub(ch);UserOuterClass.APIResponse resp = stub.login(UserOuterClass.LoginRequest.newBuilder().setUsername("hello").setPassword("world").build());System.out.println("Response " + resp);ch.shutdown();}
}

运行并输出:

Response responsemessage: "FAIL"
responseCode: 1

下一步

和springboot結合的多項目演示。

相关内容

热门资讯

【看表情包学Linux】进程地...   🤣 爆笑教程 👉 《看表情包学Linux》👈 猛...
育碧GDC2018程序化大世界... 1.传统手动绘制森林的问题 采用手动绘制的方法的话,每次迭代地形都要手动再绘制森林。这...
编译原理陈火旺版第三章课后题答... 下面答案仅供参考! 1.编写一个对于 Pascal 源程序的预处理程序。该程序的作用是...
MacBookPro M2芯片... MacBookPro M2芯片下如何搭建React-Native环境目录软件下载环境配置 目录 写在...
Android studio ... 解决 Android studio 出现“The emulator process for AVD ...
pyflink学习笔记(六):... 在pyflink学习笔记(一)中简单介绍了table-sql的窗口函数,下面简单介绍下...
创建deployment 创建deployment服务编排-DeploymentDeployment工作负载均衡器介绍Depl...
gma 1.1.4 (2023... 新增   1、地图工具    a. 增加【GetWorldDEMDataSet】。提供了一套 GEO...
AI专业教您保姆级在暗影精灵8... 目录 一、Stable Diffusion介绍    二、Stable Diffusion环境搭建 ...
vue笔记 第一个Vue应用 Document{{content}}{{...
Unity自带类 --- Ti... 1.在Unity中,自己写的类(脚本)的名字不能与Unit...
托福口语21天——day5 发... 目录 一、连读纠音 二、语料输入+造句输出 三、真题 一、连读纠音 英语中的连读方式有好几种...
五、排序与分页 一、排序 1、语法 ORDER BY 字段 ASC | DESC ASC(ascen...
Linux系统中如何安装软件 文章目录一、rpm包安装方式步骤:二、deb包安装方式步骤:三、tar....
开荒手册4——Related ... 0 写在前面 最早读文献的时候,每每看到related work部分都会选择性的忽略&...
实验01:吃鸡蛋问题 1.实验目的: 通过实验理解算法的概念、算法的表示、算法的时间复杂度和空间复杂度分析&...
8个免费图片/照片压缩工具帮您... 继续查看一些最好的图像压缩工具,以提升用户体验和存储空间以及网站使用支持。 无数图像压...
Spring Cloud Al... 前言 本文小新为大家带来 Sentinel控制台规则配置 相关知识,具体内容包括流控...
多项目同时进行,如何做好进度管... 多项目同时进行,如何做好进度管理? 大多数时候,面对项目进...
ATTCK红队评估实战靶场(二... 前言 第二个靶机来喽,地址:vulunstack 环境配置 大喊一声我...