Server

业务逻辑处理
1 Uppercase 将字符转换成大写字母
2 Count 获取当前字符的长度值

  1. package service
  3. import (
  4.     "errors"
  5.     "strings"
  6. )
  8. type StringService interface {
  9.     Uppercase(string) (string, error)
  10.     Count(string) int
  11. }
  12. type StringServiceImpl struct{}
  14. func (StringServiceImpl) Uppercase(s string) (string, error) {
  15.     if s == "" {
  16.         return "", errors.New("empty string")
  17.     }
  18.     return strings.ToUpper(s), nil
  19. }
  21. func (StringServiceImpl) Count(s string) int {
  22.     return len(s)
  23. }

Endpoints

业务代码的中间处理层，将request 请求传递给业务层，将业务层的返回结果传递给请求层

  1. package endpoints
  3. import (
  4.     "context"
  5.     "github.com/baxiang/go-note/stringsvc-v1/service"
  6.     "github.com/go-kit/kit/endpoint"
  7. )
  9. type UppercaseRequest struct {
  10.     S string `json:"s"`
  11. }
  13. type uppercaseResponse struct {
  14.     V string `json:"v"`
  15. }
  17. type CountRequest struct {
  18.     S string `json:"s"`
  19. }
  21. type countResponse struct {
  22.     V int `json:"v"`
  23. }
  24. type commonResponse struct {
  25.     Message string      `json:"message"`
  26.     Code    int         `json:"code"`
  27.     Data    interface{} `json:"data"`
  28. }
  30. func MakeUppercaseEndpoint(svc service.StringService) endpoint.Endpoint {
  31.     return func(_ context.Context, request interface{}) (response interface{}, err error) {
  32.         req := request.(UppercaseRequest)
  33.         v, err := svc.Uppercase(req.S)
  34.         if err != nil {
  35.             return commonResponse{Data: nil, Message: err.Error(), Code: 1000}, nil
  36.         }
  37.         return commonResponse{Data: uppercaseResponse{v}, Message: "success", Code: 0}, nil
  38.     }
  39. }
  41. func MakeCountEndpoint(svc service.StringService) endpoint.Endpoint {
  42.     return func(_ context.Context, request interface{}) (response interface{}, err error) {
  43.         req := request.(CountRequest)
  44.         v := svc.Count(req.S)
  45.         return commonResponse{Data: countResponse{v}, Message: "", Code: 0}, nil
  46.     }
  47. }

Transports

  1. package transport
  3. import (
  4.     "context"
  5.     "encoding/json"
  6.     "github.com/baxiang/go-note/stringsvc-v1/endpoints"
  7.     "net/http"
  8. )
  10. func DecodeUppercaseRequest(_ context.Context, r *http.Request) (interface{}, error) {
  11.     var request endpoints.UppercaseRequest
  12.     if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
  13.         return nil, err
  14.     }
  15.     return request, nil
  16. }
  18. func DecodeCountRequest(_ context.Context, r *http.Request) (interface{}, error) {
  19.     var request endpoints.CountRequest
  20.     if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
  21.         return nil, err
  22.     }
  23.     return request, nil
  24. }
  26. func EncodeResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {
  27.     return json.NewEncoder(w).Encode(response)
  28. }

main

  1. package main
  3. import (
  4.     "github.com/baxiang/go-note/stringsvc-v1/endpoints"
  5.     "github.com/baxiang/go-note/stringsvc-v1/service"
  6.     transport "github.com/baxiang/go-note/stringsvc-v1/transports"
  7.     kithttp "github.com/go-kit/kit/transport/http"
  8.     "log"
  9.     "net/http"
  10. )
  12. func main() {
  13.     svc := service.StringServiceImpl{}
  14.     uppercaseHandler := kithttp.NewServer(endpoints.MakeUppercaseEndpoint(svc), transport.DecodeUppercaseRequest, transport.EncodeResponse)
  15.     countHandler := kithttp.NewServer(endpoints.MakeCountEndpoint(svc), transport.DecodeCountRequest, transport.EncodeResponse)
  17.     http.Handle("/uppercase", uppercaseHandler)
  18.     http.Handle("/count", countHandler)
  19.     log.Fatal(http.ListenAndServe(":8090", nil))
  21. }

中间件开发

  1. package middleware
  3. import (
  4.     "github.com/baxiang/go-note/stringsvc-v1/service"
  5.     "github.com/go-kit/kit/log"
  6.     "time"
  7. )
  9. type LoggingMiddleware struct {
  10.     Logger log.Logger
  11.     Next service.StringService
  12. }
  13. func (mw LoggingMiddleware)Uppercase(s string)(output string,err error){
  14.     defer func(begin time.Time) {
  15.         _ =mw.Logger.Log(
  16.             "method", "uppercase",
  17.             "input", s,
  18.             "output", output,
  19.             "err", err,
  20.             "took", time.Since(begin),
  21.             )
  22.     }(time.Now())
  23.     output, err = mw.Next.Uppercase(s)
  24.     return
  25. }
  26. func (mw LoggingMiddleware) Count(s string) (n int) {
  27.     defer func(begin time.Time) {
  28.         _ = mw.Logger.Log(
  29.             "method","count",
  30.             "input",s,
  31.             "output",n,
  32.             "took",time.Since(begin),
  33.         )
  34.     }(time.Now())
  35.     n = mw.Next.Count(s)
  36.     return
  37. }

监控

  1. package middleware
  3. import (
  4.     "github.com/baxiang/go-note/stringsvc-v1/service"
  5.     "github.com/go-kit/kit/log"
  6.     "time"
  7. )
  9. type LoggingMiddleware struct {
  10.     Logger log.Logger
  11.     Next service.StringService
  12. }
  13. func (mw LoggingMiddleware)Uppercase(s string)(output string,err error){
  14.     defer func(begin time.Time) {
  15.         _ =mw.Logger.Log(
  16.             "method", "uppercase",
  17.             "input", s,
  18.             "output", output,
  19.             "err", err,
  20.             "took", time.Since(begin),
  21.             )
  22.     }(time.Now())
  23.     output, err = mw.Next.Uppercase(s)
  24.     return
  25. }
  26. func (mw LoggingMiddleware) Count(s string) (n int) {
  27.     defer func(begin time.Time) {
  28.         _ = mw.Logger.Log(
  29.             "method","count",
  30.             "input",s,
  31.             "output",n,
  32.             "took",time.Since(begin),
  33.         )
  34.     }(time.Now())
  35.     n = mw.Next.Count(s)
  36.     return
  37. }

main

  1. package main
  3. import (
  4.     "github.com/baxiang/go-note/stringsvc-v1/endpoints"
  5.     "github.com/baxiang/go-note/stringsvc-v1/middleware"
  6.     "github.com/baxiang/go-note/stringsvc-v1/service"
  7.     transport "github.com/baxiang/go-note/stringsvc-v1/transports"
  8.     kithttp "github.com/go-kit/kit/transport/http"
  9.     "github.com/go-kit/kit/log"
  10.     "os"
  11.     stdprometheus "github.com/prometheus/client_golang/prometheus"
  12.     "github.com/prometheus/client_golang/prometheus/promhttp"
  13.     kitprometheus "github.com/go-kit/kit/metrics/prometheus"
  14.     "net/http"
  15. )
  17. func main() {
  18.     logger := log.NewLogfmtLogger(os.Stderr)
  20.     fieldKeys := []string{"method", "error"}
  21.     requestCount := kitprometheus.NewCounterFrom(stdprometheus.CounterOpts{
  22.         Namespace: "str",
  23.         Subsystem: "string_service",
  24.         Name:      "request_count",
  25.         Help:      "Number of requests received.",
  26.     }, fieldKeys)
  28.     requestLatency := kitprometheus.NewSummaryFrom(stdprometheus.SummaryOpts{
  29.         Namespace: "str",
  30.         Subsystem: "string_service",
  31.         Name:      "request_latency_microseconds",
  32.         Help:      "Total duration of requests in microseconds.",
  33.     }, fieldKeys)
  34.     countResult := kitprometheus.NewSummaryFrom(stdprometheus.SummaryOpts{
  35.         Namespace: "str",
  36.         Subsystem: "string_service",
  37.         Name:      "count_result",
  38.         Help:      "The result of each count method.",
  39.     }, []string{}) // no fields here
  41.     var svc service.StringService
  42.     svc = service.StringServiceImpl{}
  43.     svc = middleware.LoggingMiddleware{logger, svc}
  44.     svc = middleware.InstrumentingMiddleware{requestCount, requestLatency, countResult, svc}
  45.     uppercaseHandler := kithttp.NewServer(endpoints.MakeUppercaseEndpoint(svc),
  46.         transport.DecodeUppercaseRequest,
  47.         transport.EncodeResponse)
  49.     countHandler := kithttp.NewServer(endpoints.MakeCountEndpoint(svc),
  50.         transport.DecodeCountRequest,
  51.         transport.EncodeResponse)
  53.     http.Handle("/uppercase", uppercaseHandler)
  54.     http.Handle("/count", countHandler)
  55.     http.Handle("/metrics", promhttp.Handler())
  56.     logger.Log(http.ListenAndServe(":8080", nil))
  57. }

参考

https://github.com/go-kit/kit/tree/master/examples
https://blog.csdn.net/wdy_yx/article/details/78389736?utm_medium=distribute.pc_relevant.none-task-blog-baidujs-1