add protomsg

liuxiaolong

2019-05-17 d3547e7b2ad1f43f38f4976a07792f61107963d6

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
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)
}