Repository navigation
Expand file tree
/
Copy path71-server-http-proxy.php
More file actions
38 lines (31 loc) · 1.74 KB
/
Copy path71-server-http-proxy.php
File metadata and controls
38 lines (31 loc) · 1.74 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
<?php
// $ php examples/71-server-http-proxy.php 8080
// $ curl -v --proxy http://localhost:8080 http://reactphp.org/
require __DIR__ . '/../vendor/autoload.php';
// Note how this example uses the `HttpServer` without the `StreamingRequestMiddleware`.
// This means that this proxy buffers the whole request before "processing" it.
// As such, this is store-and-forward proxy. This could also use the advanced
// `StreamingRequestMiddleware` to forward the incoming request as it comes in.
$http = new React\Http\HttpServer(function (Psr\Http\Message\ServerRequestInterface $request) {
if (strpos($request->getRequestTarget(), '://') === false) {
return React\Http\Message\Response::plaintext(
"This is a plain HTTP proxy\n"
)->withStatus(React\Http\Message\Response::STATUS_BAD_REQUEST);
}
// prepare outgoing client request by updating request-target and Host header
$host = (string)$request->getUri()->withScheme('')->withPath('')->withQuery('');
$target = (string)$request->getUri()->withScheme('')->withHost('')->withPort(null);
if ($target === '') {
$target = $request->getMethod() === 'OPTIONS' ? '*' : '/';
}
$outgoing = $request->withRequestTarget($target)->withHeader('Host', $host);
// pseudo code only: simply dump the outgoing request as a string
// left up as an exercise: use an HTTP client to send the outgoing request
// and forward the incoming response to the original client request
return React\Http\Message\Response::plaintext(
RingCentral\Psr7\str($outgoing)
);
});
$socket = new React\Socket\SocketServer(isset($argv[1]) ? $argv[1] : '0.0.0.0:0');
$http->listen($socket);
echo 'Listening on ' . str_replace('tcp:', 'http:', $socket->getAddress()) . PHP_EOL;