PHPackages                             kode/messaging - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [HTTP & Networking](/categories/http)
4. /
5. kode/messaging

ActiveLibrary[HTTP & Networking](/categories/http)

kode/messaging
==============

2.1.0(5d ago)00Apache-2.0PHPPHP >=8.2CI passing

Since Jun 4Pushed 5d agoCompare

[ Source](https://github.com/kodephp/messaging)[ Packagist](https://packagist.org/packages/kode/messaging)[ Docs](https://github.com/kodephp/messaging)[ GitHub Sponsors](https://github.com/sponsors/kodephp)[ RSS](/packages/kode-messaging/feed)WikiDiscussions master Synced 2d ago

READMEChangelogDependencies (4)Versions (1)Used By (0)

kode/messaging
==============

[](#kodemessaging)

**统一消息层 | WebSocket / SSE / MQTT / UDP / Long-Polling / CoAP / NATS / STOMP / gRPC / WebTransport / RTMP | PHP 8.2+ | PSR 合规 | 可插拔适配器**

[![PHP Version](https://camo.githubusercontent.com/13d44c226edc4671d7d176b844577a2ff00f3f21a96ada4563d539bf4bd2fed3/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f5048502d382e322b2d3737374242343f7374796c653d666c61742d737175617265266c6f676f3d706870)](https://php.net)[![License](https://camo.githubusercontent.com/22e3167c2cd3295c79bca229626e367f60df334157044771bd1b1138b1a19326/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f4c6963656e73652d417061636865253230322e302d677265656e3f7374796c653d666c61742d737175617265)](LICENSE)[![kode](https://camo.githubusercontent.com/9f3a96cf85e5367b649d6d562997d4fc653fee98fc8f6b32271c264d7bdc9a2e/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f6b6f64652d66616d696c792d626c75653f7374796c653d666c61742d737175617265)](https://packagist.org/packages/kode/)[![Version](https://camo.githubusercontent.com/d30d7eb420ef541fcc2347e387e18f34920e4a5e087534e4e17364470dc6c21f/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f76657273696f6e2d322e302e302d626c75653f7374796c653d666c61742d737175617265)](CHANGELOG.md)

简介
--

[](#简介)

`kode/messaging` 是 `kode/*` 家族中的**统一消息层** Composer 包，封装 **WebSocket**、**SSE**、**MQTT**、**UDP**、**Long-Polling**、**CoAP**、**NATS**、**STOMP**、**gRPC**、**WebTransport**、**RTMP** 等 11 种长连接 / 实时消息协议，提供**一致的 API**、**协议无关的消息抽象**和**可插拔的扩展点**。

一个 `Messaging::server()` 启动所有协议，**业务代码面向接口编程，不感知具体协议**。

特性
--

[](#特性)

特性说明🌐 **11 协议统一**WebSocket / SSE / MQTT / UDP / Long-Polling / CoAP / NATS / STOMP / gRPC / WebTransport / RTMP🔌 **可插拔适配器**新增协议不改动核心代码（3 步：Adapter / 注册 / 文档）📡 **协议无关**业务层只依赖 `MessageInterface`🧩 **中间件管道**鉴权 / 限流 / 编解码 / 校验 / 追踪🏷️ **路由**基于 event / topic 路由消息📢 **统一 Pub/Sub**进程内 / 跨进程 / 跨节点（Redis）🛡️ **PSR 合规**PSR-3 / PSR-4 / PSR-7 / PSR-14 / PSR-18⚡ **协程友好**与 `kode/fibers` 协作，无 Fiber 自动降级🔒 **安全**TLS、JWT、Origin 校验、签名鉴权、限流📊 **可观测**事件、指标、结构化日志🚀 **高性能**Swoole / Swow / stream 多传输层🔁 **重连 / 心跳**客户端内置指数退避重连、ping/pong安装
--

[](#安装)

```
composer require kode/messaging
```

按需安装可选依赖：

```
composer require kode/fibers        # 协程
composer require kode/event         # 事件派发
composer require kode/process       # 多 Worker / 集群
composer require kode/queue         # MQTT QoS 落地、延迟消息
composer require kode/jwt           # JWT 鉴权
composer require nyholm/psr7       # SSE 的 PSR-7 基础
```

快速开始
----

[](#快速开始)

### WebSocket

[](#websocket)

```