Schlagwort-Archive: PHP

在消息队列中使用Symfony的序列化

Veröffentlicht am von

PHP中，如果需要把内存中的变量进行保存，以便后续继续使用，那么就要把数据序列化。

PHP提供了 serialize()  和 unserialize()  这两个原生方法来完成。但是这样有个限制，就是要求写入和读取的时候使用同样的方法。就是说只能使用PHP原生的反序列化函数来读取PHP原生序列化的数据。 有时候我们写入是PHP，读取的时候可能是别语言，所以需要一种更加通用的格式。

比如，在项目的写入队列的过程中，我们打算用Symfony提供的序列化器代替PHP原生的。我们选择序列化的格式为JSON。但是出现了问题，发现某些属性的数据丢失了。原来需要对序列化的对象进行处理。

要让消息能被JSON序列化需要确认以下

  • 消息对象需要实现一下特定接口 (非必要)
  • 消息对象能被正确encode和decode
  • 消息对象的构造函数必须为public，且只使用标量值。如果必须要使用类，需要确保这些类实现了stringable接口。

消息需要实现特定接口

SyncCommandInterface::class,
AsyncCommandInterface::class,
EventInterface::class,
QueryInterface::class,

具体措施

消息的构造函数必须为public，且使用仅使用标量作为参数

为什么消息对象的构造函数必须为public，为啥必须用标量参数。

我猜想，因为当消息被反序列化的时候，系统只会用最简单的new方法来重新创建消息实例。

  • public类的属性

使用readonly修饰属性防止意外修改

使用标量值

对象必须实现stringable

减少复杂性。比如不使用实体对象entity，而使用id. 这点在Symfony的文档内也有介绍。

参考

分析feature toggle类

Veröffentlicht am von

项目中有些功能，只在特定调价下可供使用。所以Ben写了一个feature toggle类。故名思义就是提供功能切换的类。

背景需求

1 需要按照storefront来实现功能的开关

2 对于没有通过storefront的，还可以通过一个optimizely进行开关

首先实现了一个上下文对象，context。context里包括了 userid 和 storefront。

然后定义了一个toggle接口。只含有一个enable方法。然后实现了3个具体的toggle类。他们是

  • optimzly
  • storfont
  • oneof

配置里，使用oneof来注入到service中。oneof的构造函数接受一组（迭代器）toggles。当他被询问enable的时候，它会逐个询问它的迭代器里的每个toggle。只要有一个返回true，它就返回true。所以名字叫做oneof。

配置oneof的时候，给他配置2个toggle。一个是storefront_de。一个是optimzley。
然后在storefornt_de只配置里storefront
optimizley 是依赖外部的optimizely服务的。所以配置需要一个key和客户端。

整个实现结构清晰。明确。非常赞。

symfony scoped (http) client 的配置

Veröffentlicht am von

在改进版本中，我们使用symfony的scoped的http客户端代替原来的guzzle client。这样做的优点是，把一些基本的host配置可以从代码中抽出来，放入yaml配置中。这样在使用中，只要使用对应的名字，symfony框架就会把对应的已经配置好host的http client注入。

在测试中，我们使用的symfony提供的mock client而不是真正的scoped client，免得发出真正的http请求。

目前的问题是，除了http client，我们还有一个考虑到不同stroefront的client，称为“storefrontAwareClient”。它是在http client外面再包裹的一层。主要是解决，不同的国家(storefront)使用不同的base url和header。

在集成测试用，发现注入的不是mock client，而是真的scoped client。所以需要对stroefront进行针对测试环境的配置。保证在测试中，它注入的也是mock client

StorefrontAwareClient. 它替代了本来MarketplaceLoyaltyAccountService的部分功能

找到原因
1 测试中使用“personalized_coupons.client”未配置。因为配置被改名了。加入该key，并指出它是mock的httpClient后，问题解决

关于scope配置

在创建scoped client的配置里，有一个选项是scope。一直到我看了源码后才明白它的作用。当请求一个URL的时候，可以匹配scope里的正则表达，只有匹配的情况下，才会使用该配置。如果不匹配，请求也能发出，但是配置里的东西不会被发出。这样保证，一些秘密不会因为错误的配置被发送到其他网站。

一开始我还以为是某种强制的检查，如果不匹配就会抛除异常。