Flag of Ukraine
SymfonyCasts stands united with the people of Ukraine
TRACK

Symfony 5 >

COURSE

¡Messenger! Encola el trabajo para Despues

Buy Access to Course

Configuración de los mensajes de un sistema externo

English Español

Keep on Learning!

If you liked what you've learned so far, dive in!
Subscribe to get access to this tutorial plus
video, code and script downloads.

Start your All-Access Pass
Buy just this tutorial for $12.00
Previous Chapter

Next Chapter
Edit on GitHub

With a Subscription, click any sentence in the script to jump to that part of the video!

Login Subscribe

¿Qué pasaría si una cola en RabbitMQ estuviera llena de mensajes que se originan en un sistema externo... pero quisiéramos consumirlos y manejarlos desde nuestra aplicación Symfony? Por ejemplo, tal vez un usuario pueda solicitar que se elimine una foto desde un sistema totalmente diferente... y ese sistema necesita comunicarse con nuestra aplicación para que pueda realizar el borrado ¿Cómo funcionaría eso?

Cada transporte en Messenger tiene realmente dos funciones: una, enviar mensajes a un corredor de mensajes o sistema de colas y dos, recibir mensajes de ese mismo sistema y gestionarlos.

Y, como hablamos en el último vídeo, no es necesario que utilices ambas funciones de un transporte: puedes elegir enviar a un transporte, pero no leer ni consumir nunca esos mensajes... porque lo hará otro sistema. O puedes hacer lo contrario: crear un transporte al que nunca enviarás, pero que utilizarás para consumir mensajes... que probablemente fueron puestos ahí por algún sistema externo. El truco para hacer esto es crear un serializador que pueda entender el formato de esos mensajes externos.

Crear un nuevo Mensaje y Manejador

En lugar de sobreexplicar esto, veámoslo en acción. En primer lugar, imagina que este sistema externo imaginario necesita poder decirle a nuestra aplicación que haga algo... muy... importante: registrar un Emoji. Vale, puede que no sea el tipo de mensaje más impresionante... pero los detalles de lo que este mensaje externo le dice a nuestra aplicación que haga no son importantes: podría decirnos que subamos una imagen con detalles sobre la ubicación del archivo, que eliminemos una imagen, que enviemos un correo electrónico a un usuario registrado o que registremos un emoji

Pongamos esto en marcha. Normalmente, si quisiéramos enviar un comando para registrar un emoji, empezaríamos por crear una clase de mensaje y un manejador de mensajes. En este caso... haremos exactamente lo mismo. En el directorio Command/, crea una nueva clase PHP llamada LogEmoji

19 lines src/Message/Command/LogEmoji.php
... lines 1 - 2
namespace App\Message\Command;
class LogEmoji
{
... lines 7 - 17
}

Añade un argumento public function __construct(). Para indicarnos qué emoji debemos registrar, el sistema exterior nos enviará un índice entero del emoji que quieren - nuestra aplicación tendrá una lista de emojis. Así que añade un argumento $emojiIndex y luego pulsa Alt+Enter y selecciona "Inicializar campos" para crear esa propiedad y establecerla.

19 lines src/Message/Command/LogEmoji.php
... lines 1 - 2
namespace App\Message\Command;
class LogEmoji
{
private $emojiIndex;
public function __construct(int $emojiIndex)
{
$this->emojiIndex = $emojiIndex;
}
... lines 13 - 17
}

Para hacer que esta propiedad sea legible por el manejador, ve al menú Código -> Generar -o Comando + N en un Mac-, selecciona getters y genera getEmojiIndex().

19 lines src/Message/Command/LogEmoji.php
... lines 1 - 2
namespace App\Message\Command;
class LogEmoji
{
private $emojiIndex;
public function __construct(int $emojiIndex)
{
$this->emojiIndex = $emojiIndex;
}
public function getEmojiIndex(): int
{
return $this->emojiIndex;
}
}

¡Genial! Una clase de mensaje perfectamente aburrida y normal. Segundo paso: en el directorioMessageHandler/Command/, crea una nueva clase LogEmojiHandler. Haz que implemente nuestra clase normal MessageHandlerInterface y añadepublic function __invoke() con el tipo de mensaje: LogEmoji $logEmoji.

13 lines src/MessageHandler/Command/LogEmojiHandler.php
... lines 1 - 2
namespace App\MessageHandler\Command;
use App\Message\Command\LogEmoji;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
class LogEmojiHandler implements MessageHandlerInterface
{
public function __invoke(LogEmoji $logEmoji)
{
}
}

Ahora... ¡nos ponemos a trabajar! Voy a pegar una lista de emojis en la parte superior: aquí están los cinco que el sistema exterior puede elegir: galleta, dinosaurio, queso, robot y, por supuesto, caca

34 lines src/MessageHandler/Command/LogEmojiHandler.php
... lines 1 - 8
class LogEmojiHandler implements MessageHandlerInterface
{
private static $emojis = [
'?',
'?',
'?',
'?',
'?'
];
... lines 18 - 33
}

Y luego, como vamos a registrar algo, añade un método __construct()con la pista de tipo LoggerInterface. Pulsa Alt + Intro y selecciona "Inicializar campos" una vez más para crear esa propiedad y establecerla.

34 lines src/MessageHandler/Command/LogEmojiHandler.php
... lines 1 - 5
use Psr\Log\LoggerInterface;
... lines 7 - 8
class LogEmojiHandler implements MessageHandlerInterface
{
private static $emojis = [
'?',
'?',
'?',
'?',
'?'
];
private $logger;
public function __construct(LoggerInterface $logger)
{
$this->logger = $logger;
}
... lines 25 - 33
}

Dentro de __invoke(), nuestro trabajo es bastante sencillo. Para obtener el emoji, establece una variable$index en $logEmoji->getEmojiIndex()

34 lines src/MessageHandler/Command/LogEmojiHandler.php
... lines 1 - 5
use Psr\Log\LoggerInterface;
... lines 7 - 8
class LogEmojiHandler implements MessageHandlerInterface
{
private static $emojis = [
'?',
'?',
'?',
'?',
'?'
];
private $logger;
public function __construct(LoggerInterface $logger)
{
$this->logger = $logger;
}
public function __invoke(LogEmoji $logEmoji)
{
$index = $logEmoji->getEmojiIndex();
... lines 30 - 32
}
}

Luego $emoji = self::$emojis - para referenciar esa propiedad estática -self::$emojis[$index] ?? self::emojis[0].

34 lines src/MessageHandler/Command/LogEmojiHandler.php
... lines 1 - 5
use Psr\Log\LoggerInterface;
... lines 7 - 8
class LogEmojiHandler implements MessageHandlerInterface
{
private static $emojis = [
'?',
'?',
'?',
'?',
'?'
];
private $logger;
public function __construct(LoggerInterface $logger)
{
$this->logger = $logger;
}
public function __invoke(LogEmoji $logEmoji)
{
$index = $logEmoji->getEmojiIndex();
$emoji = self::$emojis[$index] ?? self::$emojis[0];
... lines 31 - 32
}
}

En otras palabras, si el índice existe, úsalo. Si no, vuelve a registrar una cookie... porque... a todo el mundo le gustan las cookies. Registra con$this->logger->info('Important message! ')y luego con $emoji.

34 lines src/MessageHandler/Command/LogEmojiHandler.php
... lines 1 - 5
use Psr\Log\LoggerInterface;
... lines 7 - 8
class LogEmojiHandler implements MessageHandlerInterface
{
private static $emojis = [
'?',
'?',
'?',
'?',
'?'
];
private $logger;
public function __construct(LoggerInterface $logger)
{
$this->logger = $logger;
}
public function __invoke(LogEmoji $logEmoji)
{
$index = $logEmoji->getEmojiIndex();
$emoji = self::$emojis[$index] ?? self::$emojis[0];
$this->logger->info('Important message! '.$emoji);
}
}

La gran conclusión de este nuevo gestor de mensajes y mensajes es que, bueno, ¡no se diferencia en absoluto de cualquier otro gestor de mensajes y mensajes! A Messenger no le importa si el objeto LogEmoji se enviará manualmente desde nuestra propia aplicación o si un trabajador recibirá un mensaje de un sistema externo que se asignará a esta clase.

Para probarlo, sube a ImagePostController, busca el método create() y, sólo para asegurarte de que esto funciona, añade:$messageBus->dispatch(new LogEmoji(2)).

107 lines src/Controller/ImagePostController.php
... lines 1 - 7
use App\Message\Command\LogEmoji;
... lines 9 - 25
class ImagePostController extends AbstractController
{
... lines 28 - 42
public function create(Request $request, ValidatorInterface $validator, PhotoFileManager $photoManager, EntityManagerInterface $entityManager, MessageBusInterface $messageBus)
{
... lines 45 - 73
$messageBus->dispatch(new LogEmoji(2));
... lines 75 - 76
}
... lines 78 - 105
}

Si esto funciona, deberíamos ver un mensaje en nuestros registros cada vez que subamos una foto. Busca tu terminal: veamos los logs con:

tail -f var/log/dev.log

Este es el archivo de registro del entorno dev. Despejaré mi pantalla, luego me desplazaré, seleccionaré una foto y... retrocederé. Ahí está:

¡Mensaje importante! 🧀

¡Estoy de acuerdo! ¡Eso es importante! Esto es genial... pero no es lo que realmente queremos. Lo que realmente queremos es utilizar un trabajador para consumir un mensaje de una cola -probablemente un mensaje JSON- y transformarlo de forma inteligente en un objeto LogEmoji para que Messenger pueda manejarlo. ¿Cómo lo hacemos? Con un transporte dedicado y un serializador de clientes. ¡Hagamos eso a continuación!

Leave a comment!

Most Useful Newest Oldest
2
Login or Register to join the conversation
julien_bonnier Avatar

Spent half an hour trying to use emoji in my PhpStorm (on ubuntu) and gave up... Any ideas?

EDIT: Just realized the emojis are there tailing the logs, but I can't see it in my ide. Is there any black magic I can use to make them show up?

Reply
weaverryan Avatar

Hey julien_bonnier!

Ah, sorry about that! I did meant for the silly emojis to trip things up! I'm actually not sure what would make them not show up in your IDE... it could be some missing font - but I'm speaking "above my pay grade" about this - I don't know much about how Emojis work behind the scenes :/.

Sorry I can't give you a better answer!

Reply
Cat in space

"Houston: no signs of life"
Start the conversation!

Este tutorial está construido con Symfony 4.3, pero funcionará bien en Symfony 4.4 o 5.
Symfony 4.3

What PHP libraries does this tutorial use?

// composer.json
{
    "require": {
        "php": "^7.1.3",
        "ext-ctype": "*",
        "ext-iconv": "*",
        "composer/package-versions-deprecated": "^1.11", // 1.11.99
        "doctrine/annotations": "^1.0", // v1.8.0
        "doctrine/doctrine-bundle": "^1.6.10", // 1.11.2
        "doctrine/doctrine-migrations-bundle": "^1.3|^2.0", // v2.0.0
        "doctrine/orm": "^2.5.11", // v2.6.3
        "intervention/image": "^2.4", // 2.4.2
        "league/flysystem-bundle": "^1.0", // 1.1.0
        "phpdocumentor/reflection-docblock": "^3.0|^4.0", // 4.3.1
        "sensio/framework-extra-bundle": "^5.3", // v5.3.1
        "symfony/console": "4.3.*", // v4.3.2
        "symfony/dotenv": "4.3.*", // v4.3.2
        "symfony/flex": "^1.9", // v1.18.7
        "symfony/framework-bundle": "4.3.*", // v4.3.2
        "symfony/messenger": "4.3.*", // v4.3.4
        "symfony/property-access": "4.3.*", // v4.3.2
        "symfony/property-info": "4.3.*", // v4.3.2
        "symfony/serializer": "4.3.*", // v4.3.2
        "symfony/validator": "4.3.*", // v4.3.2
        "symfony/webpack-encore-bundle": "^1.5", // v1.6.2
        "symfony/yaml": "4.3.*" // v4.3.2
    },
    "require-dev": {
        "easycorp/easy-log-handler": "^1.0.7", // v1.0.7
        "symfony/debug-bundle": "4.3.*", // v4.3.2
        "symfony/maker-bundle": "^1.0", // v1.12.0
        "symfony/monolog-bundle": "^3.0", // v3.4.0
        "symfony/stopwatch": "4.3.*", // v4.3.2
        "symfony/twig-bundle": "4.3.*", // v4.3.2
        "symfony/var-dumper": "4.3.*", // v4.3.2
        "symfony/web-profiler-bundle": "4.3.*" // v4.3.2
    }
}
Edit on GitHub
Previous Chapter
Next Chapter
userVoice