func main() {
    // step1:创建httpsvr对象。
    s := httpsvr.New(
    "127.0.0.1:10024",
    httpsvr.SetReadTimeout(time.Millisecond*200),
    httpsvr.SetWriteTimeout(time.Millisecond*200),
    httpsvr.SetMaxAccess(2),
    )
    // 优雅退出
    go GracefulExit(s)
    // step2:添加路由。
    s.AddRoute("POST", "/test/api", &ctrls.DemoCtrl{})
    // step3:开始服务。
    s.Serve()
}

// GracefulExit 优雅退出
func GracefulExit(svr *httpsvr.Server) {
        sigc := make(chan os.Signal, 0)
        signal.Notify(sigc, os.Interrupt, syscall.SIGTERM)
        <-sigc
        println("closing agent...")
        svr.GracefulExit()
        println("agent closed.")
        os.Exit(0)
}

// AddRoute ...
func (s *Server) AddRoute(method, path string, ctrl IController) {
    s.router.Handle(method, path, handle)

}

// ServeHTTP implement net/http.router
func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request) {
    s.router.ServeHTTP(w, req)
}

// http listen
    oriSvr *http.Server
    s.oriSvr = &http.Server{Addr: addr, Handler: s}

// Serve ...
func (s *Server) Serve() error {
    return s.oriSvr.ListenAndServe()
}

// ServerOption option赋值回调函数
type ServerOption func(o *option)

// IController ...
type IController interface {
    // 此方法获得接口参数的结构体，框架会直接将req.body直接unmarshal到这里面
    GenIdl() interface{}
    // 实际处理的handle函数
    Do(interface{}) interface{}
}

// InControl 入口控制
func (a *Access) InControl() error {
    if atomic.LoadInt32(&a.closed) == 1 {
        return errors.New("server is closing")
    }
    select {
    case a.bucket <- struct{}{}:
        a.wg.Add(1)
    case <-time.After(time.Millisecond * 100):
        return errors.New("server is busy please try later")
    }
    return nil
}

// OutControl 出口注销
func (a *Access) OutControl() {
    <-a.bucket
    a.wg.Done()
}

// Stop 优雅退出
func (a *Access) Stop() {
	if !atomic.CompareAndSwapInt32(&a.closed, 0, 1) {
		return
	}
	// 第一种判断桶内为空
	a.wg.Wait()
	/*第二种判断桶内为空
	for {
		if len(a.bucket)== 0 {
			return
		}
	}*/
}