替换json

utils/http_middleware/gin_recovery.go

@@ -1,12 +1,12 @@
 package http_middleware
 
 import (
-	"encoding/json"
 	"fmt"
 	"git.haoqitour.com/haoqi/go-common/utils"
 	"git.haoqitour.com/haoqi/go-common/utils/date"
 	"git.haoqitour.com/haoqi/go-common/utils/logger"
 	"github.com/gin-gonic/gin"
+	"github.com/json-iterator/go"
 	"net/http"
 	"strings"
 )
@@ -69,7 +69,7 @@ func Recovery(hostPrefix string, logger *logger.Logger) gin.HandlerFunc {
 					}
 					if i, ok := ctxt.Get(IsLogHTTPResponse); ok {
 						if isLogHttpResponse, ok := i.(bool); ok && isLogHttpResponse {
-							respB, _ := json.Marshal(res)
+							respB, _ := jsoniter.Marshal(res)
 							logger = logger.WithField("responseBody", string(respB))
 						}
 					}
@@ -86,7 +86,7 @@ func Recovery(hostPrefix string, logger *logger.Logger) gin.HandlerFunc {
 					res := utils.E(9999, "未定义", nil)
 					if i, ok := ctxt.Get(IsLogHTTPResponse); ok {
 						if isLogHttpResponse, ok := i.(bool); ok && isLogHttpResponse {
-							respB, _ := json.Marshal(res)
+							respB, _ := jsoniter.Marshal(res)
 							logger = logger.WithField("responseBody", string(respB))
 						}
 					}

utils/mq/kafka/consumer.go

@@ -1,11 +1,11 @@
 package kafka
 
 import (
-	"encoding/json"
 	"fmt"
 	"git.haoqitour.com/haoqi/go-common/utils/logger"
 	"github.com/Shopify/sarama"
 	"github.com/bsm/sarama-cluster"
+	"github.com/json-iterator/go"
 	"github.com/spf13/viper"
 	"reflect"
 )
@@ -79,7 +79,7 @@ func (c *Consumer) BindJSONChan(channel interface{}) {
 					} else {
 						oPtr = reflect.New(argType.Elem())
 					}
-					_ = json.Unmarshal(msg.Value, oPtr.Interface())
+					_ = jsoniter.Unmarshal(msg.Value, oPtr.Interface())
 					if argType.Kind() != reflect.Ptr {
 						oPtr = reflect.Indirect(oPtr)
 					}

utils/mq/kafka/producer.go

@@ -1,12 +1,12 @@
 package kafka
 
 import (
-	"encoding/json"
 	"fmt"
 	"git.haoqitour.com/haoqi/go-common/utils"
 	"git.haoqitour.com/haoqi/go-common/utils/logger"
 	"git.haoqitour.com/haoqi/go-common/utils/mq"
 	"github.com/Shopify/sarama"
+	"github.com/json-iterator/go"
 	"github.com/spf13/viper"
 )
 
@@ -16,7 +16,7 @@ func NewMsg(topic string, value interface{}) (msg *sarama.ProducerMessage, err e
 	if nil == value {
 		bytes = []byte{}
 	} else {
-		bytes, err = json.Marshal(value)
+		bytes, err = jsoniter.Marshal(value)
 		if nil != err {
 			return
 		}