| | |
|---|
| | | fmt.Println("image is not compressible") |
|---|
| | | } |
|---|
| | | bc = bc[:n] |
|---|
| | | //for { |
|---|
| | | for { |
|---|
| | | PushImgMsg(protomsg.Recvmsg{ |
|---|
| | | Id:uuid.NewV4().String(), |
|---|
| | | Addr:"", |
|---|
| | | Picdata:bc, |
|---|
| | | }) |
|---|
| | | fmt.Println("pushed img") |
|---|
| | | //time.Sleep(10*time.Second) |
|---|
| | | //} |
|---|
| | | time.Sleep(5*time.Second) |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | func InitService(){ |
|---|
| | | fmt.Println("service init!") |
|---|
| | | imgPushChan = make(chan protomsg.Recvmsg) |
|---|
| | | resultMap = make(map[string]protomsg.SdkMessage,0) |
|---|
| | | client_push = deliver.NewClient(deliver.PushPull, Url_Service_PUSH) |
|---|
| | | client_pull = deliver.NewClient(deliver.PushPull, Url_Service_PULL) |
|---|
| | | defer func() { |
|---|
| | |
|---|
| | | } |
|---|
| | | rMsg := protomsg.SdkMessage{} |
|---|
| | | if err := proto.Unmarshal(resultBytes, &rMsg);err ==nil{ |
|---|
| | | fmt.Println("recv MSG:",rMsg) |
|---|
| | | fmt.Println("received MSG:",rMsg.Cid) |
|---|
| | | resultMap[rMsg.Cid] = rMsg |
|---|
| | | } else { |
|---|
| | | fmt.Println("recv msg Err:",err) |
|---|
