main.go 835 B

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package main
  2. import (
  3. "flag"
  4. "fmt"
  5. "reflect"
  6. "sparrow/pkg/rpcs"
  7. "sparrow/pkg/server"
  8. "sparrow/services/scene-access/internal/service"
  9. )
  10. const (
  11. flagRabbitHost = "rabbithost"
  12. defaultRabbitHost = "amqp://guest:guest@localhost:5672/"
  13. )
  14. var (
  15. confRabbitHost = flag.String(flagRabbitHost, defaultRabbitHost, "rabbitmq host address, amqp://user:password@ip:port/")
  16. )
  17. func main() {
  18. // init server
  19. err := server.Init(rpcs.SceneAccessServiceName)
  20. if err != nil {
  21. server.Log.Fatal(err)
  22. return
  23. }
  24. scene := service.NewSceneService(*confRabbitHost)
  25. err = server.RegisterRPCHandler(scene)
  26. if err != nil {
  27. return
  28. }
  29. t := reflect.TypeOf(scene)
  30. for i := 0; i < t.NumMethod(); i++ {
  31. method := t.Method(i)
  32. fmt.Println(method.Name)
  33. }
  34. // start to run
  35. err = server.Run()
  36. if err != nil {
  37. server.Log.Fatal(err)
  38. }
  39. }