From d6d7fd5231983c4dfb13e854363ca21698d6f9c8 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 23 五月 2019 18:20:27 +0800
Subject: [PATCH] camera api add FindAllCameraAndTask
---
reqrepClient.go | 43 +++++++++++++++----------------------------
1 files changed, 15 insertions(+), 28 deletions(-)
diff --git a/reqrepClient.go b/reqrepClient.go
index 1a32afc..ff88b3b 100644
--- a/reqrepClient.go
+++ b/reqrepClient.go
@@ -1,12 +1,10 @@
package dbapi
import (
+ "basic.com/valib/deliver.git"
+ "basic.com/pubsub/protomsg.git"
+ "encoding/json"
"fmt"
- "os"
- "nanomsg.org/go-mangos"
- "nanomsg.org/go-mangos/protocol/req"
- "nanomsg.org/go-mangos/transport/ipc"
- "nanomsg.org/go-mangos/transport/tcp"
)
type ReqrepApi struct {
@@ -14,30 +12,19 @@
}
const (
- ReqRep_URL = "tcp://127.0.0.1:8002"
+ ReqRep_URL = "tcp://192.168.1.11:8002"
)
-func (api ReqrepApi)SendRequest(reqStr string) string {
- var sock mangos.Socket
- var err error
- var msg []byte
+func (api ReqrepApi)SendRequestAndGetReply(reqStr string) string {
+ sender := deliver.NewClient(deliver.Mode(deliver.ReqRep), ReqRep_URL)
+ var sendMsg = protomsg.SdkMessage{}
+ sendMsg.Cid = "kkkk"
+ byteArr, _ := json.Marshal(sendMsg)
+ err := sender.Send(byteArr)
+ if err !=nil {
+ fmt.Println(err)
+ }
- if sock, err = req.NewSocket(); err !=nil {
- fmt.Println("can't get new req socket!")
- os.Exit(1)
- }
- sock.AddTransport(ipc.NewTransport())
- sock.AddTransport(tcp.NewTransport())
- if err = sock.Dial(ReqRep_URL);err !=nil {
- fmt.Println("can't dial on req socket!!")
- os.Exit(1)
- }
- if err =sock.Send([]byte(reqStr));err !=nil {
- fmt.Println("can't send msg")
- }
- if msg,err = sock.Recv();err !=nil {
- fmt.Println("can't get msg from mangos reqrep server")
- }
- defer sock.Close()
- return string(msg)
+ fmt.Println("SendRequest")
+ return ""
}
\ No newline at end of file
--
Gitblit v1.8.0