Сравнение веб-фреймворка языка Go: gin, iris, echo

Go

предисловие

Поскольку golang предоставляет полную стандартную библиотеку net/http, сложность реализации веб-фреймворка на основе этой стандартной библиотеки намного ниже, чем у других языков, поэтому веб-фреймворк go просто расцветает. От старого пиршества иbeego, к новомуginirisд., а также есть некоторыеchiТакой роутер. Личные общие небольшие проекты, особенно промежуточное программное обеспечение, которое должно предоставлять некоторые http-интерфейсы, в основном просто используют chi.
Этот тест в основном касается трех фреймворков gin iris echo. Основное внимание уделяется высокой производительности, и она оценивается по двум аспектам: параллелизму и json-сериализации и десериализации, ведь фоновый проект фокусируется на этих двух аспектах.

контрольная работа

Описание тестовой среды

Чтобы выбрать фреймворк, соответствующий тяжелому вводу-выводу, теперь устанавливается демо-версия следующих сценариев Конкретные требования к демо-версии следующие:

  1. Включите функцию журнала (журналы также будут записываться при имитации обычного бизнеса) и записывайте журнал в начале и конце запроса.
  2. Используйте спящий режим для паузы в интерфейсе на 1 секунду, предполагая здесь операцию сетевого ввода-вывода (и из журнала легче увидеть, является ли сопрограмма параллельной)
  3. Использовать интерфейс POST для тестирования, в интерфейсе не производится никакой обработки, а полученное тело напрямую сериализуется и возвращается (сериализация и десериализация — наиболее частые действия фреймворка)
  4. Включите функцию доступа к фреймворку

Инструменты и сценарии тестирования следующие:

  1. Инструмент тестирования использует классический jmeter и напрямую использует интерфейс GUI для тестирования.
  2. Сценарии делятся на параллелизм 10 потоков, параллелизм 100 потоков, параллелизм 500 потоков, параллелизм 1000 потоков и параллелизм 1500 потоков.
  3. Все результаты относятся только к агрегированному отчету jmeter с упором на пропускную способность, время и количество ошибок.
  4. При запуске всех демо запускается один поток.Асинхронный фреймворк не ограничивает количество сопрограмм.Установите GOMAXPROCS=1
  5. Все тесты выполняются локально, а стресс-тест длится две минуты.
  6. В тесте используется запрос POST. Образцы данных: 565 байт, 5 КБ, 10 КБ, 50 КБ и 100 КБ. Каждый образец должен быть протестирован в разных параллельных потоках.

тестовый код

gin:

package main

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

    "github.com/gin-gonic/gin"
)

// Agent ...
type Agent struct {
    AgentID  string `json:"agent_id"`
    QueuedAt string `json:"queued_at"`
    QueuedBy string `json:"queued_by"`
}

// Details ...
type Details struct {
    EventID  string `json:"event_id"`
    Endpoint string
    Metric   string
    Content  string
    Priority int
    Status   string
}

// Test1 ...
type Test1 struct {
    Agent       Agent
    Details     Details
    Description string
    EventType   string `json:"event_type"`
    ServiceKey  string `json:"service_key"`
}

// Test2 test2
type Test2 struct {
    Data []*Test1
}

func main() {
    r := gin.New()

    // Global middleware
    // Logger middleware will write the logs to gin.DefaultWriter even if you set with GIN_MODE=release.
    // By default gin.DefaultWriter = os.Stdout
    r.Use(gin.Logger())

    r.GET("/ping", func(c *gin.Context) {
        c.JSON(200, gin.H{
            "message": "pong",
        })
    })

    r.POST("/v1/test", func(c *gin.Context) {
        var test Test1

        if err := c.BindJSON(&test); err == nil {
            log.Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            log.Println("=========================end io=======================")
            c.JSON(http.StatusOK, test)
        } else {
            c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
        }

    })
    r.POST("/v2/test", func(c *gin.Context) {
        var test Test2

        if err := c.BindJSON(&test); err == nil {
            log.Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            log.Println("=========================end io=======================")
            c.JSON(http.StatusOK, test)
        } else {
            c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
        }
    })
    r.POST("/v3/test", func(c *gin.Context) {
        var test Test2

        if err := c.BindJSON(&test); err == nil {
            log.Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            log.Println("=========================end io=======================")
            c.JSON(http.StatusOK, test)
        } else {
            c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
        }

    })
    r.POST("/v4/test", func(c *gin.Context) {
        var test Test2

        if err := c.BindJSON(&test); err == nil {
            log.Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            log.Println("=========================end io=======================")
            c.JSON(http.StatusOK, test)
        } else {
            c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
        }

    })
    r.Run() // listen and serve on 0.0.0.0:8080
}

iris:

package main

import (
    "time"

    "github.com/kataras/iris"
    "github.com/kataras/iris/middleware/logger"
)

// Agent ...
type Agent struct {
    AgentID  string `json:"agent_id"`
    QueuedAt string `json:"queued_at"`
    QueuedBy string `json:"queued_by"`
}

// Details ...
type Details struct {
    EventID  string `json:"event_id"`
    Endpoint string
    Metric   string
    Content  string
    Priority int
    Status   string
}

// Test1 ...
type Test1 struct {
    Agent       Agent
    Details     Details
    Description string
    EventType   string `json:"event_type"`
    ServiceKey  string `json:"service_key"`
}

// Test2 test2
type Test2 struct {
    Data []*Test1
}

func main() {
    app := iris.New()

    app.Use(logger.New())

    app.Get("/ping", func(c iris.Context) {
        c.WriteString("pong")
    })

    app.Post("/v1/test", func(c iris.Context) {
        var test Test1

        if err := c.ReadJSON(&test); err == nil {
            app.Logger().Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            app.Logger().Println("=========================end io=======================")
            c.JSON(test)
        } else {
            c.WriteString("failure")
        }

    })
    app.Post("/v2/test", func(c iris.Context) {
        var test Test2

        if err := c.ReadJSON(&test); err == nil {
            app.Logger().Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            app.Logger().Println("=========================end io=======================")
            c.JSON(test)
        } else {
            c.WriteString("failure")
        }
    })
    app.Post("/v3/test", func(c iris.Context) {
        var test Test2

        if err := c.ReadJSON(&test); err == nil {
            app.Logger().Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            app.Logger().Println("=========================end io=======================")
            c.JSON(test)
        } else {
            c.WriteString("failure")
        }

    })
    app.Post("/v4/test", func(c iris.Context) {
        var test Test2

        if err := c.ReadJSON(&test); err == nil {
            app.Logger().Println("========================start io=====================")
            time.Sleep(time.Duration(1) * time.Second)
            app.Logger().Println("=========================end io=======================")
            c.JSON(test)
        } else {
            c.WriteString("failure")
        }

    })

    // Start the server using a network address.
    app.Run(
        iris.Addr(":8080"),
        // disables updates:
        iris.WithoutVersionChecker,
        // skip err server closed when CTRL/CMD+C pressed:
        iris.WithoutServerError(iris.ErrServerClosed),
        // enables faster json serialization and more:
        iris.WithOptimizations)
}

echo:

package main

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

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

// Agent ...
type Agent struct {
    AgentID  string `json:"agent_id"`
    QueuedAt string `json:"queued_at"`
    QueuedBy string `json:"queued_by"`
}

// Details ...
type Details struct {
    EventID  string `json:"event_id"`
    Endpoint string
    Metric   string
    Content  string
    Priority int
    Status   string
}

// Test1 ...
type Test1 struct {
    Agent       Agent
    Details     Details
    Description string
    EventType   string `json:"event_type"`
    ServiceKey  string `json:"service_key"`
}

// Test2 test2
type Test2 struct {
    Data []*Test1
}

func main() {
    // Echo instance
    app := echo.New()

    // Middleware
    app.Use(middleware.Logger())

    // Routes
    app.GET("/ping", func(c echo.Context) error {
        return c.String(200, "pong")
    })

    app.POST("/v1/test", func(c echo.Context) error {
        var test Test1

        if err := c.Bind(&test); err != nil {
            return err
        }

        log.Println("========================start io=====================")
        time.Sleep(time.Duration(1) * time.Second)
        log.Println("=========================end io=======================")

        return c.JSON(http.StatusOK, test)

    })
    app.POST("/v2/test", func(c echo.Context) error {
        var test Test2

        if err := c.Bind(&test); err != nil {
            return err
        }

        log.Println("========================start io=====================")
        time.Sleep(time.Duration(1) * time.Second)
        log.Println("=========================end io=======================")

        return c.JSON(http.StatusOK, test)
    })
    app.POST("/v3/test", func(c echo.Context) error {
        var test Test2

        if err := c.Bind(&test); err != nil {
            return err
        }

        log.Println("========================start io=====================")
        time.Sleep(time.Duration(1) * time.Second)
        log.Println("=========================end io=======================")

        return c.JSON(http.StatusOK, test)

    })
    app.POST("/v4/test", func(c echo.Context) error {
        var test Test2

        if err := c.Bind(&test); err != nil {
            return err
        }

        log.Println("========================start io=====================")
        time.Sleep(time.Duration(1) * time.Second)
        log.Println("=========================end io=======================")

        return c.JSON(http.StatusOK, test)
    })

    // Start server
    app.Logger.Fatal(app.Start(":8080"))
}
  1. В дополнение к эху включены три другие библиотеки сериализации json, которые изначально поддерживают производительность jsoniter.
  2. Подождите 1 с, имитируйте чтение и запись ввода-вывода, подождите

Тестовое сравнение

Поскольку необходимо протестировать 5 видов образцов тела, 4 вида сценариев и 4 кадра, ключевые данные (пропускная способность, частота ошибок и 99%-ная линия в порядке убывания важности) отсеиваются, а результаты представляются в виде графика для простое сравнение и просмотр.

Результаты тестов до 565 байт



Результаты тестирования до 5 КБ



Результаты теста менее 10 КБ



Результаты теста менее 50 КБ



Результаты теста менее 100 КБ



Суммировать

Основываясь на приведенных выше результатах тестирования, видно, что и джин, и ирис — очень хорошие фреймворки.
Этот тест — просто простой тест на параллелизм трех фреймворков, связанных с json. Результаты сравнения не включают совершенство экологии и инструментов и т.д. Если есть какое-либо несовершенство в тесте, добро пожаловать на общение.
Кроме того, вы можете попробовать другой веб-фреймворк.baa, во избежание подозрений данные баа не выкладывал, тест производительности между джином и ирисом.