Zmq REQ Client

zmq-REQ-client.go

package main

import (
    "fmt"
	zmq "github.com/pebbe/zmq3"
	"log"
)

func main() {
	requester, _ := zmq.NewSocket(zmq.REQ)
	defer requester.Close()
	requester.Connect("tcp://127.0.0.1:10002") // address of zmqBroker

	data := "Hello, World"
	targetKey := "1123581321"

	requester.SendMessage([]string{targetKey, data})
	respData, _ := requester.RecvMessageBytes(0)

	//respData[0] , REP ID
	//respData[1] , result body
}