package dbapi
|
|
import (
|
"dbapi/deliver"
|
"dbapi/protomsg"
|
"encoding/json"
|
"fmt"
|
)
|
|
type ReqrepApi struct {
|
|
}
|
|
const (
|
ReqRep_URL = "tcp://127.0.0.1:8002"
|
)
|
|
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")
|
|
//recvMsg, err := sender.Recv()
|
//if err ==nil {
|
// fmt.Println(string(recvMsg))
|
//}
|
|
fmt.Println("SendRequest")
|
return ""
|
}
|
