Message Handling with Boolean Algebra Ben Deane / CppCon / 2024-09-16 1Alternative Title "The Unreasonable Effectiveness of Boolean Algebra in Software Design, Showing the Particular Application of of a Message Handling Library, with an Excursion into the Roots of Programming" 2Frontmatter No AI/LLM was used in the creation of this talk. Code is simplified for slides; may have some errors in this talk is about The workings of a message-handling library. How messages and the fields in them are specified. Efficiently identifying (with matchers) a message coming off the wire. The role of Boolean

address these pain points: ● End-to-end : The test framework validates the end (client) to end (broker/exchange) algo behavior. ● Controlled external dependencies : All external dependencies system. It sets up an internal test version of the system with a collection of components, a mocked message channel, and mocked dependencies. ● A BDD layer: Using cpp-cucumber (open source), this layer

Implementations 13 Bloomberg Dependency Injection System Analysis Component Injection Trade Security Broker Pricing Sizing Sending Execute Trade Cancel Trade Reprice Trade Dependency Injection Data bidYield_, askYield_); //... } protected: // ExtraFields std::optional<Broker> bidBroker_; std::optional<Broker> askBroker_; std::optional bidYield_; std::optional askYield_; const std::optional& LocalAsk, const std::optional<Broker>& bidBroker, const std::optional<Broker>& askBroker, const std::optional& bidYield,

.. 逻辑资源按需扩缩容 MQ集群 MQ集群 根据Load等Metrics做 出扩容决策 PV1 Broker1 PV2 Broker2 PV3 Broker3 PV4 Broker4 MQ集群 根据Load等 Metrics做出 扩容决策 PV1 PV3 Broker1 PV2 PV4 Broker2 漂移 物理资源按需扩缩容 高级能力-云原生中间件-应用的基石-MQ为例-2-Mesh化 Citadel Mixer Pliot Galley Injector MQ Broker Envoy MQ Broker Envoy MQ Broker Envoy 注册 Service Service Service Pub sub Pub sub Pub sub xDS Config • MQ Broker把Envoy作为 它与服务之间的代理 • Envoy拓展兼容了PubSub 通信的协议，比如

async_request duration : 95% & 99% Raft 命令执行时间 95% 小于 50ms；99% 小于 100ms server report failure message : 发送失败或者收到了错误的 message 如果出现了大量的 unreachadble 的消息，表明系统网络出现了问题。如果有 store not match 这样的错误， 表明收到了不属于这个集群发过来的消息 Vote 0，表明 RocksDB 忙不过来，需要注意 IO 和 CPU 了 channel full : channel 满了，表明线程太忙无法处理 如果大于 0，表明线程已经没法处理了 95% send_message_duration_seconds : 95% 发送消息的时间 小于 50ms leader/region : 每个 TiKV 的 leader/region 数量 TiDB 快速入门指南 - 22 4+ 2+ 300G auto.create.topics.enable = true ：如果还没有创建 topic，Kafka 会在 broker 上自动创建 topic broker.id ：用来标识 Kafka 集群的必备参数，不能重复；如 broker.id = 1 fs.file-max = 1000000 ：Kafka 会使用大量文件和网络 socket，建议修改成 1000000，通过

ServiceMesh-7-新发展-Mesh Broker架构 服务消费者 中心化 Mesh Broker 服务提供 者 连接创建 连接创建 服务注册 • 无端口监听 • 占用资源少 • 无网络要求 • 无底层基础设施依赖：任何PaaS间可以通信 • 无服务注册依赖，无负载均衡需求 • 简化运维：中心化后，只需要管理服务器就可以了 • 业务异步化 缺点： 单点故障，需要提供高可用方案，如Broker部署在K8S中，HPA控

streamnative.io Pulsar： 云原⽣的架构 —— 分层 + 分⽚ • 存储和计算分离 • 节点对等 • 独⽴扩展 • 灵活扩容 • 快速容错 streamnative.io Broker 容错 ⽆感知容错 零数据catchup streamnative.io Bookie容错 应⽤⽆感知 并发可控 数据恢复 streamnative.io 瞬时存储扩容 应⽤⽆感知

and semantics. If such code encounters non-ASCII text, it will gracefully fail with a clear error message, rather than silently introducing corrupt results. When this happens, modifying the code to handle for the exceptional condition to either terminate the program while printing a diagnostic error message, or if the programmer has provided code to handle such exceptional circum- stances then allow that showerror(io::IO, e::MyUndefVarError) = print(io, e.var, " not defined") Note When writing an error message, it is preferred to make the first word lowercase. For example, size(A) == size(B) || throw(Dim

and semantics. If such code encounters non-ASCII text, it will gracefully fail with a clear error message, rather than silently introducing corrupt results. When this happens, modifying the code to handle for the exceptional condition to either terminate the program while printing a diagnostic error message, or if the programmer has provided code to handle such exceptional circum- stances then allow that showerror(io::IO, e::MyUndefVarError) = print(io, e.var, " not defined") Note When writing an error message, it is preferred to make the first word lowercase. For example, size(A) == size(B) || throw(Dim

and semantics. If such code encounters non-ASCII text, it will gracefully fail with a clear error message, rather than silently introducing corrupt results. When this happens, modifying the code to handle for the exceptional condition to either terminate the program while printing a diagnostic error message, or if the programmer has provided code to handle such exceptional circum- stances then allow that showerror(io::IO, e::MyUndefVarError) = print(io, e.var, " not defined") Note When writing an error message, it is preferred to make the first word lowercase. For example, size(A) == size(B) || throw(Dim