Skip to content

Commit 95d26cd

Browse files
committed
为http和grpc端口可变准备条件
1 parent c5fafbf commit 95d26cd

File tree

1 file changed

+18
-11
lines changed

1 file changed

+18
-11
lines changed

client/lib.go

Lines changed: 18 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,11 @@ import (
1717
"net"
1818
)
1919

20-
var IsLibrary = true
20+
var (
21+
IsLibrary = true
22+
GRpcPort = 55443
23+
HttpPort = 0
24+
)
2125

2226
type LoginManager struct {
2327
pb.UnimplementedGatewayLoginManagerServer
@@ -32,35 +36,38 @@ func Run() {
3236
func start() {
3337
//启动http服务
3438
go func() {
39+
if HttpPort == 0 {
40+
HttpPort = config.ConfigMode.HttpServicePort
41+
}
3542
r := gin.Default()
3643
r.GET("/", services.GatewayManager.IndexHandler)
3744
r.GET("/DisplayQrHandler", services.GatewayManager.DisplayQrHandler)
38-
log.Printf("Http 监听端口: %d\n", config.ConfigMode.HttpServicePort)
39-
r.Run(fmt.Sprintf(":%d", config.ConfigMode.HttpServicePort))
45+
log.Printf("Http 监听端口: %d\n", HttpPort)
46+
r.Run(fmt.Sprintf(":%d", HttpPort))
4047
}()
4148
//启动grpc服务
4249
s := grpc.NewServer()
4350
pb.RegisterGatewayLoginManagerServer(s, loginManager)
44-
//port := services.GrpcPort
51+
//GRpcPort := services.GrpcPort
4552
//if runtime.GOOS == "android" {
46-
// port = 55443
53+
// GRpcPort = 55443
4754
//}
48-
port := 55443
49-
lis, err := net.Listen("tcp", fmt.Sprintf("%s:%d", config.GRpcAddr, port))
55+
56+
lis, err := net.Listen("tcp", fmt.Sprintf("%s:%d", config.GRpcAddr, GRpcPort))
5057
if err != nil {
5158
log.Fatalf("failed to listen: %v", err)
5259
return
5360
}
5461
//addr := lis.Addr().(*net.TCPAddr)
55-
log.Printf("Grpc 监听端口:%d\n", port)
62+
log.Printf("Grpc 监听端口:%d\n", GRpcPort)
5663
reflection.Register(s)
57-
go regMDNS(port)
64+
go regMDNS(GRpcPort)
5865
if err := s.Serve(lis); err != nil {
5966
log.Fatalf("failed to serve: %v", err)
6067
}
6168
}
6269

63-
func regMDNS(port int) {
70+
func regMDNS(gRpcPort int) {
6471
var Mac = "mac"
6572
interfaces, err := net.Interfaces()
6673
if err != nil {
@@ -71,7 +78,7 @@ func regMDNS(port int) {
7178
gatewayUUID, serverHost, err := services.GatewayManager.GetLoginInfo()
7279
//qrStr, err := qr.GetQrByIdAndHost(gatewayUUID, serverHost)
7380
//mDNS注册服务
74-
_, err = zeroconf.Register(fmt.Sprintf("OpenIoTHubGateway-%s", config.ConfigMode.GatewayUUID), "_openiothub-gateway._tcp", "local.", port,
81+
_, err = zeroconf.Register(fmt.Sprintf("OpenIoTHubGateway-%s", config.ConfigMode.GatewayUUID), "_openiothub-gateway._tcp", "local.", gRpcPort,
7582
[]string{"name=网关",
7683
"model=com.iotserv.services.gateway",
7784
fmt.Sprintf("mac=%s", Mac),

0 commit comments

Comments
 (0)