8000 php examples · jw0201/rabbitmq-tutorials@d287ed0 · GitHub
[go: up one dir, main page]
Skip to content < 8000 /span>

Commit d287ed0

Browse files
videlalvarovidelalvaro
committed
php examples
1 parent 1250c23 commit d287ed0

File tree

9 files changed

+174
-0
lines changed

9 files changed

+174
-0
lines changed

‎.gitignore

Lines changed: 1 addition & 0 deletions
10000
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
php/lib/php-amqplib

‎php/README.md

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
# RabbitMQ - PHP Examples #
2+
3+
## Requirements ##
4+
5+
To run the examples you need:
6+
7+
- A running RabbitMQ server
8+
- PHP 5.3
9+
- php-amqplib
10+
11+
## setup ##
12+
13+
To get the php-amqplib library execute the following command inside the present folder:
14+
15+
$ git clone http://github.com/tnc/php-amqplib.git lib/php-amqplib

‎php/config/config.php

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
<?php
2+
// define('AMQP_DEBUG', true); //enable if you want to see logs.
3+
4+
define('HOST', 'localhost');
5+
define('PORT', 5672);
6+
define('USER', 'guest');
7+
define('PASS', 'guest');
8+
define('VHOST', '/');

‎php/emit_log.php

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
<?php
2+
3+
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4+
include_once(__DIR__ . '/config/config.php');
5+
6+
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
7+
$channel = $connection->channel();
8+
$channel->exchange_declare('logs', 'fanout');
9+
10+
$data = implode(' ', array_slice($argv, 1));
11+
if(empty($data)) $data = "info: Hello World!";
12+
$msg = new AMQPMessage($data);
13+
14+
$channel->basic_publish($msg, 'logs');
15+
16+
echo " [x] Sent ", $data, "\n";
17+
18+
$channel->close();
19+
$connection->close();
20+
21+
?>

‎php/new_task.php

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
<?php
2+
3+
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4+
include_once(__DIR__ . '/config/config.php');
5+
6+
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
7+
$channel = $connection->channel();
8+
9+
$channel->queue_declare('task_queue', false, true);
10+
11+
$data = implode(' ', array_slice($argv, 1));
12+
if(empty($data)) $data = "Hello World!";
13+
$msg = new AMQPMessage($data,
14+
array('delivery_mode' => 2) # make message persistent
15+
);
16+
17+
$channel->basic_publish($msg, '', 'task_queue');
18+
19+
echo " [x] Sent ", $data, "\n";
20+
21+
$channel->close();
22+
$connection->close();
23+
24+
?>

‎php/receive.php

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
<?php
2+
3+
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4+
include_once(__DIR__ . '/config/config.php');
5+
6+
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
7+
$channel = $connection->channel();
8+
9+
$channel->queue_declare('test');
10+
11+
echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
12+
13+
$callback = function($msg){
14+
echo " [x] Received ", $msg->body, "\n";
15+
};
16+
17+
$channel->basic_consume('test', 'consumer_tag', false, true, false, false, $callback);
18+
19+
while(count($channel->callbacks)) {
20+
$channel->wait();
21+
}
22+
23+
$channel->close();
24+
$connection->close();
25+
26+
?>

‎php/receive_logs.php

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
<?php
2+
3+
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4+
include_once(__DIR__ . '/config/config.php');
5+
6+
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
7+
$channel = $connection->channel();
8+
$channel->exchange_declare('logs', 'fanout');
9+
10+
list($queue_name, ,) = $channel->queue_declare();
11+
12+
$channel->queue_bind($queue_name, 'logs');
13+
14+
echo ' [*] Waiting for logs. To exit press CTRL+C', "\n";
15+
16+
$callback = function($msg){
17+
echo $msg->body, "\n";
18+
};
19+
20+
$channel->basic_consume($queue_name, 'consumer_tag', false, true, false, false, $callback);
21+
22+
while(count($channel->callbacks)) {
23+
$channel->wait();
24+
}
25+
26+
$channel->close();
27+
$connection->close();
28+
29+
?>

‎php/send.php

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
<?php
2+
3+
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4+
include_once(__DIR__ . '/config/config.php');
5+
6+
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
7+
$channel = $connection->channel();
8+
9+
$channel->queue_declare('test');
10+
11+
$msg = new AMQPMessage('Hello World!');
12+
13+
$channel->basic_publish($msg, '', 'test');
14+
15+
echo " [x] Sent 'Hello World!'\n";
16+
17+
$channel->close();
18+
$connection->close();
19+
20+
?>

‎php/worker.php

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
<?php
2+
3+
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4+
include_once(__DIR__ . '/config/config.php');
5+
6+
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
7+
$channel = $connection->channel();
8+
9+
$channel->queue_declare('task_queue', false, true);
10+
11+
echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
12+
13+
$callback = function($msg){
14+
echo " [x] Received ", $msg->body, "\n";
15+
sleep(substr_count($msg->body, '.'));
16+
echo " [x] Done", "\n";
17+
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
18+
};
19+
20+
$channel->basic_qos(null, 1, null);
21+
$channel->basic_consume('task_queue', 'consumer_tag', false, false, false, false, $callback);
22+
23+
while(count($channel->callbacks)) {
24+
$channel->wait();
25+
}
26+
27+
$channel->close();
28+
$connection->close();
29+
30+
?>

0 commit comments

Comments
 (0)
0