草庐IT

php - 如何执行任务避免用户被迫等待响应?

coder 2024-05-02 原文

用户创建新产品后,在我的应用程序中我会执行一些操作,例如更新几个表:统计信息、财务、使用情况、库存等。

现在用户必须等待我完成所有步骤。如果很多用户托盘同时执行此操作,那么等待的时间就会更多,这就不太好了。

我的计划是创建一个特殊的 TASK_TABLE (product_id, time, task_id) 然后在后台运行这个任务但是:

  • 从大到大,
  • 不要阻止用户进行下一步操作,
  • 尽快运行此任务。

我如何在 Symfony 中做到这一点?

最好的方法是什么?

最佳答案

What is the best way to do it?

我不知道这是否"is"最好的方法,但处理此类情况的最常见方法(基于所提供的少数信息)是:

  • 解耦一个或多个中的“操作”(更新统计数据、财务、使用情况、库存等)services , 为了能够重用 它在任何地方。
  • 创建“事件”类(最后是一个简单的 DTO),在您的情况下可以是 NewProductEvent,其中存储新产品对象:
  • 创建“监听器”类 NewProductListener,其中处理执行的“操作”、顺序等。

Now users must wait for I've finished all steps.

为避免这种情况,我们必须能够仅在响应已提供给客户端后才能够"dispatch"我们的 new_product_created 事件,我们可以这样做 using a service tag更具体地说 kernel terminate event .

但是如何存储产品数据以使其在 kernel.terminate 上可用?

让我们去实现它。

“事件”类:

use Symfony\Component\EventDispatcher\Event;
use YourApp\YourBundle\Entity\Product;

class NewProductEvent extends Event
{
    const EVENT_NAME = 'new_product_created';

    protected $product;

    public function __construct(Product $newProduct)
    {
        $this->product = $newProduct;
    }

    public function getProduct()
    {
        return $this->product;
    }
}

“监听器”类:

class NewProductListener
{
    protected $product;

    public function __construct()
    {
        # then you can inject all dependencies needed to perform your tasks
    }

    public function onNewProductCreated(Product $newProduct)
    {
        # here you keep in memory the product data!
        $this->product = $newProduct->getProduct();
    }

    public function performTasks()
    {
        if ($this->product) {
            # here you can put the logic to perform all needed tasks!
        }
    }
}

监听器“服务”定义:

<service id="new_product_listener"
         class="YourApp\YourBundle\Event\NewProductListener">
    <!-- you can inject in the listener, as argument, each service task you need -->
    <!-- <argument type="service" id="financial_operation_service"/>-->
    <!-- <argument type="service" id="usage_operation_service"/>-->
    <tag name="kernel.event_listener" event="new_product_created" method="onNewProductCreated"/>
    <tag name="kernel.event_listener" event="kernel.terminate" method="performTasks"/>
</service>

现在是实际示例(我不注释代码,因为它是不言自明的):

// presuming you are in a controller:
$dispatcher = $this->get('event_dispatcher');
$newProduct = //--- I don't know from where it will come.
$event      = new NewProductEvent($newProduct);
$dispatcher->dispatch(NewProductEvent::EVENT_NAME, $event);

当您调度 NewProductEvent::EVENT_NAME (new_product_created) 时,您将在 $product 变量中存储触发 onNewProductCreated 方法的产品数据的 NewProductListener 监听器然后能够在 kernel.terminate 事件被触发后使用它!

通过这种方式,Symfony 将执行所需的任务(在后台)并且不会降低用户体验。

一些引用资料:

关于php - 如何执行任务避免用户被迫等待响应?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43813445/

有关php - 如何执行任务避免用户被迫等待响应?的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法? - 2

    总的来说,我对ruby​​还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

  3. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake,如果我把所有东西都放到Rakefile中,它会很大并且很难读取/找到东西,所以我试着将每个命名空间放在lib/rake中它自己的文件中,我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题,但没有任务。我现在只有一个.rake文件作为测试,名为“servers.rake”,它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  4. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

  5. ruby-on-rails - 如何验证 update_all 是否实际在 Rails 中更新 - 2

    给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息? 最佳答案 在Rails3中,update_all不返回任何有意义的信息,除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru

  6. ruby-openid:执行发现时未设置@socket - 2

    我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时,我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb,在下面的代码片段中:moduleNetclass

  7. ruby-on-rails - 'compass watch' 是如何工作的/它是如何与 rails 一起使用的 - 2

    我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗?当我运行compasswatch时,它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行?文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们?我自己编译的.sass文件编译成compiled/t

  8. ruby - 如何将脚本文件的末尾读取为数据文件(Perl 或任何其他语言) - 2

    我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚

  9. ruby - 如何指定 Rack 处理程序 - 2

    Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时,rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack

  10. ruby - 如何每月在 Heroku 运行一次 Scheduler 插件? - 2

    在选择我想要运行操作的频率时,唯一的选项是“每天”、“每小时”和“每10分钟”。谢谢!我想为我的Rails3.1应用程序运行调度程序。 最佳答案 这不是一个优雅的解决方案,但您可以安排它每天运行,并在实际开始工作之前检查日期是否为当月的第一天。 关于ruby-如何每月在Heroku运行一次Scheduler插件?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/8692687/

随机推荐