Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit5d8976b

Browse files
Merge pull request#632 from kafkiansky/thesis-amqp-tutorial
Added tutorial for thesis/amqp
2 parents6696c1b +bf3a835 commit5d8976b

20 files changed

+636
-0
lines changed

‎php-thesis/.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
vendor/
2+
composer.lock

‎php-thesis/Makefile

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
up:
2+
docker compose up -d
3+
4+
down:
5+
docker compose down
6+
7+
php:
8+
docker composeexec php bash
9+
10+
run-send:
11+
docker composeexec php php hello-world/send.php
12+
13+
run-receive:
14+
docker composeexec php php hello-world/receive.php
15+
16+
run-new-task:
17+
docker composeexec php php work-queue/new_task.php"A very hard task which takes two seconds.."
18+
19+
run-worker:
20+
docker composeexec php php work-queue/worker.php
21+
22+
run-emit-log:
23+
docker composeexec php php pub-sub/emit_log.php
24+
25+
run-receive-logs:
26+
docker composeexec php php pub-sub/receive_logs.php
27+
28+
run-emit-log-direct:
29+
docker composeexec php php routing/emit_log_direct.php warning"Something went wrong"
30+
31+
run-receive-logs-direct:
32+
docker composeexec php php routing/receive_logs_direct.php info warning error
33+
34+
run-emit-log-topic:
35+
docker composeexec php php topics/emit_log_topic.php"kern.critical""A critical kernel error"
36+
37+
run-receive-logs-topic:
38+
docker composeexec php php topics/receive_logs_topic.php"#"
39+
40+
run-rpc-server:
41+
docker composeexec php php rpc/rpc_server.php
42+
43+
run-rpc-client:
44+
docker composeexec php php rpc/rpc_client.php
45+
46+
run-confirms-message:
47+
docker composeexec php php publisher-confirms/message.php
48+
49+
run-confirms-batch:
50+
docker composeexec php php publisher-confirms/batch.php

‎php-thesis/README.md

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
#Non-blocking php code for RabbitMQ tutorials based on thesis/amqp
2+
3+
Run rabbitmq server and php container with`make up`.
4+
5+
##Code
6+
7+
[Tutorial one: "Hello World!"](https://www.rabbitmq.com/tutorials/tutorial-one-php):
8+
```shell
9+
make run-send
10+
make run-receive
11+
```
12+
13+
[Tutorial two: Work Queues](https://www.rabbitmq.com/tutorials/tutorial-two-php):
14+
```shell
15+
make run-new-task
16+
make run-worker
17+
```
18+
19+
[Tutorial three: Publish/Subscribe](https://www.rabbitmq.com/tutorials/tutorial-three-php)
20+
```shell
21+
make run-emit-log
22+
make run-receive-logs
23+
```
24+
25+
[Tutorial four: Routing](https://www.rabbitmq.com/tutorials/tutorial-four-php):
26+
```shell
27+
make run-emit-log-direct
28+
make run-receive-logs-direct
29+
```
30+
31+
[Tutorial five: Topics](https://www.rabbitmq.com/tutorials/tutorial-five-php):
32+
```shell
33+
make run-emit-log-topic
34+
make run-receive-logs-topic
35+
```
36+
37+
[Tutorial six: RPC](https://www.rabbitmq.com/tutorials/tutorial-six-php):
38+
```shell
39+
make run-rpc-server
40+
make run-rpc-client
41+
```
42+
43+
[Tutorial seven: Publisher Confirms](https://www.rabbitmq.com/tutorials/tutorial-seven-php):
44+
```shell
45+
make run-rpc-server
46+
make run-rpc-client
47+
```

‎php-thesis/composer.json

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
{
2+
"require": {
3+
"thesis/amqp":"^1.0"
4+
},
5+
"require-dev": {
6+
"symfony/var-dumper":"^7.3"
7+
}
8+
}

‎php-thesis/docker-compose.yaml

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
services:
2+
php:
3+
build:
4+
dockerfile:docker/php/Dockerfile
5+
volumes:
6+
-.:/app:cached
7+
command:sh -c 'trap "exit 0" TERM; tail -f /dev/null & wait'
8+
9+
rabbitmq:
10+
image:rabbitmq:4.0-management-alpine
11+
restart:always
12+
ports:
13+
-"127.0.0.1:5672:5672"
14+
-"127.0.0.1:15672:15672"

‎php-thesis/docker/php/Dockerfile

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
FROM composer:2.8 AS composer
2+
FROM mlocati/php-extension-installer:2.7 AS php-extension-installer
3+
FROM php:8.3-cli-bookworm AS php-dev
4+
5+
COPY --from=composer /usr/bin/composer /usr/bin/
6+
COPY --from=php-extension-installer /usr/bin/install-php-extensions /usr/bin/
7+
8+
ARG UID=10001
9+
ARG GID=10001
10+
11+
RUN <<EOF
12+
set -e
13+
groupmod --gid=${GID} www-data
14+
usermod --uid=${UID} --gid=${GID} www-data
15+
apt-get update
16+
apt-get install --no-install-recommends --no-install-suggests -q -y unzip
17+
EOF
18+
19+
RUN <<EOF
20+
set -e
21+
install-php-extensions opcache pcntl sockets pgsql bcmath intl uv
22+
apt-get remove -q -y ${PHPIZE_DEPS} ${BUILD_DEPENDS}
23+
EOF
24+
25+
RUN <<EOF
26+
set -e
27+
mkdir /var/.composer
28+
chown www-data:www-data /var/.composer
29+
EOF
30+
31+
ENV COMPOSER_CACHE_DIR=/var/.composer
32+
33+
USER www-data
34+
35+
WORKDIR /app

‎php-thesis/hello-world/receive.php

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
<?php
2+
3+
declare(strict_types=1);
4+
5+
useThesis\Amqp\Client;
6+
useThesis\Amqp\Config;
7+
useThesis\Amqp\DeliveryMessage;
8+
usefunctionAmp\trapSignal;
9+
10+
require_once__DIR__.'/../vendor/autoload.php';
11+
12+
$client =newClient(
13+
newConfig(
14+
urls: ['rabbitmq:5672'],
15+
),
16+
);
17+
18+
$channel =$client->channel();
19+
$channel->queueDeclare('hello');
20+
21+
echo" [*] Waiting for messages. To exit press CTRL+C\n";
22+
23+
$channel->consume(
24+
staticfunction (DeliveryMessage$delivery):void {
25+
echo" [x] Received{$delivery->message->body}\n";
26+
},
27+
queue:'hello',
28+
noAck:true,
29+
);
30+
31+
trapSignal([\SIGTERM, \SIGINT]);
32+
33+
$client->disconnect();

‎php-thesis/hello-world/send.php

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
<?php
2+
3+
declare(strict_types=1);
4+
5+
useThesis\Amqp\Client;
6+
useThesis\Amqp\Config;
7+
useThesis\Amqp\Message;
8+
9+
require_once__DIR__.'/../vendor/autoload.php';
10+
11+
$client =newClient(
12+
newConfig(
13+
urls: ['rabbitmq:5672'],
14+
),
15+
);
16+
17+
$channel =$client->channel();
18+
19+
$channel->publish(newMessage('Hello World!'), routingKey:'hello');
20+
21+
$client->disconnect();

‎php-thesis/pub-sub/emit_log.php

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
<?php
2+
3+
declare(strict_types=1);
4+
5+
useThesis\Amqp\Client;
6+
useThesis\Amqp\Config;
7+
useThesis\Amqp\Message;
8+
9+
require_once__DIR__.'/../vendor/autoload.php';
10+
11+
$client =newClient(
12+
newConfig(
13+
urls: ['rabbitmq:5672'],
14+
),
15+
);
16+
17+
$channel =$client->channel();
18+
$channel->exchangeDeclare(exchange:'logs', exchangeType:'fanout');
19+
20+
$channel->publish(
21+
newMessage(
22+
body:$data =implode('',array_slice($argv,1)) ?:'info: Hello World!',
23+
),
24+
exchange:'logs',
25+
);
26+
27+
$client->disconnect();

‎php-thesis/pub-sub/receive_logs.php

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
<?php
2+
3+
declare(strict_types=1);
4+
5+
useThesis\Amqp\Client;
6+
useThesis\Amqp\Config;
7+
useThesis\Amqp\DeliveryMessage;
8+
usefunctionAmp\trapSignal;
9+
10+
require_once__DIR__.'/../vendor/autoload.php';
11+
12+
$client =newClient(
13+
newConfig(
14+
urls: ['rabbitmq:5672'],
15+
),
16+
);
17+
18+
$channel =$client->channel();
19+
20+
$channel->exchangeDeclare(exchange:'logs', exchangeType:'fanout');
21+
$queue =$channel->queueDeclare(exclusive:true);
22+
$channel->queueBind(queue:$queue->name, exchange:'logs');
23+
24+
echo" [*] Waiting for logs. To exit press CTRL+C\n";
25+
26+
$channel->consume(
27+
callback:staticfunction (DeliveryMessage$delivery):void {
28+
echo" [x]{$delivery->message->body}\n";
29+
},
30+
queue:$queue->name,
31+
noAck:true,
32+
);
33+
34+
trapSignal([\SIGTERM, \SIGINT]);
35+
36+
$client->disconnect();

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp