#stream #cord #platform #subscriber #broker #messages #exchange

app cord-broker

为 Cord 平台提供的服务器端路由平台,用于在发布者和订阅者之间交换消息

3 个不稳定版本

0.3.1 2022年10月18日
0.3.0 2022年1月25日
0.1.0 2020年4月1日

#29#subscriber

MPL-2.0 许可证

34KB
596

Cord Broker

CI Code Testing and Linting CI Security Audit on Push

Cord 是一个用于组合、聚合和分发任意流的数据流平台。Broker 包提供了平台流聚合和分发功能。它是所有客户端进行消息交换的中心组件。

用法

首先,启动一个新的 Cord Broker

Docker

$ docker run -d -p 7101:7101 --rm cordproj/cord-broker:0

Cargo

$ cargo install cord-broker
$ cord-broker &

接下来,使用 Cord 客户端 与代理交互。最简单的方法是使用客户端 CLI。

订阅命名空间

Docker

$ docker run --rm cordproj/cord-client:0 -a <broker_addr> sub /names

Cargo

$ cargo install cord-client
$ cord-client sub /namespaces

向此命名空间发布

Docker

$ docker run -it --rm cordproj/cord-client:0 -a <broker_addr> pub /names
Start typing to create an event, then press enter to send it to the broker.
Use the format: NAMESPACE=VALUE

/names/first=Daz

Cargo

$ cord-client pub /names
Start typing to create an event, then press enter to send it to the broker.
Use the format: NAMESPACE=VALUE

/names/first=Daz

依赖关系

~12–23MB
~318K SLoC