print message when starting api server

This commit is contained in:
kevin
2020-09-16 13:27:16 +08:00
parent a50bcb90a6
commit a561884fcf
6 changed files with 112 additions and 112 deletions

View File

@@ -1,10 +1,12 @@
package main
import (
"flag"
"fmt"
"bookstore/api/internal/config"
"bookstore/api/internal/handler"
"bookstore/api/internal/svc"
"flag"
"github.com/tal-tech/go-zero/core/conf"
"github.com/tal-tech/go-zero/rest"
@@ -23,5 +25,7 @@ func main() {
defer server.Stop()
handler.RegisterHandlers(server, ctx)
fmt.Printf("Starting server at %s:%d...\n", c.Host, c.Port)
server.Start()
}

View File

@@ -4,15 +4,16 @@
package main
import (
"flag"
"fmt"
"bookstore/rpc/add/internal/config"
"bookstore/rpc/add/internal/server"
"bookstore/rpc/add/internal/svc"
add "bookstore/rpc/add/pb"
"flag"
"fmt"
"log"
"github.com/tal-tech/go-zero/core/conf"
"github.com/tal-tech/go-zero/core/logx"
"github.com/tal-tech/go-zero/rpcx"
"google.golang.org/grpc"
)
@@ -30,9 +31,7 @@ func main() {
s, err := rpcx.NewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
add.RegisterAdderServer(grpcServer, adderSrv)
})
if err != nil {
log.Fatal(err)
}
logx.Must(err)
fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
s.Start()

View File

@@ -4,15 +4,16 @@
package main
import (
"flag"
"fmt"
"bookstore/rpc/check/internal/config"
"bookstore/rpc/check/internal/server"
"bookstore/rpc/check/internal/svc"
check "bookstore/rpc/check/pb"
"flag"
"fmt"
"log"
"github.com/tal-tech/go-zero/core/conf"
"github.com/tal-tech/go-zero/core/logx"
"github.com/tal-tech/go-zero/rpcx"
"google.golang.org/grpc"
)
@@ -30,9 +31,7 @@ func main() {
s, err := rpcx.NewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
check.RegisterCheckerServer(grpcServer, checkerSrv)
})
if err != nil {
log.Fatal(err)
}
logx.Must(err)
fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
s.Start()

View File

@@ -0,0 +1,34 @@
package main
import (
"fmt"
"sync"
"time"
"github.com/tal-tech/go-zero/core/stringx"
"github.com/tal-tech/go-zero/core/syncx"
)
func main() {
const round = 5
var wg sync.WaitGroup
barrier := syncx.NewSharedCalls()
wg.Add(round)
for i := 0; i < round; i++ {
go func() {
defer wg.Done()
val, err := barrier.Do("once", func() (interface{}, error) {
time.Sleep(time.Second)
return stringx.RandId(), nil
})
if err != nil {
fmt.Println(err)
} else {
fmt.Println(val)
}
}()
}
wg.Wait()
}