fit: 修改event配置信息

app/cmd/events/etc/events.yaml

@@ -1,8 +1,8 @@
 Name: events.rpc
-ListenOn: 0.0.0.0:8080
+ListenOn: 0.0.0.0:1116
 
 Timeout: 0
-Mode: test
+Mode: prod
 
 Log:
   ServiceName: events-rpc
@@ -10,7 +10,7 @@ Log:
   Level: error
 
 #双胞胎服务
-GtServerIp: 47.96.12.136:8788
+GtServerIp: 172.16.69.188:8900
 
 RabbitMQ:
   Url: amqp://admin:devmq*1120@47.96.12.136:5672/
@@ -19,13 +19,13 @@ DtDataStoreDB:
   DataSource: ws_data:c712f89fc4f8edaf30e41b828f4e3d26@tcp(172.16.0.194:4000)/ws_data?charset=utf8mb4&parseTime=True&loc=&loc=Asia%2FShanghai
 
 Redis:
-  Host: 47.96.12.136:6379
+  Host: 172.16.69.193:36379
   Key: dc:events
   Type: node
-  Pass:
+  Pass: G62m50oigI221107
 
 Cache:
-  - Host: 47.96.12.136:6379
+  - Host: 172.16.69.193:36379
     Key: dc:events:cache
     Type: node
-    Pass:
+    Pass: G62m50oigI221107

app/cmd/events/events.go

@@ -3,8 +3,14 @@ package main
 import (
 	"GtDataStore/app/cmd/events/internal/logic/handler"
 	"GtDataStore/app/cmd/events/internal/logic/job"
+	"GtDataStore/app/cmd/events/internal/server"
+	"GtDataStore/app/cmd/events/pb"
 	"flag"
 	"fmt"
+	"github.com/zeromicro/go-zero/core/service"
+	"github.com/zeromicro/go-zero/zrpc"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/reflection"
 	"metawant.greentech.com.cn/gaoyagang/gt-common/envitem"
 
 	"GtDataStore/app/cmd/events/internal/config"
@@ -21,18 +27,18 @@ func main() {
 	conf.MustLoad(*configFile, &c)
 	ctx := svc.NewServiceContext(c)
 
-	//s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
-	//	pb.RegisterEventsServer(grpcServer, server.NewEventsServer(ctx))
-	//
-	//	if c.Mode == service.DevMode || c.Mode == service.TestMode {
-	//		reflection.Register(grpcServer)
-	//	}
-	//})
-	//defer s.Stop()
-	//fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
-	//s.Start()
-
-	if c.Mode != "dev" {
+	s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
+		pb.RegisterEventsServer(grpcServer, server.NewEventsServer(ctx))
+
+		if c.Mode == service.DevMode || c.Mode == service.TestMode {
+			reflection.Register(grpcServer)
+		}
+	})
+	defer s.Stop()
+	fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
+	s.Start()
+
+	if c.Mode == "prod" {
 		envitem.SetOptions(envitem.Options{GtServerIp: c.GtServerIp, Cache: ctx.Cache})
 
 		go func() {