delian-socketify 0.1.1

Bringing WebSockets, Http/Https High Performance servers for PyPy3 and Python3

socketify.py (delian-socketify)

Github   •   Issues   •   Examples

This is a maintained fork of cirospaciari/socketify.py published to PyPI as delian-socketify. The Python import name remains socketify, so existing code keeps working unchanged. All credit for the original work goes to Ciro Spaciari and contributors; this fork only packages and maintains it under a new distribution name.

💡 Features

• WebSocket with pub/sub support
• Fast and reliable Http/Https
• Support for Windows, Linux and macOS Silicon & x64
• Support for PyPy3 and CPython
• Dynamic URL Routing with Wildcard & Parameter support
• Sync and Async Function Support
• Really Simple API
• Fast and Encrypted TLS 1.3 quicker than most alternative servers can do even unencrypted, cleartext messaging
• Per-SNI HttpRouter Support
• Proxy Protocol v2
• Shared or Dedicated Compression Support
• Max Backpressure, Max Timeout, Max Payload and Idle Timeout Support
• Automatic Ping / Pong Support
• Per Socket Data
• Middlewares
• Templates Support (examples with Mako and Jinja2)
• ASGI Server
• WSGI Server
• Plugins/Extensions

:mag_right: Upcoming Features

• In-Memory Cache Tools
• Fetch like API powered by libuv
• Async file IO powered by libuv
• Full asyncio integration with libuv
• SSGI Server spec and support
• RSGI Server support
• Full Http3 support
• HPy integration to better support CPython, PyPy and GraalPython
• Hot Reloading

We created and adapted the full C API from uNetworking/uWebSockets and will integrate libuv powered fetch and file IO, this same C API is used by Bun

:zap: Benchmarks

Socketify WebFramework HTTP requests per second (Linux x64)

WSGI Server requests per second (Linux x64)

ASGI Server requests per second (Linux x64)

WebSocket messages per second (Linux x64)

Http tested with TFB tool plaintext benchmark
WebSocket tested with Bun.sh bench chat-client
Source code in TechEmPower and for websockets in bench

Machine OS: Debian GNU/Linux bookworm/sid x86_64 Kernel: 6.0.0-2-amd64 CPU: Intel i7-7700HQ (8) @ 3.800GHz Memory: 32066MiB

📦 Installation

For macOS x64 & Silicon, Linux x64, Windows

pip install delian-socketify
#or specify PyPy3
pypy3 -m pip install delian-socketify
#or in editable mode
pypy3 -m pip install -e .

Using install via requirements.txt

delian-socketify

pip install -r ./requirements.txt
#or specify PyPy3
pypy3 -m pip install -r ./requirements.txt

If you are using linux or macOS, you may need to install libuv and zlib in your system

macOS

brew install libuv
brew install zlib

Linux (Ubuntu/Debian)

apt install libuv1 zlib1g

Linux (RHEL/OEL)

yum install cmake zlib-devel libuv-devel

🤔 Usage

Hello world app

from socketify import App

app = App()
app.get("/", lambda res, req: res.end("Hello World socketify from Python!"))
app.listen(3000, lambda config: print("Listening on port http://localhost:%d now\n" % config.port))
app.run()

SSL version sample

from socketify import App, AppOptions

app = App(AppOptions(key_file_name="./misc/key.pem", cert_file_name="./misc/cert.pem", passphrase="1234"))
app.get("/", lambda res, req: res.end("Hello World socketify from Python!"))
app.listen(3000, lambda config: print("Listening on port http://localhost:%d now\n" % config.port))
app.run()

WebSockets

from socketify import App, 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(f'WebSocket backpressure: {ws.get_buffered_amount()}'),
    'close': lambda ws, code, message: print('WebSocket closed'),
    'subscription': lambda ws, topic, subscriptions, subscriptions_before: print(f'subscribe/unsubscribe on topic {topic} {subscriptions} {subscriptions_before}'),
})
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 for more

:hammer: Building from source

#clone and update submodules
git clone https://github.com/Delian-Alliance-Industries/socketify.py.git
cd ./socketify.py
git submodule update --init --recursive --remote
#you can use make linux, make macos or call Make.bat from Visual Studio Development Prompt to build
cd ./src/socketify/native/ && make linux && cd ../../../
#install local pip
pypy3 -m pip install .
#install in editable mode
pypy3 -m pip install -e .
#if you want to remove
pypy3 -m pip uninstall delian-socketify

:page_facing_up: Attribution

Original project: cirospaciari/socketify.py by Ciro Spaciari. Licensed under the MIT License (see LICENSE).

Special thanks to uNetworking AB for uWebSockets and uSockets, which power this library.

:grey_question: uvloop

We don't use uvloop, because uvloop doesn't support Windows and PyPy3 at this moment; this may change in the future, but right now we want to implement our own libuv + asyncio solution, and a lot more.

:dizzy: CFFI vs Cython vs HPy

Cython performs really well on Python3 but really bad on PyPy3. CFFI was chosen for better PyPy3 support until we get our hands on a stable HPy integration.