求一个Scf Client - Githubissues

wowulaile commented 3 years ago

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

Sakurasan commented 3 years ago

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 commented 3 years ago

好的谢谢大佬

发自我的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.

Sakurasan / scf-proxy

求一个Scf Client #1