package dbapi
|
|
import (
|
"basic.com/valib/deliver.git"
|
"basic.com/pubsub/protomsg.git"
|
"encoding/json"
|
"fmt"
|
)
|
|
type ReqrepApi struct {
|
|
}
|
|
const (
|
ReqRep_URL = "tcp://192.168.1.11:8002"
|
)
|
|
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)
|
}
|
|
fmt.Println("SendRequest")
|
return ""
|
}
|
