gozmq-52.go

package main

import (
	"log"
	"time"

	zmq "github.com/alecthomas/gozmq"
)

func main() {
	go func() {
		var (
			c   *zmq.Context
			s   *zmq.Socket
			err error
			m   [][]byte
		)
		if c, err = zmq.NewContext(); err != nil {
			panic(err)
		}
		defer c.Close()
		if s, err = c.NewSocket(zmq.SUB); err != nil {
			panic(err)
		}
		defer s.Close()
		if err = s.Connect("tcp://localhost:5561"); err != nil {
			panic(err)
		}
		s.SetSubscribe("p")
		count := 0
		for {
			m, err = s.RecvMultipart(0)
			if err != nil {
				panic(err)
			} else {
				log.Println("SUB:", count, string(m[0]))
				count++
			}
		}
	}()
	var (
		c   *zmq.Context
		s   *zmq.Socket
		err error
	)
	if c, err = zmq.NewContext(); err != nil {
		panic(err)
	}
	defer c.Close()
	if s, err = c.NewSocket(zmq.PUB); err != nil {
		panic(err)
	}
	defer s.Close()
	if err = s.Bind("tcp://*:5561"); err != nil {
		panic(err)
	}
	for i := 0; i < 10000; i++ {
		err = s.SendMultipart([][]byte{[]byte("ping")}, 0)
		if err != nil {
			panic(err)
		}
	}
	time.Sleep(time.Second)
}