Comments (2)
It does make sense, but I'm not yet sure, how to implement it, because there's three options:
- Setting the limit globally at server initialization affecting all clients.
- Setting the limit individually for each client during connection establishment.
- Setting a default global limit at server intialization, which is overridable by individual limits set during connection establishment.
The second option seems to be the most flexible one, this might be done in the BeforeUpgrade
hook like so:
func (srv *ServerImplementation) BeforeUpgrade(
resp http.ResponseWriter,
req *http.Request,
) bool, uint {
// accept connection, limit concurrency to max 5
return true, 5
}
Returning 0 would mean unlimited concurrency for this individual client.
from webwire-go.
The concurrency limit is now set in the BeforeUpgrade
hook this way:
func (srv *ServerImpl) BeforeUpgrade(
resp http.ResponseWriter,
req *http.Request,
) wwr.ConnectionOptions {
// return wwr.AcceptConnection(wwr.UnlimitedConcurrency)
return wwr.AcceptConnection(10) // max 10 concurrent handlers
}
The server option MaxConcurrentHandlers
is no longer available. If you still want to limit the total number of concurrent handlers for the entire server you'll need to set appropriate per-client limits (say 10
for a total 10.000
maximum concurently executed handlers for 1.000 concurrent clients) and limit the number of clients by atomically counting the number of connected clients and rejecting or redirecting incoming connections in the BeforeUpgrade
hook when the limit is reached.
from webwire-go.
Related Issues (20)
- Duplex Request-Reply HOT 2
- Request delivery order HOT 2
- Deferred client-side session destruction HOT 1
- Performance Benchmarking HOT 3
- Unsynchronized session getter HOT 1
- Use *log.Logger instead of io.Writer for logging HOT 1
- Listing all connections of a session HOT 1
- Deferred client agent closure HOT 1
- Request message requires a payload HOT 2
- Support for concurrent message processing HOT 1
- Update session relevance HOT 1
- Support for JSON message encoding HOT 1
- Add support for context.Context HOT 1
- Support multiple underlying websocket connections HOT 2
- Test hot server-side handling of messages violating the protocol
- Test the default session manager implementation.
- Add new constructor function with TLS support HOT 1
- TLS handshake error doesn't stop autoconnect HOT 1
- Subprotocol Support
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from webwire-go.