2015-10-02 03:24:38 +02:00
|
|
|
---
|
|
|
|
title: Streaming Response
|
|
|
|
menu:
|
|
|
|
main:
|
|
|
|
parent: recipes
|
|
|
|
---
|
2015-06-30 20:51:08 +02:00
|
|
|
|
2015-06-30 21:10:35 +02:00
|
|
|
- Send data as it is produced
|
|
|
|
- Streaming JSON response with chunked transfer encoding
|
|
|
|
|
2015-07-03 08:21:21 +02:00
|
|
|
## Server
|
|
|
|
|
2015-06-30 20:51:08 +02:00
|
|
|
`server.go`
|
|
|
|
|
|
|
|
```go
|
2015-06-03 17:29:13 +02:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"net/http"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
"encoding/json"
|
|
|
|
|
|
|
|
"github.com/labstack/echo"
|
|
|
|
)
|
|
|
|
|
|
|
|
type (
|
|
|
|
Geolocation struct {
|
|
|
|
Altitude float64
|
|
|
|
Latitude float64
|
|
|
|
Longitude float64
|
|
|
|
}
|
|
|
|
)
|
|
|
|
|
|
|
|
var (
|
|
|
|
locations = []Geolocation{
|
|
|
|
{-97, 37.819929, -122.478255},
|
|
|
|
{1899, 39.096849, -120.032351},
|
|
|
|
{2619, 37.865101, -119.538329},
|
|
|
|
{42, 33.812092, -117.918974},
|
|
|
|
{15, 37.77493, -122.419416},
|
|
|
|
}
|
|
|
|
)
|
|
|
|
|
|
|
|
func main() {
|
|
|
|
e := echo.New()
|
2015-06-30 21:10:35 +02:00
|
|
|
e.Get("/", func(c *echo.Context) error {
|
2015-06-03 17:29:13 +02:00
|
|
|
c.Response().Header().Set(echo.ContentType, echo.ApplicationJSON)
|
|
|
|
c.Response().WriteHeader(http.StatusOK)
|
|
|
|
for _, l := range locations {
|
|
|
|
if err := json.NewEncoder(c.Response()).Encode(l); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
c.Response().Flush()
|
|
|
|
time.Sleep(1 * time.Second)
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
})
|
|
|
|
e.Run(":1323")
|
|
|
|
}
|
2015-06-30 20:51:08 +02:00
|
|
|
```
|
|
|
|
|
2015-07-03 08:21:21 +02:00
|
|
|
## Client
|
|
|
|
|
2015-07-03 20:50:59 +02:00
|
|
|
```sh
|
|
|
|
$ curl localhost:1323
|
|
|
|
```
|
2015-06-30 21:10:35 +02:00
|
|
|
|
2015-07-03 08:21:21 +02:00
|
|
|
## Output
|
|
|
|
|
|
|
|
```sh
|
2015-06-30 21:10:35 +02:00
|
|
|
{"Altitude":-97,"Latitude":37.819929,"Longitude":-122.478255}
|
|
|
|
{"Altitude":1899,"Latitude":39.096849,"Longitude":-120.032351}
|
|
|
|
{"Altitude":2619,"Latitude":37.865101,"Longitude":-119.538329}
|
|
|
|
{"Altitude":42,"Latitude":33.812092,"Longitude":-117.918974}
|
|
|
|
{"Altitude":15,"Latitude":37.77493,"Longitude":-122.419416}
|
|
|
|
```
|
|
|
|
|
|
|
|
## [Source Code](https://github.com/labstack/echo/blob/master/recipes/streaming-response)
|