liner

Redis based message serverless broker.
Data transfer via TCP.

Python example:


def foo():
    client1 = liner.Client("client1", "topic_client", "localhost:2255", "redis://localhost/")
    client2 = liner.Client("client2", "topic_client", "localhost:2256", "redis://localhost/")
    server = liner.Client("server", "topic_server", "localhost:2257", "redis://localhost/")
    
    client1.run(receive_cback1)
    client2.run(receive_cback2)
    server.run(receive_server)
    
    b = b'hello world'
    server.send_all("topic_client", b, len(b), True)
    

def receive_cback1(to: str, from_: str, data: bytes):
    print(f"receive_from {from_}, data: {data}")

def receive_cback2(to: str, from_: str, data: bytes):
    print(f"receive_from {from_}, data: {data}")

def receive_server(to: str, from_: str, data: bytes):
    print(f"receive_from {from_}, data: {data}")

Features

high speed transmission of multiple messages (benchmark)
delivery guarantee: at least once delivery (using redis db)
message size is not predetermined and is not limited
easy api: create client, run client and send data to
interface for Python and CPP

Build (only linux)

install Rust and Cargo
install Redis
download this repo
while in the folder repo, execute in console: cargo build

Examples of use

One to one: Python / CPP / Rust

One to one for many: Python / CPP / Rust

One to many: Python / CPP / Rust

Many to many: Python / CPP / Rust

Producer-consumer: Python / CPP / Rust

Benchmark

Tests

Docs

License

Licensed under an [MIT-2.0]-license.

liner_broker 1.0.5