php入门到就业线上直播课：进入学习
Apipost = Postman + Swagger + Mock + Jmeter 超好用的API调试工具：点击使用
首先我们用go-micro构建一个服务。（关于go-micro的使用可以参照官方实例或者文档）
//新建一个微服务
micro new --type "srv" user-srv
定义我们的服务，这里定义两个rpc服务，Register和User
// 修改proto
syntax = "proto3";
package go.micro.srv.user;
service User {
rpc Register(RegisterRequest) returns (UserInfo) {}
rpc User(UserInfoRequest) returns (UserInfo) {}
rpc Stream(StreamingRequest) returns (stream StreamingResponse) {}
rpc PingPong(stream Ping) returns (stream Pong) {}
}
message UserInfoRequest {
int64 userId = 1;
}
message RegisterRequest {
string username = 1;
string email = 2;
string password = 3;
}
message UserInfo {
int64 id = 1;
string username = 2;
string email = 3;
}
message StreamingRequest {
int64 count = 1;
}
message StreamingResponse {
int64 count = 1;
}
message Ping {
int64 stroke = 1;
}
message Pong {
int64 stroke = 1;
}
然后生成执行下面命令我们就可以发现在proto文件中多出两个文件。这个proto为我们生成的，后面会用到。
protoc --proto_path=${GOPATH}/src:. --micro_out=. --go_out=. proto/user/user.proto
写我们的业务逻辑，修改handle/user.go文件
type User struct{}
// Call is a single request handler called via client.Call or the generated client code
func (e *User) Register(ctx context.Context, req *user.RegisterRequest, rsp *user.UserInfo) error {
log.Log("Received User.Register request")
rsp.Id = 1
rsp.Email = req.Email
rsp.Username = req.Username
return nil
}
func (e *User) User(ctx context.Context, req *user.UserInfoRequest, rsp *user.UserInfo) error {
log.Log("Received User.Register request")
rsp.Id = 1
rsp.Email = "741001560@qq.com"
rsp.Username = "chensi"
return nil
}
// Stream is a server side stream handler called via client.Stream or the generated client code
func (e *User) Stream(ctx context.Context, req *user.StreamingRequest, stream user.User_StreamStream) error {
log.Logf("Received User.Stream request with count: %d", req.Count)
for i := 0; i < int(req.Count); i++ {
log.Logf("Responding: %d", i)
if err := stream.Send(&user.StreamingResponse{
Count: int64(i),
}); err != nil {
return err
}
}
return nil
}
// PingPong is a bidirectional stream handler called via client.Stream or the generated client code
func (e *User) PingPong(ctx context.Context, stream user.User_PingPongStream) error {
for {
req, err := stream.Recv()
if err != nil {
return err
}
log.Logf("Got ping %v", req.Stroke)
if err := stream.Send(&user.Pong{Stroke: req.Stroke}); err != nil {
return err
}
}
}
最后修改我们的main.go文件，服务发现使用时consul。
func main() {
//initCfg()
// New Service
micReg := consul.NewRegistry()
service := micro.NewService(
micro.Server(s.NewServer()),
micro.Name("go.micro.srv.user"),
micro.Version("latest"),
micro.Registry(micReg),
)
// Initialise service
service.Init()
// Run service
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
我们使用consul做微服务发现，当然首先你需要安装consul
wget https://releases.hashicorp.com/consul/1.2.0/consul_1.6.1_linux_amd64.zip
unzip consul_1.6.1_linux_amd64.zip
mv consul /usr/local/bin/
启动consul的时候由于在是本地虚拟机上面，所以我们可以简单处理
consul agent -dev -client 0.0.0.0 -ui
这时候可以启动consul的ui了，我本地vagrant的虚拟机192.168.10.100，那么我们打开的是http://192.168.10.100:8500/ui/dc1/services
启动user-srv的服务发现consul里面出现 go.micro.srv.user 的服务注册信息了
下面来写hyperf的代码了。按照官方文档安装框架，安装的时候rpc需要选择grpc，需要注意的是你的系统上面需要安装php7.2以上的版本，swoole版本也需要4.3的版本以上，我用的是最新homestead，所以相对而言安装这些依赖比较简单，所以在此强烈