| | |
|---|
| | | package dbapi |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "dbapi/deliver" |
|---|
| | | "dbapi/protomsg" |
|---|
| | | "basic.com/valib/deliver.git" |
|---|
| | | "basic.com/pubsub/protomsg.git" |
|---|
| | | "encoding/json" |
|---|
| | | "fmt" |
|---|
| | | ) |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | const ( |
|---|
| | | ReqRep_URL = "tcp://127.0.0.1:8002" |
|---|
| | | ReqRep_URL = "tcp://192.168.1.11:8002" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | func (api ReqrepApi)SendRequestAndGetReply(reqStr string) string { |
|---|
| | | sender := deliver.NewConsumer(deliver.Mode(deliver.ReqRep), ReqRep_URL) |
|---|
| | | sender := deliver.NewClient(deliver.Mode(deliver.ReqRep), ReqRep_URL) |
|---|
| | | var sendMsg = protomsg.SdkMessage{} |
|---|
| | | sendMsg.Cid = "kkkk" |
|---|
| | | byteArr, _ := json.Marshal(sendMsg) |
|---|
| | |
|---|
| | | if err !=nil { |
|---|
| | | fmt.Println(err) |
|---|
| | | } |
|---|
| | | fmt.Println("sendedMsg") |
|---|
| | | |
|---|
| | | //recvMsg, err := sender.Recv() |
|---|
| | | //if err ==nil { |
|---|
| | | // fmt.Println(string(recvMsg)) |
|---|
| | | //} |
|---|
| | | |
|---|
| | | fmt.Println("SendRequest") |
|---|
| | | return "" |
|---|
