golang官方实现如何对httpserver做频率限制(最大连接数限制)

import(
"golang.org/x/net/netutil"
)

l, err := net.Listen("tcp", "127.0.0.1:0")
if err != nil {
 fmt.Fatalf("Listen: %v", err)
}
defer l.Close()
l = LimitListener(l, max)
http.Serve(l, http.HandlerFunc())
//bla bla bla.................

// Copyright 2013 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
// Package netutil provides network utility functions, complementing the more
// common ones in the net package.
package netutil // import "golang.org/x/net/netutil"

import (
 "net"
 "sync"
)
// LimitListener returns a Listener that accepts at most n simultaneous
// connections from the provided Listener.
func LimitListener(l net.Listener, n int) net.Listener {
 return &limitListener{l, make(chan struct{}, n)}
}
type limitListener struct {
 net.Listener
 sem chan struct{}
}
func (l *limitListener) acquire() { l.sem <- struct{}{} }
func (l *limitListener) release() { <-l.sem }
func (l *limitListener) Accept() (net.Conn, error) {
 //若connect chan已满,则会阻塞在此处
  l.acquire()
 c, err := l.Listener.Accept()
 if err != nil {
 l.release()
 return nil, err
 }
 return &limitListenerConn{Conn: c, release: l.release}, nil
}
type limitListenerConn struct {
 net.Conn
 releaseOnce sync.Once
 release func()
}
func (l *limitListenerConn) Close() error {
 err := l.Conn.Close()
  l.releaseOnce.Do(l.release)
 return err
}

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传