This bundle provides an easy way to work with AWS SQS
Follow 5 quick steps to setup this bundle.
Open a command console, enter your project directory and execute the following command to download the latest stable version of this bundle:
$ composer require tritran/sqs-queue-bundleThis command requires you to have Composer installed globally
Register bundles in app/AppKernel.php:
class AppKernel extends Kernel
{
public function registerBundles()
{
return [
// ...
new \Aws\Symfony\AwsBundle(),
new \TriTran\SqsQueueBundle\TriTranSqsQueueBundle(),
];
}
// ...
}In a default Symfony application that uses Symfony Flex, bundles are enabled/disabled automatically for you when installing/removing them, so you could ignore this step.
This bundle is using AWS SDK for PHP. Full documentation of the configuration options available can be read in the SDK Guide.
Below are sample configuration for AWS Credential in YAML format
# app/config/config.yml
aws:
version: latest
region: us-central-1
credentials:
key: not-a-real-key
secret: "@not-a-real-secret"Below are sample configuration for some queues in YAML format
# app/config/config.yml
tritran_sqs_queue:
sqs_queue:
queues:
emailpool:
queue_url: 'https://sqs.eu-central-1.amazonaws.com/49504XX59872/emailpool'
worker: "@acl.service.emailpool"
attributes:
receive_message_wait_time_seconds: 20
visibility_timeout: 30
reminder:
queue_url: 'https://sqs.eu-central-1.amazonaws.com/49504XX59872/reminder'
worker: 'AclBundle\Service\Worker\ReminderWorker'Full documentation of the queue options available can be read in the Queue Attributes.
Now, you could access to queue
emailpoolorreminderservice viatritran.sqs_queue.emailpoolortritran.sqs_queue.reminder, it's an interface of BaseQueue
Below are a sample implementation of sending a message to a specified queue
namespace AclBundle\Controller;
use Symfony\Bundle\FrameworkBundle\Controller\Controller;
use TriTran\SqsQueueBundle\Service\Message;
/**
* Class DefaultController
*
* @package AclBundle\Controller
*/
class DefaultController extends Controller
{
public function indexAction()
{
// ...
$data = [
'from' => '[email protected]',
'to' => '[email protected]',
'subject' => 'Greeting Message',
'body' => 'Congratulation! You have just received a message which was sent from AWS SQS Queue'
];
$this->get('tritran.sqs_queue.emailpool')
->sendMessage((new Message())->setBody(serialize($data)));
// ...
}
}For a FIFO queue, you must associate a non-empty
MessageGroupIdwith a message. Otherwise, the action fails.
You may provide aMessageDeduplicationIdexplicitly. If you aren't able to provide aMessageDeduplicationIdand you enableContentBasedDeduplicationfor your queue, Amazon SQS uses a SHA-256 hash to generate theMessageDeduplicationIdusing the body of the message (but not the attributes of the message).
For more information about FIFO queue, please take a look at Amazon SQS FIFO (First-In-First-Out) Queues
| Behaviour | Arguments | Description |
|---|---|---|
| sendMessage | Message $messageint $delay = 0 |
Delivers a message to the specified queue. |
| receiveMessage | int $limit = 1 |
Retrieves one or more messages (up to 10), from the specified queue. Using the WaitTimeSeconds parameter enables long-poll support. For more information, see Amazon SQS Long Polling in the Amazon SQS Developer Guide. |
| deleteMessage | string $receiptHandle |
Deletes the specified message from the specified queue. You specify the message by using the message's receipt handle and not the MessageId you receive when you send the message. Even if the message is locked by another reader due to the visibility timeout setting, it is still deleted from the queue. If you leave a message in the queue for longer than the queue's configured retention period, Amazon SQS automatically deletes the message. |
| purge | Deletes the messages in a queue specified by the QueueURL parameter. Note: you can't retrieve a message deleted from a queue. |
You could access QueueManager via service
tritran.sqs_queue.queue_manager
| Behaviour | Arguments | Description |
|---|---|---|
| listQueue | string $prefix = '' |
Returns a list of your queues. The maximum number of queues that can be returned is 1,000. If you specify a value for the optional prefix parameter, only queues with a name that begins with the specified value are returned. |
| createQueue | string $queueNamearray $queueAttribute |
Creates a new standard or FIFO queue. You can pass one or more attributes in the request. |
| deleteQueue | string $queueUrl |
Deletes the queue specified by the QueueUrl, regardless of the queue's contents. If the specified queue doesn't exist, Amazon SQS returns a successful response. |
| setQueueAttributes | string $queueUrlarray $queueAttribute |
Sets the value of one or more queue attributes. When you change a queue's attributes, the change can take up to 60 seconds for most of the attributes to propagate throughout the Amazon SQS system |
| getQueueAttributes | string $queueUrl |
Gets attributes for the specified queue. |
Below are a sample implementation of a worker, which will listen to a queue to handle the messages inside.
namespace AclBundle\Service\Worker;
use TriTran\SqsQueueBundle\Service\Message;
use TriTran\SqsQueueBundle\Service\Worker\AbstractWorker;
class ReminderWorker extends AbstractWorker
{
/**
* @param Message $message
*
* @return boolean
*/
protected function execute(Message $message)
{
echo 'The message is: ' . $message->getBody();
return true;
}
}And then you could make it executed as daemon in console via:
bin/console tritran:sqs_queue:worker reminderNote: reminder is the name of queue which you configured in the config.yml in step 4.
| Behaviour | Description |
|---|---|
| tritran:sqs_queue:create | Creates a new standard or FIFO queue. You can pass one or more attributes in the request. |
| tritran:sqs_queue:update | Update queue attribute based on its configuration which shown in config.yml |
| tritran:sqs_queue:delete | Delete a queue by url and all its messages |
| tritran:sqs_queue:attr | Retrieve the attribute of a specified queue |
| tritran:sqs_queue:purge | Deletes the messages in a queue specified by the QueueURL parameter. |
| tritran:sqs_queue:worker | Start a worker that will listen to a specified SQS queue |
| tritran:sqs_queue:ping | Send a simply message to a queue, for DEBUG only |
Note: Please using
-hfor more information for each command.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent