docs: Add server and client example

Signed-off-by: Bo-Yi Wu <[email protected]>

Author: appleboy

_example/server-client/README.md

@@ -0,0 +1,29 @@
+# Example with server and client
+
+Please refer the following steps to build server and client.
+
+## Build server
+
+```sh
+go build -o app server/main.go
+```
+
+## Build client
+
+```sh
+go build -o agent client/main.go
+```
+
+## Usage
+
+Run the multiple agent. (open two console in the same terminal)
+
+```sh
+./agent
+```
+
+Publish the message.
+
+```sh
+./app
+```

_example/server-client/client/main.go

@@ -0,0 +1,60 @@
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"time"
+
+	"github.com/golang-queue/nsq"
+	"github.com/golang-queue/queue"
+)
+
+type job struct {
+	Message string
+}
+
+func (j *job) Bytes() []byte {
+	b, err := json.Marshal(j)
+	if err != nil {
+		panic(err)
+	}
+	return b
+}
+
+func main() {
+	taskN := 10000
+	rets := make(chan string, taskN)
+
+	// define the worker
+	w := nsq.NewWorker(
+		nsq.WithAddr("127.0.0.1:4150"),
+		nsq.WithTopic("example"),
+		nsq.WithChannel("foobar"),
+		// concurrent job number
+		nsq.WithMaxInFlight(10),
+		nsq.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
+			var v *job
+			if err := json.Unmarshal(m.Bytes(), &v); err != nil {
+				return err
+			}
+			rets <- v.Message
+			return nil
+		}),
+	)
+
+	// define the queue
+	q := queue.NewPool(
+		5,
+		queue.WithWorker(w),
+	)
+
+	// wait until all tasks done
+	for i := 0; i < taskN; i++ {
+		fmt.Println("message:", <-rets)
+		time.Sleep(50 * time.Millisecond)
+	}
+
+	// shutdown the service and notify all the worker
+	q.Release()
+}

_example/server-client/go.mod

@@ -0,0 +1,8 @@
+module example
+
+go 1.16
+
+require (
+	github.com/golang-queue/nsq v0.0.3-0.20210907001930-28fb526f914f
+	github.com/golang-queue/queue v0.0.8-0.20210905095503-cc99dff8fdc3
+)

_example/server-client/go.sum

@@ -0,0 +1,19 @@
+github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/golang-queue/nsq v0.0.3-0.20210907001930-28fb526f914f h1:h8Ni0qyAdBWOeOerAq/M/HUDdcqtLuxHABWTdNXKeRY=
+github.com/golang-queue/nsq v0.0.3-0.20210907001930-28fb526f914f/go.mod h1:I2JzRTV5lLsgu/R6c4SXjPt8ZhyX/lsV8bhjTZP9yu0=
+github.com/golang-queue/queue v0.0.8-0.20210905085819-3cd1dfe014e2/go.mod h1:JS5tYJacahCjafcplU5idNLX2vkYioqh6wEDX5o9Nms=
+github.com/golang-queue/queue v0.0.8-0.20210905095503-cc99dff8fdc3 h1:ka4/BRgVndDi92gaeOpjnnfuUXrWr1y87x/Go9M3x3Y=
+github.com/golang-queue/queue v0.0.8-0.20210905095503-cc99dff8fdc3/go.mod h1:JS5tYJacahCjafcplU5idNLX2vkYioqh6wEDX5o9Nms=
+github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4=
+github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/nsqio/go-nsq v1.0.8 h1:3L2F8tNLlwXXlp2slDUrUWSBn2O3nMh8R1/KEDFTHPk=
+github.com/nsqio/go-nsq v1.0.8/go.mod h1:vKq36oyeVXgsS5Q8YEO7WghqidAVXQlcFxzQbQTuDEY=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

_example/server-client/server/main.go

@@ -0,0 +1,55 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/golang-queue/nsq"
+	"github.com/golang-queue/queue"
+)
+
+type job struct {
+	Message string
+}
+
+func (j *job) Bytes() []byte {
+	b, err := json.Marshal(j)
+	if err != nil {
+		panic(err)
+	}
+	return b
+}
+
+func main() {
+	taskN := 100
+
+	// define the worker
+	w := nsq.NewWorker(
+		nsq.WithAddr("127.0.0.1:4150"),
+		nsq.WithTopic("example"),
+		nsq.WithChannel("foobar"),
+	)
+
+	// define the queue
+	q := queue.NewPool(
+		0,
+		queue.WithWorker(w),
+	)
+
+	// assign tasks in queue
+	for i := 0; i < taskN; i++ {
+		go func(i int) {
+			if err := q.Queue(&job{
+				Message: fmt.Sprintf("handle the job: %d", i+1),
+			}); err != nil {
+				log.Fatal(err)
+			}
+		}(i)
+	}
+
+	time.Sleep(1 * time.Second)
+	// shutdown the service and notify all the worker
+	q.Release()
+}