36 lines
607 B
Go
36 lines
607 B
Go
//
|
|
// Hello World server.
|
|
// Binds REP socket to tcp://*:5555
|
|
// Expects "Hello" from client, replies with "World"
|
|
//
|
|
|
|
package main
|
|
|
|
import (
|
|
zmq "github.com/pebbe/zmq4"
|
|
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
func main() {
|
|
// Socket to talk to clients
|
|
responder, _ := zmq.NewSocket(zmq.REP)
|
|
defer responder.Close()
|
|
responder.Bind("tcp://*:5555")
|
|
|
|
for {
|
|
// Wait for next request from client
|
|
msg, _ := responder.Recv(0)
|
|
fmt.Println("Received ", msg)
|
|
|
|
// Do some 'work'
|
|
time.Sleep(time.Second)
|
|
|
|
// Send reply back to client
|
|
reply := "World"
|
|
responder.Send(reply, 0)
|
|
fmt.Println("Sent ", reply)
|
|
}
|
|
}
|