Build fast, concurrent applications with PHP

Benefit from concurrency by replacing your blocking I/O with non-blocking I/O,
or designing your system with non-blocking I/O from the ground up.

We shipped fibers in PHP 8.1 to extend its capabilities for concurrent applications.

The PHP standard library has already provided everything else we needed for years now, but it only ships the low-level building blocks. AMPHP provides higher-level libraries using non-blocking I/O under the hood. Fibers allow these libraries to just work, no matter whether they're used in concurrent or traditional contexts.

Get Started

Latest Releases

Released on 2023-03-02 3.0.0 on GitHub

amphp/file 3.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.
- Renamed BlockingDriver to BlockingFilesystemDriver
- Renamed EioDriver to EioFilesystemDriver
- Renamed ParallelDriver to ParallelFilesystemDriver
- Renamed StatusCachingDriver to StatusCachingFilesystemDriver
- Renamed UvDriver to UvFilesystemDriver
- Renamed Amp\File\Sync\AsyncFileMutex to Amp\File\FileMutex
- Added ?Cancellation as first parameter of File::read()
- Added File::isSeekable()
- Removed File::SEEK_SET, File::SEEK_CUR, and File::SEEK_END
- Added Amp\File\Whence for seeking instead
Released on 2023-02-25 2.1.8 on GitHub

amphp/http-server 2.1.8
- Fixed the first chunk read from the response body being duplicated when the content-length header was not set on the response (#342)
Released on 2023-02-21 2.0.0 on GitHub

amphp/parallel 2.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.

All classes related to ext-pthreads have been removed as this extension does not have releases on PHP 8.x.

Classes in the Amp\Parallel\Sync namespace have been moved to amphp/sync.

Context
- Process renamed to ProcessContext
- Parallel renamed to ThreadContext
- Context::isRunning() and Context::kill() replaced by Context::isClosed() and Context::close()
- Context related functions:
  - run → startContext
  - factory → contextFactory
  - create has been removed, use startContext
- Xdebug ini settings are forwarded to processes created by ProcessContext (including workers executing tasks), allowing step debugging through IDEs such as PhpStorm.
- Improved UX of uncaught exceptions in child processes and task runs. The full stack trace in the context is displayed when converting the ContextPanicError or TaskFailureThrowable to a string, i.e., when the exception is uncaught in the parent and is written to STDERR
- Added an optional Cancellation argument to ContextFactory::start()
Worker
- Pool renamed to WorkerPool and DefaultPool renamed to ContextWorkerPool
- TaskWorker has been marked as internal. Use a WorkerFactory to create Worker instances or use WorkerPool::getWorker() to get a worker from a pool
- TaskRunner has been removed
- Removed deprecated TaskException and TaskError
- Worker::enqueue() renamed to Worker::submit(), which now returns an Execution object
  - Execution::getFuture() returns a future that resolves to the eventual return value of the Task
  - Execution::await() awaits the result of the Task, it is a shortcut to calling Execution::getFuture()->await()
  - Execution::getChannel() returns a Channel that can be used to communicate with the Channel provided to Task::run()
  - The arguments to Task::run() have changed to Channel and Cancellation
IpcHub

Inter-process communication is now exposed as part of the public API for potential use outside of the context and worker components.
Released on 2023-02-08 1.7.1 on GitHub

amphp/http 1.7.1
- Fixed header validation regex to allow names containing *, +, and . (#19)
Released on 2023-02-03 2.0.1 on GitHub

amphp/byte-stream 2.0.1
- Fixed ReadableResourceStream calling Suspension::resume() when destroyed, which could throw an exception when suspending from {main} and an uncaught exception was thrown from the event loop.
Released on 2023-02-03 1.2.0 on GitHub

amphp/log 1.2.0
- Increased minimum PHP version to 7.2.
- Added support for Monolog v3.x.
Released on 2023-02-01 2.0.0 on GitHub

amphp/socket 2.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.

See some of the changes in v2.0 of amphp/byte-stream since this library extends several of the interfaces in that library, particularly ReadableStream and WritableStream.
- Moved methods from the EncryptableSocket interface to Socket and removed EncryptableSocket
- Changed SocketAddress to an interface with two implementations: InternetAddress and UnixAddress
  - These implementations can be differentiated using SocketAddress::getType(), which returns an enum SocketAddressType with cases Unix and Internet
  - SocketAddress static constructors have been relocated as functions in the Amp\Socket\SocketAddress namespace.
- Added connectTls function
- Added bindUdpSocket function
- Added ResourceUdpSocket and UdpSocket interface
- Added ServerSocketFactory interface for creating ServerSocket instances along with an implementation ResourceServerSocketFactory
- Renamed createPair function to createSocketPair
- Renamed connector to socketConnector
- Renamed Server to ResourceServerSocket and introduced ServerSocket interface
  - ResourceServerSocket::__construct() requires a BindContext instance
- Renamed Connector to SocketConnector
- Renamed DnsConnector to DnsSocketConnector
- Renamed StaticConnector to StaticSocketConnector
- Removed chunk size from BindContext, use chunk size parameters on listen / bindUdpSocket instead
- Max attempts has been removed from ConnectContext in favor of a constructor parameter to RetrySocketConnector
- DnsSocketConnector now tries each host returned from a DNS query a single time before failing. Retrying the list is accomplished through a new connector implementation, RetrySocketConnector that can be configured to retry a given number of times with an exponential backoff between attempts.
- Default required TLS version is now 1.2+ instead of 1.0+
Changes from 2.0.0 Beta 9
- Moved methods from the EncryptableSocket interface to Socket and removed EncryptableSocket
- Renamed SocketServer to ServerSocket
- Renamed SocketServerFactory to ServerSocketFactory
Released on 2023-01-21 2.0.1 on GitHub

amphp/dns 2.0.1
What’s Changed
- Fix fallback to blocking resolver by @danog and @kelunik in https://github.com/amphp/dns/pull/108 and https://github.com/amphp/dns/pull/109
- Try entire search list when resolve type is restricted by @trowski: 9d988e31
- Improve static analysis with more specific DnsResolver return types by @trowski: 7344cceb
Full Changelog: https://github.com/amphp/dns/compare/v2.0.0…v2.0.1
Released on 2023-01-10 1.0.0 on GitHub

amphp/windows-registry 1.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.
- WindowsRegistry offers the methods as static methods now instead of instance methods.
Released on 2023-01-09 2.0.0 on GitHub

amphp/process 2.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.
- Process::__construct() is now private in favor of Process::start()
- Process::start() is now static instead of an instance method
- Process::start()no longer returns the PID, use Process::getPid()
- Process::kill() no longer causes an exception to be thrown from Process::join()
- Process::getEnv() has been renamed to Process::getEnvironment()
- Improved handling if the Process object is destructed, but the process streams (STDIN, STDOUT, STDERR) are still used
- Renamed escapeArguments to escapeArgument
- Removed custom stream implementations
- Removed StatusError
- Fixed and improved wrapper copy if running inside of PHARs on Windows
- Removed nullability of Process::getWorkingDirectory()
- Avoid calling join() inside kill() to avoid suspensions in destructors
- Added an optional Cancellation parameter to Process::join()
- Fixed ended processes sometimes leaving zombie processes on *nix systems (requires ext-pcntl, an optional dependency)
Released on 2023-01-09 2.0.0 on GitHub

amphp/cache 2.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.
- Renamed ArrayCache to LocalCache, swapping the constructor argument order
- Modified LocalCache to implement IteratorAggregate and Countable, acting as an LRU cache now (#20)
- Support arbitrary values in LocalCache, NullCache, and PrefixCache
- Changed Cache to support arbitrary values
- Introduced separate StringCache interface for caching only strings
- Added StringCacheAdapter to use any Cache in place of a StringCache
- Removed FileCache (will be available in amphp/file instead)
Released on 2023-01-07 1.4.5 on GitHub

amphp/postgres 1.4.5
- Fixed cancelling an active query if a connection is closed when using ext-pgsql (#54)
Released on 2023-01-06 1.1.4 on GitHub

amphp/sql-common 1.1.4
- Fixed potential double deferred resolve when a connection pool is full.
Released on 2022-12-30 2.0.0 on GitHub

amphp/sync 2.0.0
Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.

Changes from 1.x
- ConcurrentIterator functions have been removed are now available as methods on Pipeline in amphp/pipeline
- FileMutex has been removed, as a better implementation ships as part of amphp/file
- Removed ThreadedMutex and ThreadedSemaphore
- Removed Lock::getId()
- Barrier::await supports cancellation now
- synchronized accepts any Semaphore now instead of a Mutex only
- Added Channel from amphp/parallel, which allows two way communicate between execution contexts, such as two coroutines or two processes. Channel has been modified to extend Closable
- Also added Parcel from amphp/parallel, which allows sharing a value across execution contexts with mutually-exclusive access to modifying that value using Parcel::synchronized().
- Added createChannelPair() function which returns a pair of connected Channel objects.
- Added RateLimitingSemaphore which releases locks after a given time elapses.
- Added StaticKeySemaphore, analogous to StaticKeyMutex
Changes from 2.0.0 Beta 6
- Added RateLimitingSemaphore which releases locks after a given time elapses.
- Added StaticKeySemaphore, analogous to StaticKeyMutex
Released on 2022-12-30 1.1.0 on GitHub

amphp/parser 1.1.0
- PHP 7.4 now required
- Improved performance of the parser when requesting small chunks of data and when yielding an integer length delimiter
Released on 2022-12-23 1.0.0 on GitHub

amphp/pipeline 1.0.0
Initial stable release 🎉

Changes from 1.0.0 Beta 7
- Marked ConcurrentArrayIterator, ConcurrentChainedIterator, and ConcurrentIterableIterator as @internal. Instead of these classes, use Pipeline::fromIterable() or Pipeline::concat()
- Pipeline::concat() now accepts an array of any iterable, not only other Pipeline objects
Released on 2022-12-18 1.0.2 on GitHub

amphp/sql 1.0.2
- Fix a deprecation notice on PHP 8.1 if a configuration key does not have a value.
Released on 2022-12-18 3.0.0 on GitHub

amphp/phpunit-util 3.0.0
This package has been redesigned for compatibility with AMPHP v3 and fibers. AsyncTestCase serves a similar purpose as before, providing helper methods for unit testing within an async context. Each test case is run within a unique fiber to allow suspending during the test run.
- AsyncTestCase::setUpAsync() and tearDownAsync() have been removed. Use AsyncTestCase::setUp() and tearDown() instead, as both of these methods are now able to execute async using fibers.
- AsyncTestCase::createCallback() now returns a Closure. Additionally, an optional parameter for expected arguments upon invocation have been added (uses InvocationMocker::with(...) to set expected arguments).
Released on 2022-12-18 3.0.0 on GitHub

amphp/amp 3.0.0
Event Loop

Amp no longer ships its own event loop. It’s now based on Revolt. Revolt\EventLoop is quite similar to Amp’s previous Amp\Loop. A very important difference is using float $seconds instead of int $milliseconds for timers though!

Promises

Future is a replacement for the previous Promise. There’s no need for callbacks or yield anymore! Its await() method is based on fibers and replaces generator based coroutines / Amp\Promise\wait().
- Renamed Amp\Deferred to Amp\DeferredFuture.
- Removed Amp\Promise\wait(): Use Amp\Future::await() instead, which can be called in any (nested) context unlike before.
- Removed Amp\call(): Remove the passed closure boilerplate and all yield keywords, interruption is handled via fibers now instead of generator coroutines.
- Removed Amp\asyncCall(): Replace invocations with Amp\async(), which starts a new fiber instead of using generators.
- Removed Amp\coroutine(): There’s no direct replacement.
- Removed Amp\asyncCoroutine(): There’s no direct replacement.
- Removed Amp\Promise\timeout(): Future::await() accepts an optional Cancellation, which can be used as a replacement.
- Removed Amp\Promise\rethrow(): Unhandled errors are now automatically thrown into the event loop, so there’s no need for that function anymore.
- Unhandled errors can be ignored using Future::ignore() if needed, but should usually be handled in some way.
- Removed Amp\Promise\wrap(): Use Future::finally() instead.
- Renamed Amp\getCurrentTime() to Amp\now() returning the time in seconds instead of milliseconds.
- Changed Amp\delay() to accept the delay in seconds now instead of milliseconds.
- Added Amp\weakClosure() to allow a class to hold a self-referencing Closure without creating a circular reference that prevents automatic garbage collection.
- Added Amp\trapSignal() to await one or multiple signals.
Promise Combinators

Promise combinators have been renamed:
- Amp\Promise\race() has been renamed to Amp\Future\awaitFirst()
- Amp\Promise\first() has been renamed to Amp\Future\awaitAny()
- Amp\Promise\some() has been renamed to Amp\Future\awaitAnyN()
- Amp\Promise\any() has been renamed to Amp\Future\awaitAll()
- Amp\Promise\all() has been renamed to Amp\Future\await()
CancellationToken
- CancellationToken has been renamed to Cancellation.
- CancellationTokenSource has been renamed to DeferredCancellation.
- NullCancellationToken has been renamed to NullCancellation.
- TimeoutCancellationToken has been renamed to TimeoutCancellation.
- CombinedCancellationToken has been renamed to CompositeCancellation.
- SignalCancellation has been added.
Iterators

Iterators have been removed from amphp/amp as normal PHP iterators can be used with fibers now and there’s no need for a separate API. However, there’s still some need for concurrent iterators, which is covered by the new amphp/pipeline library now.

Closable

Amp\Closable has been added as a new basic interface for closable resources such as streams or sockets.

Strict Types

Strict types now declared in all library files. This will affect callbacks invoked within this library’s code which use scalar types as parameters. Functions used with Amp\async() are the most likely to be affected by this change — these functions will now be invoked within a strict-types context.
Released on 2022-12-18 2.0.0 on GitHub

amphp/php-cs-fixer-config 2.0.0
- Common code style for all packages based on Amp v3.
- Now includes strict_types and several other minor updates.
Released on 2022-05-14 2.0.0 on GitHub

amphp/http-server-session 2.0.0
Changes from 2.0.0 Beta 4
- Removed the Serializer interface and implementations in favor of using those in amphp/seraliziation
Released on 2022-04-30 1.1.5 on GitHub

amphp/http-server-form-parser 1.1.5
- Added methods parseBody, parseUrlEncodedBody, and parseMultipartBody to BufferingParser to parse request bodies that have already been buffered (#10)
- Added parseContentBoundary function that returns the content boundary from a multipart header.
Released on 2022-04-11 1.0.3 on GitHub

amphp/websocket 1.0.3
- Added GOING_AWAY to the list of normal close codes, which will cause Client::receive() to return null instead of throwing an exception if a browser sends this code when navigating away from a page
- Fixed undefined array access in rare case where the event loop is exited after receiving a message on the websocket and then re-entered at a later time (amphp/websocket-client#39)
Released on 2022-04-10 1.0.7 on GitHub

amphp/http-server-static-content 1.0.7
- Compatibility with amphp/file @ 2.x
Released on 2022-03-10 1.0.1 on GitHub

amphp/websocket-client 1.0.1
- Ignore /docs in .gitattributes to avoid broken symlink (#38)
Full Changelog: https://github.com/amphp/websocket-client/compare/v1.0.0…v1.0.1
Released on 2022-02-03 1.1.0 on GitHub

amphp/parallel-functions 1.1.0
What’s Changed
- Update to laravel/serializable-closure instead of opis/closure by @owenvoke
- Increase minimum PHP version to PHP 7.4 by @owenvoke
New Contributors
- @sci3ma made their first contribution in https://github.com/amphp/parallel-functions/pull/24
- @owenvoke made their first contribution in https://github.com/amphp/parallel-functions/pull/31
Full Changelog: https://github.com/amphp/parallel-functions/compare/v1.0.0…v1.1.0
Released on 2022-02-02 1.0.0 on GitHub

amphp/rpc 1.0.0

Initial release.
Released on 2022-01-11 1.0.7 on GitHub

amphp/redis 1.0.7
- Fixed a case where an exception may be thrown to the event loop when a Subscriber lost connection to the Redis server.
Released on 2021-12-14 1.0.1 on GitHub

amphp/cluster 1.0.1

Update to use amphp/file v2.x.
Released on 2021-12-05 2.1.2 on GitHub

amphp/mysql 2.1.2
- Fixed a bug when decoding a JSON field (#113)
Released on 2021-10-21 1.2.0 on GitHub

amphp/http-client-cookies 1.2.0
- Added compatibility with amphp/file v2
- Updated public suffix list
Released on 2021-10-09 4.6.2 on GitHub

amphp/http-client 4.6.2
- Fixed setBodySizeLimit(0) with HTTP/2 protocol (#297)
Released on 2021-06-25 3.1.1 on GitHub

amphp/hpack 3.1.1
- Work around https://bugs.php.net/bug.php?id=79749
- Fixed deprecation warning in PHP 8.1 (#11)
Released on 2020-11-18 0.3.2 on GitHub

amphp/beanstalk 0.3.2
- Added support for Symfony YAML library v4 and v5. (#34)

Released on 2020-07-05 2.0.0 on GitHub

amphp/websocket-server 2.0.0

Changes since RC3

Renamed Endpoint to Gateway. An alias to Endpoint is provided for compatibility.
Renamed WebsocketObserver to WebsocketServerObserver.

Upgrading from v1.x to v2.0

This library has been refactored to use the new amphp/websocket library containing components that can be shared between server and clients.

Websocket is now a final class that requires an instance of ClientHandler, which has two methods to handle client handshakes and the client connection.

handleHandshake(): This method is invoked when a WebSocket connection attempt is made. The application may alter the given Response to deny the connection attempt or set application-specific headers.
handleClient(): This method is invoked upon a successful WebSocket connection. This method should use a loop to receive messages from the WebSocket connection.

use Amp\Http\Server\Request;
use Amp\Http\Server\Response;
use Amp\Http\Status;
use Amp\Success;
use Amp\Websocket\Client;
use Amp\Websocket\Server\ClientHandler;
use Amp\Websocket\Server\Gateway;
use Amp\Websocket\Server\Websocket;

$websocket = new Websocket(new class implements ClientHandler {
    public function handleHandshake(Gateway $gateway, Request $request, Response $response): Promise
    {
        if (!\in_array($request->getHeader('origin'), ['http://localhost:1337', 'http://127.0.0.1:1337', 'http://[::1]:1337'], true)) {
            return $gateway->getErrorHandler()->handleError(Status::FORBIDDEN, 'Origin forbidden', $request);
        }

        return new Success($response);
    }

    public function handleClient(Gateway $gateway, Client $client, Request $request, Response $response): Promise
    {
        return Amp\call(function () use ($gateway, $client) {
            while ($message = yield $client->receive()) {
                \assert($message instanceof Message);
                $gateway->broadcast(\sprintf('%d: %s', $client->getId(), yield $message->buffer()));
            }
        });
    }
});

WebSocket clients are now represented by a Client object. This object contains several methods for getting information about the client and for sending messages to a single client.

Servers can send to multiple clients using Gateway::broadcast() and Gateway::multicast() (plus binary versions, Gateway::broadcastBinary() and Gateway::multicastBinary()). A Gateway instance is provided to ClientHandler::handleHandshake() and ClientHandler::handleClient().

Released on 2020-03-28 1.0.0 on GitHub

amphp/serialization 1.0.0

Initial release.
Released on 2019-12-31 1.0.0 on GitHub

amphp/http-tunnel 1.0.0

Initial release.
Released on 2019-12-21 1.0.0 on GitHub

amphp/http-client-cache 1.0.0

Initial release.
Released on 2019-11-04 2.1.0 on GitHub

amphp/react-adapter 2.1.0
- React\EventLoop\Factory is now automatically replaced with another implementation that throws on each usage to prevent two loops existing concurrently by accident. Set AMP_REACT_ADAPTER_DISABLE_FACTORY_OVERRIDE=1 as environment variable or constant to disable this protection.
Released on 2019-08-21 1.0.2 on GitHub

amphp/http-server-router 1.0.2

Allow amphp/[email protected]^2
Released on 2018-03-07 0.1.0 on GitHub

amphp/react-stream-adapter 0.1.0

Initial release.

Build fast, concurrent applications with PHP

Latest Releases

amphp/file 3.0.0

amphp/http-server 2.1.8

amphp/parallel 2.0.0

Context

Worker

IpcHub

amphp/http 1.7.1

amphp/byte-stream 2.0.1

amphp/log 1.2.0

amphp/socket 2.0.0

Changes from 2.0.0 Beta 9

amphp/dns 2.0.1

What’s Changed

amphp/windows-registry 1.0.0

amphp/process 2.0.0

amphp/cache 2.0.0

amphp/postgres 1.4.5

amphp/sql-common 1.1.4

amphp/sync 2.0.0

Changes from 1.x

Changes from 2.0.0 Beta 6

amphp/parser 1.1.0

amphp/pipeline 1.0.0

Changes from 1.0.0 Beta 7

amphp/sql 1.0.2

amphp/phpunit-util 3.0.0

amphp/amp 3.0.0

Event Loop

Promises

Promise Combinators

CancellationToken

Iterators

Closable

Strict Types

amphp/php-cs-fixer-config 2.0.0

amphp/http-server-session 2.0.0

amphp/http-server-form-parser 1.1.5

amphp/websocket 1.0.3

amphp/http-server-static-content 1.0.7

amphp/websocket-client 1.0.1

amphp/parallel-functions 1.1.0

What’s Changed

New Contributors

amphp/rpc 1.0.0

amphp/redis 1.0.7

amphp/cluster 1.0.1

amphp/mysql 2.1.2

amphp/http-client-cookies 1.2.0

amphp/http-client 4.6.2

amphp/hpack 3.1.1

amphp/beanstalk 0.3.2

amphp/websocket-server 2.0.0

Changes since RC3

Upgrading from v1.x to v2.0

amphp/serialization 1.0.0

amphp/http-tunnel 1.0.0

amphp/http-client-cache 1.0.0

amphp/react-adapter 2.1.0

amphp/http-server-router 1.0.2

amphp/react-stream-adapter 0.1.0