From cd0e3e77b769396ba634429b25ae6c8a448a73f6 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期二, 21 五月 2019 17:49:12 +0800
Subject: [PATCH] update submodule url
---
reqrepClient.go | 47 ++++++++++++++++++++---------------------------
1 files changed, 20 insertions(+), 27 deletions(-)
diff --git a/reqrepClient.go b/reqrepClient.go
index 1a32afc..46abcdc 100644
--- a/reqrepClient.go
+++ b/reqrepClient.go
@@ -1,12 +1,10 @@
package dbapi
import (
+ "dbapi/deliver"
+ "dbapi/protomsg"
+ "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 {
@@ -17,27 +15,22 @@
ReqRep_URL = "tcp://127.0.0.1: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.NewConsumer(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)
+ }
+ fmt.Println("sendedMsg")
- 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)
+ //recvMsg, err := sender.Recv()
+ //if err ==nil {
+ // fmt.Println(string(recvMsg))
+ //}
+
+ fmt.Println("SendRequest")
+ return ""
}
\ No newline at end of file
--
Gitblit v1.8.0