micro_srv_test.go 749 B

123456789101112131415161718192021222324252627282930313233
  1. package micro_srv
  2. import (
  3. "context"
  4. "dashoo.cn/common_definition/auth"
  5. "dashoo.cn/opms_libary/gtoken"
  6. "fmt"
  7. "github.com/gogf/gf/frame/g"
  8. "github.com/smallnest/rpcx/client"
  9. "testing"
  10. )
  11. func TestName(t *testing.T) {
  12. grsp := gtoken.Resp{}
  13. d, _ := client.NewPeer2PeerDiscovery("tcp@127.0.0.1:8888", "")
  14. authService := client.NewXClient("Auth", client.Failtry, client.RandomSelect, d, client.DefaultOption)
  15. defer authService.Close()
  16. rsp := &auth.Response{}
  17. err := authService.Call(context.TODO(), "ValidToken", "+MFidQBXtaeIxZ3ZJI72ze6jX+mR47ZekWzzNu8HWrewJoDjs1Bf9t1+7lKapDr2", rsp)
  18. if err != nil {
  19. g.Log().Error(err)
  20. grsp.Code = 401
  21. }
  22. grsp.Code = int(rsp.Code)
  23. grsp.Msg = rsp.Msg
  24. grsp.Data = rsp.Data
  25. fmt.Println(grsp)
  26. }