基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试
Posted 杨建勇
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试相关的知识,希望对你有一定的参考价值。
基于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.go
9 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.Service
config_version: 3
http:
rules:
- selector: proto.v1.PingService.Ping
get: /ping.v1.ping
修改 pingservice
目录下的 buf.gen.yaml
文件。 修改后的完整代码如下:
version: v1
plugins:
- 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 config
grpc:
host: ""
port: ":50052"
name: "ping-grpc"
# http config
http:
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/pingservice
go 1.19
replace (
pongservice => ../pongservice
)
require (
pongservice v0.0.0
github.com/google/wire v0.5.0
github.com/grpc-ecosystem/grpc-gateway/v2 v2.15.2
github.com/spf13/viper v1.15.0
google.golang.org/grpc v1.54.0
google.golang.org/protobuf v1.30.0
)
// the other required package...
修改 config.yaml
修改pingservice/config
目录下的config.yaml
文件,添加如下代码:
# service client
client:
pong: ":50051"
修改后的完整代码如下:
# grpc config
grpc:
host: ""
port: ":50052"
name: "ping-grpc"
# http config
http:
host: ""
port: ":9002"
name: "ping-http"
# service client
client:
pong: ":50051"
生成 client.go
在pingservice/config
目录下生成client.go
文件,添加如下代码:
package config
// Client Client service config
type Client struct
Pong string `json:"pong" yaml:"pong"`
修改 config.go
在 Config
结构体中添加一个 Client
字段,代码如下:
Client Client `json:"client" yaml:"client"`
修改后的完整代码如下:
package config
import (
"net/http"
"github.com/spf13/viper"
"google.golang.org/grpc"
)
// Config Service config
type Config struct
Grpc Grpc `json:"grpc" yaml:"grpc"`
Http Http `json:"http" yaml:"http"`
Client Client `json:"client" yaml:"client"`
// NewConfig Initial service\'s config
func NewConfig(cfg string) *Config
if cfg == ""
panic("load config file failed.config file can not be empty.")
viper.SetConfigFile(cfg)
// Read config file
if err := viper.ReadInConfig(); err != nil
panic("read config failed.[ERROR]=>" + err.Error())
conf := &Config
// Assign the overloaded configuration to the global
if err := viper.Unmarshal(conf); err != nil
panic("assign config failed.[ERROR]=>" + err.Error())
return conf
// Grpc Grpc server config
type 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 config
type 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 client
func 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 service
import (
"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 client
func NewClient(conf *config.Config) (v1.PingServiceClient, error)
serverAddress := conf.Grpc.Host + conf.Grpc.Port
ctx, 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 client
func 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 service
import (
"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 struct
type Server struct
v1.UnimplementedPingServiceServer
pingClient v1.PingServiceClient
pongClient pongclientv1.PongServiceClient
conf *config.Config
// NewServer New service grpc server
func 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.PongRequestMsg: "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 wireinject
package server
import (
"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 component
func 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
Nginx虚拟主机 (基于域名 基于端口 基于ip)
Nginx虚拟主机
- 基于域名的虚拟主机
- 基于IP地址的虚拟主机
- 基于端口的虚拟主机
一,安装DNS域名解析服务器
1,安装bind服务器
[root@localhost ~]# yum install bind -y
2,修改主配置文件(named.conf)
[root@localhost ~]# vim /etc/named.conf
options {
listen-on port 53 { any; }; ##监听所有
listen-on-v6 port 53 { ::1; };
directory "/var/named";
dump-file "/var/named/data/cache_dump.db";
statistics-file "/var/named/data/named_stats.txt";
memstatistics-file "/var/named/data/named_mem_stats.txt";
recursing-file "/var/named/data/named.recursing";
secroots-file "/var/named/data/named.secroots";
allow-query { any; }; ##允许所有
3,修改区域配置文件(named.rfc1912.zones)
[root@localhost ~]# vim /etc/named.rfc1912.zones ##配置区域配置文件
zone "kgc.com" IN {
type master;
file "kgc.com.zone"; ##kgc区域数据配置文件
allow-update { none; };
};
zone "accp.com" IN {
type master;
file "accp.com.zone"; ##accp区域数据配置文件
allow-update { none; };
};
4,修改区域数据配置文件(kgc.com.zone accp.com.zone)
[root@localhost ~]# cd /var/named/
[root@localhost named]# cp -p named.localhost kgc.com.zone ##复制模板
[root@localhost named]# vim kgc.com.zone ##修改区域配置文件
$TTL 1D
@ IN SOA @ rname.invalid. (
0 ; serial
1D ; refresh
1H ; retry
1W ; expire
3H ) ; minimum
NS @
A 127.0.0.1
www IN A 192.168.13.128 ##本机地址
[root@localhost named]# cp -p kgc.com.zone accp.com.zone ##复制文件为accp区域数据配置文件
[root@localhost named]# systemctl start named ##开启dns服务
[root@localhost named]# systemctl stop firewalld.service ##关闭防火墙
[root@localhost named]# setenforce 0
5,创建两个网站的站点目录并添加首页内容
[root@localhost ~]# mkdir -p /var/www/html/accp ##创建accp站点
[root@localhost ~]# mkdir -p /var/www/html/kgc ##创建kgc站点
[root@localhost ~]# cd /var/www/html/
[root@localhost html]# ls
accp kgc
[root@localhost html]# echo "this a accp web" > accp/index.html ##创建首页内容
[root@localhost html]# echo "this a kgc web" > kgc/index.html ##创建首页内容
二,在Windows上将LAMP所需压缩软件包共享出来(此处如有问题请看之前的博客相关文章)
三,在Linux上使用远程共享获取文件并挂载到mnt目录下
[root@localhost ~]# smbclient -L //192.168.100.3/ ##远程共享访问
Enter SAMBA
oot‘s password:
Sharename Type Comment
--------- ---- -------
LNMP-C7 Disk
[root@localhost ~]# mount.cifs //192.168.100.3/LNMP-C7 /mnt ##挂载到/mnt目录下
四,编译安装Nginx
1,解压源码包到/opt下,并查看
[root@localhost ~]# cd /mnt ##切换到挂载点目录
[root@localhost mnt]# ls
Discuz_X3.4_SC_UTF8.zip nginx-1.12.2.tar.gz
mysql-boost-5.7.20.tar.gz php-7.1.20.tar.gz
[root@localhost mnt]# tar zxvf nginx-1.12.2.tar.gz -C /opt ##解压Nginx源码包到/opt下
[root@localhost mnt]# cd /opt/ ##切换到解压的目录下
[root@localhost opt]# ls
nginx-1.12.2 rh
2,安装编译需要的环境组件包
[root@localhost opt]# yum -y install gcc //c语言
gcc-c++ //c++语言
pcre-devel //pcre语言工具
zlib-devel //数据压缩用的函式库
3,创建程序用户nginx并编译Nginx
[root@localhost opt]# useradd -M -s /sbin/nologin nginx ##创建程序用户,安全不可登陆状态
[root@localhost opt]# id nginx
uid=1001(nginx) gid=1001(nginx) 组=1001(nginx)
[root@localhost opt]# cd nginx-1.12.0/ ##切换到nginx目录下
[root@localhost nginx-1.12.0]# ./configure ##配置nginx
> --prefix=/usr/local/nginx ##安装路径
> --user=nginx ##用户名
> --group=nginx ##用户组
> --with-http_stub_status_module ##状态统计模块
4,编译和安装
[root@localhost nginx-1.12.0]# make ##编译
...
[root@localhost nginx-1.12.0]# make install ##安装
...
5,优化nginx启动脚本,以便于系统识别
[root@localhost nginx]# ln -s /usr/local/nginx/sbin/nginx /usr/local/sbin/
##创建软连接让系统识别nginx启动脚本
[root@localhost nginx]# nginx -t ##检查配置文件的语法问题
nginx: the configuration file /usr/local/nginx/conf/nginx.conf syntax is ok
nginx: configuration file /usr/local/nginx/conf/nginx.conf test is successful
[root@localhost nginx]# nginx ##开启ngnix
[root@localhost nginx]# netstat -ntap | grep 80 ##查看端口,nginx已经开启
tcp 0 0 0.0.0.0:80 0.0.0.0:* LISTEN 39620/nginx: master
[root@localhost nginx]# systemctl stop firewalld.service ##关闭防火墙
[root@localhost nginx]# setenforce 0
[root@localhost nginx]# nginx ##开启
6,制作管理脚本,便于使用service管理使用
[root@localhost nginx]# cd /etc/init.d/ ##切换到启动配置文件目录
[root@localhost init.d]# ls
functions netconsole network README
[root@localhost init.d]# vim nginx ##编辑启动脚本文件
#!/bin/bash
# chkconfig: - 99 20 ##注释信息
# description: Nginx Service Control Script
PROG="/usr/local/nginx/sbin/nginx" ##设置变量为nginx命令文件
PIDF="/usr/local/nginx/logs/nginx.pid" ##设置变量PID文件 进程号为5346
case "$1" in
start)
$PROG ##开启服务
;;
stop)
kill -s QUIT $(cat $PIDF) ##关闭服务
;;
restart) ##重启服务
$0 stop
$0 start
;;
reload) ##重载服务
kill -s HUP $(cat $PIDF)
;;
*) ##错误输入提示
echo "Usage: $0 {start|stop|restart|reload}"
exit 1
esac
exit 0
[root@localhost init.d]# chmod +x /etc/init.d/nginx ##给启动脚本执行权限
[root@localhost init.d]# chkconfig --add nginx ##添加到service管理器中
[root@localhost init.d]# service nginx stop ##就可以使用service控制nginx
[root@localhost init.d]# service nginx start
7,或者方便systemctl管理,配置文件(为方便写一种即可)
[root@localhost ~]# vim /lib/systemd/system/nginx.service ##创建配置文件
[Unit]
Description=nginx ##描述
After=network.target ##描述服务类型
[Service]
Type=forking ##后台运行形式
PIDFile=/usr/local/nginx/logs/nginx.pid ##PID文件位置
ExecStart=/usr/local/nginx/sbin/nginx ##启动服务
ExecReload=/usr/bin/kill -s HUP $MAINPID ##根据PID重载配置
ExecStop=/usr/bin/kill -s QUIT $MAINPID ##根据PID终止进程
PrivateTmp=true
[Install]
WantedBy=multi-user.target
[root@localhost ~]# chmod 754 /lib/systemd/system/nginx.service ##设置执行权限
[root@localhost ~]# systemctl stop nginx.service ##关闭
[root@localhost ~]# systemctl start nginx.service ##开启
五,基于不同域名的虚拟主机
1,修改nginx配置文件信息
[root@localhost ~]# cd /usr/local/nginx/conf
[root@localhost conf]# vim nginx.conf ##修改Nginx配置文件
server {
listen 80;
server_name www.kgc.com; ##kgc网站
charset utf-8;
access_log logs/www.kgc.com.access.log; ##日志文件
location / {
root /var/www/html/kgc; ##站点目录
index index.html index.htm;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
server {
listen 80;
server_name www.accp.com; ##accp网站
charset utf-8;
access_log logs/www.accp.com.access.log; ##日志文件
location / {
root /var/www/html/accp; ##站点目录
index index.html index.htm;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
[root@localhost conf]# service nginx restart ##重启nginx服务
2,用测试机访问不同域名的网站
六,基于不同端口的虚拟主机
1,修改nginx配置文件信息
[root@localhost ~]# cd /usr/local/nginx/conf
[root@localhost conf]# vim nginx.conf ##修改Nginx配置文件
server {
listen 80;
server_name www.accp.com;
charset utf-8;
access_log logs/www.accp.com.access.log;
location / {
root /var/www/html/accp;
index index.html index.htm;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
server {
listen 192.168.13.138:8080; ##修改监听端口为8080
server_name www.accp.com;
charset utf-8;
access_log logs/www.accp8080.com.access.log; ##日志文件修改为8080
location / {
root /var/www/html/accp8080; ##8080端口的站点目录
index index.html index.htm;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
2,创建accp8080站点目录,并创建首页内容
[root@localhost conf]# cd /var/www/html/ ##切换到站点目录中
[root@localhost html]# mkdir accp8080 ##创建站点目录
[root@localhost html]# cd accp8080/
[root@localhost accp8080]# echo "this is accp8080 web" > index.html ##创建首页内容
[root@localhost accp8080]# service nginx restart ##重启Nginx服务
3,用测试机访问不同端口的网站
七,基于不同IP的虚拟主机
1,在虚拟机上添加一块网卡
192.168.13.138
192.168.13.133
2,修改dns区域数据配置文件
[root@localhost ~]# cd var/named/
[root@localhost named]# vim kgc.com.zone ##修改kgc的区域数据配置文件
$TTL 1D
@ IN SOA @ rname.invalid. (
0 ; serial
1D ; refresh
1H ; retry
1W ; expire
3H ) ; minimum
NS @
A 127.0.0.1
www IN A 192.168.13.133 ##地址为133
[root@localhost named]# vim accp.com.zone ##修改accp的区域数据配置文件
$TTL 1D
@ IN SOA @ rname.invalid. (
0 ; serial
1D ; refresh
1H ; retry
1W ; expire
3H ) ; minimum
NS @
A 127.0.0.1
www IN A 192.168.13.138 ##地址为138
[root@localhost named]# systemctl restart named ##重启dns服务
3,修改nginx配置文件信息
[root@localhost ~]# cd /usr/local/nginx/conf
[root@localhost conf]# vim nginx.conf ##修改Nginx配置文件
server {
listen 192.168.13.133:80; ##指定IP地址
server_name www.kgc.com;
charset utf-8;
access_log logs/www.kgc.com.access.log;
location / {
root /var/www/html/kgc;
index index.html index.htm;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
server {
listen 192.168.13.138:80; ##指定IP地址
server_name www.accp.com;
charset utf-8;
access_log logs/www.accp.com.access.log;
location / {
root /var/www/html/accp;
index index.html index.htm;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
[root@localhost conf]# service nginx restart ##重启Nginx服务
4,用测试机访问不同IP的网站
谢谢阅读!
以上是关于基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试的主要内容,如果未能解决你的问题,请参考以下文章
推荐算法简介:基于用户的协同过滤基于物品的协同过滤基于内容的推荐