package dbapi
|
|
import (
|
"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 {
|
|
}
|
|
const (
|
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
|
|
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)
|
}
|
