1// 2// Hello World client. 3// Connects REQ socket to tcp://localhost:5555 4// Sends "Hello" to server, expects "World" back 5// 6 7package main 8 9import ( 10 zmq "github.com/pebbe/zmq4" 11 12 "fmt" 13) 14 15func main() { 16 // Socket to talk to server 17 fmt.Println("Connecting to hello world server...") 18 requester, _ := zmq.NewSocket(zmq.REQ) 19 defer requester.Close() 20 requester.Connect("tcp://localhost:5555") 21 22 for request_nbr := 0; request_nbr != 10; request_nbr++ { 23 // send hello 24 msg := fmt.Sprintf("Hello %d", request_nbr) 25 fmt.Println("Sending ", msg) 26 requester.Send(msg, 0) 27 28 // Wait for reply: 29 reply, _ := requester.Recv(0) 30 fmt.Println("Received ", reply) 31 } 32} 33