3.8.1

sdk/Go/PhalApiClient/PhalApiClient.go

@@ -0,0 +1,144 @@
+package PhalApiClient
+
+import (
+	"encoding/json"
+	"errors"
+	"io/ioutil"
+	"net"
+	"net/http"
+	"net/url"
+	"time"
+)
+
+/**
+ * PhalApi客户端SDK包（Go版）
+ *
+ *
+ * <br>使用示例：<br>
+ ```
+	rs, err := PhalApiClient.NewRequest().
+		WithHost(`http://127.0.0.1/PhalApi/Public/index.php`).
+		WithService("Default.index").
+		WithParams(url.Values{}).
+		Get()
+	if err != nil {
+		fmt.Println(err.Error())
+	} else {
+		fmt.Println("code------------------------", rs.Code)
+		fmt.Println("data------------------------", rs.Data)
+		fmt.Println("msg------------------------", rs.Msg)
+	}
+```
+    *
+    * @package     PhalApi\SDK
+    * @author      prettyyjnic <prettyyjnic@qq.com> 2016-03-09
+*/
+
+type request struct {
+	Host    string
+	Service string
+	Params  url.Values
+	Timeout time.Duration
+}
+
+type result struct {
+	Code int64       `json:"ret"`
+	Data interface{} `json:"data"`
+	Msg  interface{} `json:"msg"`
+}
+
+func NewRequest() *request {
+	ptr_request := new(request)
+	return ptr_request
+}
+
+func (this *request) WithHost(host string) *request {
+	this.Host = host
+	return this
+}
+
+func (this *request) WithService(service string) *request {
+	this.Service = service
+	return this
+}
+
+func (this *request) WithParams(params url.Values) *request {
+	this.Params = params
+	return this
+}
+
+func (this *request) WithTimeout(timeout time.Duration) *request {
+	this.Timeout = timeout
+	return this
+}
+
+func (this *request) Reset() {
+	this.Params = url.Values{}
+	this.Host = ""
+	this.Service = ""
+	this.Timeout = 0
+}
+
+func (this *request) Get() (*result, error) {
+	client := this.getClient()
+	var str_url string
+	if this.Service != "" {
+		this.Params.Add("service", this.Service)
+	}
+	str_url = this.Host + "?" + this.Params.Encode()
+	resp, err := client.Get(str_url)
+	if err != nil {
+		return nil, err
+	} else {
+		defer resp.Body.Close()
+		return dealResult(resp)
+	}
+
+}
+
+func (this *request) Post() (*result, error) {
+	client := this.getClient()
+	var str_url string
+	if this.Service != "" {
+		str_url = this.Host + "?service=" + this.Service
+	} else {
+		str_url = this.Host
+	}
+	resp, err := client.PostForm(str_url, this.Params)
+	if err != nil {
+		return nil, err
+	} else {
+		defer resp.Body.Close()
+		return dealResult(resp)
+	}
+}
+
+func dealResult(response *http.Response) (*result, error) {
+	if response.Status == "200 OK" {
+		ret := new(result)
+		body, _ := ioutil.ReadAll(response.Body)
+		json.Unmarshal(body, ret)
+		return ret, nil
+	} else {
+		return nil, errors.New(response.Status)
+	}
+}
+
+func (this *request) getClient() *http.Client {
+	tr := &http.Transport{
+		Dial: func(netw, addr string) (net.Conn, error) {
+			if this.Timeout == 0 {
+				this.Timeout = time.Second * 3
+			}
+			conn, err := net.DialTimeout(netw, addr, this.Timeout)
+			if err != nil {
+				return nil, err
+			}
+			conn.SetDeadline(time.Now().Add(this.Timeout))
+			return conn, nil
+		},
+		ResponseHeaderTimeout: this.Timeout,
+	}
+	client := &http.Client{Transport: tr}
+	return client
+}