You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
42 lines
1.1 KiB
42 lines
1.1 KiB
2 months ago
|
package main
|
||
|
|
|
||
|
|
import (
|
||
|
|
"chat-room/config"
|
||
|
|
"chat-room/internal/kafka"
|
||
|
|
"chat-room/internal/router"
|
||
|
|
"chat-room/internal/server"
|
||
|
|
"chat-room/pkg/common/constant"
|
||
|
|
"chat-room/pkg/global/log"
|
||
|
|
"net/http"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
func main() {
|
||
|
|
log.InitLogger(config.GetConfig().Log.Path, config.GetConfig().Log.Level)
|
||
|
|
log.Logger.Info("config", log.Any("config", config.GetConfig()))
|
||
|
|
|
||
|
|
if config.GetConfig().MsgChannelType.ChannelType == constant.KAFKA {
|
||
|
|
kafka.InitProducer(config.GetConfig().MsgChannelType.KafkaTopic, config.GetConfig().MsgChannelType.KafkaHosts)
|
||
|
|
kafka.InitConsumer(config.GetConfig().MsgChannelType.KafkaHosts)
|
||
|
|
go kafka.ConsumerMsg(server.ConsumerKafkaMsg)
|
||
|
|
}
|
||
|
|
|
||
|
|
log.Logger.Info("start server", log.String("start", "start web sever..."))
|
||
|
|
|
||
|
|
newRouter := router.NewRouter()
|
||
|
|
|
||
|
|
go server.MyServer.Start()
|
||
|
|
|
||
|
|
s := &http.Server{
|
||
|
|
Addr: ":8888",
|
||
|
|
Handler: newRouter,
|
||
|
|
ReadTimeout: 10 * time.Second,
|
||
|
|
WriteTimeout: 10 * time.Second,
|
||
|
|
MaxHeaderBytes: 1 << 20,
|
||
|
|
}
|
||
|
|
err := s.ListenAndServe()
|
||
|
|
if nil != err {
|
||
|
|
log.Logger.Error("server error", log.Any("serverError", err))
|
||
|
|
}
|
||
|
|
}
|