1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- package main
- import (
- "context"
- "flag"
- "fmt"
- "github.com/longjoy/micro-go-course/section24/comment/endpoint"
- "github.com/longjoy/micro-go-course/section24/comment/service"
- "github.com/longjoy/micro-go-course/section24/comment/transport"
- "log"
- "net/http"
- "os"
- "os/signal"
- "strconv"
- "syscall"
- )
- func main() {
- servicePort := flag.Int("service.port", 8081, "service port")
- flag.Parse()
- errChan := make(chan error)
- srv := service.NewGoodsServiceImpl()
- endpoints := endpoint.CommentsEndpoints{
- CommentsListEndpoint: endpoint.MakeCommentsListEndpoint(srv),
- }
- handler := transport.MakeHttpHandler(context.Background(), &endpoints)
- go func() {
- errChan <- http.ListenAndServe(":"+strconv.Itoa(*servicePort), handler)
- }()
- go func() {
- // 监控系统信号,等待 ctrl + c 系统信号通知服务关闭
- c := make(chan os.Signal, 1)
- signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
- errChan <- fmt.Errorf("%s", <-c)
- }()
- err := <-errChan
- log.Printf("listen err : %s", err)
- }
|