| | |
|---|
| | | } |
|---|
| | | logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort) |
|---|
| | | bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId) |
|---|
| | | Push1() |
|---|
| | | go Push1() |
|---|
| | | } |
|---|
| | | |
|---|
| | | var sender chan *protomsg.CompareArgs = make(chan *protomsg.CompareArgs) |
|---|
| | |
|---|
| | | if errSize != nil { |
|---|
| | | logger.Error("Failed set MaxRecvSize: %v", err) |
|---|
| | | } |
|---|
| | | //sock.AddTransport(ipc.NewTransport()) |
|---|
| | | sock.AddTransport(tcp.NewTransport()) |
|---|
| | | serverIP, _ := GetLocalIP() |
|---|
| | | if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil { |
|---|
| | | logger.Error("请求socket拨号失败: %s", err.Error()) |
|---|
| | | } |
|---|
| | | //sock.AddTransport(ipc.NewTransport()) |
|---|
| | | sock.AddTransport(tcp.NewTransport()) |
|---|
| | | |
|---|
| | | logger.Info("序列化数据") |
|---|
| | | |
|---|
| | | for { |
|---|
