后端Web框架【免费下载链接】symfonyThe Symfony PHP framework项目地址https://gitcode.com/GitHub_Trending/sy/symfony点击查看免费下载Mercure 是一个基于 Server-Sent Events (SSE) 的实时通信协议Symfony 通过symfony/mercure-notifier桥接组件将 Mercure Hub 无缝接入 Notifier 体系使开发者可以像发送短信、邮件那样用统一的ChatMessage把实时通知推送给浏览器端订阅者。本文以 Notifier Mercure Bridge README 为主线结合仓库内 MercureTransport.php、MercureOptions.php 与 MercureTransportFactory.php 等源码实现完整讲解 DSN 配置、消息选项、发送链路与异常处理读完即可在生产项目中落地 Mercure 实时通知。一、桥接组件概览把 Mercure Hub 变成 Notifier 的 Transport该桥接位于src/Symfony/Component/Notifier/Bridge/Mercure/目录包名为symfony/mercure-notifier见 composer.json。它实现了 Notifier 的 Transport 抽象使 ChatMessage 能通过任意 Mercure Hub 发布实时事件MercureTransportFactory.php解析mercure://开头的 DSN从配置的 Hub 注册表中取出对应 HubMercureTransport.php真正的发送逻辑把 ChatMessage 转换为 MercureUpdate并调用HubInterface::publish()发布MercureOptions.php承载每条消息的发布选项topic、private、id、retry、content 等。根据 CHANGELOG.md该桥接自 5.3 版本引入并在 7.3 版本新增了content选项用于携带 Web Notification 标准的通知内容。当前 composer.json 声明依赖 PHP8.4.1、symfony/notifier^7.4|^8.0以及symfony/mercure^0.5.2|^0.6|^0.7|^0.8。二、DSN 配置与工厂解析原理2.1 DSN 语法README 给出的 DSN 示例为MERCURE_DSNmercure://HUB_ID?topicTOPIC字段含义参数说明HUB_IDMercure Hub 的标识符id对应 Symfony 配置中注册的 Hub 名称TOPIC要发布到的 topic IRI可选。默认值为https://symfony.com/notifier。支持单个 topictopichttps://foo也支持多个 topictopic[]/foo/1topic[]https://bar在 Symfony 应用中DSN 通常写入.env或.env.localMERCURE_DSNmercure://default?topic/notifications2.2 工厂如何解析 DSNMercureTransportFactory.php 的create()方法展示了完整的解析逻辑public function create(Dsn $dsn): MercureTransport { if (mercure ! $dsn-getScheme()) { throw new UnsupportedSchemeException($dsn, mercure, $this-getSupportedSchemes()); } $hubId $dsn-getHost(); $topic $dsn-getOption(topic); try { $hub $this-registry-getHub($hubId); } catch (InvalidArgumentException) { throw new IncompleteDsnException(\sprintf(Hub %s not found. Did you mean one of: %s?, $hubId, implode(, , array_keys($this-registry-all())))); } return new MercureTransport($hub, $hubId, $topic, $this-client, $this-dispatcher); }这里有几个关键点HUB_ID取自 DSN 的 host 部分而不是当作 URL 主机来连接网络——这就是为什么 MercureTransportTest.php 中testCanSetCustomPort、testCanSetCustomHost等常规 HTTP DSN 测试全部被标记跳过Mercure transport doesnt use a regular HTTP Dsn。Hub 实例来自HubRegistry工厂构造时注入HubRegistrygetHub($hubId)按名称取出配置好的 HubHub 的实际发布 URL、JWT 令牌等由 Symfony Mercure 组件配置。Hub 不存在时抛出IncompleteDsnException并附带提示当前可用的 Hub 名称列表便于排查拼写错误。该行为在 MercureTransportFactoryTest.php 中有对应测试。topic选项可直接从 DSN 读取会原样传给 Transport 作为默认 topic。2.3 DSN 的字符串化与编码规则MercureTransport::__toString()MercureTransport.php会把 Transport 还原为 DSN 字符串多 topic 通过http_build_query编码return \sprintf(mercure://%s%s, $this-hubId, ?.http_build_query([topic $this-topics], , ));测试 MercureTransportTest.php 验证了三种形态构造参数序列化结果不传 topicsmercure://hubId?topichttps%3A%2F%2Fsymfony.com%2Fnotifier/topicmercure://customHubId?topic%2Ftopic[/topic/1, [/topic/2]]mercure://customHubId?topic%5B0%5D%2Ftopic%2F1topic%5B1%5D%5B0%5D%2Ftopic%2F2可见 topic 值会被 URL 编码如/编码为%2F多 topic 以数组下标形式出现。从源码看topics既支持字符串也支持字符串数组甚至嵌套数组构造时统一通过(array)强转。三、MercureOptions为 ChatMessage 添加发布选项README 的核心实操部分是Adding Options to a Chat Message。MercureOptions实现了 Notifier 的MessageOptionsInterface通过$chatMessage-options($options)挂载到消息上。3.1 构造函数与全部参数MercureOptions.php 的构造签名如下public function __construct( string|array|null $topics null, private bool $private false, private ?string $id null, private ?string $type null, private ?int $retry null, private ?array $content null, )参数类型默认值说明$topicsstring\|array\|nullnull发布目标 topic。为null时回退到 Transport 的默认 topic即 DSN 中配置的 topic若 DSN 也未配置则为https://symfony.com/notifier$privateboolfalse是否为私有更新。true时 Mercure Hub 仅向通过授权 cookie 验证的订阅者推送$id?stringnull更新的 ID用于去重与幂等$type?stringnull更新的类型可配合id在订阅端做去重$retry?intnull订阅端连接断开后的重连间隔秒$content?arraynullWeb Notification 标准的通知内容7.3 新增详见下文 3.2注意DSN 中配置的 topic 只是 Transport 级别的默认值每条消息可以通过MercureOptions的$topics覆盖它。doSend()中采用$options-getTopics() ?? $this-topics的优先级MercureTransport.php测试testSendWithMercureOptionsButWithoutOptionTopic也验证了 options 未指定 topic 时回退到默认https://symfony.com/notifierMercureTransportTest.php。3.2 content 数组支持的通知字段$content参数是一个关联数组注释中列出的合法键MercureOptions.php如下键类型说明badgestring通知图标徽章 URLbodystring通知正文datamixed与通知关联的任意数据dirauto\|ltr\|rtl文本方向iconstring通知图标 URLimagestring通知展示大图 URLlangstring通知语言标签renotifybool新通知到达时是否重复提示requireInteractionbool通知是否需要用户交互才消失silentbool是否静默不发出声音/振动tagstring通知分组标签timestampint通知创建时间戳vibrateint\|listint振动模式单个数值或振动时长序列这些字段遵循 Web Notifications API 规范订阅端浏览器可根据它们渲染原生通知。3.3 完整发送示例继承 README 原文use Symfony\Component\Notifier\Message\ChatMessage; use Symfony\Component\Notifier\Bridge\Mercure\MercureOptions; $chatMessage new ChatMessage(Contribute To Symfony); $options new MercureOptions( [/topic/1, /topic/2], true, id, type, 1, [tag 1234, body TEST] ); // Add the custom options to the chat message and send the message $chatMessage-options($options); $chatter-send($chatMessage);对照 MercureOptionsTest.php该示例实际生成的选项数组为[ topics [/topic/1, /topic/2], private true, id id, type type, retry 1, content [tag 1234, body TEST], ]其中$chatMessage-getSubject()即Contribute To Symfony将作为事件的摘要summary发送$chatter即 Notifier 的 Chatter 服务。四、发送链路与底层实现ChatMessage 如何变成 Mercure Update4.1 支持的消息类型MercureTransport.php 的supports()明确了适用范围public function supports(MessageInterface $message): bool { return $message instanceof ChatMessage (null $message-getOptions() || $message-getOptions() instanceof MercureOptions); }即该 Transport 只处理ChatMessage。测试 MercureTransportTest.php 中SmsMessage与DummyMessage均被列为不支持的负载同时若消息携带了非MercureOptions的选项对象doSend()会抛出UnsupportedOptionsException对应测试testSendWithNonMercureOptionsThrows。4.2 doSend() 的完整转换逻辑核心发送逻辑在 MercureTransport.phpprotected function doSend(MessageInterface $message): SentMessage { if (!$message instanceof ChatMessage) { throw new UnsupportedMessageTypeException(__CLASS__, ChatMessage::class, $message); } if (($options $message-getOptions()) !$options instanceof MercureOptions) { throw new UnsupportedOptionsException(__CLASS__, MercureOptions::class, $options); } $options ?? new MercureOptions($this-topics); // see https://www.w3.org/TR/activitystreams-core/#jsonld $update new Update($options-getTopics() ?? $this-topics, json_encode([ context https://www.w3.org/ns/activitystreams, type Announce, summary $message-getSubject(), mediaType application/json, content $options-getContent(), ]), $options-isPrivate(), $options-getId(), $options-getType(), $options-getRetry()); try { $messageId $this-hub-publish($update); $sentMessage new SentMessage($message, (string) $this); $sentMessage-setMessageId($messageId); return $sentMessage; } catch (MercureRuntimeException|InvalidArgumentException $e) { throw new RuntimeException(Unable to post the Mercure message: .$e-getMessage(), $e-getCode(), $e); } }关键细节无选项时的兜底$options ?? new MercureOptions($this-topics)即未设置选项时以 Transport 默认 topic 构造一个空选项对象。ActivityStreams JSON-LD 封装消息体被编码为 JSON-LD 格式的Announce活动包含context、type、summary消息主题、mediaTypeapplication/json与content选项中的通知内容。测试 testSendWithMercureOptions 精确断言了生成的 JSON 串{context:https:\/\/www.w3.org\/ns\/activitystreams,type:Announce,summary:subject,mediaType:application\/json,content:{tag:1234,body:TEST}}MercureUpdate构造顺序new Update(topics, data, private, id, type, retry)与MercureOptions的 6 个构造参数一一对应。发布结果HubInterface::publish()返回的消息 ID 被写入SentMessage::setMessageId()调用方可据此跟踪消息测试testSendSuccessfully验证了urn:uuid:...形式的 ID 被正确回传。异常包装Mercure 层的RuntimeException与InvalidArgumentException如 JWT 无效会被统一包装为 Notifier 的RuntimeException错误信息前缀固定为Unable to post the Mercure message:。测试testSendWithTransportFailureThrows与testSendWithWrongTokenThrows分别覆盖了连接失败与令牌非法两种场景。五、异常处理与测试保障该桥接的测试集中在 Tests 目录可直接用于理解各环节的行为边界MercureTransportFactoryTest.php覆盖 DSN scheme 校验非mercure://抛UnsupportedSchemeException、单/多 topic 解析、默认 topic 兜底以及 Hub 不存在时的IncompleteDsnException提示语。MercureTransportTest.php覆盖消息类型支持、选项类型校验、JSON-LD 数据格式、发布失败与 JWT 非法异常包装、成功发布后的消息 ID 回传。MercureOptionsTest.php验证选项默认值、参数映射与错误 topic 类型传入stdClass会抛TypeError。Fixtures/DummyHub.php提供HubInterface的最小实现供测试替换真实 Hub。六、安装与接入建议在项目中使用该桥接标准方式是composer require symfony/mercure-notifier随后配置.env中的MERCURE_DSN如mercure://default?topic/notifications并确保 Symfony 的 Mercure 组件中已注册对应的 Hubdefault。需要注意的兼容性前提以 composer.json 为准PHP 8.4.1symfony/notifier^7.4|^8.0symfony/mercure^0.5.2|^0.6|^0.7|^0.8。实战建议按业务划分 Hub 与 topic把不同业务线的实时事件拆到不同 topic如/orders、/chat/room-1订阅端只监听自己关心的频道需要全量广播时可使用topic[]多值形式。区分默认 topic 与消息级 topicDSN 中的topic是兜底默认值单条消息需要发往其他 topic 时用MercureOptions覆盖避免为每个 topic 配置独立 DSN。敏感数据开启private$private true时只有通过授权验证的订阅者能收到更新适合推送个人化、私有化通知。利用idtype去重为重要事件指定稳定的id与type可帮助订阅端幂等处理重复投递。善用content渲染原生通知在订阅端结合 Web Notifications API将body、tag、icon、silent等字段映射为浏览器通知形成完整的实时提醒体验。总结Mercure Notifier 桥接把连接 Mercure Hub、构建 ActivityStreams 事件、发布更新这一整套流程封装进 Notifier 的 Transport 抽象中开发者只需配置一行MERCURE_DSN再以ChatMessageMercureOptions组织消息即可向一个或多个 topic 发布带 Web 通知语义的实时事件同时获得统一的错误包装与消息 ID 回传能力。其 DSN 解析HUB_ID取自 host、topic作为默认值、选项优先级消息级 topic 覆盖 Transport 默认 topic以及 JSON-LD 数据格式均由 MercureTransportFactory.php、MercureTransport.php 与配套测试逐一印证可作为实现与排错的可靠参考。赞分享后端Web框架【免费下载链接】symfonyThe Symfony PHP framework项目地址https://gitcode.com/GitHub_Trending/sy/symfony点击查看免费下载相关推荐Symfony Notifier Plivo 桥接组件实战DSN 配置、消息选项与 ssl 传输原理Symfony Notifier Plivo 桥接组件实战DSN 配置、消息选项与 ssl 传输原理 本篇技术指南围绕 Symfony Notifier 的后端Web框架Symfony Notifier GatewayApi 桥接组件实战DSN 配置、消息选项与短信发送全解析Symfony Notifier GatewayApi 桥接组件实战DSN 配置、消息选项与短信发送全解析 GatewayApigatewayapi.com后端Web框架LaMa 大掩码图像修复部署与运维实战指南LaMa 大掩码图像修复部署与运维实战指南 如果你需要从图片里去掉人物、水印或文字再把大块缺失区域自然地补回来LaMa 图像修复值得一试。它是 WACV 2后端Web框架创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
