最新要闻
- 英特尔以强大产品力,迎接生成式AI的广阔机遇
- 热消息:直播间卖卫星 最低200万!罗永浩:真的 把卫星价格打下来
- Redmi Note 12 Turbo晒战绩:16GB+1TB开售5分钟超过全行业历史销量之和
- 每日热闻!这就离谱!A7S3传感器用来拍Vlog 索尼ZV-E1开启预售
- vivo X Fold2影像曝光:IMX866主摄、潜望长焦取消
- 环球今头条!日本最早将于2024年度在新东名高速公路部分区间设置自动驾驶车道
- 环球即时看!小姐姐秒种草!雅迪冠能摩登发布:独创复古女王风
- 当前速讯:你家乡上榜没?中国省级“癌症地图”出炉:肺癌列第一 “穷癌”下降“富癌”上升
- 3299元性价比封神!AMD Zen4 104MB缓存锐龙7 7800X3D价格公布
- 环球快报:2磅蛋糕是几寸适合多少人吃_2磅蛋糕是几寸
- 新消息丨贾跃亭宣布历史时刻:为梦想窒息FF 91量产!老外狠拆台展示车架或未全面投产
- Windows 11 2024版发布了!首个官方ISO镜像免费下载
- 环球观点:调查显示:超半数受访者认为学历还是敲门砖
- 环球今热点:男子将父亲骨灰撒入大海被抓?为啥不能私自撒?
- 全球消息!庆祝索尼第一方游戏登陆XGP:微软推出Xbox限定主机
- 微速讯:飞沫传播图片_飞沫传播
手机
iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
- 警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- 男子被关545天申国赔:获赔18万多 驳回精神抚慰金
- 3天内26名本土感染者,辽宁确诊人数已超安徽
- 广西柳州一男子因纠纷杀害三人后自首
- 洱海坠机4名机组人员被批准为烈士 数千干部群众悼念
家电
基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 2/3
基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 1/3
基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 2/3
(资料图片)
基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 3/3
项目地址:https://github.com/janrs-io/Jgrpc
转载请注明来源:https://janrs.com/ugj7
在上一部分中,我们创建了微服务的目录结构并实现了微服务pongservice
。
这部分我们继续实现一个名为pingservice
的微服务,访问上一节已经部署好的pongservice
微服务。
创建一个新的微服务非常简单,只需复制之前创建的pongservice
微服务,然后做一些小改动。
项目结构
这部分最终的目录结构如下:
pingservice├── buf.gen.yaml├── cmd│ ├── main.go│ └── server│ ├── grpc.go│ ├── http.go│ ├── run.go│ ├── wire.go│ └── wire_gen.go├── config│ ├── client.go│ ├── config.go│ └── config.yaml├── genproto│ └── v1│ ├── gw│ │ └── pingservice.pb.gw.go│ ├── pingservice.pb.go│ └── pingservice_grpc.pb.go├── go.mod├── go.sum├── proto│ ├── buf.lock│ ├── buf.yaml│ └── v1│ ├── pingservice.proto│ └── pingservice.yaml└── service ├── client.go └── server.go9 directories, 21 files
开始
复制
在 src
目录下执行如下复制命令:
cp -R pongservice pingservice
删除 wire_gen.go
删除 pingservice/cmd/server
目录中的 wire_gen.go
文件。
修改 go.mod module
修改go.mod
文件的模块,如下代码所示:
module github.com/janrs-io/Jgrpc/src/pingservice
生成 proto
删除pingservice/proto/v1
目录下的pongservice.proto
和pongservice.yaml
文件以及整个genproto
文件夹。
然后重新创建pingservice.proto
和pingservice.yaml
文件,代码如下:
pingservice.proto
code:
syntax = "proto3";package proto.v1;option go_package = "github.com/janrs-io/Jgrpc/src/pingservice/genproto/v1";service PingService { rpc Ping(PingRequest) returns(PingResponse){}}message PingRequest { string msg = 1 ;}message PingResponse { string msg = 1;}
pingservice.yaml
code:
type: google.api.Serviceconfig_version: 3http: rules: - selector: proto.v1.PingService.Ping get: /ping.v1.ping
修改pingservice
目录下的 buf.gen.yaml
文件。 修改后的完整代码如下:
version: v1plugins: - plugin: go out: genproto/v1 opt: - paths=source_relative - plugin: go-grpc out: genproto/v1 opt: - paths=source_relative - plugin: grpc-gateway out: genproto/v1/gw opt: - paths=source_relative - grpc_api_configuration=proto/v1/pingservice.yaml - standalone=true
在pingservice
目录下执行以下命令生成 proto
文件:
buf generate proto/v1
执行命令后,将重新生成genproto
目录,并自动创建*pb.go
文件。
修改 import 路径和所有代码
检查所有文件的导入,将导入路径的pongservice
修改为pingservice
。
将所有代码的Pong/pong
改为Ping/ping
,直到没有错误为止。
修改 config.yaml
修改 config
目录下的config.yaml
文件。将 grpc
的服务器端口更改为 50052
,将 http
的服务器端口更改为 9002
。将 grpc
的服务名改为ping-grpc
,将 http
的服务名改为ping-http
。
修改后的完整代码如下:
# grpc configgrpc: host: "" port: ":50052" name: "ping-grpc"# http confighttp: host: "" port: ":9002" name: "ping-http"
生成 generate inject
在 pingservice
目录中执行以下 wire
命令以重新生成依赖注入文件:
wire ./...
引入 pongservier 服务的 go.mod
我们要在 pingservice
这个微服务中访问 pongservice
的 grpc
服务,所以需要导入 pongservice
的 go.mod
。
修改pingservice
目录下的go.mod
文件,添加导入pongservice
的代码,如下:
module github.com/janrs-io/Jgrpc/src/pingservicego 1.19replace (pongservice => ../pongservice)require (pongservice v0.0.0github.com/google/wire v0.5.0github.com/grpc-ecosystem/grpc-gateway/v2 v2.15.2github.com/spf13/viper v1.15.0google.golang.org/grpc v1.54.0google.golang.org/protobuf v1.30.0)// the other required package...
修改 config.yaml
修改pingservice/config
目录下的config.yaml
文件,添加如下代码:
# service clientclient: pong: ":50051"
修改后的完整代码如下:
# grpc configgrpc: host: "" port: ":50052" name: "ping-grpc"# http confighttp: host: "" port: ":9002" name: "ping-http"# service clientclient: pong: ":50051"
生成 client.go
在pingservice/config
目录下生成client.go
文件,添加如下代码:
package config// Client Client service configtype Client struct {Pong string `json:"pong" yaml:"pong"`}
修改 config.go
在 Config
结构体中添加一个 Client
字段,代码如下:
Client Client `json:"client" yaml:"client"`
修改后的完整代码如下:
package configimport ("net/http""github.com/spf13/viper""google.golang.org/grpc")// Config Service configtype Config struct {Grpc Grpc `json:"grpc" yaml:"grpc"`Http Http `json:"http" yaml:"http"`Client Client `json:"client" yaml:"client"`}// NewConfig Initial service"s configfunc NewConfig(cfg string) *Config {if cfg == "" {panic("load config file failed.config file can not be empty.")}viper.SetConfigFile(cfg)// Read config fileif err := viper.ReadInConfig(); err != nil {panic("read config failed.[ERROR]=>" + err.Error())}conf := &Config{}// Assign the overloaded configuration to the globalif err := viper.Unmarshal(conf); err != nil {panic("assign config failed.[ERROR]=>" + err.Error())}return conf}// Grpc Grpc server configtype Grpc struct {Host string `json:"host" yaml:"host"`Port string `json:"port" yaml:"port"`Name string `json:"name" yaml:"name"`Server *grpc.Server}// Http Http server configtype Http struct {Host string `json:"host" yaml:"host"`Port string `json:"port" yaml:"port"`Name string `json:"name" yaml:"name"`Server *http.Server}
修改 client.go
修改pingservice/service
目录下的client.go
文件,添加如下代码:
// NewPongClient New pong service clientfunc NewPongClient(conf *config.Config) (pongclientv1.PongServiceClient, error) {ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)defer cancel()conn, err := grpc.DialContext(ctx, conf.Client.Pong, grpc.WithTransportCredentials(insecure.NewCredentials()))if err != nil {fmt.Println("dial auth server failed.[ERROR]=>" + err.Error())return nil, err}client := pongclientv1.NewPongServiceClient(conn)return client, nil}
修改后的完整代码如下:
package serviceimport ("context""fmt""time""google.golang.org/grpc""google.golang.org/grpc/credentials/insecure""github.com/janrs-io/Jgrpc/src/pingservice/config"v1 "github.com/janrs-io/Jgrpc/src/pingservice/genproto/v1"pongclientv1 "github.com/janrs-io/Jgrpc/src/pongservice/genproto/v1")// NewClient New service"s clientfunc NewClient(conf *config.Config) (v1.PingServiceClient, error) {serverAddress := conf.Grpc.Host + conf.Grpc.Portctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)defer cancel()conn, err := grpc.DialContext(ctx, serverAddress, grpc.WithTransportCredentials(insecure.NewCredentials()))if err != nil {return nil, err}client := v1.NewPingServiceClient(conn)return client, nil}// NewPongClient New pong service clientfunc NewPongClient(conf *config.Config) (pongclientv1.PongServiceClient, error) {ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)defer cancel()conn, err := grpc.DialContext(ctx, conf.Client.Pong, grpc.WithTransportCredentials(insecure.NewCredentials()))if err != nil {fmt.Println("dial auth server failed.[ERROR]=>" + err.Error())return nil, err}client := pongclientv1.NewPongServiceClient(conn)return client, nil}
修改 server.go
修改pingservice/service
目录下的server.go
文件,修改后的完整代码如下:
package serviceimport ("context""google.golang.org/grpc/grpclog""github.com/janrs-io/Jgrpc/src/pingservice/config"v1 "github.com/janrs-io/Jgrpc/src/pingservice/genproto/v1"pongclientv1 "github.com/janrs-io/Jgrpc/src/pongservice/genproto/v1")// Server Server structtype Server struct {v1.UnimplementedPingServiceServerpingClient v1.PingServiceClientpongClient pongclientv1.PongServiceClientconf *config.Config}// NewServer New service grpc serverfunc NewServer(conf *config.Config,pingClient v1.PingServiceClient,pongClient pongclientv1.PongServiceClient,) v1.PingServiceServer {return &Server{pingClient: pingClient,pongClient: pongClient,conf: conf,}}func (s *Server) Ping(ctx context.Context, req *v1.PingRequest) (*v1.PingResponse, error) {pongReq := &pongclientv1.PongRequest{Msg: "request from ping service"}pongResp, err := s.pongClient.Pong(ctx, pongReq)if err != nil {grpclog.Error("connect pong failed.[ERROR]=>" + err.Error())return nil, err}return &v1.PingResponse{Msg: "response ping msg:" + req.Msg + " and msg from pong service is: " + pongResp.Msg,}, nil}
修改 wire.go
修改pingservice/cmd/server
的wire.go
文件,添加service.NewPongClient
依赖注入。 代码如下:
service.NewPongClient
修改后的完整代码如下:
//go:build wireinject// +build wireinjectpackage serverimport ("github.com/google/wire""github.com/janrs-io/Jgrpc/src/pingservice/config"v1 "github.com/janrs-io/Jgrpc/src/pingservice/genproto/v1""github.com/janrs-io/Jgrpc/src/pingservice/service")// InitServer Inject service"s componentfunc InitServer(conf *config.Config) (v1.PingServiceServer, error) {wire.Build(service.NewPongClient,service.NewClient,service.NewServer,)return &service.Server{}, nil}
在 pingservice
目录下执行以下 wire
命令重新生成依赖注入文件:
如果出现
go.mod
引入错误,只需在pingservice
目录中再次运行go mod tidy
。
wire ./...
启动 service
分别在pongservice
目录和pingservice
目录下执行go run
命令。
go run cmd/main.go
在浏览器中输入以下请求地址:
127.0.01:9002/ping.v1.ping?msg=best practice
一切正确的情况下返回以下 json 数据:
{ "msg": "response ping msg:best practice and msg from pong service is: response pong msg:request from ping service"}
总结
这部分我们新建一个 pingservice
微服务,实现访问 pongservice
的 grpc
服务。
相信通过这两次创建微服务的简单尝试,你一定觉得基于Go
和Grpc
开发微服务并不难。
在下一部分中,我们将利用 Jenkins/Gitlab/Harbor
和 Kubernets/Istio
进行 devops
的 CICD
部署。
转载请注明来源:https://janrs.com/ugj7
关键词:
-
基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 2/3
基于Go Grpc kubernetes Istio开发微服务的最佳实践尝试-1 3基于Go Grpc kubernetes Istio开发微...
来源: 基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 2/3
【焦点热闻】如何实现根据环境切换不同配置?
数据丢失不用怕,火山引擎 DataLeap 提供排查解决方案
英特尔以强大产品力,迎接生成式AI的广阔机遇
【全球快播报】北京启动存量住房交易“带押过户”模式
热消息:直播间卖卫星 最低200万!罗永浩:真的 把卫星价格打下来
Redmi Note 12 Turbo晒战绩:16GB+1TB开售5分钟超过全行业历史销量之和
每日热闻!这就离谱!A7S3传感器用来拍Vlog 索尼ZV-E1开启预售
vivo X Fold2影像曝光:IMX866主摄、潜望长焦取消
天天实时:一键获取测试脚本,轻松验证“TSBS 时序数据库性能基准测试报告”
天天快看点丨windows系统 批量处理文件名称
Python Django投稿系统代码
环球今头条!日本最早将于2024年度在新东名高速公路部分区间设置自动驾驶车道
环球即时看!小姐姐秒种草!雅迪冠能摩登发布:独创复古女王风
当前速讯:你家乡上榜没?中国省级“癌症地图”出炉:肺癌列第一 “穷癌”下降“富癌”上升
3299元性价比封神!AMD Zen4 104MB缓存锐龙7 7800X3D价格公布
迅雷临时文件读取错误怎么回事?迅雷临时文件读取错误怎么解决?
色带打印机怎么换色带?色带的正确安装方法是什么?
win10版本号与操作系统版本号有什么区别?怎么查看win10版本号?
英雄联盟狮子狗叫什么?英雄联盟狮子狗连招介绍
诺基亚X3上市时间是什么时候?诺基亚X3手机参数
CloudCanal 落地 DB2 数据迁移同步功能
观天下!hdfs disk balancer 磁盘均衡器
全球百事通!Python 应用 - jieba 分词 1:进行批量文本分词_艽野尘梦 better 的博客 - CSDN 博客
全球滚动:数论分块简介
【速看料】Mysql之SQL语句基础1
环球快报:2磅蛋糕是几寸适合多少人吃_2磅蛋糕是几寸
新消息丨贾跃亭宣布历史时刻:为梦想窒息FF 91量产!老外狠拆台展示车架或未全面投产
Windows 11 2024版发布了!首个官方ISO镜像免费下载
环球观点:调查显示:超半数受访者认为学历还是敲门砖
环球今热点:男子将父亲骨灰撒入大海被抓?为啥不能私自撒?
全球消息!庆祝索尼第一方游戏登陆XGP:微软推出Xbox限定主机
交互触摸大屏概念整理
速讯:全网最全的权限系统设计方案,不接受反驳!
要闻速递:[Redis]Redis概述
JSON多层嵌套复杂结构数据扁平化处理转为行列数据
微速讯:飞沫传播图片_飞沫传播
每日讯息!【财经分析】“意料之中”与“预期之外” 一季度债市踌躇中展现韧性
国产商用卫星上架电商:折后200万起
全球讯息:双电机三把锁!比亚迪F品牌“SF”谍照再曝光:或于6月发布
天天通讯!43万起 新一代长轴版奔驰GLC开售 网友:给我一个不买理想L9的理由
当前信息:《流浪地球2》摄影指导:没觉得中国电影比别人差
焦点热议:广东检出1例“恐龙血”:Hh孟买血型系统 比Rh还稀有
宿州埇桥:烧鸡展翅飞出一片“新天地”
Twitter营销教程_编程入门自学教程_菜鸟教程-免费教程分享
世界速递!skywalking插件工作原理剖析
全网最详细中英文ChatGPT-GPT-4示例文档-类比语句智能生成从0到1快速入门——官网推荐的48种最佳应用场景(附python/node.js/curl命
全球观察:利用Jackson序列化实现数据脱敏
特斯拉Model 3起火殃及宝马新车 车主索赔法院如此判决
新疆阿瓦提长绒棉:清爽透气纯棉背心9.9元/件狂促
小伙戒指卡手遇130名消防员演训:正好现场教学 科普一定不能硬拽
每日热门:城会玩!印度法官无法判决向ChatGPT求助 专家称或成全球法院系统标配
专为小姐姐打造!雅迪冠能Q9发布:超级续航+超级好看
环球讯息:清明将至,我省各地倡导文明祭祀育新风—— 追思亲人,如何更好“重情”
当前消息!Microsoft Edge 分屏 推荐
国家统计局:3月份采购经理指数延续扩张走势
世界速看:社保基金2022年四季度新进30股 增持64股
天天快看点丨法拉第未来发布会只展示了个车架 贾跃亭还有这些问题需要回答
女子带孩子吃饭故意往菜里扔头发 店家看监控发现:网友吐槽教坏孩子
号称德国500年纯酿造法!特斯拉推出啤酒GigaBier:3瓶卖667元
全球通讯!微软、索尼等巨头纷纷退出:全球最大游戏展E3宣布取消
当前速看:15.86万元起 新款大众途岳上市:换1.5T发动机、能喝92号油
助力“科技+产业+金融”良性发展 上海首单非公开科创债发行
让退化的森林再获新生
天天滚动:比亚迪不去美国 照样做大哥
世界观速讯丨海底捞2022年营收347亿!“最牛打工妹”杨利娟接任后扭亏为盈赚了13亿
天天热资讯!4G比5G更成熟 越来越多用户认可?三大运营商猛推5G 2025年将连接超10亿
熔断和降级有什么区别?
资讯:国际金融市场早知道:3月31日
全球播报:上证报:美元拐点将至,分析师称人民币资产或有望成为避险资产
当前播报:冯小刚主演 中国版《忠犬八公》今日上映:日本版曾感动无数人
视讯!发布/上市时间来了!NV RTX 4070国行售价大曝光:玩家直呼老黄良心了
读SQL进阶教程笔记03_自连接
pcm音频的录制、播放及转换
全球观点:非洲致命疾病 出现症状24小时内死亡:医生直呼病毒可怕引外界担心
快报:媒体:谁在开发“一键脱衣”App 行为龌龊已触犯法律 应严惩开发者
环球热文:新疆新鑫矿业(03833.HK)2022年度纯利增44.4%至7.45亿元 末期息0.15元
【世界新视野】美国火车又双叒叕脱轨了:装乙醇车厢爆炸起火
SSD还要降价!今年是涨不回来了
全球消息!实测一个月 我发现了家用脱毛仪的真相
全球资讯:FF91量产了 不过市场里已经没了贾老板的位置
全球速递!2022年全球新能源销冠 每天进账11亿!“技术为王”的比亚迪做对了什么?
全球资讯:来月经能吃人参果吗?
“门口五不放,放了家运衰”,5种东西是啥?老祖宗的经验之谈
关注:01、关于满减优惠券可叠加使用场景下的动态规划算法
当前视点!Spring AOP官方文档学习笔记(一)之AOP概述
全球焦点!魅族20系列价格公布:2999元起、无界顶配8499元!
当前头条:Epic要免费送大作《消逝的光芒》增强版了:立省百元!网友:E宝YYDS
香蕉、蜂蜜治疗便秘?又骗我好多年
当前热议!俄妹COS《生化危机1》吉尔 战斗服难掩好身材
今头条!【kafka】-生产环境问题-报错Maximum application poll interval
热议:流畅、稳定全面进化:魅族Flyme 10正式发布
天天资讯:17999元 ROG新款XG Mobile显卡坞上架:175W移动版RTX 4090
天天看点:魅族Flyme Auto车机系统正式发布:交互完全不输华为问界
世界观点:满血标准版48个月不卡!魅族20发布:2999元起
每日观点:3999元起 魅族20 PRO发布:魅族史上最高标准旗舰
环球热资讯!React Router 备忘清单_开发速查表分享
每日观点:希尔排序
环球微动态丨强网杯2022 GameMaster
环球视讯!128只债券推迟或取消发行