feat:xiugai

rpc/usercenter.go

@@ -1,7 +1,13 @@
 package main
 
 import (
-	"app.yhyue.com/moapp/jybase/endless"
+	"flag"
+	"fmt"
+	"log"
+	"net"
+	"net/http"
+	"net/rpc"
+
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/entity"
 	_ "bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/internal/config"
 	_ "bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/internal/db"
@@ -9,15 +15,11 @@ import (
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/internal/svc"
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/pb"
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/timetask"
-	"flag"
-	"fmt"
 	"github.com/zeromicro/go-zero/core/logx"
 	"github.com/zeromicro/go-zero/core/service"
 	"github.com/zeromicro/go-zero/zrpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/reflection"
-	"log"
-	"net/rpc"
 )
 
 func main() {
@@ -39,11 +41,12 @@ func main() {
 		frpc := new(entity.JyUser)
 		rpc.Register(frpc)
 		rpc.HandleHTTP()
-		err := endless.ListenAndServe(":"+entity.ConfigJson.RpcPort, nil, func() {})
+		lis, err := net.Listen("tcp", ":"+entity.ConfigJson.RpcPort)
 		if err != nil {
-			log.Println("ListenAndServe: ", err)
+			log.Fatalln("listen rpc error", err)
+		} else {
+			go http.Serve(lis, nil)
 		}
-
 	}()
 
 	s := zrpc.MustNewServer(entity.ConfigJson.RpcServerConf, func(grpcServer *grpc.Server) {