#MoonSTOMP

#0.4.0 发行候选源码

#当前默认分支源码快速开始

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

mooncakes 上的 0.3.1。从 0.1.x 升级时注意 Client、Decoder、HeartbeatClock 已改为抽象类型，见迁移说明。

#可查询的事务本地结束结果

#用法

#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 或别的运行时。
• 分层失败行为：接收侧解码/协议错误、时钟倒退或接收资源超限会关闭会话；本地 send 参数、事务归属或容量校验失败则拒绝本次操作、不登记新意图，原状态保持（前提是调用中的时钟推进尚未触发致命关闭）。不要把可修正的本地验证失败都解释成断线。
• 不自动重发：receipt 丢失时报告“结果未知”，由调用方决定，避免重复投递。
• 不做：服务端、WebSocket、自动重连、持久化 outbox、exactly-once。

#测试

• 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，不包含最新 SDK 浮动测试。异步示例和期限检查已在 0.3.1 精确 head 常规 CI通过；真实 Classic TLS 心跳、短异步与五分钟源码场景见固定 broker CI。rabbitmq.yml 每次推送都在 Docker 里起 RabbitMQ 跑互通测试（scripts/rabbitmq-interop-test.cjs）。

#性能

#目录

#许可与来源