如何在独立代码中使用Symfony Messenger组件发送AMQP消息

composer require symfony/messenger

namespace App\Message;

class MyMessage
{
    private $data;

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

    public function getData()
    {
        return $this->data;
    }
}

namespace App\MessageHandler;

use App\Message\MyMessage;

class MyMessageHandler
{
    public function __invoke(MyMessage $message)
    {
        // 处理接收到的消息
        $data = $message->getData();
        // ...
    }
}

framework:
    messenger:
        transports:
            amqp: '%env(MESSENGER_TRANSPORT_DSN)%'
        routing:
            'App\Message\MyMessage': amqp

use Symfony\Component\Messenger\MessageBusInterface;
use App\Message\MyMessage;

// 获取消息总线
$messageBus = $container->get(MessageBusInterface::class);

// 创建消息实例
$message = new MyMessage('Hello, World!');

// 发送消息
$messageBus->dispatch($message);