求一个Scf Client

[wowulaile]

大佬，能否提供个现成的client，编程苦手，调试了半天也没搞出来，跪求单播

[Sakurasan]

package main

import (
	"bytes"
	"encoding/base64"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net/http"
	"net/http/httputil"

	log "github.com/sirupsen/logrus"
)

var scfproxyUrl = "https://service.hk.apigw.tencentcs.com/release/scf-proxy"

func main() {
	fmt.Println("scf-proxy-client")
	m := http.NewServeMux()
	m.HandleFunc("/", scfproxy)
	http.ListenAndServe(":9000", m)
}

// DefineEvent 请求结构
type DefineEvent struct {
	URL     string `json:"url"`     // 目标的 URL, eg: http://cip.cc/
	Content string `json:"content"` // 最原始的 HTTP 报文, base64
}

// RespEvent 响应结构
type RespEvent struct {
	Status bool   `json:"status"` // 请求是否正常
	Error  string `json:"error"`  // 错误信息
	// Hander map[string]string `json:"Hander"`
	Data string `json:"data"` // HTTP 响应原始报文, base64
}

func scfproxy(w http.ResponseWriter, r *http.Request) {
	dumpReq, err := httputil.DumpRequest(r, true)
	if err != nil {
		log.Println(err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}
	event := &DefineEvent{
		URL:     r.URL.String(),
		Content: base64.StdEncoding.EncodeToString(dumpReq),
	}
	bytejson, err := json.Marshal(event)
	if err != nil {
		log.Println(err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}

	req, err := http.NewRequest("POST", scfproxyUrl, bytes.NewReader(bytejson))
	if err != nil {
		log.Println(err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}
	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		log.Println("client.Do()", err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}
	bytersp, _ := ioutil.ReadAll(resp.Body)
	fmt.Println(string(bytersp))
	var respevent RespEvent
	if err := json.Unmarshal(bytersp, &respevent); err != nil {
		log.Println(err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}
	if resp.StatusCode > 0 && resp.StatusCode != 200 {
		log.Println(err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}
	retByte, err := base64.StdEncoding.DecodeString(respevent.Data)
	if err != nil {
		log.Println(err)
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}
	resp.Body.Close()

	w.Write(retByte)
	return
}

效果不太理想，你可以参考下，不支持https

[wowulaile]

好的 谢谢大佬 发自我的iPhone

…

------------------ 原始邮件 ------------------ 发件人: Sakurasan ***@***.***> 发送时间: 2021年4月15日 17:14 收件人: Sakurasan/scf-proxy ***@***.***> 抄送: wowulaile ***@***.***>, Author ***@***.***> 主题: 回复：[Sakurasan/scf-proxy] 求一个Scf Client (#1) package main import ( "bytes" "encoding/base64" "encoding/json" "fmt" "io/ioutil" "net/http" "net/http/httputil" log "github.com/sirupsen/logrus" ) var scfproxyUrl = "https://service.hk.apigw.tencentcs.com/release/scf-proxy" func main() { fmt.Println("scf-proxy-client") m := http.NewServeMux() m.HandleFunc("/", scfproxy) http.ListenAndServe(":9000", m) } // DefineEvent 请求结构 type DefineEvent struct { URL string `json:"url"` // 目标的 URL, eg: http://cip.cc/ Content string `json:"content"` // 最原始的 HTTP 报文, base64 } // RespEvent 响应结构 type RespEvent struct { Status bool `json:"status"` // 请求是否正常 Error string `json:"error"` // 错误信息 // Hander map[string]string `json:"Hander"` Data string `json:"data"` // HTTP 响应原始报文, base64 } func scfproxy(w http.ResponseWriter, r *http.Request) { dumpReq, err := httputil.DumpRequest(r, true) if err != nil { log.Println(err) w.WriteHeader(http.StatusServiceUnavailable) return } event := &DefineEvent{ URL: r.URL.String(), Content: base64.StdEncoding.EncodeToString(dumpReq), } bytejson, err := json.Marshal(event) if err != nil { log.Println(err) w.WriteHeader(http.StatusServiceUnavailable) return } req, err := http.NewRequest("POST", scfproxyUrl, bytes.NewReader(bytejson)) if err != nil { log.Println(err) w.WriteHeader(http.StatusServiceUnavailable) return } resp, err := http.DefaultClient.Do(req) if err != nil { log.Println("client.Do()", err) w.WriteHeader(http.StatusServiceUnavailable) return } bytersp, _ := ioutil.ReadAll(resp.Body) fmt.Println(string(bytersp)) var respevent RespEvent if err := json.Unmarshal(bytersp, &respevent); err != nil { log.Println(err) w.WriteHeader(http.StatusServiceUnavailable) return } if resp.StatusCode > 0 && resp.StatusCode != 200 { log.Println(err) w.WriteHeader(http.StatusServiceUnavailable) return } retByte, err := base64.StdEncoding.DecodeString(respevent.Data) if err != nil { log.Println(err) w.WriteHeader(http.StatusServiceUnavailable) return } resp.Body.Close() w.Write(retByte) return } 效果不太理想，你可以参考下，不支持https — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub, or unsubscribe.