如何在 Laravel Job 类中使用绑定实现?

KKK*_*KKK 2 php containers dependency-injection solid-principles laravel

我将在我的作业中使用接口,并在作业类中获取它的上下文实现。

我读了所有的啧啧声。

我注册它:

class AppServiceProvider extends ServiceProvider
{
    public function register()
    {
        $this->app
            ->when(SendinBlueJob::class)
            ->needs(MessageProviderInterface::class)
            ->give(SendinBlueService::class);
    }
}
Run Code Online (Sandbox Code Playgroud)

我派遣工作:

class MessageObserver
{
    public function created(MessageInterface $message)
    {
        SendinBlueJob::dispatch($message);
    }
}
Run Code Online (Sandbox Code Playgroud)

在工作类别中,我想获得绑定服务:

class SendinBlueJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

     public $message;
     public $messageProvider;

    public function __construct(MessageInterface $message, MessageProviderInterface $messageProvider)
    {
        $this->message = $message;
        $this->messageProvider = $messageProvider;
        $this->handle();
     }

    public function handle()
    {
        dd($this->messageProvider);
    }
}
Run Code Online (Sandbox Code Playgroud)

我无法调度作业,因为服务器抛出错误:

函数 App\Jobs\SendinBlueJob::__construct() 的参数太少,第 16 行 /var/www/vendor/laravel/framework/src/Illuminate/Foundation/Bus/Dispatchable.php 中传递了 1 个参数,预计正好有 2 个参数

我理解它,但我不明白为什么 Laravel 在构造函数中调用接口时不注入绑定服务。

Jac*_*ack 7

您可以在方法中注入依赖项handle

class SendinBlueJob implements ShouldQueue
{
    use Dispatchable,
        InteractsWithQueue,
        Queueable,
        SerializesModels;

    public $message;

    public function __construct(MessageInterface $message)
    {
        $this->message = $message;
    }

    public function handle(MessageProviderInterface $messageProvider)
    {
        dd(
            $this->message, // MessageInterface
            $messageProvider // SendInBlueService
        );
    }
}
Run Code Online (Sandbox Code Playgroud)

更新

解决方案1

因为您正在使用上下文绑定,并且当您通过方法进行依赖项注入时上下文绑定不起作用(这是在作业中执行此操作的唯一方法),所以请考虑以下方法...

在您的服务提供商中:

class AppServiceProvider extends ServiceProvider
{
    public function register()
    {
        $this->app->when(MessagesController::class) // Your controller
                  ->needs(MessageProviderInterface::class)
                  ->give(SendinBlueService::class);
    }
}
Run Code Online (Sandbox Code Playgroud)

在你的控制器中:

class MessagesController extends Controller
{
    protected $messageProvider;

    public function __construct(MessageProviderInterface $messageProvider)
    {
        $this->messageProvider = $messageProvider;
    }

    public function store(Request $request)
    {
        // ...

        // Create your message
        $message = Message::create($request->all());

        // Dispatch your job in the controller
        SendInBlueJob::dispatch($message, $this->messageProvider);

        // ...
    }
}
Run Code Online (Sandbox Code Playgroud)

在你的工作中:

class SendinBlueJob implements ShouldQueue
{
    use Dispatchable,
        InteractsWithQueue,
        Queueable,
        SerializesModels;

    protected $message;

    protected $messageProvider;

    public function __construct(MessageInterface $message, MessageProviderInterface $messageProvider)
    {
        $this->message = $message;

        $this->messageProvider = $messageProvider;
    }

    public function handle()
    {
        dd($this->messageProvider);
    }
}
Run Code Online (Sandbox Code Playgroud)

解决方案2

或者,不要使用上下文绑定。你可以做类似下面的事情......

创建一个新的SendinBlueMessageProviderInterface

interface SendinBlueMessageProviderInterface extends MessageProviderInterface
{
    //
}
Run Code Online (Sandbox Code Playgroud)

将接口绑定到您的实现。

$this->app->bind(
    SendinBlueMessageProviderInterface::class,
    SendinBlueService::class
);
Run Code Online (Sandbox Code Playgroud)

现在您将能够通过该handle方法注入消息提供程序。

public function handle(SendinBlueMessageProviderInterface $messageProvider)
{
    dd($messageProvider);
}
Run Code Online (Sandbox Code Playgroud)