2.5. Async Message Producer
Messaging becomes really interesting if you process your messages asynchronous. PSB can hide such an asynchronous workflow behind a unified interface. You can start with synchronous message dispatching by routing your messages directly to message handlers and if you later want to improve response times you can switch to async processing on a per message basis by routing the appropriate messages to a message producer which hands them over to a messaging system like rabbitMQ, zeroMQ, gearman or beanstalkd.
2.5.1. Available MessageProducer
- BernardProducer: Queue multi-backend providing different drivers like Doctrine DBAL and Predis (see https://github.com/bernardphp/bernard for a complete list of drivers)
- GuzzleHttpProducer: Send messages to a remote system using HTTP
- ZeromqProducer: Async message handling using super fast and simple to set up ZeroMQ
If you want to set up a bus that handles all messages async you can do so by attaching a
initialized with your message producer of choice to a message bus.
Let's look at a simple example using the
//app bootstrap $container = new Container; $container['config'] = [ 'prooph' => [ 'zeromq_producer' => [ 'dsn' => 'tcp://127.0.0.1:5555', // ZMQ Server Address. 'persistent_id' => 'example', // ZMQ Persistent ID to keep connections alive between requests. 'rpc' => false, // Use as Query Bus. ] ] ]; $factory = \Prooph\ServiceBus\Message\ZeroMQ\Container\ZeroMQMessageProducerFactory; $zmqProducer = $factory($container); $commandBus = new \Prooph\ServiceBus\CommandBus(); $messageProducerForwarder = new \Prooph\ServiceBus\Plugin\MessageProducerPlugin($zmqProducer); $commandBus->utilize($messageProducerForwarder); $echoText = new ExampleCommand('It works'); $commandBus->dispatch($echoText);
You can also route individual messages to message producer by using a message router plugin.
Prooph\ServiceBus\Plugin\Router\RegexRouter is a good choice
if you want to handle all messages of a specific namespace async.
2.5.3. Async Querying
An async message producer for the QueryBus needs to provide a response by resolving the handed over
When using a messaging system like ZeroMQ for example you can make use of request/response mode or RPC mode.
HTTP APIs provide responses naturally.
So these are both good candidates to use for remote querying.