Ai
1 Star 0 Fork 0

chenjp/rpc-to-micro

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
server.go 1.50 KB
一键复制 编辑 原始数据 按行查看 历史
chenjp 提交于 2020-11-10 23:50 +08:00 . 更新进度到事件驱动机制
package main
import (
"GoCode/example/goMicroDemo/message"
"context"
"errors"
"fmt"
"github.com/micro/go-micro"
"github.com/micro/go-micro/registry"
"github.com/micro/go-plugins/registry/consul"
"log"
"time"
)
//学生服务管理实现
type StudentManager struct {
}
func (s StudentManager) GetStudent(c context.Context, request *message.StudentRequest, student *message.Student) error {
studentMap := map[string]message.Student{
"davie": {Name: "davie", Classes: "软件工程专业", Grade: 80},
"steven": {Name: "steven", Classes: "计算机科学与技术", Grade: 90},
"tony": {Name: "tony", Classes: "计算机网络工程", Grade: 85},
"jack": {Name: "jack", Classes: "工商管理", Grade: 96},
}
if request.Name == "" {
return errors.New(" 请求参数错误,请重新请求。")
}
fmt.Println(request.Name)
studentInfo := studentMap[request.Name]
fmt.Println(studentInfo)
if studentInfo.Name != "" {
*student = studentInfo
return nil
}
return errors.New(" 未查询当相关学生信息 ")
}
func main() {
consulRegistry := consul.NewRegistry(registry.Addrs("localhost:8500"))
service := micro.NewService(
micro.Name("student_service"),
micro.Version("1.0.0"),
micro.Registry(consulRegistry),
micro.RegisterTTL(10*time.Second),
micro.RegisterInterval(5*time.Second))
// 初始化
service.Init()
// 注册服务
message.RegisterStudentServiceHandler(service.Server(), new(StudentManager))
// 启动
err := service.Run()
if err != nil {
log.Fatal(err)
}
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/chensyf/rpc-to-micro.git
git@gitee.com:chensyf/rpc-to-micro.git
chensyf
rpc-to-micro
rpc-to-micro
master

搜索帮助