feat 使用直接连接进行rpc

main/main.go

@@ -4,6 +4,8 @@ import (
 	"context"
 	"gitea.timerzz.com/kedaya_haitao/common/pkg/database"
 	"gitea.timerzz.com/kedaya_haitao/common/pkg/proxy"
+	"gitea.timerzz.com/kedaya_haitao/pusher/rpc/pusher"
+	"github.com/cloudwego/kitex/client"
 	"github.com/gofiber/fiber/v3"
 	"github.com/gofiber/fiber/v3/middleware/cors"
 	"github.com/golang/glog"
@@ -34,6 +36,8 @@ func main() {
 
 	watcherCtl := watcher.NewController(ctx, db, pool)
 
+	pusher.InitClient("pusher", client.WithHostPorts("pusher:8080"))
+
 	r := fiber.New()
 	r.Use(cors.New())