Modelling
Messaging and Ecotone In Depth
Microservices PHP
Distributed Services PHP
Distribution
Ecotone provides support for communication in distributed architecture.
The support covers sending command directly to specific service (application) or publishing events, that specific services may listen for. Configuration
In order for
Ecotone how to route messages you need to register Service Name (Application Name).Modules Providing Support
Distribution Bus
Distribution Bus is Message Gateway just like CommandBus or EventBus.
The bus is responsible for distribution of your command and events.
1
interface DistributedBus
2
{
3
// Command distribution
4
​
5
public function sendCommand(string $destination, string $routingKey, string $command, string $sourceMediaType = MediaType::TEXT_PLAIN, array $metadata = []) : void;
6
​
7
public function convertAndSendCommand(string $destination, string $routingKey, object|array $command, array $metadata = []) : void;
8
​
9
// Event distribution
10
​
11
public function publishEvent(string $routingKey, string $event, string $sourceMediaType = MediaType::TEXT_PLAIN, array $metadata = []) : void;
12
​
13
public function convertAndPublishEvent(string $routingKey, object|array $event, array $metadata) : void;
14
}
Copied!
Sending Distributed Commands
routingKey- is a routing key under which CommandHandler is registered on targeted Service
1
public function changeBillingDetails(DistributedBus $distributedCommandBus)
2
{
3
$distributedCommandBus->sendCommand(
4
"billing", // destination
5
"billing.changeDetails", // routingKey
6
'["personId":"123","billingDetails":"01111"]',
7
"application/json"
8
);
9
}
Copied!
Consuming Distributed Commands
Register distributed command handler
On the consumer side register distributed command handler
1
#[Distributed]
2
#[CommandHandler("billing.changeDetails")]
3
public function changeBillingDetails(ChangeBillingDetails $command) : void
4
{
5
// do something with billing details
6
}
Copied!
To expose command handler for service distribution mark it with
Distributed attribute.Run the consumer
Run consumer for your registered distributed consumer. It will be available under your Service Name​
List:
Symfony
Laravel
Lite
1
bin/console ecotone:list
2
+--------------------+
3
| Endpoint Names |
4
+--------------------+
5
| billings |
6
+--------------------+
Copied!
1
artisan ecotone:list
2
+--------------------+
3
| Endpoint Names |
4
+--------------------+
5
| billing |
6
+--------------------+
Copied!
1
$consumers = $messagingSystem->list()
Copied!
Run it:
Symfony
Laravel
Lite
1
bin/console ecotone:run billing -vvv
Copied!
1
artisan ecotone:run billing -vvv
Copied!
1
$messagingSystem->run("billing");
Copied!
Publishing Distributed Events
routingKey- is a routing key under which event will be published
1
public function changeBillingDetails(DistributedBus $eventBus)
2
{
3
$eventBus->publishEvent(
4
"billing.detailsWereChanged", // routingKey
5
'{"personId":123,"billingDetails":0001}',
6
"application/json"
7
);
8
}
Copied!
Consuming Distributed Events
1
#[Distributed]
2
#[EventHandler("billing.detailsWereChanged")]
3
public function registerTicket(BillingDetailsWereChanged $event) : void
4
{
5
// do something with event
6
}
Copied!
To start listening for distributed events under specific key, provide
Distributed attribute.Run the consumer
Last modified 1yr ago