beego / mux Goto Github PK

GET /v1/team/:tid/duty
GET /v1/team/:svc/info

package main

import (
	"log"
	"net/http"

	"github.com/beego/mux"
)

func main() {
	m := mux.New()
	m.Get("/v1/team/:tid/duty", func(w http.ResponseWriter, r *http.Request) {
		w.Write([]byte("hello, beego mux\n"))
	})
	m.Get("/v1/team/:svc/info", func(w http.ResponseWriter, r *http.Request) {
		w.Write([]byte("hello, beego mux 2\n"))
	})

	log.Fatal(http.ListenAndServe("127.0.0.1:2222", m))
}

mozhata@pc:try$ curl http://127.0.0.1:2222/v1/team/ididid/duty
hello, beego mux
mozhata@pc:try$ curl http://127.0.0.1:2222/v1/team/ididid/info
"/v1/team/ididid/info" not implemented

mac os x and ubuntu 16.04

$go version
go version go1.8 darwin/amd64

commit 38fddcbf1be964bbc26c0cf7b91157719cfdb56f

package main

import (
    "log"
    "net/http"

    "github.com/beego/mux"
)

func Register(method string, pattern string, handler http.HandlerFunc) {
    mx.Handler(method, pattern, handler)
}

func addServer(w http.ResponseWriter, r *http.Request) {
    w.Write([]byte("addServer"))
}

func getServer(w http.ResponseWriter, r *http.Request) {
    w.Write([]byte("getServer"))
}

func delServer(w http.ResponseWriter, r *http.Request) {
    w.Write([]byte("delServer"))
}

var mx *mux.Mux

func main() {
    mx = mux.New()

    Register("POST", "/api/v1/servers/:server_name", addServer)
    Register("DELETE", "/api/v1/servers/:server_name", delServer)
    Register("GET", "/api/v1/servers/:server_name", getServer)

    log.Fatal(http.ListenAndServe("127.0.0.1:9999", mx))
}

$curl -X POST  http://127.0.0.1:9999/api/v1/servers/yy-pd.com
addServer

$curl http://127.0.0.1:9999/api/v1/servers/yy-pd.com
"GET" not allowed in "/api/v1/servers/yy-pd.com"

$curl -X DELETE  http://127.0.0.1:9999/api/v1/servers/yy-pd.com
"DELETE" not allowed in "/api/v1/servers/yy-pd.com"

t.Run("router with wildcard pattern2", func(t *testing.T) {
	assert := assert.New(t)

	mux := New()

	mux.Get("/a/:a/b", func(w http.ResponseWriter, r *http.Request) {
		params := Params(r)
		w.WriteHeader(200)
		w.Write([]byte(params[":a"]))
	})
	mux.Get("/a/:a/b/:b", func(w http.ResponseWriter, r *http.Request) {
		params := Params(r)
		w.WriteHeader(200)
		w.Write([]byte(params[":a"]))
	})
	mux.Get("/a/:a/b/:b/c", func(w http.ResponseWriter, r *http.Request) {
		params := Params(r)
		w.WriteHeader(200)
		w.Write([]byte(params[":a"]))
	})

	ts := httptest.NewServer(mux)
	defer ts.Close()

	res, err := Request("GET", ts.URL+"/a/a1/b/b1/c", nil)
	assert.Nil(err)
	assert.Equal(200, res.StatusCode)
	body, _ := ioutil.ReadAll(res.Body)
	assert.Equal("a1", string(body))
	res.Body.Close()
})