servicecontext.go 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package svc
  2. import (
  3. "app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
  4. "bp.jydev.jianyu360.cn/BaseService/biService/api/internal/config"
  5. "bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
  6. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/resource"
  7. "bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/usercenter"
  8. "github.com/zeromicro/go-zero/core/discov"
  9. "github.com/zeromicro/go-zero/zrpc"
  10. )
  11. type ServiceContext struct {
  12. Config config.Config
  13. BiServiceRpc biservice.BiService
  14. ResourceCenterRpc resource.Resource
  15. UserCenterRpc usercenter.UserCenter
  16. MessageCenterRpc messageclient.Message
  17. }
  18. func NewServiceContext(c config.Config) *ServiceContext {
  19. return &ServiceContext{
  20. Config: c,
  21. BiServiceRpc: biservice.NewBiService(zrpc.MustNewClient(c.BiServiceRpc)),
  22. ResourceCenterRpc: resource.NewResource(zrpc.MustNewClient(zrpc.RpcClientConf{
  23. Etcd: discov.EtcdConf{
  24. Hosts: c.BiServiceRpc.Etcd.Hosts,
  25. //Hosts: []string{"172.31.31.205:2379"},
  26. Key: c.ResourceCenterKey,
  27. },
  28. })),
  29. UserCenterRpc: usercenter.NewUserCenter(zrpc.MustNewClient(zrpc.RpcClientConf{
  30. Etcd: discov.EtcdConf{
  31. Hosts: c.BiServiceRpc.Etcd.Hosts,
  32. //Hosts: []string{"172.31.31.205:2379"},
  33. Key: c.UserCenterKey,
  34. },
  35. })),
  36. MessageCenterRpc: messageclient.NewMessage(zrpc.MustNewClient(zrpc.RpcClientConf{
  37. Etcd: discov.EtcdConf{
  38. Hosts: c.BiServiceRpc.Etcd.Hosts,
  39. //Hosts: []string{"172.31.31.205:2379"},
  40. Key: c.MessageCenterKey,
  41. },
  42. })),
  43. }
  44. }