如何创建自己的信使运输吗
编辑该页面警告:你浏览的文档欧宝官网下载appob娱乐下载Symfony 6.0,不再维护。
读这个页面的更新版本Symfob娱乐下载ony 6.3(当前的稳定版本)。
如何创建自己的信使运输吗
一旦你写了传输的发送方和接收方,你可以注册你的运输工厂能够通过DSN Symfony应用程序中使用它。ob娱乐下载
创建您的运输工厂
你需要给FrameworkBundle机会创建DSN运输。你需要一个运输工厂:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
使用ob娱乐下载\组件\信使\运输\接收机\ReceiverInterface;使用ob娱乐下载\组件\信使\运输\发送方\SenderInterface;使用ob娱乐下载\组件\信使\运输\序列化\SerializerInterface;使用ob娱乐下载\组件\信使\运输\TransportFactoryInterface;使用ob娱乐下载\组件\信使\运输\TransportInterface;类YourTransportFactory实现了TransportFactoryInterface{公共函数createTransport(字符串美元dsn数组,美元选项,SerializerInterface美元序列化器):TransportInterface{返回新YourTransport (/ *……* /);}公共函数支持(字符串美元dsn数组,美元选项):bool{返回0= = =(大小写敏感美元dsn,“my-transport: / /”);}}传输对象需要实现TransportInterface(结合SenderInterface和ReceiverInterface)。这是一个简化的示例数据库的运输:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17日18 19 20 21日22日23日24日25日26日27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88
使用ob娱乐下载\组件\信使\信封;使用ob娱乐下载\组件\信使\邮票\TransportMessageIdStamp;使用ob娱乐下载\组件\信使\运输\序列化\PhpSerializer;使用ob娱乐下载\组件\信使\运输\序列化\SerializerInterface;使用ob娱乐下载\组件\信使\运输\TransportInterface;使用ob娱乐下载\组件\Uid\Uuid;类YourTransport实现了TransportInterface{私人美元db;私人美元序列化器;/ * * *@paramFakeDatabase $ db是用于演示目的。它不是一个真正的类。* /公共函数__construct(FakeDatabase美元db,SerializerInterface美元序列化器= null){美元这- >db =美元db;美元这- >序列化器=美元序列化器? ?新PhpSerializer ();}公共函数得到():iterable{/ /得到一个消息来自“my_queue”美元行=美元这- >db- >createQuery (“从my_queue SELECT * (delivered_at是NULL或delivered_at < = FALSE: redeliver_timeout)和处理')- >setParameter (“redeliver_timeout”,新DateTimeImmutable (“5分钟”))- >getOneOrNullResult ();如果(零= = =美元行){返回[];}美元信封=美元这- >序列化器- >解码([“身体”= >美元行(“信封”)));返回(美元信封- >(新TransportMessageIdStamp (美元行(“id”))));}公共函数消(信封美元信封):无效{美元邮票=美元信封- >最后(TransportMessageIdStamp::类);如果(!美元邮票运算符TransportMessageIdStamp) {扔新\ LogicException (没有发现TransportMessageIdStamp在信封上。);}/ /消息标记为“处理”美元这- >db- >createQuery (“更新my_queue组处理= TRUE id =: id”)- >setParameter (“id”,美元邮票- >getId ())- >execute ();}公共函数拒绝(信封美元信封):无效{美元邮票=美元信封- >最后(TransportMessageIdStamp::类);如果(!美元邮票运算符TransportMessageIdStamp) {扔新\ LogicException (没有发现TransportMessageIdStamp在信封上。);}/ /删除消息从“my_queue”表美元这- >db- >createQuery (“删除从my_queue id =: id”)- >setParameter (“id”,美元邮票- >getId ())- >execute ();}公共函数发送(信封美元信封):信封{美元encodedMessage=美元这- >序列化器- >编码(美元信封);美元uuidUuid =(字符串)::v4 ();/ /添加一个消息到“my_queue”表美元这- >db- >createQuery (“插入my_queue (id、信封、delivered_at处理)值(id:信封,NULL, FALSE)”)- >setParameters ([“id”= >美元uuid,“信封”= >美元encodedMessage(“身体”),)- >execute ();返回美元信封- >(新TransportMessageIdStamp (美元uuid));}}上面的实现是不能运行的代码但说明TransportInterface可以实现。真正实现看到InMemoryTransport和DoctrineReceiver。
注册你的工厂
1 2 3 4
#配置/ services.yaml服务:你\ \ YourTransportFactory运输:标签:(messenger.transport_factory)用你的运输
在framework.messenger.transports。*配置,创建命名使用自己的DSN运输:
1 2 3 4 5
#配置/包/ messenger.yaml框架:信使:传输:你的:“my-transport: / /……”除了能够你的消息路由到你的发送者,这将给你获得以下服务:
messenger.sender.yours:发送者;messenger.receiver.yours:接收机。
这项工作,包括代码示例,许可下Creative Commons冲锋队3.0许可证。
