memo

• echo
  • 新規 echo プロジェクト作成
  • パラメーター取得
  • Keep-Alive タイムアウトを指定するサンプル
  • echo で zerolog を使う

echo

新規 echo プロジェクト作成

mkdir myapp && cd myapp
go mod init myapp
go get github.com/labstack/echo/v4
go mod tidy

パラメーター取得

• パスパラメーター
  (例) /users/:id
  id := c.Param("id")
• クエリーパラメーター
  (例) /users?id=1
  id := c.QueryParam("id")
• POSTボディ(URL エンコード)
  (例) curl -X POST http://127.0.0.1/save -H ‘Content-Type: application/x-www-form-urlencoded’ –d ‘id=1’ id := c.FormValue("id")
• POST JSON ボディ
  (例) curl -X POST http://127.0.0.1/save -H ‘Content-Type: application/json’ –d ‘{“id”:1,”name”:”hoge”}’

  type User struct {
    Id   int32  `json:"id"`
    Name string `json:"name"`
  }
  func save(ec echo.Context) error {
    u := new(User)
    if err := ec.Bind(u); err != nil {
      return ec.String(http.StatusBadRequest, "bad request")
    }
  }
  

Keep-Alive タイムアウトを指定するサンプル

Keep-Aliveタイムアウトを 30秒に設定

package main

import (
	"fmt"
	"io/ioutil"
	"net/http"
	"time"

	"github.com/labstack/echo/v4"
	"github.com/labstack/echo/v4/middleware"
)

const keepAliveTimeout = 30

func root(ec echo.Context) error {
	byteArray, _ := ioutil.ReadAll(ec.Request().Body)
	println(string(byteArray))

	ec.Response().Header().Add("Keep-Alive", fmt.Sprintf("timeout=%d", keepAliveTimeout))
	ec.Response().Header().Add("Connection", "keep-alive")

	return ec.String(http.StatusOK, "OK")
}

func main() {

	ec := echo.New()
	ec.Use(middleware.Logger())
	ec.Use(middleware.Recover())

	ec.POST("/", root)

	svr := &http.Server{
		Addr:        ":8080",
		IdleTimeout: time.Duration(keepAliveTimeout) * time.Second,
		Handler:     ec,
	}

	ec.Logger.Fatal(svr.ListenAndServe())
}

※デフォルトは無制限

echo で zerolog を使う

go.mod

require (
    github.com/labstack/echo/v4 v4.12.0
    gopkg.in/natefinch/lumberjack.v2 v2.2.1
)

import (
	"github.com/labstack/echo/v4"
	"github.com/labstack/echo/v4/middleware"
	"github.com/rs/zerolog"
	"github.com/rs/zerolog/log"
	"gopkg.in/natefinch/lumberjack.v2"
)

type ZerologAdapter struct {
	logger zerolog.Logger
}

func (z *ZerologAdapter) Write(p []byte) (n int, err error) {
	z.logger.Info().Msg(string(p))
	return len(p), nil
}

func main() {
	writer := &lumberjack.Logger{
		Filename:   "logs/zerolog.log",
		MaxSize:    1,
		MaxBackups: 3,
		MaxAge:     5,
		Compress:   true,
		LocalTime:  true,
	}
	zerolog.SetGlobalLevel(zerolog.DebugLevel)
	// タイムスタンプをミリ秒単位に設定(デフォルトは秒単位)
	zerolog.TimeFieldFormat = "2006-01-02T15:04:05.000Z"
	log.Logger = zerolog.New(writer).With().Timestamp().Logger()

	ec := echo.New()

	ec.Logger.SetOutput(&ZerologAdapter{logger: log.Logger})

	ec.Use(middleware.Logger())
	ec.Use(middleware.Recover())
}