open-im-server/internal/msggateway/init.go

package msggateway

import (
	"fmt"
	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/config"
	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/constant"
	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/log"
	"sync"
	"time"
)

func RunWsAndServer(rpcPort, wsPort, prometheusPort int) error {
	var wg sync.WaitGroup
	wg.Add(1)
	log.NewPrivateLog(constant.LogFileName)
	fmt.Println("start rpc/msg_gateway server, port: ", rpcPort, wsPort, prometheusPort, ", OpenIM version: ", config.Version)
	longServer, err := NewWsServer(
		WithPort(wsPort),
		WithMaxConnNum(int64(config.Config.LongConnSvr.WebsocketMaxConnNum)),
		WithHandshakeTimeout(time.Duration(config.Config.LongConnSvr.WebsocketTimeOut)*time.Second),
		WithMessageMaxMsgLength(config.Config.LongConnSvr.WebsocketMaxMsgLen))
	if err != nil {
		return err
	}
	hubServer := NewServer(rpcPort)
	go hubServer.Start()
	if hubServer.Notification() == nil {
		panic("notification is nil")
	}
	longServer.SetMessageHandler(hubServer.Notification())
	hubServer.SetLongConnServer(longServer)
	go hubServer.LongConnServer.Run()
	wg.Wait()
	return nil
}