kopia lustrzana https://github.com/cirospaciari/socketify.py
rodzic
d3cbf9cea9
commit
ce24c2ff1d
27
README.md
27
README.md
|
@ -102,6 +102,33 @@ app.listen(3000, lambda config: print("Listening on port http://localhost:%d now
|
||||||
app.run()
|
app.run()
|
||||||
```
|
```
|
||||||
|
|
||||||
|
WebSockets
|
||||||
|
```python
|
||||||
|
from socketify import App, AppOptions, OpCode, CompressOptions
|
||||||
|
|
||||||
|
def ws_open(ws):
|
||||||
|
print('A WebSocket got connected!')
|
||||||
|
ws.send("Hello World!", OpCode.TEXT)
|
||||||
|
|
||||||
|
def ws_message(ws, message, opcode):
|
||||||
|
#Ok is false if backpressure was built up, wait for drain
|
||||||
|
ok = ws.send(message, opcode)
|
||||||
|
|
||||||
|
app = App()
|
||||||
|
app.ws("/*", {
|
||||||
|
'compression': CompressOptions.SHARED_COMPRESSOR,
|
||||||
|
'max_payload_length': 16 * 1024 * 1024,
|
||||||
|
'idle_timeout': 12,
|
||||||
|
'open': ws_open,
|
||||||
|
'message': ws_message,
|
||||||
|
'drain': lambda ws: print('WebSocket backpressure: %i' % ws.get_buffered_amount()),
|
||||||
|
'close': lambda ws, code, message: print('WebSocket closed')
|
||||||
|
})
|
||||||
|
app.any("/", lambda res,req: res.end("Nothing to see here!'"))
|
||||||
|
app.listen(3000, lambda config: print("Listening on port http://localhost:%d now\n" % (config.port)))
|
||||||
|
app.run()
|
||||||
|
```
|
||||||
|
|
||||||
We have more than 20 examples [click here](https://github.com/cirospaciari/socketify.py/tree/main/examples) for more
|
We have more than 20 examples [click here](https://github.com/cirospaciari/socketify.py/tree/main/examples) for more
|
||||||
|
|
||||||
## Build local from source
|
## Build local from source
|
||||||
|
|
Ładowanie…
Reference in New Issue