12 changed files with 99 additions and 678 deletions
--- a/README.MD
+++ b/README.MD
@ -1,11 +1,10 @@
-# simpleRequest 
+_# simpleRequest 
 ## 1. 说明
-[simpleRequest](www.github.com/dorlolo/simpleRequest) 是一款面向对象的http请求库，它在Go原生的http库为基础做了一定的封装，使开发更加便捷。
-
-> [simpleRequest](www.github.com/dorlolo/simpleRequest) 具备以下特点：
- 没有在代码层面遵循restful规范，适合对接不符合规范的接口;
- 轻量级、不需要繁琐的配置;
- 易于理解和使用，减少了资料查询的时间。
+[simpleRequest](www.github.com/dorlolo/simpleRequest) 是一款面向对象开发的http请求库。他是基于Go原生http库。开发这个模块的主要目的是为了更快的对接第三方api接口。
+它具备以下特点：
+- 极简化的代码，大大提高了代码编写速度。
+- 更易于理解和使用，减少了资料查询的时间。
+- 更适合对接一些不遵循restful规范的接口。

 这是它的一个示例:
 ```go
@ -62,13 +61,12 @@ r.Headers().Set("token", "d+jfdji*D%1=").Set("Content-Type", "application/json")
 ```

 #### 2.4.4 添加多值
-
+对单个key添加多只不要使用`.set`,因为原先的值会被覆盖
 ```go
-// 对相同key的值进行覆盖，请使用Set方法
 r.Headers().Set("Accept", "text/html")
-// 对相同key的值进行追加，请使用Add方法
 r.Headers().Add("Accept","application/xhtml+xml")
 r.Headers().Add("Accept","application/xml;q=0.8")
+r.Headers().Add("Accept","image/webp")
 r.Headers().Add("Accept","*/*;q=0.8")
 ```

@ -103,16 +101,6 @@ r.Headers().ConentType_textPlain()
 //r.Headers().Set("Content-Type","text/plain; charset=utf-8")
 ```

-#### 2.4.5 忽略指定请求头/禁用默认content-Type
-在默认情况下，`Content-Type`将被自动添加到请求头中，值为`application/x-www-form-urlencoded`。但对于某些场景来说这会导致请求失败。使用下面的方法可以忽略指定的请求头
-```go
-r.Headers().Omit("Content-Type")
-```
-或者使用以下方法禁用**默认content-Type**。禁用后当你不主动设置`Content-Type`时，请求头中将不会包含`Content-Type`。
-```go
-var r = simpleRequest.NewRequest(simpleRequest.OptionDisableDefaultContentType())
-````
-
 ### 2.5 添加queryParams
 #### 2.5.1 单个赋值
 ```go
@ -243,7 +231,7 @@ func FileForwardUseBytesBody(c *gin.Context){
        writer = multipart.NewWriter(body)
    )
    // add file object
-    filePart, _ := writer.CreateFormFile("file", file.Filename)
+    filePart, _ := i.writer.CreateFormFile("file", file.Filename)
    src, err := file.Open()
    if err != nil {
        fmt.Println( err.Error())
@ -317,14 +305,11 @@ if err != nil {
 ```go
 requestContext:=r.Request
 ```
-为了让用户能够便于分析调试，在进行http请求后r.Request.Body中的数据仍旧可读，但是会丧失部分性能，如果要禁用此功能请使用以下方法。
-```go
-var r = simpleRequest.NewRequest(simpleRequest.OptionDisableDefaultContentType())
-```
+
 #### 2.10.2 获取返回的上下文对象
 ```go
 responseContext:=r.Response
 ```

 ## 3. 使用示例
-[simpleRequest_test.go](excample/simpleRequest_test.go)
+[simpleRequest_test.go](excample/simpleRequest_test.go)_
--- a/body.go
+++ b/body.go
@ -7,12 +7,7 @@

 package simpleRequest

-import (
-	"bytes"
-	"io"
-	"mime/multipart"
-	"strings"
-)
+import "mime/multipart"

 // EntryMark 请求体条目标记，用于标记输入的body内容格式
 type EntryMark string
@ -30,21 +25,6 @@ const (
 	FormFilePathKey    EntryMark = "__FORM_FILE_PATH_KEY__"
 )

-func GetStringEntryTypeBody(bodyEntries map[string]any) io.Reader {
-	data, ok := bodyEntries[StringEntryType.string()]
-	if !ok || data == nil {
-		return nil
-	}
-	return strings.NewReader(data.(string))
-}
-func GetBytesEntryTypeBody(bodyEntries map[string]any) io.Reader {
-	data, ok := bodyEntries[BytesEntryType.string()]
-	if !ok || data == "" {
-		return nil
-	}
-	return bytes.NewReader(data.([]byte))
-}
-
 type BodyConf struct {
 	simpleReq *SimpleRequest
 }
@ -77,23 +57,13 @@ func (s *BodyConf) SetModel(model any) *BodyConf {
 	s.simpleReq.BodyEntries[ModelEntryType.string()] = model
 	return s
 }
-
-// 添加上传文件
 func (s *BodyConf) SetFromDataFile(key, filePath string) *BodyConf {
 	s.simpleReq.BodyEntryMark = MultipartEntryType
 	s.simpleReq.BodyEntries[FormFilePathKey.string()+key] = filePath
-	if s.simpleReq.headers.Get(hdrContentTypeKey) == "" {
-		s.simpleReq.headers.Set(hdrContentTypeKey, formDataType)
-	}
 	return s
 }
-
-// 添加文件，适用于服务端文件转发场景，比如直接从c.FormFile("file")中获取FileHeader对象转发即可
 func (s *BodyConf) SetFromDataMultipartFile(key string, multFile *multipart.FileHeader) *BodyConf {
 	s.simpleReq.BodyEntryMark = MultipartEntryType
 	s.simpleReq.BodyEntries[key] = multFile
-	if s.simpleReq.headers.Get(hdrContentTypeKey) == "" {
-		s.simpleReq.headers.Set(hdrContentTypeKey, formDataType)
-	}
 	return s
 }
--- a/excample/simpleRequest_test.go
+++ b/excample/simpleRequest_test.go
@ -11,7 +11,6 @@ import (
 	"fmt"
 	"github.com/dorlolo/simpleRequest"
 	"net/http"
-	"os"
 	"strings"
 	"testing"
 	"time"
@ -51,7 +50,7 @@ func TestRequest(t *testing.T) {
 }

 // 测试content-type 为 multipart/form-data格式的数据请求
-func TestAuth_formData(t *testing.T) {
+func TestAuth_fotmData(t *testing.T) {
 	req := simpleRequest.NewRequest()
 	req.Headers().ConentType_formData()
 	req.Headers().SetRandomUerAgent()
@ -133,24 +132,3 @@ func TestTextPlain(t *testing.T) {
 	}

 }
-
-// 阿里云Oss文件上传示例
-func TestUploadFileToOss(t *testing.T) {
-	var signedUrl = ""    //STS授权url
-	var xOssCallback = "" //回调信息
-	var req = simpleRequest.NewRequest()
-	req.Headers().
-		Sets(map[string]string{
-			"X-Oss-Callback": xOssCallback,
-		})
-
-	fileData, err := os.ReadFile("./CHANGELOG.MD")
-	req.Body().SetBytes(fileData)
-
-	body, err := req.PUT(signedUrl)
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	fmt.Println(string(body))
-}
--- a/headers.go
+++ b/headers.go
@ -69,7 +69,7 @@ func (s *HeadersConf) Omit(keys ...string) *HeadersConf {
 	return s
 }

-//deprecated
+//一般用不到
 //func (s *HeadersConf) Values(keys string) *HeadersConf {
 //	s.simpleReq.headers.Values(keys)
 //	return s
--- a/options.go
+++ b/options.go
@ -15,20 +15,3 @@ func OptionNewBodyEntryParser(contentType string, parser IBodyEntryParser) OPTIO
 		return r
 	}
 }
-
-// OptionDisableDefaultContentType 禁用默认的ContentType
-// 当未指定ContentType时，将不会使用默认的ContentType
-func OptionDisableDefaultContentType() OPTION {
-	return func(r *SimpleRequest) *SimpleRequest {
-		r.disableDefaultContentType = true
-		return r
-	}
-}
-
-// OptionDisableCopyRequestBody 禁用复制RequestBody
-func OptionDisableCopyRequestBody() OPTION {
-	return func(r *SimpleRequest) *SimpleRequest {
-		r.disableCopyRequestBody = true
-		return r
-	}
-}
--- a/options_test.go
+++ b/options_test.go
@ -1,49 +0,0 @@
-// Package simpleRequest -----------------------------
-// @file      : options_test.go
-// @author    : JJXu
-// @contact   : wavingbear@163.com
-// @time      : 2024/1/12 11:27
-// -------------------------------------------
-package simpleRequest
-
-import (
-	"io"
-	"testing"
-)
-
-func TestOptionDisableDefaultContentType(t *testing.T) {
-	go httpserver()
-	var r = NewRequest(OptionDisableDefaultContentType())
-	r.Headers()
-	bodyData := "{'a'=123,'b'=56}"
-	r.Body().SetString(bodyData)
-	_, err := r.POST("http://localhost:8989")
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	if r.Request.Header.Get(hdrContentTypeKey) != "" {
-		t.Errorf("query params want '%s' but get '%s'", "", r.Request.Header.Get(hdrContentTypeKey))
-	}
-}
-
-func TestOptionOptionDisableCopyRequestBody(t *testing.T) {
-	go httpserver()
-	var r = NewRequest(OptionDisableCopyRequestBody())
-	r.Headers()
-	bodyData := "{'a'=123,'b'=56}"
-	r.Body().SetString(bodyData)
-	_, err := r.POST("http://localhost:8989")
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	body, err := io.ReadAll(r.Request.Body)
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	if string(body) != "" {
-		t.Errorf("query params want '%s' but get '%s'", "", body)
-	}
-}
--- a/parser.go
+++ b/parser.go
@ -9,21 +9,17 @@ package simpleRequest
 import (
 	"bytes"
 	"encoding/json"
-	"encoding/xml"
 	"fmt"
 	"io"
 	"mime/multipart"
-	"net/url"
 	"os"
 	"path/filepath"
 	"strings"
 )

-// 通用类型解析器
 var bodyEntryParsers = map[string]IBodyEntryParser{
 	jsonContentType: new(JsonParser),
 	formDataType:    new(FormDataParser),
-	xmlDataType:     new(XmlParser),
 }

 type IBodyEntryParser interface {
@ -35,9 +31,9 @@ type JsonParser struct{}
 func (JsonParser) Unmarshal(bodyType EntryMark, BodyEntry map[string]any) io.Reader {
 	switch bodyType {
 	case StringEntryType:
-		return GetStringEntryTypeBody(BodyEntry)
+		return strings.NewReader(BodyEntry[StringEntryType.string()].(string))
 	case BytesEntryType:
-		return GetBytesEntryTypeBody(BodyEntry)
+		return bytes.NewReader(BodyEntry[BytesEntryType.string()].([]byte))
 	case ModelEntryType:
 		jsonData, err := json.Marshal(BodyEntry[ModelEntryType.string()])
 		if err == nil {
@ -83,9 +79,9 @@ func (f *FormDataParser) Unmarshal(bodyType EntryMark, BodyEntry map[string]any)
 		}
 		body, f.ContentType = multipartCommonParse(mapper)
 	case StringEntryType:
-		return GetStringEntryTypeBody(BodyEntry)
+		return strings.NewReader(BodyEntry[StringEntryType.string()].(string))
 	case BytesEntryType:
-		return GetBytesEntryTypeBody(BodyEntry)
+		return bytes.NewReader(BodyEntry[BytesEntryType.string()].([]byte))
 	default:
 		body, f.ContentType = multipartCommonParse(BodyEntry)
 	}
@ -142,54 +138,3 @@ func multipartCommonParse(BodyEntry map[string]any) (reader io.Reader, contentTy
 	}
 	return body, formWriter.FormDataContentType()
 }
-
-type XmlParser struct{}
-
-func (f XmlParser) Unmarshal(bodyType EntryMark, BodyEntry map[string]any) (body io.Reader) {
-	switch bodyType {
-	case MapEntryType:
-		xmlData, err := xml.Marshal(BodyEntry[bodyType.string()])
-		if err == nil {
-			return bytes.NewReader(xmlData)
-		} else {
-			return strings.NewReader("")
-		}
-	case ModelEntryType:
-		xmlData, err := xml.Marshal(BodyEntry[bodyType.string()])
-		if err == nil {
-			return bytes.NewReader(xmlData)
-		} else {
-			return strings.NewReader("")
-		}
-	case StringEntryType:
-		return GetStringEntryTypeBody(BodyEntry)
-	case BytesEntryType:
-		return GetBytesEntryTypeBody(BodyEntry)
-	default:
-		return strings.NewReader("")
-	}
-}
-
-type CommonParser struct {
-}
-
-func (f CommonParser) Unmarshal(bodyType EntryMark, BodyEntry map[string]any) (body io.Reader) {
-	tmpData := url.Values{}
-	for k, v := range BodyEntry {
-		switch k {
-		case StringEntryType.string():
-			body = GetStringEntryTypeBody(BodyEntry)
-			break
-		case BytesEntryType.string():
-			body = GetBytesEntryTypeBody(BodyEntry)
-			break
-		default:
-			if strings.HasPrefix(k, FormFilePathKey.string()) {
-				k = k[len(FormFilePathKey):]
-			}
-			tmpData.Set(k, fmt.Sprintf("%v", v))
-		}
-	}
-	body = strings.NewReader(tmpData.Encode())
-	return
-}
--- a/parser_test.go
+++ b/parser_test.go
@ -1,118 +0,0 @@
-// Package simpleRequest -----------------------------
-// @file      : parser_test.go
-// @author    : JJXu
-// @contact   : wavingbear@163.com
-// @time      : 2024/1/11 18:35
-// -------------------------------------------
-package simpleRequest
-
-import (
-	"io"
-	"reflect"
-	"testing"
-)
-
-func TestFormDataParser_Unmarshal(t *testing.T) {
-	type fields struct {
-		ContentType string
-	}
-	type args struct {
-		bodyType  EntryMark
-		BodyEntry map[string]any
-	}
-	tests := []struct {
-		name     string
-		fields   fields
-		args     args
-		wantBody io.Reader
-	}{
-		{
-			name:   "StringEntryType",
-			fields: fields{},
-			args: args{
-				bodyType:  StringEntryType,
-				BodyEntry: map[string]any{StringEntryType.string(): "test"},
-			},
-			wantBody: nil,
-		},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			f := &FormDataParser{
-				ContentType: tt.fields.ContentType,
-			}
-			if gotBody := f.Unmarshal(tt.args.bodyType, tt.args.BodyEntry); !reflect.DeepEqual(gotBody, tt.wantBody) {
-				t.Errorf("Unmarshal() = %v, want %v", gotBody, tt.wantBody)
-			}
-		})
-	}
-}
-
-func TestJsonParser_Unmarshal(t *testing.T) {
-	type args struct {
-		bodyType  EntryMark
-		BodyEntry map[string]any
-	}
-	tests := []struct {
-		name string
-		args args
-		want io.Reader
-	}{
-		// TODO: Add test cases.
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			js := JsonParser{}
-			if got := js.Unmarshal(tt.args.bodyType, tt.args.BodyEntry); !reflect.DeepEqual(got, tt.want) {
-				t.Errorf("Unmarshal() = %v, want %v", got, tt.want)
-			}
-		})
-	}
-}
-
-func TestXmlParser_Unmarshal(t *testing.T) {
-	type args struct {
-		bodyType  EntryMark
-		BodyEntry map[string]any
-	}
-	tests := []struct {
-		name     string
-		args     args
-		wantBody io.Reader
-	}{
-		// TODO: Add test cases.
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			f := XmlParser{}
-			if gotBody := f.Unmarshal(tt.args.bodyType, tt.args.BodyEntry); !reflect.DeepEqual(gotBody, tt.wantBody) {
-				t.Errorf("Unmarshal() = %v, want %v", gotBody, tt.wantBody)
-			}
-		})
-	}
-}
-
-func Test_multipartCommonParse(t *testing.T) {
-	type args struct {
-		BodyEntry map[string]any
-	}
-	tests := []struct {
-		name            string
-		args            args
-		wantReader      io.Reader
-		wantContentType string
-	}{
-		// TODO: Add test cases.
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			gotReader, gotContentType := multipartCommonParse(tt.args.BodyEntry)
-			if !reflect.DeepEqual(gotReader, tt.wantReader) {
-				t.Errorf("multipartCommonParse() gotReader = %v, want %v", gotReader, tt.wantReader)
-			}
-			if gotContentType != tt.wantContentType {
-				t.Errorf("multipartCommonParse() gotContentType = %v, want %v", gotContentType, tt.wantContentType)
-			}
-		})
-	}
-}
--- a/simpleRequest.go
+++ b/simpleRequest.go
@ -8,9 +8,7 @@
 package simpleRequest

 import (
-	"bytes"
 	"crypto/tls"
-	"errors"
 	"fmt"
 	"io"
 	"net/http"
@ -50,16 +48,14 @@ type SimpleRequest struct {
 	omitHeaderKeys []string
 	transport      *http.Transport

-	BodyEntryMark             EntryMark                   // 用于标记输入的body内容格式
-	BodyEntries               map[string]any              // 输入的body中的内容
-	bodyEntryParsers          map[string]IBodyEntryParser // 用于将BodyEntries中的内容解析后传入request body中
-	disableDefaultContentType bool                        // 禁用默认的ContentType
-	disableCopyRequestBody    bool                        // 禁用复制请求体，在进行http请求后SimpleRequest.Request.Body中内容会无法读取，但是会提高性能
+	BodyEntryMark    EntryMark
+	BodyEntries      map[string]any
+	bodyEntryParsers map[string]IBodyEntryParser

 	timeout time.Duration

-	Response *http.Response //用于获取完整的返回内容。请注意要在请求之后才能获取
-	Request  *http.Request  //用于获取完整的请求内容。请注意要在请求之后才能获取
+	Response http.Response //用于获取完整的返回内容。请注意要在请求之后才能获取
+	Request  http.Request  //用于获取完整的请求内容。请注意要在请求之后才能获取
 	//cookies           map[string]string
 	//data              any
 	//cli               *http.Client
@ -147,17 +143,23 @@ func (s *SimpleRequest) do(request *http.Request) (body []byte, err error) {
 	//3.1 发送数据
 	resp, err := client.Do(request)
 	if err != nil {
-		err = errors.New("[client.Do Err]:" + err.Error())
+		fmt.Println("【Request Error】:", err.Error())
 		return
 	}

 	//v0.0.2更新，将request和response内容返回，便于用户进行分析 JJXu 03-11-2022
-	s.Request = request
 	if resp != nil {
-		s.Response = resp
-		defer resp.Body.Close()
-		body, err = io.ReadAll(resp.Body)
+		s.Response = *resp
+	} else {
+		return
 	}
+	if request != nil {
+		s.Request = *request
+	}
+
+	defer resp.Body.Close()
+	//3.2 获取数据
+	body, err = io.ReadAll(resp.Body)
 	return
 }

@ -173,32 +175,17 @@ func (s *SimpleRequest) GET(urls string) (body []byte, err error) {

 // 通用的请求方法
 func (s *SimpleRequest) LaunchTo(urls, method string) (body []byte, err error) {
-	var r *http.Request
 	// body
 	s.initBody()
-	var copBody []byte
-	if s.body != nil {
-		copBody, err = io.ReadAll(s.body)
-		if err != nil {
-			return
-		}
-	}
-	if !s.disableCopyRequestBody {
-		// 使r.body在请求后仍旧可读,便于使用者对请求过程进行分析
-		r, err = http.NewRequest(method, urls, io.NopCloser(bytes.NewBuffer(copBody)))
-		if err != nil {
-			return nil, err
-		}
-		defer func() {
-			r.Body = io.NopCloser(bytes.NewBuffer(copBody))
-		}()
-	} else {
-		r, err = http.NewRequest(method, urls, s.body)
-		if err != nil {
-			return nil, err
-		}
+	r, err := http.NewRequest(method, urls, s.body)
+	if err != nil {
+		return nil, err
 	}
 	//headers
+	//for k := range s.headers {
+	//	r.Header[k] = append(r.Header[k], s.headers[k]...)
+	//	s.headers.Del(k)
+	//}
 	r.Header = s.headers
 	for _, k := range s.omitHeaderKeys {
 		r.Header.Del(k)
@ -260,101 +247,64 @@ func (s *SimpleRequest) TRACE(url string) (body []byte, err error) {

 // ------------------------------------------------------
 //
-//	Automatically parses the request body based on the content-type type defined in the request header
+//	这里数据
 func (s *SimpleRequest) initBody() {
 	contentTypeData := s.headers.Get(hdrContentTypeKey)
-	if contentTypeData != "" {
-		switch {
-		case IsJSONType(contentTypeData):
-			var parser, ok = s.bodyEntryParsers[jsonContentType]
-			if !ok {
-				parser = new(JsonParser)
-			}
-			s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
-
-		case strings.Contains(contentTypeData, formDataType):
-			var parser, ok = s.bodyEntryParsers[formDataType]
-			if !ok {
-				parser = new(FormDataParser)
-			}
-			s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
-			fdParser := parser.(*FormDataParser)
-			s.headers.Set("Content-Type", fdParser.ContentType)
-
-		case IsXMLType(contentTypeData):
-			//application/soap+xml ,application/xml
-			var parser, ok = s.bodyEntryParsers[xmlDataType]
-			if !ok {
-				s.body = GetStringEntryTypeBody(s.BodyEntries)
-				return
-			}
-			s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
-
-		case strings.Contains(contentTypeData, "text") || strings.Contains(contentTypeData, javaScriptType):
-			var parser, ok = s.bodyEntryParsers[textPlainType]
-			if !ok {
-				s.body = GetStringEntryTypeBody(s.BodyEntries)
-				return
-			}
-			s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
-
-		case strings.Contains(contentTypeData, "form-urlencoded"):
-			//default header type is "x-www-form-urlencoded"
-			var parser, ok = s.bodyEntryParsers["form-urlencoded"]
-			if !ok {
-				for k, v := range s.BodyEntries {
-					if v == nil {
-						break
-					}
-					switch k {
-					case StringEntryType.string():
-						s.body = GetStringEntryTypeBody(s.BodyEntries)
-						break
-					case BytesEntryType.string():
-						s.body = GetBytesEntryTypeBody(s.BodyEntries)
-						break
-					default:
-						tmpData := url.Values{}
-						if strings.HasPrefix(k, FormFilePathKey.string()) {
-							k = k[len(FormFilePathKey):]
-						}
-						tmpData.Set(k, fmt.Sprintf("%v", v))
-						s.body = strings.NewReader(tmpData.Encode())
-					}
-				}
-				//s.Headers().ConentType_formUrlencoded()
-				return
-			}
-			s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
-		default:
-			// 自动处理body数据
-			s.body = new(CommonParser).Unmarshal(s.BodyEntryMark, s.BodyEntries)
-		}
-	} else {
-		switch s.BodyEntryMark {
-		case BytesEntryType:
-			s.body = GetBytesEntryTypeBody(s.BodyEntries)
-		case StringEntryType:
-			s.body = GetStringEntryTypeBody(s.BodyEntries)
-		default:
-			var parser, ok = s.bodyEntryParsers["form-urlencoded"]
-			if !ok {
-				tmpData := url.Values{}
-				for k, v := range s.BodyEntries {
-					if strings.HasPrefix(k, FormFilePathKey.string()) {
-						k = k[len(FormFilePathKey):]
-					}
-					tmpData.Set(k, fmt.Sprintf("%v", v))
-				}
-				s.body = strings.NewReader(tmpData.Encode())
-				if !s.disableDefaultContentType {
-					s.Headers().ConentType_formUrlencoded()
-				}
-				return
-			}
-			s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
+	switch {
+	case IsJSONType(contentTypeData):
+		var parser, ok = s.bodyEntryParsers[jsonContentType]
+		if !ok {
+			parser = new(JsonParser)
 		}
+		s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)

+	case strings.Contains(contentTypeData, formDataType):
+		var parser, ok = s.bodyEntryParsers[formDataType]
+		if !ok {
+			parser = new(FormDataParser)
+		}
+		s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
+		fdParser := parser.(*FormDataParser)
+		s.headers.Set("Content-Type", fdParser.ContentType)
+
+	case IsXMLType(contentTypeData):
+		//application/soap+xml ,application/xml
+		var parser, ok = s.bodyEntryParsers[xmlDataType]
+		if !ok {
+			data, _ := s.BodyEntries[StringEntryType.string()].(string)
+			s.body = strings.NewReader(data)
+			return
+		}
+		s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
+
+	case strings.Contains(contentTypeData, "text") || strings.Contains(contentTypeData, javaScriptType):
+		var parser, ok = s.bodyEntryParsers[textPlainType]
+		if !ok {
+			data, _ := s.BodyEntries[StringEntryType.string()].(string)
+			s.body = strings.NewReader(data)
+			return
+		}
+		s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
+
+	case contentTypeData == "" || strings.Contains(contentTypeData, "form-urlencoded"):
+		//default header type is "x-www-form-urlencoded"
+		var parser, ok = s.bodyEntryParsers["form-urlencoded"]
+		if !ok {
+			tmpData := url.Values{}
+			for k, v := range s.BodyEntries {
+				tmpData.Set(k, fmt.Sprintf("%v", v))
+			}
+			s.body = strings.NewReader(tmpData.Encode())
+			s.Headers().ConentType_formUrlencoded()
+			return
+		}
+		s.body = parser.Unmarshal(s.BodyEntryMark, s.BodyEntries)
+	default:
+		//todo Automatically determine the data type
+		tmpData := url.Values{}
+		for k, v := range tmpData {
+			tmpData.Set(k, fmt.Sprintf("%v", v))
+		}
+		s.body = strings.NewReader(tmpData.Encode())
 	}
-
 }
--- a/simpleRequest_test.go
+++ b/simpleRequest_test.go
@ -8,6 +8,7 @@ package simpleRequest

 import (
 	"encoding/json"
+	"fmt"
 	"io"
 	"net/http"
 	"testing"
@ -34,7 +35,7 @@ func httpserver() {
 			io.WriteString(w, "false")
 		}
 	})
-	//fmt.Println("http服务启动了")
+	fmt.Println("http服务启动了")
 	http.ListenAndServe(":8989", nil)
 }

@ -97,64 +98,8 @@ func TestQueryUrl2(t *testing.T) {
 		t.Error(err.Error())
 	} else {
 		if r.Request.URL.RawQuery != "a=123&b=456&c=3" {
-			t.Errorf("query params want '%s' but get '%s'", "a=123&b=456&c=3", r.Request.URL.RawQuery)
+			t.Errorf("query params wangt '%s' but get '%s'", "a=123&b=456&c=3", r.Request.URL.RawQuery)
 		}
 	}

 }
-
-// 请求后，r.Request.Body中的内容仍旧可读
-func TestQueryUseStringBody(t *testing.T) {
-	go httpserver()
-	var r = NewRequest()
-	r.Headers().ConentType_json()
-	bodyData := "{'a'=123,'b'=56}"
-	r.Body().SetString(bodyData)
-	_, err := r.POST("http://localhost:8989")
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	body, err := io.ReadAll(r.Request.Body)
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	if string(body) != bodyData {
-		t.Errorf("request body want '%s' but get '%s'", bodyData, body)
-	}
-}
-
-func TestEmptyBody(t *testing.T) {
-	go httpserver()
-	var r = NewRequest()
-	r.Headers().ConentType_json()
-	_, err := r.POST("http://localhost:8989")
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	body, err := io.ReadAll(r.Request.Body)
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	if string(body) != "{}" {
-		t.Errorf("request body want '%s' but get '%s'", "{}", body)
-	}
-
-	r.Headers().ConentType_formUrlencoded()
-	_, err = r.POST("http://localhost:8989")
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	body, err = io.ReadAll(r.Request.Body)
-	if err != nil {
-		t.Error(err)
-		return
-	}
-	if string(body) != "" {
-		t.Errorf("request body want '%s' but get '%s'", "", body)
-	}
-}
--- a/utils.go
+++ b/utils.go
@ -7,11 +7,6 @@

 package simpleRequest

-import (
-	"encoding/xml"
-	"fmt"
-)
-
 func IsJSONType(ct string) bool {
 	return jsonCheck.MatchString(ct)
 }
@ -29,84 +24,3 @@ func IsInArray(arr []string, str string) bool {
 	}
 	return false
 }
-
-type xmlMapEntry struct {
-	XMLName xml.Name
-	Value   interface{} `xml:",chardata"`
-}
-
-//	func MapToXml(data map[string]any) ([]byte, error) {
-//		xmlData, err := mapToXML(data)
-//		if err != nil {
-//			return nil, err
-//		}
-//		return xml.MarshalIndent(xmlData, "", "  ")
-//	}
-//
-//	func mapToXML(m map[string]interface{}) (xmlMap map[string]xmlMapEntry, err error) {
-//		if len(m) > 1 {
-//			return nil, errors.New("xml format must have a root name,the map value must like this: map[string]interface{}{\"rootName\":map[string]interface{}{}}")
-//		}
-//		xmlMap = make(map[string]xmlMapEntry)
-//		var rootName string
-//		for root, data := range m {
-//			rootName = root
-//			for k, v := range data.(map[string]interface{}) {
-//				switch typeV := v.(type) {
-//				case map[string]interface{}:
-//					subXmlMap, err := mapToXML(typeV)
-//					if err != nil {
-//						return
-//					}
-//
-//				default:
-//					entry := xmlMapEntry{XMLName: xml.Name{Local: k}, Value: v}
-//					xmlMap[k] = entry
-//				}
-//			}
-//		}
-//
-//		xmlData := struct {
-//			XMLName xml.Name
-//			Data    []xmlMapEntry `xml:",any"`
-//		}{
-//			XMLName: xml.Name{Local: rootName},
-//			Data:    make([]xmlMapEntry, 0, len(xmlMap)),
-//		}
-//
-//		for _, v := range xmlMap {
-//			xmlData.Data = append(xmlData.Data, v)
-//		}
-//
-//		return xml.MarshalIndent(xmlData, "", "  ")
-//	}
-
-func mapToXML(m map[string]interface{}) ([]byte, error) {
-	xmlData := make([]xmlNode, 0)
-
-	for k, v := range m {
-		node := xmlNode{
-			XMLName: xml.Name{Local: k},
-		}
-
-		switch value := v.(type) {
-		case map[string]interface{}:
-			childXML, err := mapToXML(value)
-			if err != nil {
-				return nil, err
-			}
-			node.Data = childXML
-		default:
-			node.Data = []byte(fmt.Sprintf("%v", v))
-		}
-
-		xmlData = append(xmlData, node)
-	}
-
-	return xml.MarshalIndent(xmlData, "", "  ")
-}
-
-type xmlNode struct {
-	XMLName xml.Name
-	Data    []byte `xml:",innerxml"`
-}
--- a/utils_test.go
+++ b/utils_test.go
@ -1,82 +0,0 @@
-// Package simpleRequest -----------------------------
-// @file      : utils_test.go
-// @author    : JJXu
-// @contact   : wavingbear@163.com
-// @time      : 2023/11/17 16:37
-// -------------------------------------------
-package simpleRequest
-
-import (
-	"fmt"
-	"testing"
-)
-
-func Test_mapToXML(t *testing.T) {
-	type args struct {
-		m map[string]interface{}
-	}
-	tests := []struct {
-		name    string
-		args    args
-		want    string
-		wantErr bool
-	}{
-		{
-			name: "多级xml测试",
-			args: args{
-				m: map[string]interface{}{
-					"UserInfo": map[string]any{
-						"Name":      "JJXu",
-						"Age":       18,
-						"isTrueMan": true,
-						"assets": map[string]any{
-							"car":   "BMW",
-							"house": "shanghai",
-						},
-					},
-				},
-			},
-			want:    "<UserInfo>\n<Age>18</Age>\n<isTrueMan>true</isTrueMan>\n<assets></assets>\n<Name>JJXu</Name>\n</UserInfo>",
-			wantErr: false,
-		},
-		{
-			name:    "错误格式测试",
-			args:    args{},
-			want:    "",
-			wantErr: false,
-		},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			got, err := mapToXML(tt.args.m)
-			if (err != nil) != tt.wantErr {
-				t.Errorf("mapToXML() error = %v, wantErr %v", err, tt.wantErr)
-				return
-			}
-			if string(got) != tt.want {
-				t.Errorf("mapToXML() got = %v, want %v", string(got), tt.want)
-			}
-		})
-	}
-}
-func Test_mapToXML2(t *testing.T) {
-	person := map[string]interface{}{
-		"userInfo": map[string]interface{}{
-			"name": "John",
-			"age":  30,
-			"address": map[string]interface{}{
-				"street": "123 Main St",
-				"city":   "New York",
-			},
-		},
-	}
-
-	xmlBytes, err := mapToXML(person)
-	if err != nil {
-		fmt.Println("Error:", err)
-		return
-	}
-
-	xmlString := string(xmlBytes)
-	fmt.Println(xmlString)
-}