Skip to content

Instantly share code, notes, and snippets.

@wallyqs

wallyqs/Docker Compose + NATS example

Last active February 18, 2024 22:27
Show Gist options
  • Save wallyqs/7f72efdc3fd6371364f8b28cbe32c5ee to your computer and use it in GitHub Desktop.
Save wallyqs/7f72efdc3fd6371364f8b28cbe32c5ee to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. Waldemar Quevedo revised this gist Jun 23, 2016. 2 changed files with 2 additions and 0 deletions.
    1 change: 1 addition & 0 deletions Docker Compose + NATS example
    View file
    Original file line number Diff line number Diff line change
    @@ -2,6 +2,7 @@ FROM golang:1.6.2

    COPY . /go

    RUN go get github.com/nats-io/nats
    RUN go build api-server.go

    EXPOSE 8080
    1 change: 1 addition & 0 deletions Dockerfile Example Worker
    View file
    Original file line number Diff line number Diff line change
    @@ -2,6 +2,7 @@ FROM golang:1.6.2

    COPY . /go

    RUN go get github.com/nats-io/nats
    RUN go build worker.go

    EXPOSE 8080
  2. Waldemar Quevedo revised this gist Jun 23, 2016. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion worker.go
    View file
    Original file line number Diff line number Diff line change
    @@ -11,7 +11,7 @@ import (
    )

    func healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Println(w, "OK")
    fmt.Fprintln(w, "OK")
    }

    func main() {
  3. Waldemar Quevedo renamed this gist Jun 21, 2016. 1 changed file with 0 additions and 0 deletions.
    0 Dockerfile Example Server → Docker Compose + NATS example
    View file
    File renamed without changes.
  4. Waldemar Quevedo revised this gist Jun 20, 2016. 1 changed file with 3 additions and 3 deletions.
    6 changes: 3 additions & 3 deletions api-server.go
    View file
    Original file line number Diff line number Diff line change
    @@ -37,16 +37,16 @@ func main() {
    var s server
    var err error
    uri := os.Getenv("NATS_URI")

    for i := 0; i < 5; i++ {
    nc, err := nats.Connect(uri)
    if err == nil {
    s.nc = nc
    break
    }

    fmt.Println("Waiting before connecting to NATS at:", uri)
    time.Sleep(1 * time.Second)
    s.nc = nc
    time.Sleep(1 * time.Second)
    }
    if err != nil {
    log.Fatal("Error establishing connection to NATS:", err)
  5. Waldemar Quevedo revised this gist Jun 20, 2016. 2 changed files with 45 additions and 48 deletions.
    43 changes: 23 additions & 20 deletions api-server.go
    View file
    Original file line number Diff line number Diff line change
    @@ -10,52 +10,55 @@ import (
    "github.com/nats-io/nats"
    )

    type Server struct {
    type server struct {
    nc *nats.Conn
    }

    func (s *Server) baseRoot(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Basic NATS based microservice example v0.0.1")
    func (s server) baseRoot(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintln(w, "Basic NATS based microservice example v0.0.1")
    }

    func (s *Server) createTask(w http.ResponseWriter, r *http.Request) {
    func (s server) createTask(w http.ResponseWriter, r *http.Request) {
    requestAt := time.Now()
    response, err := s.nc.Request("tasks", []byte("help please"), 500*time.Millisecond)
    response, err := s.nc.Request("tasks", []byte("help please"), 5*time.Second)
    if err != nil {
    log.Printf("Error making NATS request: %s", err)
    log.Println("Error making NATS request:", err)
    }
    duration := time.Since(requestAt)

    fmt.Fprintf(w, "Task scheduled in %+v\nResponse: %v\n", duration, string(response.Data))
    }

    func (s *Server) healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "OK\n")
    func (s server) healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintln(w, "OK")
    }

    func main() {
    s := &Server{}
    uri := os.Getenv("NATS_URI")
    var s server
    var err error
    uri := os.Getenv("NATS_URI")

    for i := 0; i < 5; i++ {
    nc, err := nats.Connect(uri)
    if err != nil {
    log.Println("Waiting before connecting to NATS at %q", uri)
    time.Sleep(1 * time.Second)
    if err == nil {
    break
    }
    s.nc = nc

    break
    fmt.Println("Waiting before connecting to NATS at:", uri)
    time.Sleep(1 * time.Second)
    s.nc = nc
    }
    if err != nil {
    log.Printf("Error establishing connection to NATS: %s\n", err)
    os.Exit(1)
    log.Fatal("Error establishing connection to NATS:", err)
    }
    log.Printf("Connected to NATS at %v\n", s.nc.ConnectedUrl())

    fmt.Println("Connected to NATS at:", s.nc.ConnectedUrl())
    http.HandleFunc("/", s.baseRoot)
    http.HandleFunc("/createTask", s.createTask)
    http.HandleFunc("/healthz", s.healthz)

    log.Println("Server listening on port 8080...")
    http.ListenAndServe(":8080", nil)
    fmt.Println("Server listening on port 8080...")
    if err := http.ListenAndServe(":8080", nil); err != nil {
    log.Fatal(err)
    }
    }
    50 changes: 22 additions & 28 deletions worker.go
    View file
    Original file line number Diff line number Diff line change
    @@ -10,44 +10,38 @@ import (
    "github.com/nats-io/nats"
    )

    type Server struct {
    nc *nats.Conn
    }

    func (s *Server) healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "OK\n")
    func healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Println(w, "OK")
    }

    func main() {
    s := &Server{}
    uri := os.Getenv("NATS_URI")
    var err error
    var nc *nats.Conn

    for i := 0; i < 5; i++ {
    nc, err := nats.Connect(uri)
    if err != nil {
    log.Println("Waiting before connecting to NATS at %q", uri)
    time.Sleep(1 * time.Second)
    nc, err = nats.Connect(uri)
    if err == nil {
    break
    }
    s.nc = nc

    break
    fmt.Println("Waiting before connecting to NATS at:", uri)
    time.Sleep(1 * time.Second)
    }
    if err != nil {
    log.Printf("Error establishing connection to NATS: %s\n", err)
    os.Exit(1)
    log.Fatal("Error establishing connection to NATS:", err)
    }
    log.Printf("Connected to NATS at %v\n", s.nc.ConnectedUrl())

    s.nc.Subscribe("tasks", func(m *nats.Msg) {
    log.Printf("Got task request on %q\n", m.Subject)
    go func() {
    // Do the rest in a goroutine in order to not block
    // any other requests which we might be able to handle.
    s.nc.Publish(m.Reply, []byte("Done!"))
    }()
    fmt.Println("Connected to NATS at:", nc.ConnectedUrl())
    nc.Subscribe("tasks", func(m *nats.Msg) {
    fmt.Println("Got task request on:", m.Subject)
    nc.Publish(m.Reply, []byte("Done!"))
    })
    log.Println("Worker subscribed to 'tasks' for processing requests...")
    log.Println("Server listening on port 8181...")
    http.HandleFunc("/healthz", s.healthz)
    http.ListenAndServe(":8181", nil)

    fmt.Println("Worker subscribed to 'tasks' for processing requests...")
    fmt.Println("Server listening on port 8181...")

    http.HandleFunc("/healthz", healthz)
    if err := http.ListenAndServe(":8181", nil); err != nil {
    log.Fatal(err)
    }
    }
  6. Waldemar Quevedo revised this gist Jun 14, 2016. 1 changed file with 20 additions and 12 deletions.
    32 changes: 20 additions & 12 deletions api-server.go
    View file
    Original file line number Diff line number Diff line change
    @@ -14,6 +14,21 @@ type Server struct {
    nc *nats.Conn
    }

    func (s *Server) baseRoot(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Basic NATS based microservice example v0.0.1")
    }

    func (s *Server) createTask(w http.ResponseWriter, r *http.Request) {
    requestAt := time.Now()
    response, err := s.nc.Request("tasks", []byte("help please"), 500*time.Millisecond)
    if err != nil {
    log.Printf("Error making NATS request: %s", err)
    }
    duration := time.Since(requestAt)

    fmt.Fprintf(w, "Task scheduled in %+v\nResponse: %v\n", duration, string(response.Data))
    }

    func (s *Server) healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "OK\n")
    }
    @@ -37,17 +52,10 @@ func main() {
    os.Exit(1)
    }
    log.Printf("Connected to NATS at %v\n", s.nc.ConnectedUrl())

    s.nc.Subscribe("tasks", func(m *nats.Msg) {
    log.Printf("Got task request on %q\n", m.Subject)
    go func() {
    // Do the rest in a goroutine in order to not block
    // any other requests which we might be able to handle.
    s.nc.Publish(m.Reply, []byte("Done!"))
    }()
    })
    log.Println("Worker subscribed to 'tasks' for processing requests...")
    log.Println("Server listening on port 8181...")
    http.HandleFunc("/", s.baseRoot)
    http.HandleFunc("/createTask", s.createTask)
    http.HandleFunc("/healthz", s.healthz)
    http.ListenAndServe(":8181", nil)

    log.Println("Server listening on port 8080...")
    http.ListenAndServe(":8080", nil)
    }
  7. Waldemar Quevedo revised this gist Jun 14, 2016. 2 changed files with 0 additions and 0 deletions.
    0 Dockerfile Frontend Server → Dockerfile Example Server
    View file
    File renamed without changes.
    0 Dockerfile Worker → Dockerfile Example Worker
    View file
    File renamed without changes.
  8. Waldemar Quevedo revised this gist Jun 14, 2016. No changes.
  9. Waldemar Quevedo renamed this gist Jun 14, 2016. 1 changed file with 0 additions and 0 deletions.
    0 Dockerfile API server → Dockerfile Frontend Server
    View file
    File renamed without changes.
  10. Waldemar Quevedo revised this gist Jun 14, 2016. 2 changed files with 57 additions and 0 deletions.
    37 changes: 37 additions & 0 deletions build
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,37 @@
    $ docker-compose -f build.yml up
    nats uses an image, skipping
    Building api
    Step 1 : FROM golang:1.6.2
    ---> 5850add7ecc2
    Step 2 : COPY . /go
    ---> 188fa03a7cf5
    Removing intermediate container 37ee6fd35e0d
    Step 3 : RUN go build api-server.go
    ---> Running in 048e4010e539
    ---> 21dbaf567bbb
    Removing intermediate container 048e4010e539
    Step 4 : EXPOSE 8080
    ---> Running in b07dde665ad2
    ---> 3a6a59102f81
    Removing intermediate container b07dde665ad2
    Step 5 : ENTRYPOINT /go/api-server
    ---> Running in e3c5de88d6d4
    ---> faf4d12797f3
    Removing intermediate container e3c5de88d6d4
    Successfully built faf4d12797f3
    Building worker
    Step 1 : FROM golang:1.6.2
    ---> 5850add7ecc2
    Step 2 : COPY . /go
    ---> Using cache
    ---> 0376e8a54e9d
    Step 3 : RUN go build worker.go
    ---> Using cache
    ---> 1a53e068ad91
    Step 4 : EXPOSE 8080
    ---> Using cache
    ---> 77b8a0e0ab4f
    Step 5 : ENTRYPOINT /go/worker
    ---> Using cache
    ---> 7d23b0d4e846
    Successfully built 7d23b0d4e846
    20 changes: 20 additions & 0 deletions docker-compose up
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,20 @@
    $ docker-compose -f build.yml up
    nats_1 | [1] 2016/06/14 01:30:25.563332 [INF] Starting nats-server version 0.8.0
    nats_1 | [1] 2016/06/14 01:30:25.564371 [DBG] Go build version go1.6.2
    nats_1 | [1] 2016/06/14 01:30:25.564392 [INF] Listening for client connections on 0.0.0.0:4222
    nats_1 | [1] 2016/06/14 01:30:25.564444 [DBG] Server id is VYcRrgxx6c097Tq62NIIVp
    nats_1 | [1] 2016/06/14 01:30:25.564451 [INF] Server is ready
    nats_1 | [1] 2016/06/14 01:30:25.799723 [DBG] 172.18.0.3:32999 - cid:1 - Client connection created
    nats_1 | [1] 2016/06/14 01:30:25.800213 [TRC] 172.18.0.3:32999 - cid:1 - ->> [CONNECT {"verbose":false,"pedantic":false,"tls_required":false,"name":"","lang":"go","version":"1.2.0"}]
    nats_1 | [1] 2016/06/14 01:30:25.800308 [TRC] 172.18.0.3:32999 - cid:1 - ->> [PING]
    nats_1 | [1] 2016/06/14 01:30:25.800311 [TRC] 172.18.0.3:32999 - cid:1 - <<- [PONG]
    nats_1 | [1] 2016/06/14 01:30:25.800703 [TRC] 172.18.0.3:32999 - cid:1 - ->> [SUB tasks 1]
    worker_1 | 2016/06/14 01:30:25 Connected to NATS at nats://nats:4222
    worker_1 | 2016/06/14 01:30:25 Worker subscribed to 'tasks' for processing requests...
    worker_1 | 2016/06/14 01:30:25 Server listening on port 8181...
    nats_1 | [1] 2016/06/14 01:30:26.009136 [DBG] 172.18.0.4:47156 - cid:2 - Client connection created
    nats_1 | [1] 2016/06/14 01:30:26.009536 [TRC] 172.18.0.4:47156 - cid:2 - ->> [CONNECT {"verbose":false,"pedantic":false,"tls_required":false,"name":"","lang":"go","version":"1.2.0"}]
    nats_1 | [1] 2016/06/14 01:30:26.009562 [TRC] 172.18.0.4:47156 - cid:2 - ->> [PING]
    nats_1 | [1] 2016/06/14 01:30:26.009566 [TRC] 172.18.0.4:47156 - cid:2 - <<- [PONG]
    api_1 | 2016/06/14 01:30:26 Connected to NATS at nats://nats:4222
    api_1 | 2016/06/14 01:30:26 Server listening on port 8080...
  11. Waldemar Quevedo revised this gist Jun 14, 2016. 4 changed files with 104 additions and 0 deletions.
    8 changes: 8 additions & 0 deletions Dockerfile API server
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,8 @@
    FROM golang:1.6.2

    COPY . /go

    RUN go build api-server.go

    EXPOSE 8080
    ENTRYPOINT ["/go/api-server"]
    8 changes: 8 additions & 0 deletions Dockerfile Worker
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,8 @@
    FROM golang:1.6.2

    COPY . /go

    RUN go build worker.go

    EXPOSE 8080
    ENTRYPOINT ["/go/worker"]
    35 changes: 35 additions & 0 deletions build.yml
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,35 @@
    version: "2"

    services:
    nats:
    image: 'nats:0.8.0'
    entrypoint: "/gnatsd -DV"
    expose:
    - "4222"
    ports:
    - "8222:8222"
    hostname: nats-server
    api:
    build:
    context: "./api"
    entrypoint: /go/api-server
    links:
    - nats
    environment:
    - "NATS_URI=nats://nats:4222"
    depends_on:
    - nats
    ports:
    - "8080:8080"
    worker:
    build:
    context: "./worker"
    entrypoint: /go/worker
    links:
    - nats
    environment:
    - "NATS_URI=nats://nats:4222"
    depends_on:
    - nats
    ports:
    - "8181:8181"
    53 changes: 53 additions & 0 deletions worker.go
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,53 @@
    package main

    import (
    "fmt"
    "log"
    "net/http"
    "os"
    "time"

    "github.com/nats-io/nats"
    )

    type Server struct {
    nc *nats.Conn
    }

    func (s *Server) healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "OK\n")
    }

    func main() {
    s := &Server{}
    uri := os.Getenv("NATS_URI")
    var err error
    for i := 0; i < 5; i++ {
    nc, err := nats.Connect(uri)
    if err != nil {
    log.Println("Waiting before connecting to NATS at %q", uri)
    time.Sleep(1 * time.Second)
    }
    s.nc = nc

    break
    }
    if err != nil {
    log.Printf("Error establishing connection to NATS: %s\n", err)
    os.Exit(1)
    }
    log.Printf("Connected to NATS at %v\n", s.nc.ConnectedUrl())

    s.nc.Subscribe("tasks", func(m *nats.Msg) {
    log.Printf("Got task request on %q\n", m.Subject)
    go func() {
    // Do the rest in a goroutine in order to not block
    // any other requests which we might be able to handle.
    s.nc.Publish(m.Reply, []byte("Done!"))
    }()
    })
    log.Println("Worker subscribed to 'tasks' for processing requests...")
    log.Println("Server listening on port 8181...")
    http.HandleFunc("/healthz", s.healthz)
    http.ListenAndServe(":8181", nil)
    }
  12. Waldemar Quevedo revised this gist Jun 14, 2016. No changes.
  13. Waldemar Quevedo created this gist Jun 14, 2016.
    53 changes: 53 additions & 0 deletions api-server.go
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,53 @@
    package main

    import (
    "fmt"
    "log"
    "net/http"
    "os"
    "time"

    "github.com/nats-io/nats"
    )

    type Server struct {
    nc *nats.Conn
    }

    func (s *Server) healthz(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "OK\n")
    }

    func main() {
    s := &Server{}
    uri := os.Getenv("NATS_URI")
    var err error
    for i := 0; i < 5; i++ {
    nc, err := nats.Connect(uri)
    if err != nil {
    log.Println("Waiting before connecting to NATS at %q", uri)
    time.Sleep(1 * time.Second)
    }
    s.nc = nc

    break
    }
    if err != nil {
    log.Printf("Error establishing connection to NATS: %s\n", err)
    os.Exit(1)
    }
    log.Printf("Connected to NATS at %v\n", s.nc.ConnectedUrl())

    s.nc.Subscribe("tasks", func(m *nats.Msg) {
    log.Printf("Got task request on %q\n", m.Subject)
    go func() {
    // Do the rest in a goroutine in order to not block
    // any other requests which we might be able to handle.
    s.nc.Publish(m.Reply, []byte("Done!"))
    }()
    })
    log.Println("Worker subscribed to 'tasks' for processing requests...")
    log.Println("Server listening on port 8181...")
    http.HandleFunc("/healthz", s.healthz)
    http.ListenAndServe(":8181", nil)
    }