#MoonSTOMP

#快速开始

git clone https://github.com/sundaysebasidian-byte/moonstomp.git
cd moonstomp
moon test                                   # 单元 / 属性 / 对抗测试
moon build --target js                      # 构建 Node 用的 bridge
node tools/stomp-cli.cjs demo               # 进程内 demo broker：发一条、收一条
node examples/demo/01-pubsub.cjs            # 最后一行输出 PASS pubsub
moon run examples/versions --target js      # 1.0 / 1.1 / 1.2 协商与边界

moon add sundaysebasidian-byte/moonstomp@0.3.1

0.2.0 已发布到 Mooncakes。 Registry 实际版本、metadata 和发布 ZIP checksum 均已核对；全新 registry 消费者通过核心 API、多版本及模拟 TCP/TLS 验证。历史 0.1.2 仅支持 STOMP 1.2。精确发布 commit、CI、校验和与未验范围见0.2.0 回执。

#用法

#MoonBit：喂字节，拿事件

let client = @stomp.Client::new()
let bytes = client.send(@stomp.connect("localhost"), 0) // 写给 socket
ignore(client.receive(b"CONNECTED\nversion:1.2\n\n\x00", 0))
ignore(client.send(@stomp.subscribe("sub-1", "/queue/jobs", ack="client-individual"), 0))

// 一个 MESSAGE 帧被 TCP 拆成两段到达
let first = client.receive(b"MESSAGE\nsubscription:sub-1\nmessage-id:m1\ndestination:/queue/jobs\nack:a1\ncontent-len", 0)
assert_eq(first.length(), 0) // 半包：还没有完整帧
let events = client.receive(b"gth:5\n\nhello\x00", 0)
match events[0] {
  @stomp.Message(frame) => assert_eq(frame.body, b"hello")
  _ => fail("expected a MESSAGE")
}
ignore(client.send(@stomp.acknowledge("a1"), 0))

#Node：连真实 broker

node tools/demo-broker.cjs --port 61613 &
node tools/stomp-cli.cjs subscribe --port 61613 --destination /queue/jobs --count 1 &
node tools/stomp-cli.cjs send --port 61613 --destination /queue/jobs --body hello
# sent destination=/queue/jobs bytes=5 receipt=confirmed

#场景示例

#规范覆盖（STOMP 1.2，兼容 1.0 / 1.1）

#真实 broker 互通

#设计取舍

• sans-I/O：核心只做协议，I/O、定时器、重连策略都留给宿主。同一套核心可接 Node、Wasm 或别的运行时。
• 失败即关闭：协议错误、时钟倒退、超限都会让会话进入 Closed，不会带着坏状态继续收发。
• 不自动重发：receipt 丢失时报告“结果未知”，由调用方决定，避免重复投递。
• 不做：服务端、WebSocket、自动重连、持久化 outbox、exactly-once。RabbitMQ 尚未实测。

#测试

• MoonBit 测试覆盖编解码、头部转义、心跳、会话状态、版本矩阵、属性测试和对抗输入；实际执行结果以对应提交的验收回执为准。
• 与 stomp.js 7.2.0 解析器的差分测试（scripts/differential.cjs，按不同分段长度喂入），Node 适配器的生命周期 / TLS / 凭据测试。
• CI：ci.yml 在官方 SDK 上跑完整验证（scripts/verify.py --transport）；fresh-clone.yml 模拟新用户 git clone 后直接 moon test、本页快速开始和场景示例，并在最新 SDK 上同样跑一遍。本地新增异步示例尚无远端CI回执。

#目录

#许可与来源