更新记录

1.0.2（2026-10-17）

1.调整多主题。

2. 优化逻辑

1.0.0（2026-10-17）

1.支持AQMP协议直接连接通讯

平台兼容性

uni-app(4.75)

zyj-RabbitMQtt

uni-app / uni-app x 的 RabbitMQ（AMQP）客户端插件，封装 amqp-client，支持多队列订阅、事件方式接收消息、自动重连。

仅支持 Android（iOS 为空实现）。

能力

安装与生效

插件内含第三方库（utssdk/app-android/libs/zyj-amqp.aar），必须制作自定义基座才能生效：

运行 → 运行到手机或模拟器 → 制作自定义基座
运行 → 运行到手机或模拟器 → 运行到 Android App 基座

每次修改插件原生代码或 aar 后，都要重新制作基座。

使用示例

import {
    connect, startListen, onGetMsg, onDisconnect, onReconnect,
    sendMsg, isConnected, close
} from "@/uni_modules/zyj-RabbitMQtt"

const QUEUES = ["QUEUE", "QUEUE111"]

// 1. 连接（host, port, user, pwd, vhost）
let ok = connect("10.168.2.188", 5672, "sz_prod", "sm*259MQZORw", "/")
if (!ok) {
    console.log("连接失败，看控制台日志")
    return
}

// 2. 注册事件（只需注册一次）
//    消息到达：queue = 来源队列名，msg = 消息内容
onGetMsg((queue, msg) => {
    console.log("收到消息", queue, msg)
})

//    连接断开：reason 为断开原因，插件会自动重连
onDisconnect((reason) => {
    console.log("连接断开，自动重连中", reason)
})

//    重连成功：消费者已自动恢复，无需重新订阅
onReconnect(() => {
    console.log("已重新连接")
})

// 3. 订阅队列
startListen(QUEUES)

// 发消息（队列必须已存在）
sendMsg("QUEUE", "hello from pda")

// 查询连接状态
if (isConnected()) {
    console.log("已连接")
}

// 页面卸载时断开，释放资源
close()

调用顺序

connect → onGetMsg / onDisconnect / onReconnect → startListen → close

事件要在 startListen 之前注册，避免漏掉最早到达的消息。

API

完整参数说明见 utssdk/interface.uts。

注意事项

1. 事件只注册一次。重复调用会让 callback 常驻内存。
2. 自动 ack。消息取出即从服务器删除；若队列还有其他消费者，会互相抢占消息。
3. 端口别填错。AMQP 是 5672，15672 是管理后台端口。
4. sendMsg 要求队列已存在，队列不存在时消息会被丢弃且不报错。
5. 主动 close() 不触发 onDisconnect，需自行更新 UI 状态。
6. 仅 Android 5.0（API 21）及以上可用。