main.go 555 B

123456789101112131415161718192021222324252627
  1. package main
  2. import (
  3. "github.com/RaymondCode/simple-demo/initialize"
  4. "github.com/RaymondCode/simple-demo/kafka"
  5. "github.com/gin-gonic/gin"
  6. )
  7. func main() {
  8. /* fmt.Println(service.GetToken("weqwe"))
  9. time.Sleep(time.Second)
  10. fmt.Println(service.GetToken("weqwe"))*/
  11. initialize.AssignMent()
  12. // go kafkatest.RunProducer();
  13. go kafka.RunConsumer()
  14. // dao.GetList()
  15. //util.GetSnapshot("D:\\CF\\stg.mp4","D:\\CF\\BEAR",20)
  16. r := gin.Default()
  17. initRouter(r)
  18. r.Run(":8089") // listen and serve on 0.0.0.0:8080 (for windows "localhost:8080")
  19. }