接口调用报错处理

yinbentan

2024-07-08 f4508a84236a4aff1c7b5bfa17a14a8ff95728ba

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
package init_client
 
import (
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
    "wms/conf"
    "wms/pkg/logx"
)
 
var (
    AdminConn *grpc.ClientConn
    ApsConn   *grpc.ClientConn
    CrmConn   *grpc.ClientConn
    SrmConn   *grpc.ClientConn
)
 
func InitClient() {
    var err error
    ApsConn, err = grpc.Dial(conf.GrpcServerConf.ApsAddr, grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        logx.Errorf("grpc dial product service error: %v", err.Error())
        return
    }
    CrmConn, err = grpc.Dial(conf.GrpcServerConf.CrmAddr, grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        logx.Errorf("grpc dial product service error: %v", err.Error())
        return
    }
    SrmConn, err = grpc.Dial(conf.GrpcServerConf.SrmAddr, grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        logx.Errorf("grpc dial product service error: %v", err.Error())
        return
    }
    if len(conf.GrpcServerConf.AdminAddr) > 0 {
        AdminConn, err = grpc.Dial(conf.GrpcServerConf.AdminAddr, grpc.WithTransportCredentials(insecure.NewCredentials()))
        if err != nil {
            logx.Errorf("grpc dial product service error: %v", err.Error())
            return
        }
    }
}
 
func CloseClient() {
    if AdminConn != nil {
        AdminConn.Close()
    }
    if ApsConn != nil {
        ApsConn.Close()
    }
    if CrmConn != nil {
        CrmConn.Close()
    }
    if SrmConn != nil {
        SrmConn.Close()
    }
}