加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
engine1_test.go 2.34 KB
一键复制 编辑 原始数据 按行查看 历史
wenxian 提交于 2023-11-03 19:01 . 重构注册中心-路由规则
package main
import (
"goway/component/router"
"net/http"
"testing"
)
func TestRouter(t *testing.T) {
routers := router.Routers
req, _ := http.NewRequest("GET", "/", nil)
req.Header.Set("Targets", "a/b/v1/")
t.Log(routers.RouteFromHttp(req))
req.Header.Set("Targets", "a/c/v2/")
t.Log(routers.RouteFromHttp(req))
}
func TestXxx(t *testing.T) {
resp, err := http.Get("http://10.255.40.180:16200/tasks/v1/files/containers/10.255.40.134/tasks/T-RSU-231018112943-oc74i/testers/wenxian@cictci.com/cases/RSU_MTBF_AT_2/timestamps/1698299833/files/RSU_MTBF_AT_2_log_20231026_140035.html/open")
if err != nil {
t.Fatal(err)
}
t.Log(resp.StatusCode)
data := make([]byte, 1024*1024*100)
size, err := resp.Body.Read(data)
if err != nil {
t.Fatal(err)
}
resp.Body.Close()
t.Logf("%s", string(data[:size]))
}
// import (
// "bytes"
// "encoding/json"
// "fmt"
// "goway/component/registry"
// "goway/component/registry/instance"
// "goway/component/tracer"
// "goway/global/logging"
// "net/http"
// "os"
// "testing"
// )
// func GetInstances(resp http.ResponseWriter, req *http.Request) {
// defer func() {
// for _, trace := range tracer.TraceManager.FetchAll() {
// res, err := json.Marshal(trace)
// if err != nil {
// fmt.Println(err)
// return
// }
// var out bytes.Buffer
// if err = json.Indent(&out, res, "", "\t"); err != nil {
// fmt.Println(err)
// return
// }
// out.WriteTo(os.Stdout)
// fmt.Printf("\n")
// }
// }()
// response := struct {
// Instances []*instance.Instance `json:"instances"`
// }{
// Instances: registry.RegistrationCenter.GetAllInstances(),
// }
// data, err := json.Marshal(response)
// if err != nil {
// logging.Log.Fatal(err)
// }
// resp.Header().Add("Content-Type", "application/json;charset=utf-8")
// resp.WriteHeader(http.StatusOK)
// resp.Write(data)
// }
// func TestEngine_Register(t *testing.T) {
// reg := registry.RegistrationCenter
// reg.Register(instance.NewInstance(
// &instance.RegisterInstance{
// Env: "test",
// AppId: "baidu",
// AppVer: "0.1.0",
// InstanceId: "www.baidu.com",
// Addrs: []string{"https://www.baidu.com/"},
// }))
// t.Logf("%v", reg.GetAllInstances()[0])
// enigne := NewEngine(reg)
// enigne.GET("/registry/fetchall", GetInstances)
// t.Fatal(enigne.ListenAndServe(":9999"))
// }
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化